在系統間的進行資料傳遞,特別是資料量較大,分別插入不同的資料庫的時候。
同時保證系統效率和響應時間,減少資料庫負擔的時候,使用訊息佇列是非常有幫助的。
廢話不多說,直接上**:(把下面的**建為基類直接呼叫就可以了)
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的...