args)
2 {
3 var messagesReceived = 0;
4 var maxMessage = 5;
5 var channelName = \"幸福框架\";
6
7 using (var redisConsumer = new RedisClient())
8 {
9 using (var subscription = redisConsumer.CreateSubscription())10 {11 subscription.OnSubscribe = channel =>12 {13 Console.WriteLine(String.Format(\"订阅频道:'{0'\" channel));14 ;15 subscription.OnUnSubscribe = channel =>16 {17 Console.WriteLine(String.Format(\"取消订阅频道:'{0'\" channel));18 ;19 subscription.OnMessage = (channel msg) =>20 {21 Console.WriteLine(String.Format(\"从频道:'{0'获取了消息:'{1'\" channel msg));22 23 if (++messagesReceived == maxMessage)24 {25 subscription.UnSubscribeFromAllChannels();26 27 ;28 29 ThreadPool.QueueUserWorkItem(x =>30 {31 Thread.Sleep(200);32 Console.WriteLine(\"开始发布消息\");33 34 using (var redisPublisher = new RedisClient())35 {36 for (var i = 1; i <= 5; i++)37 {38 var message = \"段光伟:\" + DateTime.Now;39 Console.WriteLine(String.Format(\"发布消息:'{0'到频道:'{1'\" message channelName));40 redisPublisher.PublishMessage(channelName message);41 42 43 );44 45 Console.WriteLine(String.Format(\"开始监听频道:'{0'\" channelName));46 subscription.SubscribeToChannels(channelName); //blocking47 48 49
相关经验推荐
- 戴尔|华为的5G专利全球最多,就是做不出5G手机,这不是闹笑话?
- 高通骁龙|两千元以下的骁龙870手机盘点二(vivo iQOO Neo5 活力版 )
- CPU|决定手机流畅的因素,不仅与运存有关,还与手机处理器和系统有关
- soul app|华为手机在俄销量暴增300%,龙芯蓄势待发,英特尔AMD开始慌了
- 红米手机|低于红米K50!高通888+独显芯片+屏幕指纹,国产真香旗舰开启清仓
- 芯片|高通778G 4G芯片的手机,华为凭什么能卖4000多?
- qq浏览器|怎么在浏览器上查找历史浏览记录
- 手机壳|机械革命继续推出低价爆品,i7-12700H笔记本到手价5599元
- iphone13|第一次用iPhone 13需要注意什么?我选了以下三款耐尔金手机配件
- OPPO Find|手机成熬夜罪魁祸首?OPPO打工人睡眠报告来袭,看OPPO如何巧助眠
