首页 > 代码库 > redis13---事务处理。
redis13---事务处理。
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=http://www.mamicode.com/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命令执行后和事务提交之前,如果数据发生了修改操作,事务执行就不会成功,
redis13---事务处理。