C# 使用消息隊列，包括遠程訪問

    近期做一個小的功能需求，用到了隊列，用的時候出了很多問題，現在總結一下，希望能對有需要的人提供幫助。

    我的需求很簡單，就是多個客戶端連接到我的一個小型的數據轉發服務器上，開始使用的是Socket通信實現這個功能，一旦數據服務器接收到來自不同客戶端發來的消息，就對這些消息進行處理（我這里是將數據接收到后再轉發到另一個服務器上），但考慮到客戶端是每隔一個很短的時間周期向服務器發送信息，並且連接客服端數量比較多的時候，擔心會產生並發訪問的問題，也希望避免 數據轉發服務器 頻繁地從多個不同線程獲取信息而出現其他未知問題，所以在處理客戶端向數據轉發服務器發送信息的時候采取隊列的方式。

    一般情況下，使用MSMQ，要先安裝消息服務，這個直接百度就行；

    在VS里添加 Messaging引用，就可以使用MessageQueue這個類了；接下來就要思考清楚你的數據（消息）的流向問題，之前因為自己對隊列的錯誤認識，對到底在哪創建隊列，隊列的消息又由誰去發送和接收沒有弄清除，還有參考的一些寫得不是太清晰地博文，繞了好大一圈，所以今天在這里以我自己的項目需求為例子，說明 1、如何創建隊列 2、如何向隊列發送消息 3、 如何獲取隊列中的消息

   首先、創建隊列：根據我的需求，我要通過Socket通信將信息發送至數據轉發服務器，因此為了避免並發訪問問題的產生，消息隊列應當建立在數據轉發服務器上；

　　　　　　　MessageQueue myqueue = null;
　　　　　　　string queuepath = @".\private$\queuedemo";

            if (!MessageQueue.Exists(queuepath))
            {
                myqueue = MessageQueue.Create(queuepath);
            }
            myqueue = new MessageQueue(queuepath);

    這樣就在數據轉發服務器端創建了一個名為queuedemo的消息隊列；從客戶端要發送的消息就保存在這個隊列里，你可以通過計算機管理->服務和應用下的消息隊列中看到你創建的queuedemo隊列，private$關鍵字是說明隊列為專用隊列，如果沒有這個關鍵字還要配置域服務器，還是挺麻煩，這個還是借助百度吧，前面的“.”代表創建的隊列目錄是本機，這個隊列一旦創建成功，就是系統的事了，接下來要做的就是你怎么去把消息寫進這個隊列，或者讀取隊列的值 這里要特別注意，不要將queuepath路徑字符串寫成

string queuepath = @"FormatName:Direct=TCP:192.168.1.153\private$\queuedemo";

這樣寫的話是用於遠程計算機對這個隊列進行訪問的，因為MessageQueue的Create()和Exisit()方法是沒辦法去識別上述FormatName格式的,還有要確保Create()函數要被執行了之后再用MessageQueue實例去引用；這樣服務器端隊列的創建就完成了；

     在客戶端中，向隊列發送信息；

    

string s = "客戶端往隊列里發送的信息");
            System.Messaging.Message msg = new System.Messaging.Message();
            msg.Body = s;
            msg.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
            MessageQueue mq = new MessageQueue(@"FormatName:Direct=TCP:192.168.1.153\private$\queuedemo");
            mq.Send(msg);

在客戶端中，用一個MessageQueue實例指向服務器本機上創建的隊列路徑，這時，MessageQueue實例的構造函數里的路徑就一定要用FormatName格式，指明是TCP通信還是HTTP還是Machine如我上面代碼所示，然后調用Send()方法，將消息寫進隊列，這個要求發送的對象要以序列化的方式寫進去，所以要設置formatter,這里用的是XmlMessageFormatter 還有BinaryMessageFormatter等等 注意保存你消息的 消息體Body是Object類型的 因此可以將你寫的任何一個類的對象發送至消息隊列

    在服務器中接收消息隊列

MessageQueue mq = new MessageQueue(@".\private$\queuedemo");

            mq.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
            Thread th = new Thread(() =>
                {
                    while (true)
                    {
                        System.Messaging.Message msg = mq.Receive();
                        if (msg != null)
                        {
                            MessageBox.Show(msg.Body.ToString());
                        }

                    }
                });
            th.IsBackground = true;
            th.Start();

在本機上可以新創建一個隊列實例指向本機的隊列，然后按照之前約定的序列化格式反序列化消息體所以將新的隊列實例的foarmatter屬性賦值為發送時的formatter屬性如代碼所示，這個時候就直接用Receive()得到消息體，然后對消息體里的信息做處理，我這里是開啟一個線程顯示隊列的消息，只要有新的消息寫入，我就在消息框中輸出

 

    這個時候可能客戶端無法向遠程服務器成功發送消息，原因基本權限問題 服務器的消息隊列的權限沒有對未驗證的客戶端開放  你要在服務器隊列里分配對應權限 如果你想讀取隊列的內容 還需要加系統變量

 

 問題解決辦法

1. 服務器端

• 服務器上消息隊列權限設置：給ANONYMOUS LOGON賦予所有權限；
  
  
• 修改服務器的注冊表，允許非驗證客戶端訪問
  
  • 注冊表新增HKLM\Software\Microsoft\MSMQ\Parameters\security\AllowNonauthenticatedRpc項，設置其DWORD值為1
  • 注冊表新增HKLM\Software\Microsoft\MSMQ\Parameters\security\NewRemoteReadServerDenyWorkgroupClient項，設置其DWORD值為1
    
    MSMQ的安全訪問控制說明參見：http://msdn.microsoft.com/en-us/library/4108f68e-80f5-40e1-b3df-b713cc4dff79(prot.20).aspx
• 

 

這樣客戶端就可以讀取服務器里的隊列信息了 當然一般業務邏輯上不這么做 因為他只負責發送消息 ，綜上，就是使用消息隊列 跨服務器讀寫的 最基本的用法