当前位置:首页 > 文章列表 > 数据库 > Redis > Redis PUBSUB shard channels 与普通频道如何选

Redis PUBSUB shard channels 与普通频道如何选

来源:17golang原创 2026-09-15 00:04:34 0浏览 收藏

如果 Redis Cluster 里的消息需要让所有节点都能收到,选普通 Pub/Sub;如果消息只服务某个租户、区域或业务分片,并且跨节点传播已经成为压力,选 Redis 7.0 引入的 shard channels。两者最关键的区别不是“哪个命令更快”,而是消息要传播到哪里。

要点速览
  • SUBSCRIBE/PUBLISH 是全局 Pub/Sub,发布可以连接任意节点,消息会在集群范围传播。
  • SSUBSCRIBE/SPUBLISH 按频道哈希到槽位,只在所属分片内传播;发布端要能路由到拥有该槽位的节点。
  • 两种 Pub/Sub 都是 at-most-once;断线补不回消息,要求重放或至少一次投递时应改用 Streams。

先看广播范围:普通频道和 shard channel 不是同一条路

普通频道适合“所有在线消费者都可能关心”的事件,例如全局配置刷新、跨区域广播或统一下线通知。Redis Cluster 会把普通 Pub/Sub 消息传播到各节点,因此发布端不需要先计算频道槽位,但集群总线也要承担这份传播成本。

shard channel 则把频道名按与键相同的算法映射到槽位。消息只在拥有该槽位的分片内转发,客户端可以连到该分片的主节点或副本。订单状态、租户通知、区域内 WebSocket 推送这类天然分区的消息,更适合这个模型。

Redis Cluster 普通 Pub/Sub 与 shard channel 的全局传播和分片内传播示意
图1:Redis Pub/Sub 路由示意图;普通频道向集群范围传播,shard channel 只在所属分片内传播。图中内容为结构示意。

命令怎么换:订阅端和发布端必须成对

普通频道使用 SUBSCRIBEPUBLISH;分片频道使用 SSUBSCRIBESPUBLISH。不要只把订阅命令改成 SSUBSCRIBE,发布端仍用 PUBLISH,那会落到两套不同的投递语义里。

# 普通频道:发布端可以连接任意集群节点,适合全局广播
redis-cli -c -h 127.0.0.1 -p 7000 SUBSCRIBE app:config
redis-cli -c -h 127.0.0.1 -p 7001 PUBLISH app:config '{"version": "v2"}'

# 分片频道:订阅与发布都使用 shard Pub/Sub 命令
redis-cli -c -h 127.0.0.1 -p 7000 SSUBSCRIBE tenant:{42}:events
redis-cli -c -h 127.0.0.1 -p 7001 SPUBLISH tenant:{42}:events '{"id": 901}'

上面的第二组命令中,{42} 是哈希标签示例。它让同一租户的相关频道更容易落在同一槽位,但不代表所有租户都会落在同一分片。真正上线前要用集群路由和客户端库的 cluster 支持验证,不能只凭频道字符串猜节点。

高压场景怎么选:看跨分片流量和订阅关系

可以先用下面这张表做第一轮决策:

场景优先方案原因
所有节点都要收到同一条通知普通 Pub/Sub全局广播语义直观,不需要管理槽位
租户、区域或订单分片各自消费shard channels传播限制在所属分片,减少集群总线流量
单个订阅连接要监听多个不同槽位谨慎使用 shard一次 SSUBSCRIBE 的频道必须属于同一槽位,不同槽位要分次订阅
消费者断线后必须补消息Redis StreamsPub/Sub 不保存历史,不能提供可靠重放

不要用“shard 一定更快”作为结论。只有当消息本来就能按槽位分区,并且全局 Pub/Sub 的跨节点传播成为瓶颈时,shard channels 的收益才明显。如果订阅者本来就分散在全局,强行分片只会增加路由、连接和故障处理复杂度。

Redis shard channel 按槽位订阅、发布和观测检查示意
图2:shard channel 的槽位、订阅连接与观测命令关系示意;这是帮助理解的结果示意图,不是真实运行截图。

上线前的检查:别把 Pub/Sub 当成队列

先检查 Redis 版本和客户端是否支持 Redis 7.0 的 SSUBSCRIBESUNSUBSCRIBESPUBLISH。再分别观察普通频道和分片频道的活跃状态:

# 普通频道只统计当前有订阅者的频道
redis-cli -c -h 127.0.0.1 -p 7000 PUBSUB CHANNELS 'app:*'

# 分片频道信息是当前节点所在分片的视角
redis-cli -c -h 127.0.0.1 -p 7000 PUBSUB SHARDCHANNELS 'tenant:*'

# 需要看订阅数时,分别使用普通频道和 shard channel 的统计命令
redis-cli -c -h 127.0.0.1 -p 7000 PUBSUB NUMSUB app:config
redis-cli -c -h 127.0.0.1 -p 7000 PUBSUB SHARDNUMSUB tenant:{42}:events

PUBSUB SHARDCHANNELS 返回的是活跃 shard channel,而且是分片级视角,不是把整个集群的频道列表一次性拼出来。监控时应按节点或分片采集,再结合客户端连接数、发布返回值和集群总线流量判断是否真的改善。

最后确认可靠性:普通 Pub/Sub 和 shard Pub/Sub 都是最多一次投递,消费者掉线期间的消息不会自动补发。若业务需要消费进度、重试、消费组或历史回放,应该让事件进入 Redis Streams,把 Pub/Sub 留给实时提示或缓存失效这类“错过也能恢复状态”的通知。

常见问题

Redis 7.0 以前能用 shard channels 吗?

不能按官方 sharded Pub/Sub 命令直接使用。老版本只能使用普通 Pub/Sub,升级时还要同步确认客户端库版本。

SSUBSCRIBE 可以一次监听任意多个频道吗?

可以监听多个,但同一次调用里的 shard channel 必须属于同一槽位;不同槽位要分开调用,并让客户端处理可能出现的重定向。

为什么 SPUBLISH 返回的数量和集群总订阅者不一致?

Redis 文档说明,在集群中返回值只包含与发布客户端连接在同一节点的客户端数量,不应把它当成全局订阅者总数。

普通 Pub/Sub 和 shard Pub/Sub 都能保证消息不丢吗?

不能。它们都不保存消息;需要可靠投递、确认和重放时,应使用 Redis Streams 或专用消息系统。

版本声明
本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
Go embed 同名文件来自多个目录时如何避免构建失败Go embed 同名文件来自多个目录时如何避免构建失败
上一篇
Go embed 同名文件来自多个目录时如何避免构建失败
SkildArt做AI白底图时哪些商品要先小样?透明、反光与细边缘判断
下一篇
SkildArt做AI白底图时哪些商品要先小样?透明、反光与细边缘判断
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • PubMedQA数据集详解:生物医学问答基准、功能与应用指南
    PubMedQA
    深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
    26次使用
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    130次使用
  • LMArena是什么?伯克利AI模型评估平台使用指南与功能解析
    LMArena
    LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
    62次使用
  • 斯坦福HELM:大语言模型Holistic Evaluation整体评估框架详解
    HELM
    深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
    23次使用
  • OpenCompass大模型评测体系详解:功能、使用指南与应用场景
    OpenCompass
    OpenCompass是上海AI实验室推出的开源大模型评测平台,提供CompassKit、CompassHub和CompassRank三大核心组件,支持LLM及多模态模型的一站式标准化评估与排行榜查询。
    81次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码