Redis如何实现订阅和发布消息功能

来源:IPIPP.com作者:头衔:全栈工程师
导读:本期聚焦于小伙伴创作的《Redis如何实现订阅和发布消息功能》,敬请观看详情,探索知识的价值。以下视频、文章将为您系统阐述其核心内容与价值。如果您觉得《Redis如何实现订阅和发布消息功能》有用,将其分享出去将是对创作者最好的鼓励。

Redis的发布订阅(Pub/Sub)是基于事件驱动的消息通信模式,支持消息的异步传递,在很多轻量级消息通知场景中都有广泛应用。下面我们通过具体示例来学习如何使用这个功能。

Redis如何实现订阅和发布消息功能

Redis发布订阅核心命令

Redis提供了几个核心命令来支持发布订阅功能,我们逐一了解:

  • SUBSCRIBE channel [channel ...]:订阅一个或多个频道,接收发送到这些频道的消息
  • PUBLISH channel message:向指定频道发送消息,返回收到消息的订阅者数量
  • UNSUBSCRIBE [channel ...]:退订指定的频道,如果不指定频道则退订所有已订阅的频道
  • PSUBSCRIBE pattern [pattern ...]:订阅符合指定模式的所有频道,支持通配符匹配
  • PUNSUBSCRIBE [pattern ...]:退订符合指定模式的频道订阅

命令行客户端演示

我们先打开两个Redis命令行客户端,一个作为订阅者,一个作为发布者,来演示基础流程。

订阅者操作

在第一个客户端中订阅news频道:

# 订阅news频道
SUBSCRIBE news
# 订阅成功后会返回订阅信息,之后会阻塞等待消息

发布者操作

在第二个客户端中向news频道发送消息:

# 向news频道发送消息
PUBLISH news "今天Redis发布订阅功能更新了"
# 返回1,表示有1个订阅者收到了消息

此时第一个客户端会立即收到消息:

1) "message"
2) "news"
3) "今天Redis发布订阅功能更新了"

Python客户端实现示例

实际项目中我们更多会使用编程语言客户端来操作,下面是Python使用redis-py库实现发布订阅的示例。

订阅者代码

import redis

# 连接Redis
r = redis.Redis(host='127.0.0.1', port=6379, db=0)
# 创建发布订阅对象
pubsub = r.pubsub()
# 订阅news频道
pubsub.subscribe('news')

# 循环监听消息
for message in pubsub.listen():
    # 过滤订阅成功的反馈消息
    if message['type'] == 'message':
        print(f"收到消息:{message['data'].decode('utf-8')}")

发布者代码

import redis

# 连接Redis
r = redis.Redis(host='127.0.0.1', port=6379, db=0)
# 向news频道发送消息
count = r.publish('news', 'Python客户端发送的消息')
print(f"消息发送成功,共有{count}个订阅者收到")

模式订阅示例

如果需要订阅一类频道,比如所有news.开头的频道,可以使用模式订阅:

# 订阅所有news.开头的频道
PSUBSCRIBE news.*
# 此时向news.sports、news.tech等频道发送消息都会被收到

适用场景与注意事项

Redis发布订阅功能适合轻量级的消息通知场景,比如简单的实时通知、轻量级聊天室等,但它也有明显的局限性:

  • 消息不支持持久化,如果订阅者离线期间发送的消息,上线后无法收到
  • 没有消息确认机制,发送者无法知道消息是否被成功处理
  • 如果消息生产速度远快于消费速度,可能会导致消息堆积,甚至丢失

如果需要更可靠的消息队列能力,建议考虑Redis Stream或者专业的消息中间件。但对于不需要严格可靠性的简单场景,Redis发布订阅是一个轻量且易用的选择。

Redis发布订阅消息队列Pub/Sub修改时间:2026-05-24 23:26:44

免责声明:已尽一切努力确保本网站所含信息的准确性。网站部分内容来源于网络或由用户自行发表,内容观点不代表本站立场。本站是个人网站免费分享,内容仅供个人学习、研究或参考使用,如内容中引用了第三方作品,其版权归原作者所有。若内容触犯了您的权益,请联系我们进行处理。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。前端、网络、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握网站开发与运维所需的核心技术栈。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端逻辑,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。