快捷導(dǎo)航

【Redis緩存機(jī)制】詳解Java連接Redis_Jedis_事務(wù)

更新時(shí)間：2016年12月15日 14:25:36 作者：光仔December

這篇文章主要介紹了【Redis緩存機(jī)制】詳解Java連接Redis_Jedis_事務(wù)，詳細(xì)的介紹了Jedis事務(wù)和實(shí)例，有興趣的可以了解一下。

Jedis事務(wù)

我們使用JDBC連接Mysql的時(shí)候，每次執(zhí)行sql語(yǔ)句之前，都需要開啟事務(wù)；在MyBatis中，也需要使用openSession()來(lái)獲取session事務(wù)對(duì)象，來(lái)進(jìn)行sql執(zhí)行、查詢等操作。當(dāng)我們對(duì)數(shù)據(jù)庫(kù)的操作結(jié)束的時(shí)候，是事務(wù)對(duì)象負(fù)責(zé)關(guān)閉數(shù)據(jù)庫(kù)連接。

事務(wù)對(duì)象用于管理、執(zhí)行各種數(shù)據(jù)庫(kù)操作的動(dòng)作。它能夠開啟和關(guān)閉數(shù)據(jù)庫(kù)連接，執(zhí)行sql語(yǔ)句，回滾錯(cuò)誤的操作。

我們的Redis也有事務(wù)管理對(duì)象，其位于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();//返回一個(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()語(yǔ)句后加入transaction.discard()語(yǔ)句:

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ù)來(lái)處理一些邏輯:

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ù)前如果該鍵被別人修改過(guò)，那事務(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í)行的過(guò)程中，防止其它的操作打斷事務(wù)，或者是影響事務(wù)的計(jì)算結(jié)果，導(dǎo)致“幻讀”、“臟數(shù)據(jù)”等異常情況的發(fā)生。watch命令建立了一個(gè)鍵，一旦發(fā)現(xiàn)執(zhí)行過(guò)程中該鍵被別人修改過(guò)，那事務(wù)就會(huì)失敗，程序中通?？梢圆东@這類錯(cuò)誤再重新執(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ù)被打斷，請(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ù)前如果該鍵被別人修改過(guò)，那事務(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ù)提交失敗，說(shuō)明在執(zhí)行期間數(shù)據(jù)被修改過(guò) 
         
        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)行一下，看一下效果：