欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

【Redis缓存机制】详解Java连接Redis_Jedis_事务

程序员文章站 2024-03-09 10:47:53
jedis事务 我们使用jdbc连接mysql的时候,每次执行sql语句之前,都需要开启事务;在mybatis中,也需要使用opensession()来获取sessi...

jedis事务

我们使用jdbc连接mysql的时候,每次执行sql语句之前,都需要开启事务;在mybatis中,也需要使用opensession()来获取session事务对象,来进行sql执行、查询等操作。当我们对数据库的操作结束的时候,是事务对象负责关闭数据库连接。

事务对象用于管理、执行各种数据库操作的动作。它能够开启和关闭数据库连接,执行sql语句,回滚错误的操作。

我们的redis也有事务管理对象,其位于redis.clients.jedis.transaction下。

jedis事务的相关代码:

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();//返回一个事务控制对象 
     
    //预先在事务对象中装入要执行的操作 
    transaction.set("k4", "v4"); 
    transaction.set("k5", "v5"); 
     
    transaction.exec();//执行 
  } 
} 

我们查看一下redis:

【Redis缓存机制】详解Java连接Redis_Jedis_事务

发现数据已经加入进去

我们把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();//返回一个事务控制对象 
     
    //预先在事务对象中装入要执行的操作 
    transaction.set("k4", "v44"); 
    transaction.set("k5", "v55"); 
 
    transaction.discard();//回滚 
  } 
} 

会发现数据插入操作被回滚,redis中那两个值未被改变:

【Redis缓存机制】详解Java连接Redis_Jedis_事务

我们模拟一个刷一次信用卡的交易,使用redis的事务来处理一些逻辑:

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被其他人修改,拿在提交事务(执行exec)时就会报错, 
   * 程序中通常可以捕获这类错误再重新执行一次,直到成功。 
   * */ 
  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");//此句不该出现,为了模拟其他程序已经修改了该条目 
    balance = integer.parseint(jedis.get("balance")); 
    if(balance < amttosubtract){//可用余额小于实刷金额,拒绝交易 
      jedis.unwatch(); 
      system.out.println("可用余额不足!"); 
      return false; 
    }else{//可用余额够用的时候再去执行扣费操作 
      system.out.println("扣费transaction事务开始执行..."); 
      transaction transaction = jedis.multi(); 
      transaction.decrby("balance",amttosubtract);//余额减去amttosubtract的钱数 
      transaction.incrby("debt", amttosubtract);//信用卡欠款增加amttosubtract的钱数 
      transaction.exec();//执行事务 
      balance = integer.parseint(jedis.get("balance")); 
      debt = integer.parseint(jedis.get("debt")); 
      system.out.println("扣费transaction事务执行结束..."); 
       
      system.out.println("您的可用余额:"+balance); 
      system.out.println("您目前欠款:"+debt); 
      return true; 
    } 
  } 
   
} 

此代码就是模拟用户使用信用卡刷了100元的东西,此时应该减去信用卡的可用余额100元,增加100元的欠款。

运行结果:

【Redis缓存机制】详解Java连接Redis_Jedis_事务

redis的结果:

【Redis缓存机制】详解Java连接Redis_Jedis_事务

证明我们的操作是成功的。

加watch命令是为了在事务执行的过程中,防止其它的操作打断事务,或者是影响事务的计算结果,导致“幻读”、“脏数据”等异常情况的发生。watch命令建立了一个键,一旦发现执行过程中该键被别人修改过,那事务就会失败,程序中通常可以捕获这类错误再重新执行一次,直到成功。所以watch命令可以保证数据的同步安全。

为了证明watch命令的用途,我们把上面代码里面的jedis.set("balance", "1100");注释释放,然后transmethod方法抛出打断异常:throws interruptedexception,main方法捕获打断异常,然后弹出相应警告框。

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("事务被打断,请重新执行!"); 
    }finally{ 
      if(retvalue){ 
        system.out.println("使用信用卡消费成功!"); 
      }else{ 
        if(!interrupted){ 
          system.out.println("使用信用卡消费失败!余额不足!"); 
        } 
      } 
    } 
  } 
 
  /** 
   * 通俗点讲,watch命令就是标记一个键,如果标记了一个键, 
   * 在提交事务前如果该键被别人修改过,那事务就会失败,这种情况通常可以在程序中 
   * 重新再尝试一次。 
   * 
   * 首先标记了balance,然后检查余额是否足够,不足就取消标记,并不做扣减; 
   * 足够的话,就启动事务进行更新操作。 
   * 如果在此期间键balance被其他人修改,拿在提交事务(执行exec)时就会报错, 
   * 程序中通常可以捕获这类错误再重新执行一次,直到成功。 
   * */ 
  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");//此句不该出现,为了模拟其他程序已经修改了该条目 
    balance = integer.parseint(jedis.get("balance")); 
    if(balance < amttosubtract){//可用余额小于实刷金额,拒绝交易 
      jedis.unwatch(); 
      system.out.println("可用余额不足!"); 
      return false; 
    }else{//可用余额够用的时候再去执行扣费操作 
      system.out.println("扣费transaction事务开始执行..."); 
      transaction transaction = jedis.multi(); 
      transaction.decrby("balance",amttosubtract);//余额减去amttosubtract的钱数 
      transaction.incrby("debt", amttosubtract);//信用卡欠款增加amttosubtract的钱数 
      list<object> result = transaction.exec();//执行事务 
       
      if(result==null){//事务提交失败,说明在执行期间数据被修改过 
         
        system.out.println("扣费transaction事务执行中断..."); 
        throw new interruptedexception(); 
         
      }else{//事务提交成功 
        balance = integer.parseint(jedis.get("balance")); 
        debt = integer.parseint(jedis.get("debt")); 
        system.out.println("扣费transaction事务执行结束..."); 
         
        system.out.println("您的可用余额:"+balance); 
        system.out.println("您目前欠款:"+debt); 
         
        return true; 
      } 
    } 
  } 
   
} 

再运行一下,看一下效果:

【Redis缓存机制】详解Java连接Redis_Jedis_事务

这就说明了,如果在watch命令执行后和事务提交之前,如果数据发生了修改操作,事务执行就不会成功,此举保证了数据的安全性。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。