很久很久沒有寫過日志了,,可能是遺忘了,也可能是明白了些什么..

趁著這次工作的機會算是把WCF進行了完整再學習,其中一些不足的遺忘的點都零零碎碎的拼接在了一起
為避免再次遺失,還是記錄如下...

一、為什么要使用MSMQ

在一個分布式的環(huán)境中，我們往往需要根據(jù)具體的情況采用不同的方式進行數(shù)據(jù)的傳輸。比如在一個Intranet內，我們一般通過TCP進行高效的數(shù)據(jù)通信；而在一個Internet的環(huán)境中，我們則通常使用Http進行跨平臺的數(shù)據(jù)交換。而這些通信方式具有一個顯著的特點，那就是他們是基于Connection的，也就是說，交互雙方在進行通信的時候必須保證有一個可用的Connection存在于他們之間。而在某些時候，比如那些使用撥號連接的用戶、以及使用便攜式計算機的用戶，我們不能保證在他們和需要訪問的Server之間有一個的可靠的連接，在這種情況下，基于Messaging Queue的連接就顯得尤為重要了。我們今天就來談談在WCF中如何使用MSMQ。
MSMQ不僅僅是作為支持客戶端連接工具而存在，合理的使用MSMQ可以在很大程度上提升系統(tǒng)的Performance和Scalability。我們先來看看MSMQ能給我們帶來怎樣的好處：
1．MSMQ是基于Disconnection
MSMQ通過Message Queue進行通信，這種通信方式為離線工作成為了可能。比如在介紹MSMQ時都會提到的Order Delivery的例子：在一個基于B2C的系統(tǒng)中，訂單從各種各樣的客戶傳來，由于 客戶的各異性，不能保證每個客戶在每時每刻都和用于接收訂單的Server保持一個可靠的連接，我們有時候甚至允許客戶即使在離線的情況下也可以遞交訂單（雖然訂單不能發(fā)送到訂單的接收方，但是我們可以通過某種機制保證先在本地保存該訂單，一旦連接建立，則馬上向接收方遞交訂單），而MSMQ則有效地提供了這樣的機制：Server端建立一個Message Queue來接收來個客戶的訂單，客戶端通過向該Message Queue發(fā)送承載了訂單數(shù)據(jù)的Message實現(xiàn)訂單的遞交。如果在客戶離線的情況下，他仍然可以通過客戶端程序進行訂單遞交的操作，存儲著訂單數(shù)據(jù)的Message會被暫時保存在本地的Message Queue中，一旦客戶聯(lián)機，MSMQ將Message從中取出，發(fā)送到真正的接收方，而這個動作對于用戶的透明的。
2．MSMQ天生是One-way、異步的
在MSMQ中，Message始終以One-way的方式進行發(fā)送，所以MSMQ具有天生的異步特性。所以MSMQ使用于那些對于用戶的請求，Server端無需立即響應的場景。也就是說Server對數(shù)據(jù)的處理無需和Client的數(shù)據(jù)的發(fā)送進行同步，它可以獨自地按照自己的Schedule進行工作。這可以避免峰值負載。比如Server端可以在一個相對低負載的時段（比如深夜）來對接收到的Order進行批處理，而無需一天24小時一直進行Order的監(jiān)聽、接收和處理。
3．MSMQ能夠提供高質量的Reliable Messaging
我們知道，在一般的情況下，如果Client端以異步的方式對Service進行調用就意味著：Client無法獲知Message是否成功抵達Service端；也不會獲得Service端執(zhí)行的結果和出錯信息。但是我們仍然說MSMQ為我們提供了可靠的傳輸（Reliable Messaging），這主要是因為MSMQ為我們提供一些列Reliable Messaging的機制：

• 
  超時機制（Timeout）：可以設置發(fā)送和接收的時間，超出該時間則被認為操作失敗。
  
• 
  確認機制（Acknowledgement）：當Message成功抵達Destination Queue，或者被成功接收，向發(fā)送端發(fā)送一個Acknowledgement message用以確認操作的狀態(tài)。
  
• 
  日志機制（Journaling）：當Message被發(fā)送或接收后，被Copy一份存放在Journal Queue中。
  

此外，MSMQ還提供了死信隊列（Dead letter Queue）用以保存發(fā)送失敗的message。這一切保證了保證了Reliable Messaging。
二、 MSMQ在WCF的運用
在WCF中，MSMQ提供的數(shù)據(jù)傳輸功能被封裝在一個Binding中，提供WCF Endpoint之間、以及Endpoint和現(xiàn)有的基于MSMQ的Application進行通信的實現(xiàn)。為此WCF為我們提供了兩種不同的built-in binding：

• 
  NetMsmqBinding：從提供的功能和使用 方式上看，NetMsmqBinding和一般使用的binding，比如basicHttpBinding，netTcpBinding沒有什么區(qū)別：在兩個Endpoint之間實現(xiàn)了數(shù)據(jù)的通信，所不同的是，它提供的是基于MSMQ的Reliable Messaging。從變成模式上看，和一般的binding完全一樣。
  
• 
  MsmqIntegrationBinding：從命名上我們可以看出，MsmqIntegrationBinding主要用于需要將我們的WCF Application和現(xiàn)有的基于MSMQ的Application集成的情況。MsmqIntegrationBinding實現(xiàn)了WCF Endpoint和某個Message Queue進行數(shù)據(jù)的通信，具體來說，就是實現(xiàn)了單一的向某個Message Queue 發(fā)送Message，和從某個Message Queue中接收Message的功能。從編程模式上看，也有所不同，比如Operation只接收一個MsmqMessage<T>的參數(shù)。
  

這是Client和Service通信的圖示：


三、MSMQ和Transaction
MSMQ提供對Transaction的支持。在一般的情況下，MSMQ通過Message Queue Transaction實現(xiàn)對Transaction的原生的支持，借助Message Queue Transaction，可以把基于一個或多個Message Queue的相關操作納入同一個Transaction中。
Message Queue Transaction僅僅限于基于Message Queue的操作，倘若操作涉及到另外一些資源，比如SQL Server, 則可以使用基于DTC的分布式Transaction。
對于WCF中MSMQ，由于Client和Service的相對獨立（可能Client發(fā)送Message到Service處理Message會相隔很長一段時間），所以Client和Service的操作只能納入不同的Transaction中，如下圖。



代碼: 
1.終結點配置
<endpoint address="net.msmq://localhost/private/orders" binding="netMsmqBinding"

bindingConfiguration="msmqBinding" contract="Contract.IOrderProcessor" />

2.托管創(chuàng)建MSMQ隊列

string path = @".\private$\orders";

if(!MessageQueue.Exists(path))
{
MessageQueue.Create(path,true);
}

3.客戶端使用

ChannelFactory<IOrderProcessor> channelFactory = new ChannelFactory<IOrderProcessor>("defaultEndpoint");

IOrderProcessor channel = channelFactory.CreateChannel();
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))

{
       channel.Submit(order);
       scope.Complete();
}

天然斷開異步事務集于一身,,使用簡單方便更乃王道...

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國云服務器，動態(tài)BGP最優(yōu)骨干路由自動選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡助力業(yè)務部署。公司持有工信部辦法的idc、isp許可證， 機房獨有T級流量清洗系統(tǒng)配攻擊溯源，準確進行流量調度，確保服務器高可用性。佳節(jié)活動現(xiàn)已開啟，新人活動云服務器買多久送多久。

成都創(chuàng)新互聯(lián)成都網(wǎng)站建設定制網(wǎng)站，是成都網(wǎng)站建設公司,為高空作業(yè)車租賃提供網(wǎng)站建設服務,有成熟的網(wǎng)站定制合作流程，提供網(wǎng)站定制設計服務：原型圖制作、網(wǎng)站創(chuàng)意設計、前端HTML5制作、后臺程序開發(fā)等。成都網(wǎng)站建設熱線：13518219792

標題名稱：WCF筆記--MSMQ的使用-創(chuàng)新互聯(lián)
文章路徑：http://chinadenli.net/article4/dgpoie.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供軟件開發(fā)、營銷型網(wǎng)站建設、網(wǎng)站導航、小程序開發(fā)、移動網(wǎng)站建設、App開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)