Redis事务概述

前言

事务是关系型数据库中一项基础功能，用于将多个命令打包执行，确保所有命令按顺序完成后，才会处理其他命令。在支付系统中，事务的重要性尤为突出。例如，在消费过程中，只有正常完成后才会扣减账户余额。如果没有事务保障，可能会出现扣款失败但账户余额已扣减的情况，这显然无法接受。因此，事务是关系型数据库的核心功能之一。

事务基本使用

在其他语言中，事务通常分为三个阶段：

开启事务

执行业务逻辑

处理异常（回滚事务）

Redis的事务机制虽然与其他语言不同，但同样遵循三个阶段。Redis的事务执行流程包括以下三个阶段：

开启事务

命令入列

执行事务或放弃事务

开启事务

开启事务使用multi命令。执行multi后，客户端会进入事务模式，并返回OK。如果客户端已经处于事务模式，再次执行multi会返回错误ERR MULTI calls can not be nested，但不会终止事务状态。

命令入列

在事务模式下，所有命令依次入列，返回QUEUED。命令入列遵循FIFO原则，按顺序执行。

执行事务或放弃事务

执行事务使用exec命令，放弃事务使用discard命令。

事务示例

以下是事务执行示例：

> multi
OK
> set k v
QUEUED
> exec
1) OK
> get k
v

放弃事务示例：

> multi
OK
> set k v
QUEUED
> discard
OK
> get k
v

事务错误与回滚

事务执行中的错误分为三类：

执行时错误

入列时错误（不终止事务）

入列时错误（终止事务）

执行时错误

以下是执行时错误示例：

> get k
v
> multi
OK
> set k v2
QUEUED
> expire k 10s
QUEUED
> exec
1) OK
2) (error) ERR value is not an integer or out of range
> get k v2
v2

入列时错误（不终止事务）

以下是入列时错误不终止事务示例：

> get k v
v
> multi
OK
> set k v2
QUEUED
> multi
(error) ERR MULTI calls can not be nested
> exec
1) OK
> get k v2
v2

入列时错误（终止事务）

以下是入列时错误终止事务示例：

> get k v2
v2
> multi
OK
> set k v3
QUEUED
> set k
(error) ERR wrong number of arguments for 'set' command
> exec
(error) EXECABORT Transaction discarded because of previous errors.
> get k v2
v2

为什么不支持事务回滚？

Redis不支持事务回滚的原因包括：

编程错误通常发生在开发环境中，而非生产环境。

Redis内部设计复杂，支持事务回滚会影响性能和简单性。

监控

watch命令用于在多客户端环境下提供乐观锁。执行watch监控某个键，如果键在事务过程中被修改，整个事务终止。

以下是watch示例：

> watch k
OK
> multi
OK
> set k v2
QUEUED
> exec
1) OK
> get k
nil

unwatch命令用于取消监控。

以下是unwatch示例：

> set k v
OK
> watch k
OK
> multi
OK
> unwatch
QUEUED
> set k v2
QUEUED
> exec
1) OK
> get k
v2

事务在程序中使用

以下是Java中使用Redis事务的示例：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;
public class TransactionExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("xxx.xxx.xxx.xxx", 6379);
        jedis.auth("xxx");
        jedis.set("k", "v");
        jedis.watch("k");
        Transaction tx = jedis.multi();
        tx.set("k", "v2");
        tx.exec();
        System.out.println(jedis.get("k"));
        jedis.close();
    }
}