当前位置: 首页 > news >正文

【Redis】Redis 发布订阅通信模式 ( 发布订阅模式 | 订阅频道 | 发布消息 | 接收消息 )

文章目录

  • 一、发布订阅模式
  • 二、订阅频道
  • 三、发布消息
  • 四、接收消息





一、发布订阅模式



Redis 中 存在一种 发布订阅 消息通信模式 :

  • 消息发布者 : 负责发送消息 , 订阅者需要订阅该发布者频道 ;
  • 消息订阅者 : 负责接收消息 ;

订阅者 先 订阅 发布者频道 , 当 发布者 发布消息时 , 订阅者 会接收到该信息 ;


在 Redis 中 , 发布者 是 消息频道 , 订阅者 是 Redis 客户端 ;

  • 一个 Redis 客户端可以 订阅多个 消息频道 ;
  • 一个 消息频道 可以 被多个 Redis 客户端 订阅 ;

当 消息频道 发送消息后 , 订阅该频道的 客户端 , 就会收到该频道发送的消息 ;





二、订阅频道



订阅频道 : 在一个命令行中 , 执行

subscribe channel1

命令 , 可以 订阅 名称为 channel1 的 消息频道 ;


上述命令执行后 , 在命令行中会 阻塞等待 channel1 的消息到来 ;


代码示例 :

127.0.0.1:6379> subscribe channel1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel1"
3) (integer) 1

在这里插入图片描述





三、发布消息



重新打开一个 CMD 命令行工具 , 执行

publish channel1 hello

命令 , 向 channel1 通道中 , 发送 hello 消息 ;


代码示例 :

127.0.0.1:6379> publish channel1 hello
(integer) 1
127.0.0.1:6379>

在这里插入图片描述





四、接收消息



命令行 1 中 , 执行 subscribe channel1 命令 , 订阅了 channel1 频道 ;

命令行 2 中 , 执行 publish channel1 hello 命令 , 向 channel1 频道发送了 hello 消息 ;

然后在 命令行 1 中 , 接收到了 hello 消息 ;


代码示例 :

127.0.0.1:6379> subscribe channel1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel1"
3) (integer) 1
1) "message"
2) "channel1"
3) "hello"

在这里插入图片描述

接收的消息内容是 :

1) "message"
2) "channel1"
3) "hello"
http://www.lryc.cn/news/12999.html

相关文章:

  • VNCTF 2023复现
  • python基础知识有哪些需要背(记住是基础知识)我是初学者
  • Linux下TCP连接断开后不释放的解决办法
  • 1.关于嵌入式开发软件工程师的理解
  • 1760字,让你拿捏 [‘列表‘]
  • A562基于android的养老APP
  • java面试题-并发基础
  • 用纯C语言实现3D空间中的点坐标转化为屏幕二维点坐标,包含主视图、侧视图、俯视图、正等轴投影
  • .sh脚本文件的执行方式
  • Android 基础知识4-2.5View与VIewGroup的概念、关系与区别
  • 【ESP 保姆级教程】玩转巴法云篇① ——初识巴法云
  • Python学习-----模块3.0(正则表达式-->re模块)
  • JSP中http与内置对象学习笔记
  • Windows Server 2016远程桌面配置全过程
  • SPI通讯简介
  • Python 迭代器
  • Python语言零基础入门教程(二十七)
  • Redis基础操作以及数据类型
  • 自抗扰控制ADRC之反馈控制律(NLSEF)
  • “生成音乐“ 【循环神经网络】
  • 能否手写vue3响应式原理-面试进阶
  • 前端工程师leetcode算法面试必备-简单的二叉树
  • 【什么程度叫熟悉linux系统】
  • 编译安装MySQL
  • Kubernetes一 Kubernetes之入门
  • SQLServer2000 断电后数据库suspect“置疑”处理
  • 多模态机器学习入门Tutorial on MultiModal Machine Learning——第一堂课个人学习内容
  • Java ~ Collection/Executor ~ LinkedBlockingDeque【总结】
  • .NET7的AOT的使用
  • 分布式缓存的问题