Redis 事务使用详解_redis如何执行事务

一、简介

  本文今天主要是Redis的事务的使用，以及redis对应的Java实现该怎么用。因为篇幅问题，我这里写了一个测试类，引入 RedisTemplate对象，后面例子里就不一一引入了。大家理解就行，如果大家还不知道如何通过Spring Boot 整合redis则可以查看我之前的文章：SpringBoot整合redis（redis支持单节点和集群）

package com.alian.datastruct;

import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.util.List;
import java.util.concurrent.TimeUnit;

@Slf4j
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class RedisTransactionTest {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

二、常用方法

2.1、MULTI、EXEC、DISCARD、WATCH、UNWATCH

• MULTI 标记一个事务块的开始
• EXEC 执行所有事务块内的命令
• DISCARD 取消事务，放弃执行事务块内的所有命令
• WATCH 监视一个(或多个) key ，如果在事务执行之前这个(或这些) key 被其他命令所改动，那么事务将被打断
• UNWATCH 取消 WATCH 命令对所有 key 的监视

一个事务从开始到执行会经历以下三个阶段：

• 开始事务
• 命令入队
• 执行事务

2.2、提交事务

MULTI
命令1
命令2
...
命令n
EXEC
1
2
3
4
5
6

命令操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set name alian
QUEUED
127.0.0.1:6379> set age 28
QUEUED
127.0.0.1:6379> set sex nan
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) OK
127.0.0.1:6379> get name
"alian"
127.0.0.1:6379> get age
"28"
127.0.0.1:6379> get sex
"nan"
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

Java操作

    @Test
    public void startTransaction() {
        redisTemplate.delete(Arrays.asList("name", "age", "sex"));
        redisTemplate.execute(new SessionCallback<List<Object>>() {
            public List<Object> execute(RedisOperations operations) throws DataAccessException {
                operations.multi();
                operations.opsForValue().set("name", "alian");
                operations.opsForValue().set("age", "28");
                operations.opsForValue().set("sex", "男");
                return operations.exec();
            }
        });
        log.info("事务提交后的姓名：{}", redisTemplate.opsForValue().get("name"));
        log.info("事务提交后的年龄：{}", redisTemplate.opsForValue().get("age"));
        log.info("事务提交后的性别：{}", redisTemplate.opsForValue().get("sex"));
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

事务提交后的姓名：alian
事务提交后的年龄：28
事务提交后的性别：男
1
2
3

2.3、取消事务

MULTI
命令1
命令2
...
命令n
DISCARD
1
2
3
4
5
6

命令操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set orderId 202212230102
QUEUED
127.0.0.1:6379> set title BirthdayCake
QUEUED
127.0.0.1:6379> set price 168
QUEUED
127.0.0.1:6379> discard
OK
127.0.0.1:6379> get orderId
(nil)
127.0.0.1:6379> get title
(nil)
127.0.0.1:6379> get price
(nil)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

Java操作

    @Test
    public void cancelTransaction() {
        redisTemplate.delete(Arrays.asList("orderId", "title", "price"));
        redisTemplate.execute(new SessionCallback<List<Object>>() {
            public List<Object> execute(RedisOperations operations) throws DataAccessException {
                operations.multi();
                operations.opsForValue().set("orderId", "202212230102");
                operations.opsForValue().set("title", "BirthdayCake");
                operations.opsForValue().set("price", "168");
                operations.discard();
                return null;
            }
        });
        log.info("事务取消后的姓名：{}", redisTemplate.opsForValue().get("orderId"));
        log.info("事务取消后的年龄：{}", redisTemplate.opsForValue().get("title"));
        log.info("事务取消后的性别：{}", redisTemplate.opsForValue().get("price"));
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

事务取消后的姓名：null
事务取消后的年龄：null
事务取消后的性别：null
1
2
3

从这里可以看到，取消事务后，命令都未执行。

2.4、编译时异常

  一般是命令写错了或者命令不存在导致，比如不存在的命令

命令操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set name alian
QUEUED
127.0.0.1:6379> set age 28
QUEUED
127.0.0.1:6379> setget sex man    ##故意写错命令
(error) ERR unknown command `setget`, with args beginning with: `sex`, `man`,
127.0.0.1:6379> set hobby write
QUEUED
127.0.0.1:6379> exec
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> get name
(nil)
127.0.0.1:6379> get age
(nil)
127.0.0.1:6379> get hobby
(nil)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

  编译时异常后面的命令都执行失败

2.5、运行时异常

  一般是类型错误了，比如没有按指定类型获取值，或者是给非数字字符做自增等

命令操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set title basketball
QUEUED
127.0.0.1:6379> set price 239
QUEUED
127.0.0.1:6379> hgetall title    ##title的类型是string不是hash
QUEUED
127.0.0.1:6379> set address shenzhen
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) (error) WRONGTYPE Operation against a key holding the wrong kind of value
4) OK
127.0.0.1:6379> get title
"basketball"
127.0.0.1:6379> get price
"239"
127.0.0.1:6379> get address
"shenzhen"
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

  运行时异常并不影响后面命令的执行。

   Redis单条命令是原子性的，但是Redis事务是不保证原子性的，会按照顺序一条条执行

2.6、乐观锁

用一个场景来模拟乐观锁。

• 终端1，监控key，开启事务
• 终端1，命令对key操作入队
• 终端2，命令对key的值进行修改
• 终端1，提交事务（失败）

终端1

127.0.0.1:6379> set money 0
OK
127.0.0.1:6379> set num 10
OK
127.0.0.1:6379> watch money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incrby money 100
QUEUED
127.0.0.1:6379> decrby num 1
QUEUED
1
2
3
4
5
6
7
8
9
10
11
12

• 初始化数据
• 监控key，开启事务
• 命令入队（还未执行）

终端2

127.0.0.1:6379> get money
"0"
127.0.0.1:6379> incrby money 50
(integer) 50
1
2
3
4

• 修改监控的值

终端1

127.0.0.1:6379> exec
(nil)
127.0.0.1:6379> get money
"50"
127.0.0.1:6379> get num
"10"
1
2
3
4
5
6

• 在终端2修改监控值之后，执行事务
• 发现全部执行失败

正常操作

127.0.0.1:6379> unwatch
OK
127.0.0.1:6379> watch money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incrby money 100
QUEUED
127.0.0.1:6379> decrby num 1
QUEUED
127.0.0.1:6379> exec
1) (integer) 150
2) (integer) 9
1
2
3
4
5
6
7
8
9
10
11
12
13