簡介



MSMQ（微軟消息隊列）是Windows操作系統(tǒng)中消息應(yīng)用程序的基礎(chǔ)，是用于創(chuàng)建分布式、松散連接的消息通訊應(yīng)用程序的開發(fā)工具。消息隊列和電子郵件有著很多相似處，他們都包含多個屬性，用于保存消息，消息類型中都指出發(fā)送者和接收者的地址；然而他們的用處卻有著很大的區(qū)別：消息隊列的發(fā)送者和接收者是應(yīng)用程序，而電子郵件的發(fā)送者和接收者通常是人。



如同電子郵件一樣，消息隊列的發(fā)送和接收也不需要發(fā)送者和接收者同時在場，可以存儲在消息隊列或是郵件服務(wù)器中。因此，我們可以用下圖來描述MSMQ應(yīng)用程序的體系結(jié)構(gòu)：


從上圖可以看出，開發(fā)MSMQ應(yīng)用程序并不是十分困難的事情。不過要使用MSMQ開發(fā)你的消息處理程序，必須在開發(fā)系統(tǒng)和使用程序的主機上安裝消息隊列。消息隊列的安裝屬于Windows組件的安裝，和一般的組件安裝方法類似。安裝好消息隊列后，就可以開發(fā)你自己的消息處理程序了。不過有一點需要注意，如果你的計算機處于工作組中，而不是某個域中，可能你的公用隊列不能使用，不過這并不影響你的程序開發(fā)。



消息處理程序不外乎消息的發(fā)送和接收，然而要收發(fā)消息，還必須引用一個隊列，通常我們引用公用隊列和專用隊列，這兩個隊列都存放用戶生成的消息。引用隊列后，就可以發(fā)送、接收和閱讀消息了。消息接收服務(wù)位于System.Messaging中，如果你找不到這一命名空間，你必須手動添加。點擊[項目]中的[添加引用]，按下瀏覽按鈕，找到System.Messaging.dll文件，添加進來即可。



引用隊列



引用隊列有三種方法，通過路徑、格式名和標(biāo)簽引用隊列，這里我只介紹最簡單和最常用的方法：通過路徑應(yīng)用隊列。隊列路徑的形式為 machinename\queuename。指向隊列的路徑總是唯一的。下表列出用于每種類型的隊列的路徑信息：



隊列類型
路徑中使用的語法

公共隊列
MachineName\QueueName

專用隊列
MachineName\Private$\QueueName

日志隊列
MachineName\QueueName\Journal$




如果是發(fā)送到本機上，還可以使用”.”代表本機名稱。具體的引用方法通過Path屬性來進行，也可以在初始化消息隊列時進行。



如果在初始化時引用消息隊列，那么消息隊列必須存在于系統(tǒng)中，否則會產(chǎn)生中斷。往系統(tǒng)中添加隊列十分的簡單，打開[控制面板]中的[計算機管理]，展開[服務(wù)和應(yīng)用程序]，找到并展開[消息隊列]（如果找不到，說明你還沒有安裝消息隊列），右擊希望添加的消息隊列的類別，選擇新建隊列即可。當(dāng)然，在程序中也可以實現(xiàn)消息隊列的創(chuàng)建，下文會有相應(yīng)的說明。在初始化時引用消息隊列的代碼很簡單，如下所示：



MessageQueue Mq=new MessageQueue(“.\\private$\\jiang”)；

通過Path屬性引用消息隊列的代碼也十分簡單：

MessageQueue Mq=new MessageQueue()；

Mq.Path=”.\\private$\\jiang”;

使用 Create 方法可以在計算機上創(chuàng)建隊列：

System.Messaging.MessageQueue.Create(@".\private$\jiang");



發(fā)送消息



隊列引用過后，就可以發(fā)送消息了。消息的發(fā)送可以分為簡單消息和復(fù)雜消息，簡單消息類型就是常用的數(shù)據(jù)類型，例如整型、字符串等數(shù)據(jù)；復(fù)雜消息的數(shù)據(jù)類型通常對應(yīng)于系統(tǒng)中的復(fù)雜數(shù)據(jù)類型，例如結(jié)構(gòu)，對象等等。



簡單消息的發(fā)送示例如下：

Mq.Send(1000); //發(fā)送整型數(shù)據(jù)

Mq.Send(“This is a test message!”); //發(fā)送字符串



復(fù)雜消息的發(fā)送和簡單消息的發(fā)送大同小異，只是發(fā)送時，通常不是直接給出發(fā)送的消息內(nèi)容，而是代表發(fā)送消息內(nèi)容的變量。下面的代碼分別通過消息變量和復(fù)雜數(shù)據(jù)類型變量發(fā)送一條復(fù)雜消息。



//下面的代碼中發(fā)送的消息由消息變量表示

Message Msg;

Msg=new Message(“A Complex Message!”);

Msg.Label=”This is the label”;

Msg.Priority=MessagePriority.High;

Mq.Send(Msg);



//下面的代碼中發(fā)送的消息由復(fù)雜數(shù)據(jù)類型變量表示,Customer為自定義的一個類

Customer customer = new Customer();
customer.LastName = "Copernicus";

customer.FirstName = "Nicolaus";

Mq.Send(customer);



接收消息



接收消息相比發(fā)送消息要復(fù)雜一點。接收消息由兩種方式：通過Receive方法接收消息同時永久性地從隊列中刪除消息；通過Peek方法從隊列中取出消息而不從隊列中移除該消息。如果知道消息的標(biāo)識符（ID），還可以通過ReceiveById方法和PeekById方法完成相應(yīng)的操作。



接收消息的代碼很簡單：

Mq.Receive(); //或Mq.ReceiveById(ID);

Mq.Peek(); // 或Mq.PeekById(ID);



閱讀消息



接收到的消息只有能夠讀出來才是有用的消息，因此接收到消息以后還必須能讀出消息，而讀出消息算是最復(fù)雜的一部操作了。在應(yīng)用程序能夠閱讀的消息和消息隊列中的消息格式不同，因而應(yīng)用程序發(fā)送出去的消息經(jīng)過序列化以后才發(fā)送給了消息隊列，這一過程由系統(tǒng)自動完成了，程序開發(fā)人員不必為此編寫代碼，然而在接收到消息后就面臨著消息序列化的問題。



消息的序列化可以通過Visual Studio 和 .NET Framework 附帶的三個預(yù)定義的格式化程序來完成：XMLMessageFormatter 對象（ MessageQueue 組件的默認格式化程序設(shè)置）、BinaryMessageFormatter 對象、ActiveXMessageFormatter 對象。由于后兩者格式化后的消息通常不能為人閱讀，所以我們經(jīng)常用到的是XMLMessageFormatter對象。



使用XMLMessageFormatter對象格式化消息的代碼如下所示：

string[] types = { "System.String" };
((XmlMessageFormatter)mq.Formatter).TargetTypeNames = types;

Message m=mq.Receive(new TimeSpan(0,0,3));
將接收到的消息傳送給消息變量以后，通過消息變量m的Body屬性就可以讀出消息了：
MessageBox.Show((string)m.Body);
關(guān)閉消息隊列
消息隊列的關(guān)閉很簡單，和其他對象一樣，通過Close函數(shù)就可以實現(xiàn)了：
Mq.Close();
到此為止，MSMQ應(yīng)用程序的基礎(chǔ)知識就介紹完全了，但是開發(fā)出一個功能強大的MSMQ應(yīng)用程序顯然不是這么簡單，要了解更詳細的資料可以參考MSDN和Windows操作系統(tǒng)中關(guān)于消息隊列的