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

 更新时间:2016年12月15日 14:25:36   作者:光仔December  
这篇文章主要介绍了【Redis缓存机制】详解Java连接Redis_Jedis_事务,详细的介绍了Jedis事务和实例,有兴趣的可以了解一下。

Java技术迷

Jedis事务

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

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

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

Jedis事务的相关代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
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()语句:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
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的事务来处理一些逻辑:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
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方法捕获打断异常,然后弹出相应警告框。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
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命令执行后和事务提交之前,如果数据发生了修改操作,事务执行就不会成功,此举保证了数据的安全性。

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

蓄力AI

微信公众号搜索 “ 脚本之家 ” ,选择关注

程序猿的那些事、送书等活动等着你

原文链接:http://blog.csdn.net/acmman/article/details/53579378

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符,请将相关资料发送至 reterry123@163.com 进行投诉反馈,一经查实,立即处理!

相关文章

  • Spring内置定时任务调度@Scheduled使用详解

    Spring内置定时任务调度@Scheduled使用详解

    这篇文章主要介绍了Spring内置定时任务调度@Scheduled使用详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-12-12
  • servlet3新特性_动力节点Java学院整理

    servlet3新特性_动力节点Java学院整理

    这篇文章主要为大家详细介绍了servlet3新特性的相关资料,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-07-07
  • java中ArrayList的两种排序方法实例

    java中ArrayList的两种排序方法实例

    ArrayList是一个数组队列,相当于 动态数组,与Java中的数组相比,它的容量能动态增长,这篇文章主要给大家介绍了关于java中ArrayList的两种排序方法,需要的朋友可以参考下
    2021-07-07
  • 使用MyBatis从hive中读取数据

    使用MyBatis从hive中读取数据

    Hive是一个基于Hadoop的数据仓库工具,它可以方便地对大规模数据进行查询和分析,本文主要介绍了使用MyBatis从hive中读取数据,具有一定的参考价值,感兴趣的可以了解一下
    2024-05-05
  • SpringBoot中各种Controller的写法

    SpringBoot中各种Controller的写法

    这篇文章主要介绍了SpringBoot中各种Controller的写法,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • Java多线程之并发编程的核心AQS详解

    Java多线程之并发编程的核心AQS详解

    AQS ( AbstractQueuedSynchronizer)是一个用来构建锁和同步器的框架,使用AQS能简单且高效地构造出应用广泛的大量的同步器,下面小编和大家来一起学习一下吧
    2021-09-09
  • 一文详解SpringBoot3如何自定义starter

    一文详解SpringBoot3如何自定义starter

    在Spring Boot中,starter是一种特殊的依赖,它可以帮助开发人员快速引入和配置某个特定的功能模块,我们在面试中通过会被问到SpringBoot3如何自定义starter,所以本文小编给大家详细介绍了SpringBoot3自定义starter的步骤,需要的朋友可以参考下
    2024-09-09
  • SpringBoot常用计量与bean属性校验和进制数据转换规则全面分析

    SpringBoot常用计量与bean属性校验和进制数据转换规则全面分析

    这篇文章主要介绍了SpringBoot常用计量、bean属性校验与进制数据转换规则,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习吧
    2022-10-10
  • Java中的OkHttp使用教程

    Java中的OkHttp使用教程

    OkHttp是目前非常火的网络库,OKHttp与HttpClient类似,也是一个Http客户端,提供了对 HTTP/2 和 SPDY 的支持,并提供了连接池,GZIP 压缩和 HTTP 响应缓存功能,本文重点给大家介绍Java OkHttp使用,感兴趣的朋友一起看看吧
    2022-04-04
  • Eclipse中maven的配置详解

    Eclipse中maven的配置详解

    这篇文章主要介绍了Eclipse中maven的配置详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-10-10

最新评论