欧美日韩国产一区二区|qovd片|小明个人发布看看|小浪货你夹真紧水又多|老头把我添高潮了A片故|99热久久精品国产一区二区|久久久春色AV

  1. 首頁(yè) > 科技 > >

手機(jī)瀏覽器|Redis：在windows環(huán)境安裝Redis( 二 )

手機(jī)瀏覽器


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(\"開(kāi)始發(fā)布消息\");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(\"發(fā)布消息：'{0'到頻道：'{1'\" message channelName));40                                 redisPublisher.PublishMessage(channelName message);41                             42                         43                     );44 45                     Console.WriteLine(String.Format(\"開(kāi)始監(jiān)聽(tīng)頻道：'{0'\" channelName));46                     subscription.SubscribeToChannels(channelName); //blocking47                 48             49        

相關(guān)經(jīng)驗(yàn)推薦