Windows訊息佇列MQ的使用

2021-07-12 00:15:09 字數 1875 閱讀 3223

在系統間的進行資料傳遞,特別是資料量較大,分別插入不同的資料庫的時候。

同時保證系統效率和響應時間,減少資料庫負擔的時候,使用訊息佇列是非常有幫助的。

廢話不多說,直接上**:(把下面的**建為基類直接呼叫就可以了)

using system.messaging;//標頭檔案

using system;

using system.collections.generic;

using system.linq;

using system.text;

using system.threading.tasks;

using system.messaging;

namespace _157

#endregion

public bool sendmessagebylocalprivate(string messagequeuename, object message)

", messagequeuename);

messagequeue mq = null;

trycatch (exception ex)

finally}}

///

/// 遠端傳送訊息

///

/// ip位址

/// 訊息佇列名稱

/// 傳送訊息

///

public bool sendmessagebydomainprivate(string ipaddress, string messagequeuename, object message)

\private$\", ipaddress, messagequeuename);

messagequeue mq = null;

try;

mq.send(message);

return true;

}catch (exception ex)

finally}}

public object getmessagebylocalprivate(string messagequeuename)

", messagequeuename);

messagequeue mq = null;

message msg = null;

trycatch (exception ex)

finally

}public object getmessagebylocalprivate(string messagequeuename, timespan timespan)

", messagequeuename);

messagequeue mq = null;

message msg = null;

trycatch (exception ex)

finally

}///

/// 遠端接收訊息

///

/// ip位址

/// 訊息佇列名稱

/// 間隔時間(毫秒)

///

public object getmessagebydomainprivate(string ipaddress, string messagequeuename, timespan timespan)

\private$\", ipaddress, messagequeuename);

messagequeue mq = null;

message msg = null;

try;

msg = mq.receive(timespan);

return msg == null ? null : msg.body;

}catch (exception ex)

finally}}

}

訊息佇列MQ

目錄 一 簡介 二 為什麼需要訊息佇列 mq 三 介紹 訊息佇列 message queuing 在電腦科學中,是一種程序間通訊或同一程序間不同執行緒的通訊方式。廣義上講訊息佇列是解決分布式系統中,各個功能模組間的資訊傳遞通訊方式。與檔案傳輸和rpc相比,訊息佇列具有更好的平台無關性,並能夠很好地支...

MQ訊息佇列

1.解耦 系統a將userid寫到訊息佇列中,系統c和系統d從訊息佇列中拿資料。這樣有什麼好處?系統a只負責把資料寫到佇列中,誰想要或不想要這個資料 訊息 系統a一點都不關心。即便現在系統d不想要userid這個資料了,系統b又突然想要userid這個資料了,都跟系統a無關,系統a一點 都不用改。系...

MQ訊息佇列應用

很榮幸,原來一直聽說的訊息佇列終於在前段時間用到了自己的專案中。為什麼會用到訊息佇列?毫無疑問,當然是傳輸訊息。這裡訊息一般是一串字串,當然,訊息的含義很多,可以是 hello world 可以是 你吃飯了嗎?可以是一串正式的xml報文。也可以是乙個txt檔案或者xml檔案 在用active mq的...