Jedis事務(wù)
我們使用JDBC連接Mysql的時(shí)候，每次執(zhí)行sql語句之前，都需要開啟事務(wù)；在MyBatis中，也需要使用openSession()來獲取session事務(wù)對(duì)象，來進(jìn)行sql執(zhí)行、查詢等操作。當(dāng)我們對(duì)數(shù)據(jù)庫的操作結(jié)束的時(shí)候，是事務(wù)對(duì)象負(fù)責(zé)關(guān)閉數(shù)據(jù)庫連接。
事務(wù)對(duì)象用于管理、執(zhí)行各種數(shù)據(jù)庫操作的動(dòng)作。它能夠開啟和關(guān)閉數(shù)據(jù)庫連接，執(zhí)行sql語句，回滾錯(cuò)誤的操作。
我們的Redis也有事務(wù)管理對(duì)象，其位于redis.clients.jedis.Transaction下。
Jedis事務(wù)的相關(guān)代碼:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
package cn.com.redis; import redis.clients.jedis.Jedis; import redis.clients.jedis.Transaction; public class Test7 { public static void main(String[] args) { Jedis jedis = new Jedis("192.168.248.129",6379); Transaction transaction=jedis.multi();//返回一個(gè)事務(wù)控制對(duì)象 //預(yù)先在事務(wù)對(duì)象中裝入要執(zhí)行的操作 transaction.set("k4", "v4"); transaction.set("k5", "v5"); transaction.exec();//執(zhí)行 } } |
我們查看一下redis:
發(fā)現(xiàn)數(shù)據(jù)已經(jīng)加入進(jìn)去
我們把k4的value和k5的value改為“v44”和“v55”,然后在transaction.exec()語句后加入transaction.discard()語句:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
package cn.com.redis; import redis.clients.jedis.Jedis; import redis.clients.jedis.Transaction; public class Test7 { public static void main(String[] args) { Jedis jedis = new Jedis("192.168.248.129",6379); Transaction transaction=jedis.multi();//返回一個(gè)事務(wù)控制對(duì)象 //預(yù)先在事務(wù)對(duì)象中裝入要執(zhí)行的操作 transaction.set("k4", "v44"); transaction.set("k5", "v55"); transaction.discard();//回滾 } } |
會(huì)發(fā)現(xiàn)數(shù)據(jù)插入操作被回滾，redis中那兩個(gè)值未被改變:
我們模擬一個(gè)刷一次信用卡的交易，使用redis的事務(wù)來處理一些邏輯:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
package cn.com.redis; import redis.clients.jedis.Jedis; import redis.clients.jedis.Transaction; public class TestTransaction { //模擬信用卡消費(fèi)和還款 public static void main(String[] args) { TestTransaction t = new TestTransaction(); boolean retValue = t.transMethod(100); if(retValue){ System.out.println("使用信用卡消費(fèi)成功！"); }else{ System.out.println("使用信用卡消費(fèi)失敗！"); } } /** * 通俗點(diǎn)講，watch命令就是標(biāo)記一個(gè)鍵，如果標(biāo)記了一個(gè)鍵， * 在提交事務(wù)前如果該鍵被別人修改過，那事務(wù)就會(huì)失敗，這種情況通常可以在程序中 * 重新再嘗試一次。 * * 首先標(biāo)記了balance，然后檢查余額是否足夠，不足就取消標(biāo)記，并不做扣減； * 足夠的話，就啟動(dòng)事務(wù)進(jìn)行更新操作。 * 如果在此期間鍵balance被其他人修改，拿在提交事務(wù)(執(zhí)行exec)時(shí)就會(huì)報(bào)錯(cuò)， * 程序中通常可以捕獲這類錯(cuò)誤再重新執(zhí)行一次，直到成功。 * */ private boolean transMethod(int amount) { System.out.println("您使用信用卡預(yù)付款"+amount+"元"); Jedis jedis = new Jedis("192.168.248.129",6379); int balance = 1000;//可用余額 int debt;//欠額 int amtToSubtract = amount;//實(shí)刷額度 jedis.set("balance", String.valueOf(balance)); jedis.watch("balance"); //jedis.set("balance", "1100");//此句不該出現(xiàn)，為了模擬其他程序已經(jīng)修改了該條目 balance = Integer.parseInt(jedis.get("balance")); if(balance < amtToSubtract){//可用余額小于實(shí)刷金額，拒絕交易 jedis.unwatch(); System.out.println("可用余額不足！"); return false; }else{//可用余額夠用的時(shí)候再去執(zhí)行扣費(fèi)操作 System.out.println("扣費(fèi)transaction事務(wù)開始執(zhí)行..."); Transaction transaction = jedis.multi(); transaction.decrBy("balance",amtToSubtract);//余額減去amtToSubtract的錢數(shù) transaction.incrBy("debt", amtToSubtract);//信用卡欠款增加amtToSubtract的錢數(shù) transaction.exec();//執(zhí)行事務(wù) balance = Integer.parseInt(jedis.get("balance")); debt = Integer.parseInt(jedis.get("debt")); System.out.println("扣費(fèi)transaction事務(wù)執(zhí)行結(jié)束..."); System.out.println("您的可用余額:"+balance); System.out.println("您目前欠款:"+debt); return true; } } } |
此代碼就是模擬用戶使用信用卡刷了100元的東西，此時(shí)應(yīng)該減去信用卡的可用余額100元，增加100元的欠款。
運(yùn)行結(jié)果:
redis的結(jié)果:
證明我們的操作是成功的。
加watch命令是為了在事務(wù)執(zhí)行的過程中，防止其它的操作打斷事務(wù)，或者是影響事務(wù)的計(jì)算結(jié)果，導(dǎo)致“幻讀”、“臟數(shù)據(jù)”等異常情況的發(fā)生。watch命令建立了一個(gè)鍵，一旦發(fā)現(xiàn)執(zhí)行過程中該鍵被別人修改過，那事務(wù)就會(huì)失敗，程序中通常可以捕獲這類錯(cuò)誤再重新執(zhí)行一次，直到成功。所以watch命令可以保證數(shù)據(jù)的同步安全。
為了證明watch命令的用途，我們把上面代碼里面的jedis.set("balance", "1100");注釋釋放，然后transMethod方法拋出打斷異常:throws InterruptedException，main方法捕獲打斷異常，然后彈出相應(yīng)警告框。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
package cn.com.redis; import java.util.List; import redis.clients.jedis.Jedis; import redis.clients.jedis.Transaction; public class TestTransaction { //模擬信用卡消費(fèi)和還款 public static void main(String[] args) { TestTransaction t = new TestTransaction(); boolean retValue=false; boolean Interrupted = false; try { retValue = t.transMethod(100); } catch (InterruptedException e) { Interrupted = true; System.out.println("事務(wù)被打斷，請(qǐng)重新執(zhí)行!"); }finally{ if(retValue){ System.out.println("使用信用卡消費(fèi)成功！"); }else{ if(!Interrupted){ System.out.println("使用信用卡消費(fèi)失敗！余額不足！"); } } } } /** * 通俗點(diǎn)講，watch命令就是標(biāo)記一個(gè)鍵，如果標(biāo)記了一個(gè)鍵， * 在提交事務(wù)前如果該鍵被別人修改過，那事務(wù)就會(huì)失敗，這種情況通常可以在程序中 * 重新再嘗試一次。 * * 首先標(biāo)記了balance，然后檢查余額是否足夠，不足就取消標(biāo)記，并不做扣減； * 足夠的話，就啟動(dòng)事務(wù)進(jìn)行更新操作。 * 如果在此期間鍵balance被其他人修改，拿在提交事務(wù)(執(zhí)行exec)時(shí)就會(huì)報(bào)錯(cuò)， * 程序中通常可以捕獲這類錯(cuò)誤再重新執(zhí)行一次，直到成功。 * */ private boolean transMethod(int amount) throws InterruptedException{ System.out.println("您使用信用卡預(yù)付款"+amount+"元"); Jedis jedis = new Jedis("192.168.248.129",6379); int balance = 1000;//可用余額 int debt;//欠額 int amtToSubtract = amount;//實(shí)刷額度 jedis.set("balance", String.valueOf(balance)); jedis.watch("balance"); jedis.set("balance", "1100");//此句不該出現(xiàn)，為了模擬其他程序已經(jīng)修改了該條目 balance = Integer.parseInt(jedis.get("balance")); if(balance < amtToSubtract){//可用余額小于實(shí)刷金額，拒絕交易 jedis.unwatch(); System.out.println("可用余額不足！"); return false; }else{//可用余額夠用的時(shí)候再去執(zhí)行扣費(fèi)操作 System.out.println("扣費(fèi)transaction事務(wù)開始執(zhí)行..."); Transaction transaction = jedis.multi(); transaction.decrBy("balance",amtToSubtract);//余額減去amtToSubtract的錢數(shù) transaction.incrBy("debt", amtToSubtract);//信用卡欠款增加amtToSubtract的錢數(shù) List<Object> result = transaction.exec();//執(zhí)行事務(wù) if(result==null){//事務(wù)提交失敗，說明在執(zhí)行期間數(shù)據(jù)被修改過 System.out.println("扣費(fèi)transaction事務(wù)執(zhí)行中斷..."); throw new InterruptedException(); }else{//事務(wù)提交成功 balance = Integer.parseInt(jedis.get("balance")); debt = Integer.parseInt(jedis.get("debt")); System.out.println("扣費(fèi)transaction事務(wù)執(zhí)行結(jié)束..."); System.out.println("您的可用余額:"+balance); System.out.println("您目前欠款:"+debt); return true; } } } } |
再運(yùn)行一下，看一下效果：
這就說明了，如果在watch命令執(zhí)行后和事務(wù)提交之前，如果數(shù)據(jù)發(fā)生了修改操作，事務(wù)執(zhí)行就不會(huì)成功，此舉保證了數(shù)據(jù)的安全性。
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：http://blog.csdn.net/acmman/article/details/53579378
