0

0

redis如何实现订阅发布 redis订阅发布模式的完整实现教程

下次还敢

下次还敢

发布时间:2025-07-07 09:37:02

|

546人浏览过

|

来源于php中文网

原创

redis 的订阅发布机制允许客户端通过 publish、subscribe 等命令实现实时消息传递,适用于解耦组件和事件驱动架构。1. 发布消息使用 publish 命令向指定频道发送消息;2. 订阅频道使用 subscribe 命令监听一个或多个频道;3. 取消订阅使用 unsubscribe 命令停止接收特定频道消息;4. 模式匹配订阅使用 psubscribe 命令按模式订阅多个频道。构建简单聊天室可让用户连接 redis 后订阅频道并发布消息,但存在消息丢失、无持久化等局限。相比 redis streams,pub/sub 更适合实时性高但可靠性要求低的场景,而 streams 支持持久化和消费者组,适用于需可靠传递的场景。

redis如何实现订阅发布 redis订阅发布模式的完整实现教程

Redis 的订阅发布(Pub/Sub)机制允许你构建消息队列和事件驱动的应用程序。它提供了一种发布者(publisher)向多个订阅者(subscriber)发送消息的方式,而无需知道具体的订阅者是谁。这对于解耦应用程序组件非常有用。

Redis 订阅发布模式的完整实现教程

实现 Redis 的订阅发布,大致可以分为以下几个步骤:发布消息、订阅频道、取消订阅、模式匹配订阅。

发布消息

发布消息很简单,使用 PUBLISH 命令即可。

PUBLISH channel "Hello, Redis Pub/Sub!"

这会将消息 "Hello, Redis Pub/Sub!" 发布到名为 "channel" 的频道。任何订阅了该频道的客户端都会收到这条消息。要注意的是,Redis 不会存储发布的消息,如果客户端在消息发布时没有订阅,那么消息就会丢失。

订阅频道

客户端使用 SUBSCRIBE 命令订阅一个或多个频道。

SUBSCRIBE channel1 channel2

订阅之后,客户端会进入订阅状态,只能接收订阅相关的命令(如 SUBSCRIBEUNSUBSCRIBEPSUBSCRIBEPUNSUBSCRIBE)和接收发布到已订阅频道的消息。 如果尝试执行其他命令,Redis 会返回错误。

收到消息后,客户端会收到一个包含三个元素的数组:消息类型("message"),频道名称,以及消息内容。

取消订阅

使用 UNSUBSCRIBE 命令可以取消订阅。

UNSUBSCRIBE channel1

如果不指定频道,则取消订阅所有已订阅的频道。

Avatar AI
Avatar AI

AI成像模型,可以从你的照片中生成逼真的4K头像

下载

模式匹配订阅

除了订阅特定频道,还可以使用模式匹配订阅,使用 PSUBSCRIBE 命令。

PSUBSCRIBE news.*

这会订阅所有以 "news." 开头的频道,例如 "news.sports"、"news.politics" 等。 取消模式匹配订阅使用 PUNSUBSCRIBE 命令。

PUNSUBSCRIBE news.*

UNSUBSCRIBE 类似,如果不指定模式,则取消订阅所有已订阅的模式。

如何使用 Redis Pub/Sub 构建一个简单的聊天室?

构建一个简单的聊天室,可以分为以下几个步骤:

  1. 客户端连接 Redis: 每个用户连接到 Redis 服务器。
  2. 用户订阅聊天频道: 用户使用 SUBSCRIBE 命令订阅一个特定的聊天频道(例如 "chat:room1")。
  3. 用户发送消息: 用户输入消息后,客户端使用 PUBLISH 命令将消息发布到聊天频道。
  4. 所有订阅者接收消息: 所有订阅了该聊天频道的用户都会收到消息,并在客户端显示。

这个方案很简单,但存在一些问题,例如没有消息持久化,如果用户离线,则无法收到消息。 此外,也没有用户身份验证和权限管理。 可以考虑使用 Redis Streams 来解决消息持久化问题,并使用其他机制来实现用户身份验证和权限管理。

Redis Pub/Sub 的局限性是什么?

Redis Pub/Sub 虽然简单易用,但也存在一些局限性:

  • 消息丢失: 如前所述,Redis 不会存储发布的消息,如果客户端离线或未订阅,消息就会丢失。
  • 不可靠性: Redis Pub/Sub 是一种“fire and forget”的机制,不保证消息传递的可靠性。如果 Redis 服务器崩溃,消息可能会丢失。
  • 缺乏消息确认: 发布者无法知道消息是否成功发送给所有订阅者。
  • 不支持消息持久化: 消息不会被持久化到磁盘,因此无法在服务器重启后恢复。

对于需要可靠消息传递的场景,建议使用 Redis Streams 或其他消息队列系统,例如 RabbitMQ 或 Kafka。 Redis Streams 提供了消息持久化、消费者组和消息确认等功能,可以更好地满足可靠消息传递的需求。

Redis Pub/Sub 与 Redis Streams 有什么区别?

Redis Pub/Sub 和 Redis Streams 都是 Redis 提供的消息传递机制,但它们的设计目标和适用场景有所不同。

  • Redis Pub/Sub: 是一种简单的发布订阅模式,适用于实时性要求高,但可靠性要求不高的场景,例如实时聊天、实时通知等。
  • Redis Streams: 是一种更复杂的消息队列,提供了消息持久化、消费者组和消息确认等功能,适用于需要可靠消息传递的场景,例如订单处理、日志收集等。

可以简单地理解为,Pub/Sub 更像是一个广播系统,而 Streams 更像是一个消息队列。 选择哪种机制取决于具体的应用场景和需求。 如果只需要简单的实时消息传递,Pub/Sub 可能更合适。 如果需要可靠的消息传递和消息持久化,Streams 则是更好的选择。 也可以将两者结合使用,例如使用 Pub/Sub 进行实时通知,使用 Streams 进行消息持久化和处理。

实际上,在某些场景下,选择消息队列(如 Kafka、RabbitMQ)可能比 Redis Streams 更合适,因为它们在消息可靠性、吞吐量和可扩展性方面通常更具优势。 选择哪种技术取决于具体的业务需求和技术栈。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

207

2024.02.23

Java 消息队列与异步架构实战
Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用,涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理,以及在高并发系统中的异步解耦设计。通过实战案例,帮助学习者掌握 使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

48

2026.01.28

kafka消费者组有什么作用
kafka消费者组有什么作用

kafka消费者组的作用:1、负载均衡;2、容错性;3、广播模式;4、灵活性;5、自动故障转移和领导者选举;6、动态扩展性;7、顺序保证;8、数据压缩;9、事务性支持。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

175

2024.01.12

kafka消费组的作用是什么
kafka消费组的作用是什么

kafka消费组的作用:1、负载均衡;2、容错性;3、灵活性;4、高可用性;5、扩展性;6、顺序保证;7、数据压缩;8、事务性支持。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

159

2024.02.23

rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

207

2024.02.23

Java 流式处理与 Apache Kafka 实战
Java 流式处理与 Apache Kafka 实战

本专题专注讲解 Java 在流式数据处理与消息队列系统中的应用,系统讲解 Apache Kafka 的基础概念、生产者与消费者模型、Kafka Streams 与 KSQL 流式处理框架、实时数据分析与监控,结合实际业务场景,帮助开发者构建 高吞吐量、低延迟的实时数据流管道,实现高效的数据流转与处理。

170

2026.02.04

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

443

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

605

2023.08.10

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
进程与SOCKET
进程与SOCKET

共6课时 | 0.4万人学习

Redis+MySQL数据库面试教程
Redis+MySQL数据库面试教程

共72课时 | 7.1万人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号