【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:
发现数据已经加入进去
我们把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命令执行后和事务提交之前,如果数据发生了修改操作,事务执行就不会成功,此举保证了数据的安全性。
来源:http://blog.csdn.net/acmman/article/details/53579378
猜你喜欢
- 一、Java语言本身也是多线程,回顾Java创建线程方式如下:1、继承Thread类,(Thread类实现Runnable接口),来个类图加
- 背景为了了解Seata AT模式的原理,我通过源码解读的方式画出了Seata AT模式启动的图示:如果是基于Springboot项目的话,项
- 为什么需要网关呢?我们知道我们要进入一个服务本身,很明显我们没有特别好的办法,直接输入IP地址+端口号,我们知道这样的做法很糟糕的,这样的做
- 前言序列化想必大家都很熟悉了,对象在进行网络传输过程中,需要序列化之后才能传输到客户端,或者客户端的数据序列化之后送达到服务端序列化的标准解
- 【漏洞通告】2月19日,NVD发布安全通告披露了jackson-databind由JNDI注入导致的远程代码执行漏洞(CVE-2020-88
- Android之文件数据存储一、文件保存数据介绍Activity提供了openFileOutput()方法可以用于把数据输出到文件中,具体的
- 这篇文章主要介绍了spring cloud gateway请求跨域问题解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定
- 有时候在配置中心有些参数是需要修改的,这时候如何不重启而达到实时生效的效果呢?添加依赖<dependencies>
- 介绍备忘录模式(Memento Pattern)是一种行为型设计模式,它允许在不破坏封装性的前提下,捕获并保存一个对象的内部状态,并在之后可
- android线程消息机制主要由Handler,Looper,Message和MessageQuene四个部分组成。平常在开发中,我们常用来
- 1.问题描述在我引入SpringCloud-gateway,运行时报错如下:org.springframework.beans.factor
- 目录1.基于注释声明缓存1.1@EnableCaching1.2@Cacheable1.2.1默认key生成规则1.2.2声明自定义key
- 光流的概念是由一个叫Gibson的哥们在1950年提出来的。它描述是空间运动物体在观察成像平面上的像素运动的瞬时速度,利用图像序列中像素在时
- 本文实例为大家分享了Java分页展示的具体代码,供大家参考,具体内容如下先上图吧,大致如图,也就提供个思路(ps:使用了SSH框架) 前台J
- 一般而言,Android 应用在请求数据时都是以 Get 或 Post 等方式向远程服务器发起请求,那你有没有想过其实我们也可以在 Andr
- 目录一、前言二、正文2.1 注解2.1.1 注解1:@Target({ElementType.TYPE})2.1.2 注解2:@Retent
- 测试spring cloud 使用consul注册服务的时候,出现critical,如下:怎么解决这个问题,现在只能看到health che
- 1介绍MVC框架是什么MVC全名是Model View Controller,是模型(model)-视图(view)-控制器(control
- 本文实例讲述了C#实现最完整的文件和目录操作类。分享给大家供大家参考。具体如下:using System;using System.Text
- 本文实例为大家分享了JDBC实现学生管理系统的具体代码,供大家参考,具体内容如下1、学生类package manage;import jav