【Redis】Redis事务详解

Redis的事务（transaction）允许在一个单独的操作序列中执行多个命令，并保证这些命令在其他客户端无法中断的情况下执行。Redis通过MULTI、EXEC、DISCARD和WATCH命令来实现事务管理。

Redis事务的基本命令

MULTI：开启一个事务块。
EXEC：执行所有在事务块中排队的命令。
DISCARD：取消事务，放弃事务块中的所有命令。
WATCH：监视一个或多个键，如果在事务执行之前这些键被修改，那么事务将被取消。

Redis事务的使用步骤

使用MULTI命令开始一个事务。
执行一系列的命令，这些命令将被放入事务队列中，而不会立即执行。
使用EXEC命令提交事务，所有的命令将按顺序执行。
如果在事务开始后但在执行之前需要取消事务，可以使用DISCARD命令。

代码示例

下面是一个使用Jedis（Java的Redis客户端）来实现Redis事务的示例代码：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;public class RedisTransactionExample {public static void main(String[] args) {Jedis jedis = new Jedis("localhost", 6379);try {// 清空当前数据库jedis.flushDB();// 开启一个事务Transaction transaction = jedis.multi();try {// 在事务中添加多个命令transaction.set("key1", "value1");transaction.set("key2", "value2");transaction.incr("counter");// 提交事务transaction.exec();} catch (Exception e) {// 如果发生任何异常，取消事务transaction.discard();e.printStackTrace();}// 验证结果System.out.println("key1: " + jedis.get("key1"));System.out.println("key2: " + jedis.get("key2"));System.out.println("counter: " + jedis.get("counter"));} finally {// 关闭连接jedis.close();}}
}

乐观锁（Optimistic Locking）

Redis的WATCH命令用于实现乐观锁。当一个或多个键被WATCH监视后，如果这些键在事务执行之前被其他客户端修改，事务将被取消。

WATCH命令示例

public class RedisOptimisticLockingExample {public static void main(String[] args) {Jedis jedis = new Jedis("localhost", 6379);try {// 清空当前数据库jedis.flushDB();// 设置初始值jedis.set("balance", "100");jedis.set("debt", "0");// 监视balance键jedis.watch("balance");int balance = Integer.parseInt(jedis.get("balance"));int debt = Integer.parseInt(jedis.get("debt"));int payment = 30;// 检查余额是否足够支付if (balance >= payment) {// 开启事务Transaction transaction = jedis.multi();try {// 更新余额和债务transaction.decrBy("balance", payment);transaction.incrBy("debt", payment);// 提交事务transaction.exec();System.out.println("Transaction successful");} catch (Exception e) {transaction.discard();System.out.println("Transaction failed");e.printStackTrace();}} else {System.out.println("Insufficient balance");}// 验证结果System.out.println("balance: " + jedis.get("balance"));System.out.println("debt: " + jedis.get("debt"));} finally {// 取消监视jedis.unwatch();// 关闭连接jedis.close();}}
}