Jedis事務
我們使用JDBC連接Mysql的時候，每次執(zhí)行sql語句之前，都需要開啟事務；在MyBatis中，也需要使用openSession()來獲取session事務對象，來進行sql執(zhí)行、查詢等操作。當我們對數(shù)據(jù)庫的操作結束的時候，是事務對象負責關閉數(shù)據(jù)庫連接。
事務對象用于管理、執(zhí)行各種數(shù)據(jù)庫操作的動作。它能夠開啟和關閉數(shù)據(jù)庫連接，執(zhí)行sql語句，回滾錯誤的操作。
我們的Redis也有事務管理對象，其位于redis.clients.jedis.Transaction下。
Jedis事務的相關代碼:
|
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();//返回一個事務控制對象 //預先在事務對象中裝入要執(zhí)行的操作 transaction.set("k4", "v4"); transaction.set("k5", "v5"); transaction.exec();//執(zhí)行 } } |
我們查看一下redis:
發(fā)現(xiàn)數(shù)據(jù)已經加入進去
我們把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();//返回一個事務控制對象 //預先在事務對象中裝入要執(zhí)行的操作 transaction.set("k4", "v44"); transaction.set("k5", "v55"); transaction.discard();//回滾 } } |
會發(fā)現(xiàn)數(shù)據(jù)插入操作被回滾，redis中那兩個值未被改變:
我們模擬一個刷一次信用卡的交易，使用redis的事務來處理一些邏輯:
|
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 { //模擬信用卡消費和還款 public static void main(String[] args) { TestTransaction t = new TestTransaction(); boolean retValue = t.transMethod(100); if(retValue){ System.out.println("使用信用卡消費成功！"); }else{ System.out.println("使用信用卡消費失??！"); } } /** * 通俗點講，watch命令就是標記一個鍵，如果標記了一個鍵， * 在提交事務前如果該鍵被別人修改過，那事務就會失敗，這種情況通?？梢栽诔绦蛑? * 重新再嘗試一次。 * * 首先標記了balance，然后檢查余額是否足夠，不足就取消標記，并不做扣減； * 足夠的話，就啟動事務進行更新操作。 * 如果在此期間鍵balance被其他人修改，拿在提交事務(執(zhí)行exec)時就會報錯， * 程序中通?？梢圆东@這類錯誤再重新執(zhí)行一次，直到成功。 * */ private boolean transMethod(int amount) { System.out.println("您使用信用卡預付款"+amount+"元"); Jedis jedis = new Jedis("192.168.248.129",6379); int balance = 1000;//可用余額 int debt;//欠額 int amtToSubtract = amount;//實刷額度 jedis.set("balance", String.valueOf(balance)); jedis.watch("balance"); //jedis.set("balance", "1100");//此句不該出現(xiàn)，為了模擬其他程序已經修改了該條目 balance = Integer.parseInt(jedis.get("balance")); if(balance < amtToSubtract){//可用余額小于實刷金額，拒絕交易 jedis.unwatch(); System.out.println("可用余額不足！"); return false; }else{//可用余額夠用的時候再去執(zhí)行扣費操作 System.out.println("扣費transaction事務開始執(zhí)行..."); Transaction transaction = jedis.multi(); transaction.decrBy("balance",amtToSubtract);//余額減去amtToSubtract的錢數(shù) transaction.incrBy("debt", amtToSubtract);//信用卡欠款增加amtToSubtract的錢數(shù) transaction.exec();//執(zhí)行事務 balance = Integer.parseInt(jedis.get("balance")); debt = Integer.parseInt(jedis.get("debt")); System.out.println("扣費transaction事務執(zhí)行結束..."); System.out.println("您的可用余額:"+balance); System.out.println("您目前欠款:"+debt); return true; } } } |
此代碼就是模擬用戶使用信用卡刷了100元的東西，此時應該減去信用卡的可用余額100元，增加100元的欠款。
運行結果:
redis的結果:
證明我們的操作是成功的。
加watch命令是為了在事務執(zhí)行的過程中，防止其它的操作打斷事務，或者是影響事務的計算結果，導致“幻讀”、“臟數(shù)據(jù)”等異常情況的發(fā)生。watch命令建立了一個鍵，一旦發(fā)現(xiàn)執(zhí)行過程中該鍵被別人修改過，那事務就會失敗，程序中通常可以捕獲這類錯誤再重新執(zhí)行一次，直到成功。所以watch命令可以保證數(shù)據(jù)的同步安全。
為了證明watch命令的用途，我們把上面代碼里面的jedis.set("balance", "1100");注釋釋放，然后transMethod方法拋出打斷異常:throws InterruptedException，main方法捕獲打斷異常，然后彈出相應警告框。
|
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 { //模擬信用卡消費和還款 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("事務被打斷，請重新執(zhí)行!"); }finally{ if(retValue){ System.out.println("使用信用卡消費成功！"); }else{ if(!Interrupted){ System.out.println("使用信用卡消費失??！余額不足！"); } } } } /** * 通俗點講，watch命令就是標記一個鍵，如果標記了一個鍵， * 在提交事務前如果該鍵被別人修改過，那事務就會失敗，這種情況通常可以在程序中 * 重新再嘗試一次。 * * 首先標記了balance，然后檢查余額是否足夠，不足就取消標記，并不做扣減； * 足夠的話，就啟動事務進行更新操作。 * 如果在此期間鍵balance被其他人修改，拿在提交事務(執(zhí)行exec)時就會報錯， * 程序中通常可以捕獲這類錯誤再重新執(zhí)行一次，直到成功。 * */ private boolean transMethod(int amount) throws InterruptedException{ System.out.println("您使用信用卡預付款"+amount+"元"); Jedis jedis = new Jedis("192.168.248.129",6379); int balance = 1000;//可用余額 int debt;//欠額 int amtToSubtract = amount;//實刷額度 jedis.set("balance", String.valueOf(balance)); jedis.watch("balance"); jedis.set("balance", "1100");//此句不該出現(xiàn)，為了模擬其他程序已經修改了該條目 balance = Integer.parseInt(jedis.get("balance")); if(balance < amtToSubtract){//可用余額小于實刷金額，拒絕交易 jedis.unwatch(); System.out.println("可用余額不足！"); return false; }else{//可用余額夠用的時候再去執(zhí)行扣費操作 System.out.println("扣費transaction事務開始執(zhí)行..."); Transaction transaction = jedis.multi(); transaction.decrBy("balance",amtToSubtract);//余額減去amtToSubtract的錢數(shù) transaction.incrBy("debt", amtToSubtract);//信用卡欠款增加amtToSubtract的錢數(shù) List<Object> result = transaction.exec();//執(zhí)行事務 if(result==null){//事務提交失敗，說明在執(zhí)行期間數(shù)據(jù)被修改過 System.out.println("扣費transaction事務執(zhí)行中斷..."); throw new InterruptedException(); }else{//事務提交成功 balance = Integer.parseInt(jedis.get("balance")); debt = Integer.parseInt(jedis.get("debt")); System.out.println("扣費transaction事務執(zhí)行結束..."); System.out.println("您的可用余額:"+balance); System.out.println("您目前欠款:"+debt); return true; } } } } |
再運行一下，看一下效果：
這就說明了，如果在watch命令執(zhí)行后和事務提交之前，如果數(shù)據(jù)發(fā)生了修改操作，事務執(zhí)行就不會成功，此舉保證了數(shù)據(jù)的安全性。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：http://blog.csdn.net/acmman/article/details/53579378
