Redis 作为一款高性能的键值存储数据库，常用于缓存、会话管理和队列等场景。在多线程或分布式环境中，数据一致性是关键挑战。Redis 事务机制允许客户端将一组命令打包执行，提供了一种“原子性”的方式来执行多个操作，避免中间状态被其他客户端干扰。

Redis 事务不同于传统数据库（如 MySQL）的 ACID 事务：它不提供回滚机制，也没有严格的隔离级别，但通过

和命令队列实现了轻量级的原子执行。事务从 Redis 2.2 版本引入，适用于操作顺序严格的场景，如库存扣减或多键原子更新。

Redis 事务将多个命令放入一个队列中，延迟到 

 命令执行时才一次性应用于数据库。这确保了命令的顺序性和原子性（在执行期内不可被中断），但如果事务中某个命令语法错误，整个事务可能失败或部分成功。

> MULTI
OK
> SET user:1 name "Alice"
QUEUED  # 命令入队，不执行
> INCR counter  # 假设 counter 不存在，本应失败，但入队
QUEUED
> GET user:1 name
QUEUED
> EXEC
1) OK
2) (integer) 1  # INCR 执行成功，因为 counter 自动创建
3) "Alice"

假设我们需要原子地更新用户余额：扣除 100 元，如果余额 >= 100。

> SET balance:1001 500  # 初始余额 500
OK
> MULTI
OK
> GET balance:1001
QUEUED
> DECRBY balance:1001 100
QUEUED
> EXEC
1) "500"
2) (integer) 400  # 原子执行，余额变为 400

Jedis 是 Redis 的 Java 官方客户端，支持事务。以下是扣除余额的示例，确保原子性。

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); // 连接 Redis 
        jedis.set("balance:1001", "500"); 
        try { 
            // 开启事务 
            Transaction tx = jedis.multi(); 
            // 入队命令 
            tx.get("balance:1001"); 
            tx.decrBy("balance:1001", 100); 
            // 执行事务 
            Object[] results = tx.exec(); 
            if (results != null && results.length > 0) { 
                String oldBalance = (String) results[0]; 
                Long newBalance = (Long) results[1]; 
                System.out.println("旧余额: " + oldBalance + ", 新余额: " + newBalance); 
            } else { 
                System.out.println("事务失败或被中断"); 
            } 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } finally { 
            jedis.close(); 
        } 
    } 
}

，每个元素对应一个命令的结果。如果事务失败，返回 

。Jedis 事务是线程不安全的，仅限单个连接。

WATCH 实现 CAS（Compare-And-Swap）语义，防止 ABA 问题。监视键在 MULTI 前设置，如果键值变化，EXEC 失败（返回 null），客户端可重试。

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction; 
import java.util.List; 

public class WatchExample { 

    public static boolean deductBalance(Jedis jedis, String key, long amount) { 

        while (true) {  // 重试循环 
            jedis.watch(key);  // 监视键 
            String value = jedis.get(key); 
            if (value != null && Long.parseLong(value) >= amount) { 
                Transaction tx = jedis.multi(); 
                tx.decrBy(key, amount); 
                List<Object> results = tx.exec(); 
                if (results != null && !results.isEmpty()) { 
                    System.out.println("扣款成功，新余额: " + results.get(0)); 
                    jedis.unwatch();  // 取消监视 
                    return true; 
                } 
            } 
            jedis.unwatch();  // 失败时取消 
            // 可添加重试延迟或次数限制 
            try { 
                Thread.sleep(10); 
            } catch (InterruptedException e) { 
                Thread.currentThread().interrupt(); 
                return false; 
            } 
        } 
    } 

    public static void main(String[] args) { 
        Jedis jedis = new Jedis("localhost", 6379); 
        jedis.set("balance:1001", "500"); 
        // 模拟另一个线程修改 
        new Thread(() -> { 
            try { 
                Thread.sleep(50); 
                jedis.set("balance:1001", "200"); 
                System.out.println("其他客户端修改余额为 200"); 
            } catch (InterruptedException e) { 
                Thread.currentThread().interrupt(); 
            } 
        }).start(); 
        deductBalance(jedis, "balance:1001", 100);  // 会重试直到成功或失败 
        jedis.close(); 
    } 
}

：重试机制防止无限循环（实际中添加最大重试次数）。WATCH 不阻塞，适合高并发场景。

对于条件逻辑复杂的事务，用 EVAL 执行 Lua 脚本。Lua 在 Redis 服务端运行，原子执行，支持读写操作。

> EVAL "if redis.call('GET', KEYS[1]) then redis.call('DECRBY', KEYS[1], ARGV[1]) return 1 else return 0 end" 1 balance:1001 100
(integer) 1  # 成功

import redis.clients.jedis.Jedis;

public class LuaExample { 

    public static void main(String[] args) { 

        Jedis jedis = new Jedis("localhost", 6379); 
        jedis.set("balance:1001", "500"); 
        String luaScript = "if tonumber(redis.call('GET', KEYS[1])) >= tonumber(ARGV[1]) " + 
                           "then redis.call('DECRBY', KEYS[1], ARGV[1]) return 1 " + 
                           "else return 0 end"; 

        Long result = (Long) jedis.eval(luaScript, 1, "balance:1001", "100"); 
        System.out.println("扣款结果: " + (result == 1 ? "成功" : "失败")); 
        jedis.close(); 
    } 
}

：EVAL 参数：脚本、KEYS 数、键列表、ARGV 值列表。Lua 原子性强，支持循环/条件，比事务灵活。SHA1 缓存

Redis中的事务详解

本文将详细讲解 Redis 事务的核心概念、命令实现、特性、示例以及注意事项。前提假设读者熟悉基本的 Redis 操作（如 SET、GET）

编程语言

前端

Redis事务机制详解：高性能键值数据库的原子操作实现，涵盖MULTI/EXEC命令、乐观锁WATCH及Lua脚本应用。解析Redis事务的队列化执行、无回滚特性及分布式环境下的数据一致性保障方案，提供Java客户端实现示例，帮助开发者实现可靠的缓存与数据操作。

数据一致性

数据库

服务器

MySQL

Redis

Java

腾讯云数据库特惠，新用户首单0.5折起


2026新春采购季

tencentdb-catalog

4核4G3M云服务器 新用户低至38元/年！

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云AI代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

功能1上新10个字符

功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符。

功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符。

功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符

功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符

功能4上新

文章&问答评论现已支持表情

全新交互，全新视觉，新增快捷键、悬浮工具栏、高亮块等功能并同时优化现有功能，全面提升创作效率和体验

社区富文本编辑器全新改版！诚邀体验～ 

精选全网热门MCP server，让你的AI更好用 🚀

💥开发者 MCP广场重磅上线！

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

Redis中的事务详解

Redis中的事务详解

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐