WCF排隊調(diào)用由NetMsmqBinding支持
在WCF中,有一種叫做WCF排隊調(diào)用的操作技術(shù),可以幫助我們在程序開發(fā)中實現(xiàn)一些特定分功能。那么在這里,我們就會對此做一個詳細的介紹,以方便大家在實際應(yīng)用中能夠獲得一些幫助。#t#
Windows Communication Foundation 使用 NetMsmqBinding 來支持WCF排隊調(diào)用。Windows Communication Foundation 在傳輸消息時不是通過 TCP 或 HTTP,而是通過 Microsoft® 消息隊列 (MSMQ)。客戶端也不是將 Windows Communication Foundation 消息發(fā)送到某個在線服務(wù),而是發(fā)送到 MSMQ 隊列。所有客戶端所面向和交互的對象是隊列,而非服務(wù)端點。因此,調(diào)用在本質(zhì)上是異步的、是不連接的。直到服務(wù)在將來某一時刻處理消息時,這些調(diào)用才得以執(zhí)行。
請注意,Windows Communication Foundation 消息并不直接映射到 MSMQ 消息。一個 MSMQ 消息可以包含一個或多個 Windows Communication Foundation 消息,具體個數(shù)視合約會話模式而定。對于必需會話模式,多個 Windows Communication Foundation 調(diào)用可共存于一個 MSMQ 消息中;而對于允許或不允許會話模式(由單調(diào)用和單例式服務(wù)使用),每個 Windows Communication Foundation 調(diào)用將位于單獨的 MSMQ 消息中。
如同各 Windows Communication Foundation 服務(wù)一樣,客戶端會與代理進行交互,如圖 1 所示。由于已將代理配置為使用 MSMQ 綁定,因而該代理不會向任何特定服務(wù)發(fā)送 Windows Communication Foundation 消息,而是將調(diào)用轉(zhuǎn)換為 MSMQ 消息,然后將這些消息發(fā)布到端點地址所指定的隊列中。
在服務(wù)端,當(dāng)具有排隊端點的服務(wù)主機啟動后,主機會安裝隊列偵聽程序。隊列偵聽程序會檢測到隊列中的消息并使其出隊,然后創(chuàng)建主機端以調(diào)度程序為終點的偵聽器鏈。調(diào)度程序會照例調(diào)用服務(wù)實例。如果客戶端向隊列發(fā)布了多個消息,偵聽程序會隨著消息的出隊創(chuàng)建新的實例,最終以異步、非連接的并發(fā)調(diào)用結(jié)束。
如果主機處于離線狀態(tài),消息將在隊列中保持待處理狀態(tài)。待下次主機上線時,消息會被轉(zhuǎn)發(fā)給服務(wù)。
面向隊列進行的、可能處于非連接狀態(tài)的調(diào)用不可能返回任何值,因為在將消息調(diào)度到隊列時并未調(diào)用任何服務(wù)邏輯。此外,調(diào)用可能會在客戶端應(yīng)用程序停止運行后被調(diào)度給服務(wù)進行處理,而這時客戶端根本無法處理返回的值。同樣,調(diào)用也無法將任何服務(wù)端異常返回給客戶端,而且也沒有客戶端用來捕獲和處理異常。由于客戶端不會因為調(diào)用操作而被封鎖,更確切地說,客戶端只有在將消息送去排隊的片刻才才被封鎖,因而從客戶端的角度來看,WCF排隊調(diào)用在本質(zhì)上屬于異步調(diào)用。這些是單向調(diào)用的典型特征。因此,由使用 NetMsmqBinding 的端點所提供的任何合約都只能具有單向操作。Windows Communication Foundation 會在加載服務(wù)和代理時對此進行驗證:
- //只能對排隊合約執(zhí)行單向調(diào)用
- [ServiceContract]
- interface IMyContract
- {
- [OperationContract(IsOneWay = true)]
- void MyMethod();
- }
由于與 MSMQ 的交互封裝在綁定中,因而在服務(wù)調(diào)用代碼或客戶端調(diào)用代碼中沒有任何與調(diào)用排隊相關(guān)的內(nèi)容。服務(wù)代碼和客戶端代碼看起來與任何其他 Windows Communication Foundation 客戶端代碼和服務(wù)代碼都是一樣的,如圖 2 所示。
針對排隊服務(wù)定義端點時,端點地址中必須包含隊列名稱和隊列類型(公有或私有):
- < endpoint
- address = "net.msmq://localhost/private/
- MyServiceQueue"
- binding = "netMsmqBinding"
- ...
- />
***,MSMQ 是 Windows Communication Foundation 的事務(wù)性資源管理器。如果隊列是事務(wù)性的,則當(dāng)客戶端的事務(wù)中止時,客戶端所發(fā)布的消息將會回滾。在服務(wù)端,從隊列中讀取消息時會啟動新的事務(wù)。如果服務(wù)參與并中止該事務(wù)(可能因異常而導(dǎo)致),消息會回滾到隊列中等待下一次重試。Windows Communication Foundation 提供了完善的故障檢測和病毒消息處理支持功能。
以上就是我們?yōu)榇蠹医榻B的WCF排隊調(diào)用的相關(guān)內(nèi)容。