Redis實(shí)現(xiàn)消息隊(duì)列比MSMQ更方便

什么是隊(duì)列：簡單的說就是數(shù)據(jù)存儲(chǔ)到一個(gè)空間里（可以是內(nèi)存，也可以是物理文件），先存儲(chǔ)的數(shù)據(jù)對(duì)象，先被取出來，這與堆棧正好相反，消息隊(duì)列也是這樣，將可能出現(xiàn)高并發(fā)的數(shù)據(jù)進(jìn)行隊(duì)列存儲(chǔ)，并按著入隊(duì)的順序依次處理，實(shí)現(xiàn)消息隊(duì)列的工具有很多，如微軟的MSMQ，及一些開源的KV存儲(chǔ)工具，今天主要介紹用Redis實(shí)現(xiàn)消息隊(duì)列。

這是我的redis項(xiàng)目結(jié)構(gòu)

redis服務(wù)有一個(gè)console的程序，可以支持在windows和linux下運(yùn)行。

我用MVC應(yīng)用程序來作這個(gè)例子，由表單向內(nèi)存中寫信息，然后每5秒中從內(nèi)存中將消息取出來，看代碼

/// <summary>
  /// 消息對(duì)象類型
  /// </summary>
  public class MessageQuene
  {
      static System.Timers.Timer timer = new System.Timers.Timer(5000);
      public static ChatModels CurrentChatModels = new ChatModels();
      static Redis.Utils.RedisClient redisClient;
      static MessageQuene()
      {
          redisClient = new Redis.Utils.RedisClient();
          timer.AutoReset = true;
          timer.Enabled = true;
          timer.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed);//subscribe a event
          timer.Start();

      }
      private static void timer_Elapsed(object sender, ElapsedEventArgs e)
      {
          CurrentChatModels = (ChatModels)redisClient.LeftPop("MessageQuene");
      }
  }

前臺(tái)顯示的action

public ActionResult Index()
 {
     ViewData["pop"] = MessageQuene.CurrentChatModels == null ? "沒?有D記?錄?" : MessageQuene.CurrentChatModels.Chat;
     ViewData["MSMQ"] = redisClient.ListRange("MessageQuene") == null
       ? new List<ChatModels>()
       : redisClient.ListRange("MessageQuene").Cast<ChatModels>().ToList();
}

表單提交的action

事件上，如果我們?cè)陧?xiàng)目中用到消息隊(duì)列時(shí)，可以直接使用ViewData["pop"]這個(gè)對(duì)象，它就是當(dāng)前取出的隊(duì)列元素，我們可以對(duì)它進(jìn)行數(shù)據(jù)操作等。