日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

.net微软消息队列(msmq)简单案例

發(fā)布時間:2025/4/14 编程问答 28 豆豆
生活随笔 收集整理的這篇文章主要介紹了 .net微软消息队列(msmq)简单案例 小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

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.創(chuàng)建實例:【using System.Messaging;】

?protected MessageQueueTransactionType transactionType = MessageQueueTransactionType.Automatic;//定義事務

MessageQueue?queue = new MessageQueue(queuePath); //根據(jù)傳入quueuPath創(chuàng)建隊列
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;
}
}

/// 發(fā)送消息【lable:消息標識,msq:消息】
public virtual void Send(string label, object msg)
{
? ?queue.Send(msg, label, transactionType);
}

5.備注:

當我們跨主機調用時會出現(xiàn),消息隊列權限提示,要在msmq中設置network service權限

消息隊列存儲可以使字符串,也可以使對象形式。

比如:我們定義一個對象:SolImgCreateModel。接受消息進行強制轉換即可:

(SolImgCreateModel)((Message)?Receive()).Body;

轉載于:https://www.cnblogs.com/guozefeng/p/4170178.html

總結

以上是生活随笔為你收集整理的.net微软消息队列(msmq)简单案例的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。