来源: 【由浅至深】redis 实现发布订阅的几种方式 – nicye – 博客园
非常感谢依乐祝发表文章《.NET Core开发者的福音之玩转Redis的又一傻瓜式神器推荐》,对csredis作了一次完整的诠释。
1|0前言
提到消息队列,最熟悉无疑是 rabbitmq,它基本是业界标准的解决方案。本文详细介绍 redis 多种实现轻订阅方法,作者认为非常有趣并加以总结,希望对有需要的朋友学习 redis 功能有一定的带入作用。
2|0方法一:SUBSCRIBE + PUBLISH
优势:支持多端订阅、简单、性能高;
缺点:数据会丢失;
参考资料:http://doc.redisfans.com/pub_sub/subscribe.html
3|0方法二:BLPOP + LPUSH(争抢)
优势:数据不会丢失、简单、性能高;
缺点:不支持多端(存在资源争抢);
总结:为了解决方法一的痛点,我们实现了本方法,并且很漂亮的制造了一个新问题(不支持多端订阅)。
3|1学习使用 BLPOP
BLPOP key [key …] timeout
BLPOP 是列表的阻塞式(blocking)弹出原语。
它是 LPOP 命令的阻塞版本,当给定列表内没有任何元素可供弹出的时候,连接将被 BLPOP 命令阻塞,直到等待超时或发现可弹出元素为止。
当给定多个 key 参数时,按参数 key 的先后顺序依次检查各个列表,弹出第一个非空列表的头元素。
非阻塞行为
当 BLPOP 被调用时,如果给定 key 内至少有一个非空列表,那么弹出遇到的第一个非空列表的头元素,并和被弹出元素所属的列表的名字一起,组成结果返回给调用者。
当存在多个给定 key 时, BLPOP 按给定 key 参数排列的先后顺序,依次检查各个列表。
假设现在有 job 、 command 和 request 三个列表,其中 job 不存在, command 和 request 都持有非空列表。考虑以下命令:
BLPOP job command request 0
BLPOP 保证返回的元素来自 command ,因为它是按”查找 job -> 查找 command -> 查找 request “这样的顺序,第一个找到的非空列表。
阻塞行为
如果所有给定 key 都不存在或包含空列表,那么 BLPOP 命令将阻塞连接,直到等待超时,或有另一个客户端对给定 key 的任意一个执行 LPUSH 或 RPUSH 命令为止。
超时参数 timeout 接受一个以秒为单位的数字作为值。超时参数设为 0 表示阻塞时间可以无限期延长(block indefinitely) 。
更多学习资料:http://doc.redisfans.com/list/blpop.html
4|0方法三:BLPOP + LPUSH(非争抢)
本方法根据方法二演变而来,设计图如下:
如何实现三端订阅,都可收到消息,三端分别为 sub3, sub4, sub5:
1、sub3, sub4, sub5 使用【方法二】订阅 listkey:list1_sub3,list1_sub4,list1_sub5;
2、总订阅端订阅 listkey:list1,总订阅端收到消息后,执行 lpush list1_sub1 msg, lpush list1_sub2 msg, lpush list1_sub3 msg;
总订阅端订阅原始消息,随后将消息分发给其他订阅端,从而解决【方法二】不支持多端同时订阅的缺点。
最终实现的逻辑为:多端先争抢 list1 消息,抢到者再向其他端转发消息。
5|0测试代码
nuget Install-Package CSRedisCore
测试功能时,发布端可以使用 redis-cli 工具。
6|0结语
redis 功能何其多且相当好玩有趣 ,大家应尽可能多带着兴趣爱好去学习它。
若文中有不好的地方,请提出批评与改正方法,谢谢观赏。
本文使用到 CSRedisCore 的开源地址:https://github.com/2881099/csredis