（ 1 ）先安裝 Message Queuing Services

通過 Control Panel ， “Add/Remove Programs” – “Add/Remove Windows Components” 步驟安裝 MSMQ 。

MSMQ 可以安裝為工作組模式或域模式。如果安裝程序沒有找到一臺運行提供目錄服務的消息隊列的服務器，則只可以安裝為工作組模式，此計算機上的“消息隊列”只支持創(chuàng)建專用隊列和創(chuàng)建與其他運行“消息隊列”的計算機的直接連接。

（ 2 ）配置 MSMQ

打開 Computer Management – Message Queuing ，在 Private Queues 下創(chuàng)建 MSMQDemo 隊列

? （ 3 ）編寫代碼－簡單演示 MSMQ 對象

MessageQueue 類是“消息隊列”周圍的包裝。 MessageQueue 類提供對“消息隊列”隊列的引用?？梢栽? MessageQueue 構造函數(shù)中指定一個連接到現(xiàn)有資源的路徑，或者可在服務器上創(chuàng)建新隊列。在調(diào)用 Send 、 Peek 或 Receive 之前，必須將 MessageQueue 類的新實例與某個現(xiàn)有隊列關聯(lián)。

MessageQueue 支持兩種類型的消息檢索：同步和異步。同步的 Peek 和 Receive 方法使進程線程用指定的間隔時間等待新消息到達隊列。異步的 BeginPeek 和 BeginReceive 方法允許主應用程序任務在消息到達隊列之前，在單獨的線程中繼續(xù)執(zhí)行。這些方法通過使用回調(diào)對象和狀態(tài)對象進行工作，以便在線程之間進行信息通訊。

// Send Message

private void btnSendMessage_Click ( object sender , System . EventArgs e )

{

?????? // Open queue

?????? System . Messaging . MessageQueue queue = new System . Messaging . MessageQueue (".""Private$""MSMQDemo");

?????? // Create message

?????? System . Messaging . Message message = new System . Messaging . Message ();

?????? message . Body = txtMessage . Text . Trim ();

?????? message . Formatter = new System . Messaging . XmlMessageFormatter ( new Type [] { typeof ( string )});

?????? // Put message into queue

?????? queue . Send ( message );

}

// Receive Message

private void btnReceiveMessage_Click ( object sender , System . EventArgs e )

{

?????? // Open queue

?????? System . Messaging . MessageQueue queue = new System . Messaging . MessageQueue (".""Private$""MSMQDemo");

?

?????? // Receive message, 同步的 Receive 方法阻塞當前執(zhí)行線程，直到一個 message 可以得到

?????? System . Messaging . Message message = queue . Receive ();

?????? message . Formatter = new System . Messaging . XmlMessageFormatter ( new Type [] { typeof ( string )});

?????? txtReceiveMessage . Text = message . Body . ToString ();

. Net 環(huán)境下消息隊列（ MSMQ ）對象的應用