MSMQ 是 Windows 自帶的消息隊(duì)列，它提供了在多機(jī)器，多系統(tǒng)之間實(shí)現(xiàn)可靠的消息互聯(lián)，MSMQ 支持可擴(kuò)展，線程安全，使用簡(jiǎn)單等強(qiáng)勢(shì)特性。

MSDN 上說：消息隊(duì)列技術(shù)使不同時(shí)刻運(yùn)行的程序可以在異構(gòu)網(wǎng)絡(luò)或者異構(gòu)系統(tǒng)中進(jìn)行交互，即使對(duì)方不在線也沒有關(guān)系，應(yīng)用程序僅關(guān)心如何從隊(duì)列中讀取或?qū)懭胂ⅰ?/p>

通常和 MSMQ 交互的應(yīng)用程序有兩種角色，發(fā)布者 和 消費(fèi)者，發(fā)布者應(yīng)用程序?qū)⑾l(fā)送后，不要求消費(fèi)者應(yīng)用程序保持備戰(zhàn)狀態(tài)，實(shí)際上這個(gè)消息是被送到 操作系統(tǒng)維護(hù)的 消息隊(duì)列 中，供后續(xù)某個(gè)時(shí)刻需要此消息的 接收者應(yīng)用程序 消費(fèi)。

創(chuàng)建隊(duì)列

可以在 Windows 控制面板上通過 Turn Windows features on or off 選項(xiàng)進(jìn)行 MSMQ 的安裝，一旦 MSMQ 安裝好之后，接下來就可以創(chuàng)建隊(duì)列了，你可以在 Computer Management 上的 Message Queuing 節(jié)點(diǎn)上可視化創(chuàng)建，也可以通過編程的方式創(chuàng)建，本篇就來討論后面這種方式。

編程創(chuàng)建 MSMQ

先引用 System.Messaging 命名空間，然后使用 MessageQueue.Create 創(chuàng)建消息隊(duì)列，下面的代碼展示了如何實(shí)現(xiàn)。

MessageQueue.Create(@".\Private$\IDG");

隊(duì)列創(chuàng)建好之后，接下來就可以向其發(fā)送 message 了，如下代碼所示：

MessageQueue.Create(@".\Private$\IDG");????messageQueue?=?new?MessageQueue(@".\Private$\IDG");messageQueue.Label?=?"This?is?a?test?queue.";messageQueue.Send("This?is?a?test?message.",?"IDG");

有一點(diǎn)要注意，在發(fā)送消息之前，你需要檢查隊(duì)列是否存在，如果不存在，你必須要先創(chuàng)建一個(gè)，如果存在則不必再創(chuàng)建，下面的代碼展示了如何去實(shí)現(xiàn)。

static?void?Main(string[]?args){MessageQueue?messageQueue?=?null;string?description?=?"This?is?a?test?queue.";string?message?=?"This?is?a?test?message.";string?path?=?@".\Private$\IDG";try{if?(MessageQueue.Exists(path)){messageQueue?=?new?MessageQueue(path);messageQueue.Label?=?description;}else{MessageQueue.Create(path);messageQueue?=?new?MessageQueue(path);messageQueue.Label?=?description;}messageQueue.Send(message);}catch{throw;}finally{messageQueue.Dispose();}}

上面是消息的發(fā)送，接下來再看一下如何從 消息隊(duì)列 中獲取消息，代碼如下：

private?static?List<string>?ReadQueue(string?path){List<string>?lstMessages?=?new?List<string>();using?(MessageQueue?messageQueue?=?new?MessageQueue(path)){System.Messaging.Message[]?messages?=?messageQueue.GetAllMessages();foreach?(System.Messaging.Message?message?in?messages){message.Formatter?=?new?XmlMessageFormatter(new?String[]?{?"System.String,?mscorlib"?});string?msg?=?message.Body.ToString();lstMessages.Add(msg);}}return?lstMessages;}

上面的案例演示的是向消息隊(duì)列中塞入 string 類型，其實(shí)還可以塞入 model ，為了簡(jiǎn)單起見，我定義了一個(gè)只有兩個(gè)屬性的 LogMessage 類，如下代碼所示：

public?class?LogMessage{public?string?MessageText?{?get;?set;?}public?DateTime?MessageTime?{?get;?set;?}}

下面的代碼展示了如何將 logMessage 實(shí)例送入到 消息隊(duì)列 中。

private?static?void?SendMessage(string?queueName,?LogMessage?msg){MessageQueue?messageQueue?=?null;if?(!MessageQueue.Exists(queueName))?messageQueue?=?MessageQueue.Create(queueName);else?messageQueue?=?new?MessageQueue(queueName);try{messageQueue.Formatter?=?new?XmlMessageFormatter(new?Type[]?{?typeof(LogMessage)?});messageQueue.Send(msg);}catch{//Write?code?here?to?do?the?necessary?error?handling.}finally{messageQueue.Close();}}

接下來看看 SendMessage 方法是如何對(duì) LogMessage 進(jìn)行填充數(shù)據(jù)的，如下代碼所示：

LogMessage?msg?=?new?LogMessage(){MessageText?=?"This?is?a?test?message.",MessageTime?=?DateTime.Now};SendMessage(@".\Private$\IDGLog",?msg);

然后再看看看如何從 消息隊(duì)列 中讀取 LogMessage 。

private?static?LogMessage?ReceiveMessage(string?queueName){if?(!MessageQueue.Exists(queueName))?return?null;MessageQueue?messageQueue?=?new?MessageQueue(queueName);LogMessage?logMessage?=?null;try{messageQueue.Formatter?=?new?XmlMessageFormatter(new?Type[]?{?typeof(LogMessage)?});logMessage?=?(LogMessage)messageQueue.Receive().Body;}catch?{?}finally{messageQueue.Close();}return?logMessage;}

譯文鏈接：https://www.infoworld.com/article/3060115/how-to-work-with-msmq-in-c.html

總結(jié)

以上是生活随笔為你收集整理的如何在 C# 中使用 MSMQ的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。