Redis實現消息隊列比MSMQ更方便

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

這是我的redis項目結構

redis服務有一個console的程序，可以支持在windows和linux下運行。

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

/// <summary>
  /// 消息對象類型
  /// </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");
      }
  }

前臺顯示的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

事件上，如果我們在項目中用到消息隊列時，可以直接使用ViewData["pop"]這個對象，它就是當前取出的隊列元素，我們可以對它進行數據操作等。