Java开发 - Redis事务怎么用？

àì夳堔傛蜴生んèń 2023-10-14 07:29 45阅读 0赞

## 前言 ##

最近博主感觉捅了Redis窝，从Redis主从，哨兵，集群，集群原理纷纷讲了一遍，不知道大家都学会了多少，想着送佛送到西，不如再添一把火，所以今天带给大家的博客是Redis事务！有人要问，什么？Redis也有事务？没错，Redis也有类似于MySQL的事务，不要惊奇，这也不是刚刚有，只是很多人平时不常用罢了。

## 事务 ##

事务我们知道，是存在于关系型数据库中的一种数据处理手段，主要责任是数据的CRUD，还包括了事务提交和回滚。那么在Redis里，有没有一种机制也能处理数据的提交和回滚呢？答案是肯定的，那就是Redis事务，它是一个类原子的隔离操作，将一系列指令按需排队并顺序执行，期间不会被其他指令插队。但，Redis事务在运行时无法预测，所以也无法回滚。

### 指令 ###

在Redis事务中，共有三大指令：

*  multi：开启事务
 *  exec：执行事务
 *  discard：取消事务

在multi之后开启事务，此时可以set多个key，这些key将按照顺序存入先进先出的队列，exec执行事务，这些事务将按照入队的顺序执行，在这些事务执行过程中，不受其他的插入指令影响。在组队阶段使用discard指令，由于未使用exec指令开启事务，所以前面队列中的操作将全部取消。

我们来做个演示，首先开启一个Redis服务：

redis-server redis1.conf

连接redis：

redis-cli -h localhost -p 6379

#### 正常执行 ####

![c646c22c5b224778b269dbdd0afcb220.png][]

#### 取消执行 ####

#### ![96a4f3847d944c68a8a3baa8326cb98b.png][] ####

因为没有执行exec，所以discard后，前面的c和d都不会执行。

#### 组队错误 ####

![89eb36fa403b45d78a6cde4188f3998e.png][]

可以看到，在组队时抱了错，事务是不会执行的。

#### 执行错误 ####

![05bfab6bb5ca4406bcd321358add85dc.png][]

我们在set c之后对c进行+1操作，由于c不是integer类型，所以报错了，但是我们发现，最终c和d被存储进了redis，从这一点来看，运行过程中的异常不会导致队列中的任务取消。

#### Redis和锁 ####

为了保证数据的安全性，我们有时候在做key的存储的时候会给key加锁，防止多个线程的情况下key被篡改去情况发生，一般发生在抢购/秒杀时对库存的操作上。

被关锁就不再多提了，使用被关锁可以完全防止key被篡改，但相应的，线程也将被阻塞，降低效率，这里说说乐观锁在redis里的使用，我们看如下操作。

首先我们需要再开一个命令行，模拟两个线程的场景:

在开始前，我们先通过flushdb指令清空redis中的数据：

![fb2aa77fd7cb4c86a5e07461f36bc15d.png][]

##### 监听key并开启事务 #####

线程1:

![0c706df3625240e8adfdeb7d2b826d4c.png][]

线程2:

![977b91c8dcf2460c8edb09ebaf3ff0d0.png][]

操作并提交key

线程1:

![749b8e962fab495a820ca7c686da1c23.png][]

线程2:

![2b652bb592044794ae7178dfa1224a0d.png][]

可以看到线程2在对a+1的时候出问题了，返回nil。像不像CAS，没错，乐观锁的本质就是CAS，比较并交换，比较的值被改变了，自然不会存入新值。

### 回滚与原子性 ###

#### Redis回滚 ####

那有人要问了 ，redis到底能不能回滚？其实在上面我们已经得到了答案，就是在组队阶段是可以回滚的，看“组队错误”，在执行阶段是不支持回滚的，看“执行错误”。

所以，最终我们得出结论，在使用中，redis可支持回滚，但是情况比较复杂，是一种可预知的错误，而那些不可预知的错误，则是无法回滚。

#### 原子性 ####

基于以上redis事务执行时出现的组队和执行问题，所以利用redis做库存的扣减似乎是一件不太稳妥的事，所以，为了弥补这个缺陷，我们需要使用redis的原子性。原子性的特点就是：要么一起执行，要么不执行。这里我们应该都听说一个东西叫lua脚本，其特点我就不多说了，总之就是执行快且保证原子性（不被打断），但是，lua脚本也不支持回滚，所以关于redis的回滚，大家就不要纠结了。

## Spring Boot接入Redis事务 ##

关于Spring Boot接入Redis事务，怎么说呢？感觉没太大必要，哈哈，不过也不能说一无是处，用还是有人在用的，这里博主就简单讲讲怎么用。

### 启动Redis服务 ###

![fc82fd35f989416ca91260c30af09aeb.png][]

上面Redis已经启动了，直接用。

### redisTemplate使用事务 ###

#### 添加依赖 ####

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>

#### 添加配置 ####

spring.redis.host=127.0.0.1
    spring.redis.port=6379

#### 准备测试代码 ####

@Test
        void testTransaction() {
            //开启事务支持
            redisTemplate.setEnableTransactionSupport(true);
            //开启事务
            redisTemplate.multi();
            redisTemplate.opsForValue().set("name1", "codingfire1");
            redisTemplate.opsForValue().set("name2", "codingfire2");
    
            //执行事务
            redisTemplate.exec();
            System.out.println(redisTemplate.opsForValue().get("name1"));
            System.out.println(redisTemplate.opsForValue().get("name2"));
        }

以上代码在运行的时候发现报错了：

![7192702c334d402cb9ebe96046b88e35.png][]

但是当我打开redis可视化工具查看时发现数据已经存进去了：

![3f546c0f751348baa98aa3699293a44b.png][]

官方是通过Jedis来实现事务的，所以这个问题出现了还让人有点懵，很多人说是因为没开启事务支持，但是博主明显开启了，所以有些无从解答了，有知道原因的可以告诉博主。

但是活人不能让尿憋死啊，有一种SessionCallback的方式是很多人都推荐使用的，我们来看看：

@Test
        public void testTransaction2(){
            redisTemplate.execute(new SessionCallback<List<Object>>(){
                @Override
                public List<Object> execute(RedisOperations operations) throws DataAccessException {
                    operations.multi();
                    operations.opsForValue().set("name3","codingfire3");
                    operations.opsForValue().set("name4","codingfire4");
                    operations.opsForValue().set("name5","codingfire5");
                    return redisTemplate.exec();
                }
            });
        }

执行后没报错，我们看下redis可视化工具：

![e32d7876d1ab4cd4860200f7b954e66a.png][]

测试成功。

### Jedis引入 ###

我们刚刚提到了一种Jedis实现的方式，下面我们来说说Jedis怎么实现。

#### 添加依赖 ####

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    
    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>3.3.0</version>
    </dependency>

#### 添加配置 ####

spring.redis.host=127.0.0.1
    spring.redis.port=6379

#### 准备测试代码 ####

@Test
        public void testTransaction3(){
            Jedis jedis =new Jedis("127.0.0.1",6379);
            ;//开启事务
            Transaction transaction = jedis.multi();
            try {
                transaction.set("key1", "v1");
                //制造异常,测试取消事务
                //int i=1/0;
                transaction.set("key2", "v2");
                //执行事务
                transaction.exec();
            }catch (Exception e){
                //取消事务
                transaction.discard();
                e.printStackTrace();
            }
        }

查看redis可视化工具：

![bbedbf7070ec497a921d0c4034916a5a.png][]

测试成功。

## 结语 ##

以上是对redis事务的一个实操过程，建议大家在做key的存入的时候不要对多个key进行关联，主要是避免出现数据不一致的情况。整体上就是这样，推荐使用SessionCallback和Jedis的方式，虽然你可能不一定会用到这东西，但是万一用到了呢？

[c646c22c5b224778b269dbdd0afcb220.png]: https://img-blog.csdnimg.cn/c646c22c5b224778b269dbdd0afcb220.png
[96a4f3847d944c68a8a3baa8326cb98b.png]: https://img-blog.csdnimg.cn/96a4f3847d944c68a8a3baa8326cb98b.png
[89eb36fa403b45d78a6cde4188f3998e.png]: https://img-blog.csdnimg.cn/89eb36fa403b45d78a6cde4188f3998e.png
[05bfab6bb5ca4406bcd321358add85dc.png]: https://img-blog.csdnimg.cn/05bfab6bb5ca4406bcd321358add85dc.png
[fb2aa77fd7cb4c86a5e07461f36bc15d.png]: https://img-blog.csdnimg.cn/fb2aa77fd7cb4c86a5e07461f36bc15d.png
[0c706df3625240e8adfdeb7d2b826d4c.png]: https://img-blog.csdnimg.cn/0c706df3625240e8adfdeb7d2b826d4c.png
[977b91c8dcf2460c8edb09ebaf3ff0d0.png]: https://img-blog.csdnimg.cn/977b91c8dcf2460c8edb09ebaf3ff0d0.png
[749b8e962fab495a820ca7c686da1c23.png]: https://img-blog.csdnimg.cn/749b8e962fab495a820ca7c686da1c23.png
[2b652bb592044794ae7178dfa1224a0d.png]: https://img-blog.csdnimg.cn/2b652bb592044794ae7178dfa1224a0d.png
[fc82fd35f989416ca91260c30af09aeb.png]: https://img-blog.csdnimg.cn/fc82fd35f989416ca91260c30af09aeb.png
[7192702c334d402cb9ebe96046b88e35.png]: https://img-blog.csdnimg.cn/7192702c334d402cb9ebe96046b88e35.png
[3f546c0f751348baa98aa3699293a44b.png]: https://img-blog.csdnimg.cn/3f546c0f751348baa98aa3699293a44b.png
[e32d7876d1ab4cd4860200f7b954e66a.png]: https://img-blog.csdnimg.cn/e32d7876d1ab4cd4860200f7b954e66a.png
[bbedbf7070ec497a921d0c4034916a5a.png]: https://img-blog.csdnimg.cn/bbedbf7070ec497a921d0c4034916a5a.png