redis 实现消息队列及常用命令(二)|学习笔记

简介: 快速学习 redis 实现消息队列及常用命令(二)

开发者学堂课程【Redis 入门实战演练  redis 实现消息队列及常用命令(二)】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/653/detail/10838


redis 实现消息队列及常用命令(二)


六、查看队列所有消息

开一个 redis - c

127.0.0.1:6379> LRANGE(加队列名称) channel 1  0  -1(从开始到结尾)

1) "msg5"

2) "msg4"

3) "msg3"

4)"msg2"

5) "msg1

1668262141071.jpg

 

七、生产者消费者的消息

后期在程序里面通过 RPOP  来弹,但是一定要注意顺序,先进先出。当然我们的数据是最简单的数据。

127.0.0.1:6379> RPoP channel 1#从管道的右侧消费

"msg1"

127.0.0.1:6379> POP channel 1

"msg2"

127.0.0.1:6379> POP channel 1

"msg3"

127.0.0.1:6379> POP channel 1

"msg4"

127.0.0.1:6379> POP channel 1

"msg5"

127.0.0.1:6379 > POP channel 1

(nil)

1668262254247.jpg

(大家不用关心其他的消息队列软件是怎么用的,我们之后会讲到。)

 

八、支持发布者和订阅者模式

这个模式比较特殊,为什么比较特殊?因为之前的消息在生产者、消费者、订阅者模式下。这个消息只能被消耗一次。但是订阅模式不一样。生产者和消费者模式是一对一的,由生产者生产一个东西这个消息只能被一个消费者利用。在有多个生产者和消费者的情况下不需要一一绑定。

订阅者模式,一对多,一个消息可以被多个消费者消费,而且可以同时被消费。

在发布者订阅模式下,发布者将消息发布到指定的 channel 里面,凡是监听该Channel 的消费者都会受到同样的一份消息,这种模式类似于是收音机的广播模式,即凡是收听到某个频道的观众都会受到主持人发布的相同的消息内容。

1668262281477.jpg

订阅者在相同的群或者相同的频道内。

此模式常用语群聊天、群通知、群公告等场景。

(这个消息可以让当前在群里的人都可以看到,而不是只能让一个人看到。)

Subscriber:订阅者

Publisher:发布者

Channel:频道(会有好多频道,当然在公司里会给频道定义名称)

 

九、阅读者监听频道

在里面监听一个队列。这个频道名称没有也可以。

比如说监听一个 linux39

127.0.0.1:6379【2】>SUBSCRIBE linux39

1)“subscribe”

2)“linux39”

3)(integer) 1

这个频道需要找一个终端来模拟

这是一个发布者。

 

十、发布者发布消息

127.0.0.1:6379>PUBLISH channel 1 test #发布者发布消息

(integer) 2

127.0.0.1:6379> PUBLISH channel 1 test 2

(integer) 2

这个消息就可以看到。

只要发布之后过去之后,就看不到这个消息了。只能看见从当前开始往后的。

频道名称可以任意改变。

 

十一、可以订阅多个频道

订阅指定的多个频道

>SUBSCRIBE channel 1 channel 2

(在SUBSCRIBE这条指令后面可以跟多个频道名称,订购多个频道是根据公司的业务和能力来确定的 )

订阅者是负责接受上一级的请求在数据库中写账号和密码。

如果公司中有两套不同的业务,两个业务后台的数据不一样,但是都会经过订阅者到数据库这一步骤。

下图:无论是新产品还是二手交易都要做登录,这是需要将登陆消息发布到 MQ中,之后再由订阅者服务到数据库中做认证。之后订阅者就会对 MQ 做监控。这是订阅者就会监控多个序列里面的数据,分别是:新产品,二手交易。

1668262339283.jpg

127.0.0.1:6379> SUBSCRIBE Linux39 magedu

Reading messages... (press Ctrl-C to quit)

1)"subscribe

2)"linux39"

3) (integer)1

1)"subscribe"

2)"magedu"

3). (integer) 2

1)"message'

2)"magedu

3)"msg2"

 

十二、订阅所有频道

127.0.0.1:6379> PSUBSCRIBE*

在当前的 rides 内可以订阅所有频道。

127.0.0.1:637921> SUBSCRIBE

Reading messages.  (press Ctrl-C to quit)

1)"subscribe"

2)...

3)(integer) 1

1668262376993.jpg

这种模式用的不多,在当前 DB 中,所有频道都能订阅到。

1668262391208.jpg

相关文章
|
3天前
|
人工智能 API 内存技术
刚刚 DeepSeek V4.1 Flash 开启内测,1 分钟教你用上!
刚刚 DeepSeek 内测群发布了 DeepSeek V4.1 Flash 中间版本内测的消息,这次的模型采用了新的结构,原生支持多模态、能力更强、速度更快、且成本更低。
1637 5
|
8天前
|
人工智能 运维 BI
阿里云千问办公QwenWork深度解析:基于Qwen3.8,六大核心能力重构企业全自动化工作流与计费选型指南
传统AI办公工具大多停留在对话问答、文档摘要、简单文案生成层面,只能完成单点碎片化任务,无法自主拆解复杂业务流程,很难串联多工具、多文档、外部业务系统完成端到端完整工作交付。很多企业在落地AI办公的时候,需要组合多款不同工具,来回切换界面,手动复制粘贴中间结果,智能化改造落地门槛居高不下。千问办公QwenWork是整合多款智能体产品能力打造的一体化企业办公智能体平台,底层基座依托Qwen3.8大模型,打通桌面端Agent、云端Agent、企业协同Agent三种运行形态,不再局限简单问答,接收业务目标之后自主拆解任务步骤,调用各类工具,处理文档、表格、浏览器自动化、数据查询,直接输出可交付的办公
1608 0
|
5天前
|
SQL 人工智能 前端开发
QoderWake 1.0 正式发布:从桌面里的 Agent,到工作现场的数字员工
QoderWake v1.0正式发布:企业级数字员工团队平台。支持“一句话建岗”,预置10类特训岗位;Waker常驻钉钉/飞书群,@即响应、自动协作、跨任务记忆;具备定时/事件/API多触发方式与统一任务看板;已沉淀27.6万条记忆、12.3万项技能,助力组织实现人机协同增效。
706 1
|
16天前
|
人工智能 自然语言处理 安全
阿里云千问办公、Qoder Teams、Qoder CN区别与选择指南:模型能力、适用场景与最新活动参考
本文聚焦阿里云2026年推出的三款自研AI办公产品,清晰拆解千问办公、Qoder Teams、Qoder CN的差异化定位与能力边界:千问办公主打职场全场景提效,支持自然语言指令一键完成PPT生成、数据分析等高频办公任务;Qoder Teams面向程序员团队,深度整合AI代码生成、团队协同与企业知识库能力;Qoder CN则专为金融、政务等强合规场景打造,实现数据不出境与VPC私有化部署。文章同步给出分场景选型指南与最新活动定价,帮助不同类型的企业按需组合产品,实现业务岗、研发岗与强合规场景的AI能力全覆盖。
3854 5
阿里云千问办公、Qoder Teams、Qoder CN区别与选择指南:模型能力、适用场景与最新活动参考
|
8天前
|
人工智能 自然语言处理 安全
阿里云AI数智鉴密:AI 生成内容如何拿到一张"防篡改的身份证"
隐形水印 + C2PA签名:让AI生成内容“持证上岗”。
1141 0
|
9天前
|
网络协议 Linux iOS开发
【2026实测】Wireshark下载+安装+汉化+使用教程(图文版,巨详细)
Wireshark 是一款免费开源的网络协议分析工具,可实时捕获、解析并可视化数据包,助你诊断网络故障、分析通信协议(如HTTP、DNS、TCP等)。支持Windows/macOS/Linux,含中文界面,新手入门便捷。(239字)
|
2天前
|
缓存 测试技术 API
DeepSeek V4.1 Flash 内测接入:改个模型名即可调用(附代码)
DeepSeek V4.1 Flash 内测不用申请,base_url 不变、改个模型名就能调,9/10 到期。本文讲清接入、计费限流与多模态注意点。
661 0
DeepSeek V4.1 Flash 内测接入:改个模型名即可调用(附代码)