|
今天繼續WCF分布式開發步步為贏系列的第4節:WCF服務可靠性傳輸配置與編程開發。這個章節,我們要介紹什么是WCF服務的可靠性傳輸,隨便介紹網絡協議的概念,Web Service為什么不支持可靠性傳出,具體的WCF綁定協議和可靠性的關系,實現可靠性傳輸有什么方式,以及配置和開發的詳細實現代碼分析部分。【1】可靠性傳輸【2】配置方式實現可靠性傳輸【3】編程方式實現可靠性傳輸【4】編程實現必備有序傳遞【5】結果分析和總結。
下面進入正式的內容:
【1】可靠性傳輸:
【1.0】網絡協議基礎知識:
這里我們有必要先介紹OSI參考模型幾個主要協議的基本概念,見下表:
OSI中的層 | 功能 | TCP/IP協議族 |
應用層 | 文件傳輸,電子郵件,文件服務,虛擬終端 | TFTP,HTTP,SNMP,FTP,SMTP,DNS,TelNET |
表示層 | 數據格式化,代碼轉換,數據加密 | 沒有協議 |
會話層 | 解除或建立與別的接點的聯系 | 沒有協議 |
傳輸層 | 提供端對端的接口 | TCP,UDP |
網絡層 | 為數據包選擇路由 | IP,ICMP,RIP,OSPF,BGP,IGMP |
數據鏈路層 | 傳輸有地址的幀以及錯誤檢測功能 | SLIP,CSLIP,PPP,ARP,RARP,MTU |
物理層 | 以二進制數據形式在物理媒體上傳輸數據 | ISO2110,IEEE802。IEEE802.2 |
TCP/IP是一個協議族,為了幫助大家理解下面協議綁定的內容,把IP想像成一種高速公路,它允許其它協議在上面行駛并找到到其它電腦的出口。TCP和UDP是高速公路上的汽車,汽車上貨物就是HTTP,SNMP,FTP,SMTP,DNS,TelNET 協議等。
TCP和UDP是FTP,HTTP和SMTP等應用層協議使用的傳輸層協議。TCP提供面向連接、有保證的數據傳輸,而UDP不提供。TCP有一個特殊的機制來確保數據安全的不出錯的從一個端點傳到另一個端點,而UDP不提供任何這樣的保證。
HTTP(超文本傳輸協議)是利用TCP協議在兩臺機器(通常是Web服務器和客戶端)之間傳輸信息的協議。客戶端使用Web瀏覽器發起HTTP請求給Web服務器,Web服務器發送被請求的信息給客戶端。
這里隨便介紹一下SOAP協議,它也是基于XML語言,可以實現分布式系統間的數據交換的協議。 SOAP:Simple Object Access Protocol簡單對象訪問協議是一種輕量的、簡單的、基于 XML 的協議,它被設計成在 WEB 上交換結構化的和固化的信息。 SOAP 可以和現存的許多因特網協議和格式結合使用,包括超文本傳輸協議( HTTP),簡單郵件傳輸協議(SMTP),多用途網際郵件擴充協議(MIME)。它還支持從消息系統到遠程過程調用(RPC)等大量的應用程序,當然也可以映射到TCP協議。
【1.1】WCF可靠性傳輸簡介:
WCF與其他面向服務技術之間(ASP.NET /j2ee Web Service技術等)最大的區別在于傳輸可靠性(Transport Reliability)與消息可靠性(Message Reliability)。傳輸可靠性(例如通過TCP傳輸)在網絡數據包層提供了點對點保證傳遞(Point-to-Point Guaranteed Delivery),以確保數據包的順序無誤。傳輸可靠性不會受到網絡連接的中斷或其他通信問題的影響。消息可靠性提供了端對端保證傳遞(End-to-End Guaranteed Delivery),確保消息的順序無誤。消息可靠性與引入的中間方的數量無關,與網絡跳數(NETwork Hops)的數量也沒有關聯。消息可靠性基于一個行業標準。該行業標準為可靠的基于消息的通信維持了一個在傳輸層的會話。如果傳輸失敗,例如無線連接中斷,消息可靠性就會重試(Retries)功能。它還能夠自動處理網絡阻塞(Congestion)、消息緩存(Message Buffering)以及流控制(Flow Control),根據具體情況適時調整發送的消息數。消息可靠性還能夠通過對連接的驗證管理連接自身,并在不需要連接時清除它們。
這里WCF的可靠性傳輸首先來說數據傳輸同樣依賴底層的網絡傳輸協議,如TCP協議,TCP傳輸控制協議底層就是要求建立連接的狀態進行數據傳遞。其次消息可靠性也是對已有消息可靠性行業標準的支持,WCF框架實現或者擴展了消息可靠性行業標準。
Web Service使用http/post/get/soap三種方式進行訪問,http協議是請求/響應協議,不會維持特定的傳輸通道,本身是不支持可靠性。
【1.2】傳輸協議與可靠性:
看來以上的介紹內容,我們再來介紹WCF綁定協議的可靠性,同樣WCF的可靠性和具體的綁定協議彌補可分??偨Y了綁定、可靠性、有序傳遞(Ordered Delivery)以及它們各自的默認值之間的關系??煽啃耘c綁定對應關系如下:
BasicHttpBinding不支持可靠性,BasicHttpBinding面向舊的ASMX Web服務,是不具有可靠性的;
NETMsmqBinding不支持可靠性,MSMQ協議,使用消息隊列,針對斷開調用,不存在傳輸會話;
MsmqIntegrationBinding不支持可靠性;支持WCF與MSMQ協議通信,不存在傳輸會話;
NETPeerTcpBinding不支持可靠性。NETPeerTcpBinding則為廣播場景設計。
WSDualHttpBinding支持可靠性的,建立兩個http會話通道,保持回調通道,確?;贖TTP協議的客戶端存在;
NETTcpBinding 支持可靠性,顯然使用TCP傳輸數據。以及各種WS綁定,默認情況下并不支持可靠性,允許啟用;
NETNamedPipeBinding綁定總是擁有一個確定的從客戶端到服務的跳數,因而它的可靠性是綁定固有的;
WSFederationHttpBinding支持可靠性,支持聯邦通信協議,支持在多個安全區域進行安全會話。
WS綁定協議一般都提供了對可靠性傳遞的支持,可以編程或者配置方式在項目里啟用。可靠性傳輸要根據綁定的目標場景而定。
【1.3】有序消息:
TCP提供了差錯和流量控制。WCF消息可靠性也以具體的綁定協議底層的傳輸協議和自身擴展的機制確保了消息的有序傳遞,允許消息按照發送順序而非接收順序執行。我們在實際的WCF項目里及可以只啟用可靠性,而不啟用有序傳遞。
同樣WCF也為我們提供了靈活的方式來配置啟用項目中的傳輸可靠性和傳遞的有序性,你可以使用配置文件方式也可以使用編程方式實現。如果我們啟用了可靠性,則客戶端與服務端必須保持配置一致,否則客戶端無法與服務通信。我們可以只對支持它的綁定配置可靠性。下面我們就來進行詳細的介紹。
【2】配置方式實現可靠性傳輸:
下面我們使用服務端配置文件,啟用了TCP綁定的可靠性。代碼如下:
<system.serviceModel><services>
<service behaviorConfiguration="WCFService.WCFServiceBehavior"
name="WCFService.WCFService">
<endpoint
address="http://localhost:8001/WCFService"
binding="wsHttpBinding"
contract="WCFService.IWCFService">
</endpoint>
<endpoint
address="NET.tcp://localhost:8002/WCFService"
binding="NETTcpBinding"
bindingConfiguration="ReliableTCP"
contract="WCFService.IWCFService">
</endpoint>
<endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
<endpoint address="mex" binding="mexTcpBinding" contract="IMetadataExchange" />
<host>
<baseAddresses>
<add baseAddress="http://localhost:8001/"/>
<add baseAddress="NET.tcp://localhost:8002/"/>
</baseAddresses>
</host>
</service>
</services>
<behaviors>
<serviceBehaviors>
<behavior name="WCFService.WCFServiceBehavior">
<serviceMetadata httpGetEnabled="true" />
<serviceDebug includeExceptionDetailInFaults="false" />
</behavior>
</serviceBehaviors>
</behaviors>
<bindings>
<NETTcpBinding >
<binding name="ReliableTCP">
<reliableSession enabled="True"/>
</binding>
</NETTcpBinding>
</bindings>
</system.serviceModel>
【3】編程方式實現可靠性傳輸:
至于編程配置方式,這里我們稍作介紹,TCP綁定和WS綁定提供了略微不同的屬性來配置可靠性。這里的例子我們繼續使用的是針對TCP編程實現可靠性傳輸的示例代碼:
//采用自托管方式,也可以是IIS、WAS,Windows服務等用戶自定義程序托管服務public class WCFHost
{
static void Main(string[] args)
{
//反射方式創建服務實例,
//Using方式生命實例,可以在對象生命周期結束時候,釋放非托管資源
using (ServiceHost host = new ServiceHost(typeof(WCFService.WCFService)))
{
//相同的服務注冊多個基地址
//添加服務和URI,用戶資源標識符
Uri tcpAddress = new Uri("NET.tcp://localhost:8001/WCFService");
//Uri httpAddress = new Uri("http://localhost:8002/WCFService");
//Uri pipeAddress = new Uri("NET.pipe://localhost:8002/WCFService");
SecurityMode securityMode = new SecurityMode();//實例化安全模型
//設置可靠性會話為真
NETTcpBinding NETTcpBinding = new NETTcpBinding(securityMode, true);
//添加服務終結點,方式不變
host.AddServiceEndpoint(typeof(WCFService.IWCFService), NETTcpBinding, tcpAddress);
//host.AddServiceEndpoint(typeof(WCFService.IWCFService), new WSHttpBinding(), httpAddress);
//host.AddServiceEndpoint(typeof(WCFService.IWCFService), new NETNamedPipeBinding(), pipeAddress);
////判斷是否以及打開連接,如果尚未打開,就打開偵聽端口
if (host.State != CommunicationState.Opening)
host.Open();
//顯示運行狀態
Console.WriteLine("Host is runing! and state is {0}", host.State);
//等待輸入即停止服務
Console.Read();
}
}
【4】編程實現必備有序傳遞:
我們這里在簡單介紹一下WCF有序傳遞的概念。我們知道服務代碼和契約定義應該與它使用的綁定及屬性無關。實際上,WCF服務的實現或者數據契約本身都會依賴于系統消息的有序傳遞(Ordered Delivery)。為了幫助契約或服務的開發者能夠約束支持的綁定,WCF定義了DeliveryRequirementsAttribute類,這是一個密封類,不可繼承,我們使用他來定義服務的傳遞屬性。這里應用到服務屬性,設置服務啟用有序隊列傳遞。
[DeliveryRequirementsAttribute(QueuedDeliveryRequirements = QueuedDeliveryRequirementsMode.Allowed,
RequireOrderedDelivery = true
)]
public class WCFService : IWCFService
{
//實現接口定義的方法
public string SayHello(string name)
{
Console.WriteLine("Hello! {0},Using string

return "Hello! " + name;
}
//實現接口定義的方法
public string SayHelloToUser(User user)
{
Console.WriteLine("Hello! {0} {1},Using DataContract

return "Hello! " + user.FirstName + " " + user.LastName;
}
}
【5】結果分析和總結。
配置完畢后,我們可以在客戶端添加WCF服務引用,生成的配置文件,內容包含對可靠消息傳遞的配置信息,具體如下:
<NETTcpBinding><binding name="NETTcpBinding_IWCFService" closeTimeout="00:01:00"
openTimeout="00:01:00" receiveTimeout="00:10:00" sendTimeout="00:01:00"
transactionFlow="false" transferMode="Buffered" transactionProtocol="OleTransactions"
hostNameComparisonMode="StrongWildcard" listenBacklog="10"
maxBufferPoolSize="524288" maxBufferSize="65536" maxConnections="10"
maxReceivedMessageSize="65536">
<readerQuotas maxDepth="32" maxStringContentLength="8192" maxArrayLength="16384"
maxBytesPerRead="4096" maxNameTableCharCount="16384" />
<reliableSession ordered="true" inactivityTimeout="00:10:00"
enabled="true" />
<security mode="Transport">
<transport clientCredentialType="Windows" protectionLevel="EncryptAndSign" />
<message clientCredentialType="Windows" />
</security>
</binding>
</NETTcpBinding>
NET技術:WCF分布式開發步步為贏系列的(4):WCF服務可靠性傳輸配置與編程開發,轉載需保留來源!
鄭重聲明:本文版權歸原作者所有,轉載文章僅為傳播更多信息之目的,如作者信息標記有誤,請第一時間聯系我們修改或刪除,多謝。