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

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:

发现数据已经加入进去

我们把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的事务来处理一些逻辑:

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的结果:

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

加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; 
      } 
    } 
  } 
   
} 

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

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

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

# java  # jedis操作redis  # jedis  # 事务  # redis  # redis中事务机制及乐观锁的实现  # Redis 事务与过期时间详细介绍  # redis事务常用操作详解  # Redis中的事务和Redis乐观锁详解  # redis中的事务操作案例分析  # Redis 基础教程之事务的使用方法  # Redis事务处理的使用操作方法  # 关于Jedis的用法以及Jedis使用Redis事务  # Redis实现分布式事务的示例  # Redis事务处理的实现示例  # 的钱  # 就会  # 这类  # 您的  # 再重新  # 在此  # 这种情况  # 不做  # 时就  # 再去  # 报错  # 您目前  # 过程中  # 象中  # 也有  # 这就  # 弹出  # 或者是  # 当我们  # 看一下 

相关文章： 如何在阿里云完成域名注册与建站？  如何在阿里云虚拟服务器快速搭建网站？  深圳网站制作案例,网页的相关名词有哪些？  如何配置IIS站点权限与局域网访问？  如何通过虚拟主机快速搭建个人网站？  简历在线制作网站免费,免费下载个人简历的网站是哪些？  小型网站建站如何选择虚拟主机？  企业网站制作公司网页,推荐几家专业的天津网站制作公司？  零基础网站服务器架设实战：轻量应用与域名解析配置指南  昆明网站制作哪家好,昆明公租房申请网上登录入口？  长沙做网站要多少钱,长沙国安网络怎么样？  如何在阿里云ECS服务器部署织梦CMS网站？  ,网站推广常用方法？  建站主机选购指南：核心配置与性价比推荐解析  专业的网站制作设计是什么,如何制作一个企业网站，建设网站的基本步骤有哪些？  c# 服务器GC和工作站GC的区别和设置  网站制作服务平台,有什么网站可以发布本地服务信息？  高端企业智能建站程序：SEO优化与响应式模板定制开发  大型企业网站制作流程,做网站需要注册公司吗？  高防服务器租用指南：配置选择与快速部署攻略  ,网页ppt怎么弄成自己的ppt？  微信小程序 input输入框控件详解及实例（多种示例）  北京营销型网站制作公司,可以用python做一个营销推广网站吗？  Thinkphp 中 distinct 的用法解析  C#如何在一个XML文件中查找并替换文本内容  百度网页制作网站有哪些,谁能告诉我百度网站是怎么联系？  如何续费美橙建站之星域名及服务？  高防服务器租用如何选择配置与防御等级？  郑州企业网站制作公司,郑州招聘网站有哪些？  相册网站制作软件,图片上的网址怎么复制？  建站之星后台密码遗忘？如何快速找回？  如何确保FTP站点访问权限与数据传输安全？  如何通过IIS搭建网站并配置访问权限？  沈阳个人网站制作公司,哪个网站能考到沈阳事业编招聘的信息？  如何做网站制作流程,*游戏网站怎么搭建？  深圳 网站制作,深圳招聘网站哪个比较好一点啊？  创业网站制作流程,创业网站可靠吗？  武清网站制作公司,天津武清个人营业执照注销查询系统网站？  建站之星伪静态规则如何设置？  网站制作软件免费下载安装,有哪些免费下载的软件网站？  购物网站制作费用多少,开办网上购物网站，需要办理哪些手续？  在线制作视频的网站有哪些,电脑如何制作视频短片？  网站企业制作流程,用什么语言做企业网站比较好？  C++如何编写函数模板？（泛型编程入门）  大连网站设计制作招聘信息,大连投诉网站有哪些？  深圳网站制作的公司有哪些,dido官方网站？  我的世界制作壁纸网站下载,手机怎么换我的世界壁纸？  建站之星logo尺寸如何设置最合适？  如何快速搭建高效简练网站？  c++23 std::expected怎么用 c++优雅处理函数错误返回【详解】