.net微软消息队列(msmq)简单案例
1.首先我們需要安裝消息隊列服務,它是獨立的消息記錄的服務,并保存在硬盤文件中。
? ?我們添加名為:DMImgUpload的私有消息隊列。
2.定義消息隊列的連接字符串建議采用IP:
(1)FormatName:DIRECT=OS:Pac_gzf-PC\Private$\DMImgUpload
(2)FormatName:DIRECT=TCP:192.168.1.105\Private$\DMImgUpload
? string?queuePath="FormatName:DIRECT=TCP:192.168.1.105\Private$\DMImgUpload";
2.創建實例:【using System.Messaging;】
?protected MessageQueueTransactionType transactionType = MessageQueueTransactionType.Automatic;//定義事務
MessageQueue?queue = new MessageQueue(queuePath); //根據傳入quueuPath創建隊列
TimeSpan?timeout = TimeSpan.FromSeconds(3);//設置讀取消息間隔時間;
queue.DefaultPropertiesToSend.AttachSenderId = false;
queue.DefaultPropertiesToSend.UseAuthentication = false;
queue.DefaultPropertiesToSend.UseEncryption = false;
queue.DefaultPropertiesToSend.AcknowledgeType = AcknowledgeTypes.None;
queue.DefaultPropertiesToSend.UseJournalQueue = false;
3.
/// 接收消息方法
public virtual object Receive()
{
try
{
using (Message message = queue.Receive(timeout, transactionType))
return message;
}
catch (MessageQueueException mqex)
{
if (mqex.MessageQueueErrorCode == MessageQueueErrorCode.IOTimeout)
throw new TimeoutException();
throw mqex;
}
}
/// 發送消息【lable:消息標識,msq:消息】
public virtual void Send(string label, object msg)
{
? ?queue.Send(msg, label, transactionType);
}
5.備注:
當我們跨主機調用時會出現,消息隊列權限提示,要在msmq中設置network service權限
消息隊列存儲可以使字符串,也可以使對象形式。
比如:我們定義一個對象:SolImgCreateModel。接受消息進行強制轉換即可:
(SolImgCreateModel)((Message)?Receive()).Body;
轉載于:https://www.cnblogs.com/guozefeng/p/4170178.html
總結
以上是生活随笔為你收集整理的.net微软消息队列(msmq)简单案例的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: FireFox火狐浏览器与IE兼容问题
- 下一篇: 2014-06-27nbsp;20:47