C#佇列學習筆記：MSMQ入門一-有解無憂

一、引言

MSMQ全稱MicroSoft Message Queue，微軟訊息佇列，是在多個不同的應用之間實作相互通信的一種異步傳輸模式，相互通信的應用可以分布于同一臺機器上，也可以分布于相連的網路空間中的任一位置，它的實作原理是：訊息的發送者把自己想要發送的資訊放入一個容器中（我們稱之為Message），然后把它保存至一個系統公用空間的訊息佇列(Message Queue)中，本地或者異地的訊息接收程式再從該佇列中取出發給它的訊息進行處理，

訊息Message是由通信的雙方所需要傳遞的資訊，訊息是MSMQ的存盤物件，封裝為System.Messaging.Message物件，它由一個主體(body)和若干屬性構成，其中我們的用戶資料通常被序列化裝入body主體中，這也是我們稱它為資料容器的原因，除了body屬性，還有幾個屬性相對來說比較重要：Priority(訊息的優先級)，Label(用戶定義的訊息標識)，Formatter(訊息的序列組件，當用戶將復雜型別資料填充到body中，用戶的資料會先被序列化)，

佇列分事務性佇列和非事務性佇列，默認創建的是非事務性佇列，當我們勾選事務性復選框，就會創建事務性佇列，那么什么是事務性佇列呢？事務性佇列將訊息保存在磁盤上，實作了持久化，也就是說當關機斷電后，下次再啟動機器，我們的訊息依然保存在佇列里面，而非事務性佇列則將訊息保存在記憶體中，也就是說重啟電腦后，佇列里面的訊息將不存在了，

佇列的型別主要包括以下幾種：

“公共佇列”在整個“訊息佇列”網路中復制，并且有可能由網路連接的所有站點訪問，

“專用佇列”不在整個網路中發布，相反，它們僅在所駐留的本地計算機上可用，專用佇列只能由知道佇列的完整路徑名或標簽的應用程式訪問，

“管理佇列”包含確認在給定“訊息佇列”網路中發送的訊息回執的訊息，指定希望 MessageQueue 組件使用的管理佇列（如果有的話），

“回應佇列”包含目標應用程式接收到訊息時回傳給發送應用程式的回應訊息，指定希望 MessageQueue 組件使用的回應佇列（如果有的話），

優點：穩定、訊息優先級、脫機能力以及安全性，有保障的訊息傳遞和執行許多業務處理的可靠的防故障機制，

缺點：MSMQ不適合于Client需要Server端實時互動情況；大量請求的時候回應延遲，

二、安裝

在運行中輸入appwiz.cpl->打開或關閉 Windows 功能->Microsoft Message Queue (MSMQ) 服務器，

安裝成功后，在運行中輸入compmgmt.msc->服務和應用程式->訊息佇列，

右鍵訊息佇列->屬性，可更改默認存盤路徑等，

三、示例演示

注意：需參考System.Messaging，

    class Program
    {
        static void Main(string[] args)
        {
            #region MSMQ入門一
            //創建訊息佇列，默認存盤路徑：C:\Windows\System32\msmq\storage
            if (MessageQueue.Exists(@".\Private$\HelloMSMQ"))
                MessageQueue.Delete(@".\Private$\HelloMSMQ");   //洗掉訊息佇列HelloMSMQ
            if (MessageQueue.Exists(@".\Private$\WorldMSMQ"))
                MessageQueue.Delete(@".\Private$\WorldMSMQ");   //洗掉訊息佇列WorldMSMQ

            MessageQueue mqHello = MessageQueue.Create(@".\Private$\HelloMSMQ");
            MessageQueue mqWorld = MessageQueue.Create(@".\Private$\WorldMSMQ");

            //發送訊息
            mqHello.Send("Hi World,I am Hello.", "mqHello1");
            mqHello.Send("Are you free?", "mqHello2");
            mqWorld.Send("Hi Hello,I am World.", "mqWorld1");
            mqWorld.Send("I guess I'll be free.", "mqWorld2");

            //回傳本機所有私有佇列的訊息
            foreach (MessageQueue item in MessageQueue.GetPrivateQueuesByMachine("cx168"))
            {
                item.Formatter = new XmlMessageFormatter(new string[] { "System.String" });
                Message[] messages = item.GetAllMessages();
                foreach (Message message in messages)
                {
                    Console.WriteLine($"Label: {message.Label} Body: {message.Body}");
                }
            }

            //回傳指定佇列的訊息
            if (MessageQueue.Exists(@".\Private$\HelloMSMQ"))
            {
                using (MessageQueue theOne = new MessageQueue(@".\Private$\HelloMSMQ"))
                {
                    Console.WriteLine();

                    //設定訊息佇列格式化器
                    theOne.Formatter = new XmlMessageFormatter(new string[] { "System.String" });
                    //接受但不洗掉訊息
                    Message msg = mqHello.Peek();
                    Console.WriteLine($"Label: {msg.Label} Body: {msg.Body}");
                    //接受并洗掉訊息
                    msg = mqHello.Receive();
                    Console.WriteLine($"Label: {msg.Label} Body: {msg.Body}");
                    msg = mqHello.Peek();
                    Console.WriteLine($"Label: {msg.Label} Body: {msg.Body}");
                    //洗掉所有訊息
                    mqHello.Purge();
                    Console.WriteLine($"mqHello count: {mqHello.GetAllMessages().Count()}");
                }
            }

            Console.Read();
            #endregion
        }
    }

運行結果如下：

參考自：

https://www.cnblogs.com/tenghoo/archive/2009/11/05/1596456.html

https://www.cnblogs.com/shaoshun/p/3800208.html

轉載請註明出處，本文鏈接：https://www.uj5u.com/net/59620.html

標籤：C#

上一篇：linq 多表分組左連接查詢查詢統計

下一篇：.NET Core 3 Web Api Cors fetch 一直 307 Temporary Redirect