Redis发布订阅模式如何处理突发流量_通过削峰填谷策略优化Redis负载均衡

秋浩姑娘_9199

秋浩姑娘_9199

2026-04-04

575人浏览

原创

pub/sub不支持削峰填谷,因无缓冲、不落盘、不排队;真正实现削峰填谷需用list或stream等有状态、可持久、可回溯结构。

redis发布订阅模式如何处理突发流量_通过削峰填谷策略优化redis负载均衡

PUB/SUB 本身不支持削峰填谷——它没有缓冲、不落盘、不排队,消息一发即逝。想靠它扛住突发流量,等于让快递员把包裹直接扔进人群里,没人接就丢。

真正能做削峰填谷的,是 LIST、STREAM 这类有状态、可持久、可回溯的数据结构。但 PUB/SUB 可以配合它们用,比如用它广播“有新订单来了”,下游消费者再从 STREAM 拉取具体数据。


SUBSCRIBE 阻塞连接在高并发下会快速耗尽连接数

  • Redis 的 SUBSCRIBE 是长连接,每个订阅者独占一个连接;一旦订阅多个频道或使用 PSUBSCRIBE,连接不会复用
  • 默认 maxclients 是 10000,但实际中 2000+ 活跃订阅者就可能触发 ERR max number of clients reached
  • Java 客户端(如 Lettuce)默认为每个 MessageListener 启动独立连接,没做连接复用时极易打满

建议:

  • 用单个连接 + 多频道订阅(SUBSCRIBE ch1 ch2 ch3),而不是为每个频道建新连接
  • 避免在循环里反复调用 SUBSCRIBE,订阅一次即可,重复执行会报 ERR already subscribed to this channel
  • 若必须模式匹配,优先用 PSUBSCRIBE alert.* 而非大量 SUBSCRIBE alert.error、alert.warn 等分散频道

PUBLISH 在突发流量下会阻塞主线程,且不保证送达

  • PUBLISH 是同步命令:Redis 主线程遍历所有订阅者连接,逐个写入 socket;若某订阅者网络卡顿或处理慢,整个 PUBLISH 调用会被拖住
  • 没有重试、无 ACK、无消费确认;客户端断连期间的消息永久丢失
  • 单次 PUBLISH 向 5000 个订阅者发消息,实测延迟可能飙到 200ms+,直接拖垮上游服务

应对方式:

  • 绝对不要在核心交易链路(如下单、支付回调)中直接 PUBLISH
  • 把发布行为异步化:先写入 STREAM 或 LIST,再由后台 worker 异步 PUBLISH 通知(仅作轻量广播)
  • 对关键消息,改用 XADD + XREADGROUP,它支持 ACK、pending list、多消费者负载分摊

用 STREAM 替代 PUB/SUB 实现真削峰填谷

  • STREAM 是追加写、有序、可分组、带游标、支持消费者组的持久化结构,天然适合削峰
  • 示例:订单创建后写入 XADD orders * order_id 123 status created,下游多个 worker 通过 XREADGROUP GROUP wg1 c1 COUNT 10 STREAMS orders > 拉取并 ACK

关键配置注意点:

  • 创建消费者组时必须指定 START 位置,否则新组无法读历史消息:XGROUP CREATE orders wg1 $ MKSTREAM
  • XPENDING 要定期巡检,防止消息卡在 pending list 中超时未处理
  • 不要给 STREAM 设 MAXLEN 过小(如 MAXLEN ~ 1000),否则削峰能力归零;按峰值 5 分钟积压量预估长度

PUB/SUB 的价值不在扛流量,而在低延迟广播控制信号——比如“清空本地缓存”“切换灰度开关”“触发配置热重载”。它快、轻、无状态,但也因此极难监控和兜底。真正要填谷,得靠 STREAM 的 backlog 和消费者组的伸缩性;而削峰,本质是把“推”变成“拉”,把“即时”变成“可重试”。

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
counta和count的区别
counta和count的区别

Count函数用于计算指定范围内数字的个数,而CountA函数用于计算指定范围内非空单元格的个数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2023.11.20

2808

5

scripterror怎么解决
scripterror怎么解决

scripterror的解决办法有检查语法、文件路径、检查网络连接、浏览器兼容性、使用try-catch语句、使用开发者工具进行调试、更新浏览器和JavaScript库或寻求专业帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.18

949

5

500error怎么解决
500error怎么解决

500error的解决办法有检查服务器日志、检查代码、检查服务器配置、更新软件版本、重新启动服务、调试代码和寻求帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.25

2680

5

treenode的用法
treenode的用法

​在计算机编程领域,TreeNode是一种常见的数据结构,通常用于构建树形结构。在不同的编程语言中,TreeNode可能有不同的实现方式和用法,通常用于表示树的节点信息。更多关于treenode相关问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.12.01

2361

7

C++ 高效算法与数据结构
C++ 高效算法与数据结构

本专题讲解 C++ 中常用算法与数据结构的实现与优化,涵盖排序算法(快速排序、归并排序)、查找算法、图算法、动态规划、贪心算法等,并结合实际案例分析如何选择最优算法来提高程序效率。通过深入理解数据结构(链表、树、堆、哈希表等),帮助开发者提升 在复杂应用中的算法设计与性能优化能力。

2025.12.22

336

20

深入理解算法:高效算法与数据结构专题
深入理解算法:高效算法与数据结构专题

本专题专注于算法与数据结构的核心概念,适合想深入理解并提升编程能力的开发者。专题内容包括常见数据结构的实现与应用,如数组、链表、栈、队列、哈希表、树、图等;以及高效的排序算法、搜索算法、动态规划等经典算法。通过详细的讲解与复杂度分析,帮助开发者不仅能熟练运用这些基础知识,还能在实际编程中优化性能,提高代码的执行效率。本专题适合准备面试的开发者,也适合希望提高算法思维的编程爱好者。

2026.01.06

377

22

C++ 数据结构与算法实现教程合集
C++ 数据结构与算法实现教程合集

以 C++ 为实现语言,系统讲解核心数据结构与算法,涵盖链表(单链表/双链表/环检测)、栈与队列(单调栈/优先队列)、二叉树(遍历/BST/AVL/红黑树)、哈希表(开地址法/链地址法)、图(邻接表/BFS/DFS/Dijkstra/拓扑排序)、常见排序算法(快排/归并/堆排/计数排序)的实现与复杂度分析,同时分享 LeetCode 刷题技巧、竞赛编程常用模板(二分/前缀和/滑动窗口/动态规划),帮助开发者夯实算法基础。

2026.05.09

432

25

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

2023.08.10

3878

6

Golang channel原理
Golang channel原理

本专题整合了Golang channel通信相关介绍,阅读专题下面的文章了解更多详细内容。

2025.11.14

434

8

热门下载

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

精品课程

更多
热门推荐
/
最新课程
phpStudy极速入门视频教程
phpStudy极速入门视频教程

共6课时 | 54.6万人学习

独孤九贱(4)_PHP视频教程
独孤九贱(4)_PHP视频教程

共89课时 | 133.4万人学习