Redis实现分布式事务的示例

import redis.clients.jedis.Jedis;
import redis.clients.jedis.exceptions.JedisException;

public class RedisTransactionExample {

    private static final String REDIS_HOST = "localhost";
    private static final int REDIS_PORT = 6379;

    public static void main(String[] args) {
        Jedis jedis = new Jedis(REDIS_HOST, REDIS_PORT);

        try {
            // 开始事务
            jedis.watch("product:p001");
            String stockStr = jedis.get("product:p001");

            if (stockStr != null && Integer.parseInt(stockStr) > 0) {
                jedis.multi(); // 标记事务开始
                jedis.decr("product:p001"); // 减少库存
                jedis.sadd("user:1001", "p001"); // 添加购买记录
                List<Object> results = jedis.exec(); // 执行事务

                if (results != null && results.size() == 2) {
                    System.out.println("Transaction executed successfully.");
                } else {
                    System.out.println("Transaction failed or was cancelled.");
                }
            } else {
                System.out.println("Not enough stock.");
            }

        } catch (NumberFormatException e) {
            System.err.println("Invalid stock value: " + stockStr);
        } catch (JedisException e) {
            System.err.println("Error while executing transaction: " + e.getMessage());
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }
    }
}