redis 发布订阅
非常感谢，对csredis作了一次完整的诠释。
1|0前言
提到消息队列，最熟悉无疑是 rabbitmq，它基本是业界标准的解决方案。本文详细介绍 redis 多种实现轻订阅方法，作者认为非常有趣并加以总结，希望对有需要的朋友学习 redis 功能有一定的带入作用。
2|0方法一：SUBSCRIBE + PUBLISH
//程序1：使用代码实现订阅端 var sub = RedisHelper.Subscribe(("chan1", msg => Console.WriteLine(msg.Body))); //sub.Disponse(); //停止订阅 //程序2：使用代码实现发布端 RedisHelper.Publish("chan1", "111");优势：支持多端订阅、简单、性能高；
缺点：数据会丢失；
参考资料：http://doc.redisfans.com/pub_sub/subscribe.html
3|0方法二：BLPOP + LPUSH（争抢）
//程序1：使用代码实现订阅端 while (running) { try { var msg = RedisHelper.BLPop(5, "list1"); if (string.IsNullOrEmpty(msg) == false) { Console.WriteLine(msg); } } catch (Exception ex) { Console.WriteLine(ex.Message); } } //程序2：使用代码实现发布端 RedisHelper.LPush("list1", "111");优势：数据不会丢失、简单、性能高；
缺点：不支持多端（存在资源争抢）；
总结：为了解决方法一的痛点，我们实现了本方法，并且很漂亮的制造了一个新问题（不支持多端订阅）。
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测试代码
var rds = new CSRedis.CSRedisClient("127.0.0.1:6379,password=,poolsize=50,ssl=false,writeBuffer=10240"); //sub1, sub2 争抢订阅（只可一端收到消息） var sub1 = rds.SubscribeList("list1", msg => Console.WriteLine($"sub1 -> list1 : {msg}")); var sub2 = rds.SubscribeList("list1", msg => Console.WriteLine($"sub2 -> list1 : {msg}")); //sub3, sub4, sub5 非争抢订阅（多端都可收到消息） var sub3 = rds.SubscribeListBroadcast("list2", "sub3", msg => Console.WriteLine($"sub3 -> list2 : {msg}")); var sub4 = rds.SubscribeListBroadcast("list2", "sub4", msg => Console.WriteLine($"sub4 -> list2 : {msg}")); var sub5 = rds.SubscribeListBroadcast("list2", "sub5", msg => Console.WriteLine($"sub5 -> list2 : {msg}")); //sub6 是redis自带的普通订阅 var sub6 = rds.Subscribe(("chan1", msg => Console.WriteLine(msg.Body))); Console.ReadKey(); sub1.Dispose(); sub2.Dispose(); sub3.Dispose(); sub4.Dispose(); sub5.Dispose(); sub6.Dispose(); rds.Dispose(); return;nuget Install-Package CSRedisCore
测试功能时，发布端可以使用 redis-cli 工具。
6|0结语
redis 功能何其多且相当好玩有趣 ，大家应尽可能多带着兴趣爱好去学习它。
若文中有不好的地方，请提出批评与改正方法，谢谢观赏。
本文使用到 CSRedisCore 的开源地址：https://github.com/2881099/csredis
__EOF__
本文作者：本文链接：
关于博主：评论和私信会在第一时间回复。或者直接私信我。
版权声明：本博客所有文章除特别声明外，均采用 BY-NC-SA 许可协议。转载请注明出处！
声援博主：如果您觉得文章对您有帮助，可以点击文章右下角【推荐】一下。您的鼓励是博主的最大动力！