WCF學(xué)習(xí)筆記之?dāng)?shù)據(jù)報(bào)信息交換模式案例分析
學(xué)習(xí)了WCF很長(zhǎng)時(shí)間，現(xiàn)在我就把我的WCF學(xué)習(xí)筆記分享給大家，希望通過(guò)我經(jīng)驗(yàn)可以給大家?guī)?lái)知識(shí)的財(cái)富，我們看一個(gè)實(shí)例分析。在所有的WCF服務(wù)中，有一些服務(wù)使用了非常典型的通訊模式。在WCF文檔中引用的通訊模式是消息交換模式，但是“Shape”還被描述為我們實(shí)現(xiàn)模式的接口類型。WCF學(xué)習(xí)筆記實(shí)例概述，下面是三個(gè)消息交換模式：
1. 數(shù)據(jù)報(bào)模式，或稱為單行模式。在這種模式下數(shù)據(jù)流僅僅從客戶端向服務(wù)端傳輸。
2. 請(qǐng)求響應(yīng)模式，在這種模式下，數(shù)據(jù)流從客戶端到達(dá)服務(wù)端，然后服務(wù)端又會(huì)將響應(yīng)信息傳回客戶端。
3. 數(shù)據(jù)報(bào)和請(qǐng)求響應(yīng)模式，這種模式同時(shí)兼有兩種模式的特點(diǎn)。
#T#由于數(shù)據(jù)報(bào)模式是一種基礎(chǔ)模式，并且實(shí)現(xiàn)起來(lái)非常簡(jiǎn)單。因此，本文的例子將以數(shù)據(jù)報(bào)模式實(shí)現(xiàn)。在這個(gè)例子中，通道棧中有三個(gè)通道。一個(gè)是傳輸通道，負(fù)責(zé)創(chuàng)建和傳輸消息，另兩個(gè)是協(xié)議通道，負(fù)責(zé)將消息頭附著在消息數(shù)據(jù)上。管理WCF通訊的狀態(tài)機(jī)可以使用異步或同步的方式調(diào)用通道的功能。每一個(gè)消息交換模式包含每一個(gè)調(diào)用類型。為了簡(jiǎn)單起見(jiàn)，在這里只使用同步方式來(lái)實(shí)現(xiàn)。還有就是本例直接和通道棧進(jìn)行交互。因此，在例子代碼中并沒(méi)有聲明契約。為了運(yùn)行例子程序，我們需要***的SDK。
從上面的內(nèi)容可知，本例實(shí)現(xiàn)了數(shù)據(jù)報(bào)信息交換模式。因此，通道需要實(shí)現(xiàn)IInputChannel接口，WCF學(xué)習(xí)筆記實(shí)例概述代碼如下：
- class TestTransportChannel :
- ChannelBase,IInputChannel { protected EndpointAddress localAddress;
- public TestTransportChannel(TestTransportChannelListener parent, EndpointAddress address) :
- base(parent) { ... ... this.localAddress = address; }
在IInputChannel中有兩個(gè)關(guān)鍵的方法，WaitForMessage和Receive方法。當(dāng)一個(gè)消息出現(xiàn)時(shí)，WaitForMessage返回true。然后Receive獲得了這個(gè)消息。下面的使用其中一個(gè)協(xié)議棧接收消息的代碼：
- public Message Receive(TimeSpan timeout) { Message msg; MessageHeader mh;
- BigHelper.DisplayMessage("Receive " + this.ToString());
- msg = ((TestLevel2ChannelListener)this.Manager) .GetMessage(timeout);
- mh = MessageHeader.CreateHeader ("Level2", "http://Level2ns", "2");
- msg.Headers.Add(mh); return msg; }
Receive方法返回一個(gè)Message對(duì)象。Message對(duì)象將被傳遞到WCF的各個(gè)層。接下來(lái)，讓我們來(lái)看看ChannelListener的實(shí)現(xiàn)。
