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"]這個對象，它就是當前取出的隊列元素，咱們能夠對它進行數據操做等。