讲师中心 微信公众号
AI工具推荐 视频效率加速

Redis中使用Lua脚本实现分布式计数器如何保证一致性?

老静大大_9411

老静大大_9411

发布时间:2026-08-22 11:33:22

|

454人浏览过

|

来源于php中文网

原创

“先查后incr”必出错,因其非原子操作:Java中get、判断、incr三步存在竞态窗口,多请求可同时读旧值并写入,导致计数翻倍或漏限;而Lua脚本将判断、计数、过期设置全置于Redis单线程内执行,天然强一致。

redis中使用lua脚本实现分布式计数器如何保证一致性?

为什么“先查后 incr”一定会出错

因为这不是原子操作。常见写法是 Java 里先 stringRedisTemplate.opsForValue().get("counter"),再 if 判断,最后 incr("counter")。这三步之间有竞态窗口:多个请求可能同时读到旧值、同时判定未超限、同时写入,最终计数翻倍或漏限。

Redis 单命令(如 INCR)本身原子,但跨命令的逻辑判断不在 Redis 控制范围内。网络延迟、JVM 调度、本地计算时间都会放大这个窗口。

  • GET 和 INCR 是两次独立网络往返,中间可能插入任意其他客户端请求
  • MULTI/EXEC 不能解决「读-算-写」逻辑竞争,它只保证命令序列不被穿插,不保证条件分支不出错
  • 哪怕用 WATCH 做乐观锁,失败重试在高并发下开销大,且业务逻辑仍暴露在客户端

必须把全部逻辑塞进 Lua 脚本里

Lua 脚本在 Redis 单线程中一次性执行完毕,中间不会被任何其他命令打断。只要判断、计数、过期设置全在脚本内完成,就天然强一致。

典型固定窗口限流脚本结构:

local key = KEYS[1]
local window = tonumber(ARGV[1])  -- 窗口秒数,如 60
local max = tonumber(ARGV[2])     -- 最大请求数,如 100
<p>local current = redis.call('INCR', key)
if current == 1 then
redis.call('EXPIRE', key, window)
end
if current > max then
return 0
else
return 1
end
  • INCR 自动初始化 key(不存在时从 0 开始),无需先 GET
  • EXPIRE 只在首次 INCR 时设置,避免重复覆盖过期时间
  • 返回值直接告诉调用方是否放行,Java 层不做任何判断

EVALSHA 与 SCRIPT LOAD 必须配对使用

生产环境绝不能每次都用 EVAL 发送完整脚本字符串。脚本太长会触发 ERR Error running script (call to f_): @user_script: N: user_script: too long 错误(Redis 默认限制 4KB)。

Redis Skill - 高性能缓存管理
Redis Skill - 高性能缓存管理

Redis 缓存和数据结构管理技能。通过自然语言操作 Redis,支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。

下载

正确做法是提前注册脚本,后续只传哈希值:

  • 首次调用前,必须执行 SCRIPT LOAD,例如:redis-cli --eval "script.lua" 1 counter 或代码中显式调用 redisTemplate.execute(RedisScript, ...) 触发预热
  • 之后统一用 EVALSHA,只传 40 字符 SHA1 值,大幅减少网络包体积和 Redis 解析开销
  • 若忘记 SCRIPT LOAD,EVALSHA 直接返回 NOSCRIPT 错误——这个错误极易被吞掉,导致限流完全失效

Redis Cluster 下多 key 的坑必须绕开

想用一个脚本同时操作多个计数器(比如按用户+接口双维度限流),在 Cluster 模式下会遇到 CROSSSLOT Keys in request don't hash to the same slot 报错。

这不是脚本问题,而是 Redis Cluster 架构硬约束:所有 KEYS 必须落在同一个 slot 才能被路由到同一节点执行。

  • 解决方案只有两个:要么改用单节点 Redis(适合中小规模);要么设计 key 名称让相关计数器强制落在同 slot,例如加固定前缀 {user:123}:api:/order,花括号内内容决定 slot 分配
  • 别试图在脚本里用 redis.call('GET', 'other:key') 跨 key 访问——Cluster 下照样报 CROSSSLOT
  • 如果真要跨 slot 计数,只能拆成多次 EVALSHA 调用,但此时「全局一致性」已无法保证,需接受最终一致性

真正难的不是写脚本,而是让整个链路没死角:脚本逻辑闭环、预热机制可靠、Cluster 分片可控、错误反馈可监控。少一个环节,一致性就塌一块。

热门AI工具

更多
WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

LibLibAI
LibLibAI Hot

一款AI视频创作工具,主要用于国内领先的AI创意平台,以海量模型、低门槛操作与“创作-分享-商业化”生态,让小白与专业创作者都能高效实现图文乃至视频创意表达,适合需要提升相关任务效率的用户。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

相关专题

更多
什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

1933

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

2774

2023.10.07

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4289

2023.11.02

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

3775

2023.11.14

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

6852

2024.04.02

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

623

2024.04.07

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

736

2024.04.07

mysql和redis怎么保证双写一致性
mysql和redis怎么保证双写一致性

确保 mysql 和 redis 双写一致性的技术包括:1、事务性更新:同时更新 mysql 和 redis,保证一致性;2、主从复制:mysql 主服务器更改同步到 redis 从服务器;3、基于事件的更新:mysql 记录更改并发送到 redis等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

6462

2024.04.07

LLVM自定义Pass怎么写
LLVM自定义Pass怎么写

本专题聚焦LLVM自定义Pass开发,整理Pass类结构、run()方法、PreservedAnalyses、CMake构建、插件注册、-load-pass-plugin加载和测试用例编写流程。

80

2026.09.30

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

进程与SOCKET
进程与SOCKET

共6课时 | 0.5万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn