快捷導(dǎo)航

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

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

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

Jedis事務(wù)

我們使用JDBC連接Mysql的時候，每次執(zhí)行sql語句之前，都需要開啟事務(wù)；在MyBatis中，也需要使用openSession()來獲取session事務(wù)對象，來進行sql執(zhí)行、查詢等操作。當(dāng)我們對數(shù)據(jù)庫的操作結(jié)束的時候，是事務(wù)對象負責(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)加入進去

我們把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 { 
  //模擬信用卡消費和還款 
  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命令就是標記一個鍵，如果標記了一個鍵， 
   * 在提交事務(wù)前如果該鍵被別人修改過，那事務(wù)就會失敗，這種情況通?？梢栽诔绦蛑?
   * 重新再嘗試一次。 
   * 
   * 首先標記了balance，然后檢查余額是否足夠，不足就取消標記，并不做扣減； 
   * 足夠的話，就啟動事務(wù)進行更新操作。 
   * 如果在此期間鍵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í)行扣費操作 
      System.out.println("扣費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("扣費transaction事務(wù)執(zhí)行結(jié)束..."); 
       
      System.out.println("您的可用余額:"+balance); 
      System.out.println("您目前欠款:"+debt); 
      return true; 
    } 
  } 
   
}

此代碼就是模擬用戶使用信用卡刷了100元的東西，此時應(yīng)該減去信用卡的可用余額100元，增加100元的欠款。

運行結(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 { 
  //模擬信用卡消費和還款 
  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("使用信用卡消費成功！"); 
      }else{ 
        if(!Interrupted){ 
          System.out.println("使用信用卡消費失?。∮囝~不足！"); 
        } 
      } 
    } 
  } 
 
  /** 
   * 通俗點講，watch命令就是標記一個鍵，如果標記了一個鍵， 
   * 在提交事務(wù)前如果該鍵被別人修改過，那事務(wù)就會失敗，這種情況通?？梢栽诔绦蛑?
   * 重新再嘗試一次。 
   * 
   * 首先標記了balance，然后檢查余額是否足夠，不足就取消標記，并不做扣減； 
   * 足夠的話，就啟動事務(wù)進行更新操作。 
   * 如果在此期間鍵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í)行扣費操作 
      System.out.println("扣費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("扣費transaction事務(wù)執(zhí)行中斷..."); 
        throw new InterruptedException(); 
         
      }else{//事務(wù)提交成功 
        balance = Integer.parseInt(jedis.get("balance")); 
        debt = Integer.parseInt(jedis.get("debt")); 
        System.out.println("扣費transaction事務(wù)執(zhí)行結(jié)束..."); 
         
        System.out.println("您的可用余額:"+balance); 
        System.out.println("您目前欠款:"+debt); 
         
        return true; 
      } 
    } 
  } 
   
}

再運行一下，看一下效果：