Jedis事務(wù)
我們使用JDBC連接Mysql的時候，每次執(zhí)行sql語句之前，都需要開啟事務(wù)；在MyBatis中，也需要使用openSession()來獲取session事務(wù)對象，來進(jìn)行sql執(zhí)行、查詢等操作。當(dāng)我們對數(shù)據(jù)庫的操作結(jié)束的時候，是事務(wù)對象負(fù)責(zé)關(guān)閉數(shù)據(jù)庫連接。
事務(wù)對象用于管理、執(zhí)行各種數(shù)據(jù)庫操作的動作。它能夠開啟和關(guān)閉數(shù)據(jù)庫連接，執(zhí)行sql語句，回滾錯誤的操作。
我們的Redis也有事務(wù)管理對象，其位于redis.clients.jedis.Transaction下。
Jedis事務(wù)的相關(guān)代碼:
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();//返回一個事務(wù)控制對象 //預(yù)先在事務(wù)對象中裝入要執(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()語句:
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();//返回一個事務(wù)控制對象 //預(yù)先在事務(wù)對象中裝入要執(zhí)行的操作 transaction.set("k4", "v44"); transaction.set("k5", "v55"); transaction.discard();//回滾 } } 會發(fā)現(xiàn)數(shù)據(jù)插入操作被回滾，redis中那兩個值未被改變:
我們模擬一個刷一次信用卡的交易，使用redis的事務(wù)來處理一些邏輯:
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)記一個鍵，如果標(biāo)記了一個鍵， * 在提交事務(wù)前如果該鍵被別人修改過，那事務(wù)就會失敗，這種情況通?？梢栽诔绦蛑? * 重新再嘗試一次。 * * 首先標(biāo)記了balance，然后檢查余額是否足夠，不足就取消標(biāo)記，并不做扣減； * 足夠的話，就啟動事務(wù)進(jìn)行更新操作。 * 如果在此期間鍵balance被其他人修改，拿在提交事務(wù)(執(zhí)行exec)時就會報錯， * 程序中通?？梢圆东@這類錯誤再重新執(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;//實刷額度 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){//可用余額小于實刷金額，拒絕交易 jedis.unwatch(); System.out.println("可用余額不足！"); return false; }else{//可用余額夠用的時候再去執(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元的東西，此時應(yīng)該減去信用卡的可用余額100元，增加100元的欠款。
運(yùn)行結(jié)果:
redis的結(jié)果:
證明我們的操作是成功的。
加watch命令是為了在事務(wù)執(zhí)行的過程中，防止其它的操作打斷事務(wù)，或者是影響事務(wù)的計算結(jié)果，導(dǎo)致“幻讀”、“臟數(shù)據(jù)”等異常情況的發(fā)生。watch命令建立了一個鍵，一旦發(fā)現(xiàn)執(zhí)行過程中該鍵被別人修改過，那事務(wù)就會失敗，程序中通?？梢圆东@這類錯誤再重新執(zhí)行一次，直到成功。所以watch命令可以保證數(shù)據(jù)的同步安全。
為了證明watch命令的用途，我們把上面代碼里面的jedis.set("balance", "1100");注釋釋放，然后transMethod方法拋出打斷異常:throws InterruptedException，main方法捕獲打斷異常，然后彈出相應(yīng)警告框。
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ù)被打斷，請重新執(zhí)行!"); }finally{ if(retValue){ System.out.println("使用信用卡消費(fèi)成功！"); }else{ if(!Interrupted){ System.out.println("使用信用卡消費(fèi)失??！余額不足！"); } } } } /** * 通俗點(diǎn)講，watch命令就是標(biāo)記一個鍵，如果標(biāo)記了一個鍵， * 在提交事務(wù)前如果該鍵被別人修改過，那事務(wù)就會失敗，這種情況通?？梢栽诔绦蛑? * 重新再嘗試一次。 * * 首先標(biāo)記了balance，然后檢查余額是否足夠，不足就取消標(biāo)記，并不做扣減； * 足夠的話，就啟動事務(wù)進(jìn)行更新操作。 * 如果在此期間鍵balance被其他人修改，拿在提交事務(wù)(執(zhí)行exec)時就會報錯， * 程序中通?？梢圆东@這類錯誤再重新執(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;//實刷額度 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){//可用余額小于實刷金額，拒絕交易 jedis.unwatch(); System.out.println("可用余額不足！"); return false; }else{//可用余額夠用的時候再去執(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í)行就不會成功，此舉保證了數(shù)據(jù)的安全性。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
圖片精選
