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

作者:光仔December 时间:2023-05-23 19:59:55 

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命令执行后和事务提交之前,如果数据发生了修改操作,事务执行就不会成功,此举保证了数据的安全性。

来源:http://blog.csdn.net/acmman/article/details/53579378

标签:java,jedis,redis
0
投稿

猜你喜欢

  • Java OpenCV4.0.0实现实时人脸识别

    2023-11-16 07:29:14
  • Mybatis Plus 中的LambdaQueryWrapper示例详解

    2023-03-26 04:52:06
  • Java JVM程序指令码实例解析

    2022-05-16 15:09:38
  • WinFrom中label背景透明的实现方法

    2023-05-08 13:05:40
  • idea +junit单元测试获取不到bean注入的解决方式

    2022-12-09 05:59:27
  • ThreadLocal的set方法原理示例解析

    2023-11-09 15:06:09
  • Spring学习之Bean的装配多种方法

    2023-09-04 09:32:36
  • java内存模型jvm虚拟机简要分析

    2022-09-08 09:29:34
  • 深入多线程之:内存栅栏与volatile关键字的使用分析

    2021-05-29 10:02:56
  • SpringMVC实现文件上传和下载功能

    2022-10-03 18:22:27
  • Kotlin协程之Flow基础原理示例解析

    2021-10-17 21:07:44
  • SpringCloud如何解决服务之间的通信问题

    2023-03-27 03:13:05
  • Android4.4新增函数访问外部存储

    2022-09-14 18:34:04
  • Java String源码分析并介绍Sting 为什么不可变

    2021-09-23 06:10:42
  • Android listview的滑动冲突解决方法

    2022-07-19 02:50:59
  • Spring和Hibernate的整合操作示例

    2023-08-08 11:57:52
  • Java基础之Stream流原理与用法详解

    2021-06-07 22:16:05
  • Android实现拍照截图功能

    2023-06-21 04:43:23
  • Java后端Tomcat实现WebSocket实例教程

    2023-08-22 17:31:09
  • Java基础教程之HashMap迭代删除使用方法

    2023-10-04 02:15:32
  • asp之家 软件编程 m.aspxhome.com