WCF學習筆記之數(shù)據(jù)報信息交換模式案例分析
學習了WCF很長時間,現(xiàn)在我就把我的WCF學習筆記分享給大家,希望通過我經驗可以給大家?guī)碇R的財富,我們看一個實例分析。在所有的WCF服務中,有一些服務使用了非常典型的通訊模式。在WCF文檔中引用的通訊模式是消息交換模式,但是“Shape”還被描述為我們實現(xiàn)模式的接口類型。WCF學習筆記實例概述,下面是三個消息交換模式:
1. 數(shù)據(jù)報模式,或稱為單行模式。在這種模式下數(shù)據(jù)流僅僅從客戶端向服務端傳輸。
2. 請求響應模式,在這種模式下,數(shù)據(jù)流從客戶端到達服務端,然后服務端又會將響應信息傳回客戶端。
3. 數(shù)據(jù)報和請求響應模式,這種模式同時兼有兩種模式的特點。
#T#由于數(shù)據(jù)報模式是一種基礎模式,并且實現(xiàn)起來非常簡單。因此,本文的例子將以數(shù)據(jù)報模式實現(xiàn)。在這個例子中,通道棧中有三個通道。一個是傳輸通道,負責創(chuàng)建和傳輸消息,另兩個是協(xié)議通道,負責將消息頭附著在消息數(shù)據(jù)上。管理WCF通訊的狀態(tài)機可以使用異步或同步的方式調用通道的功能。每一個消息交換模式包含每一個調用類型。為了簡單起見,在這里只使用同步方式來實現(xiàn)。還有就是本例直接和通道棧進行交互。因此,在例子代碼中并沒有聲明契約。為了運行例子程序,我們需要***的SDK。
從上面的內容可知,本例實現(xiàn)了數(shù)據(jù)報信息交換模式。因此,通道需要實現(xiàn)IInputChannel接口,WCF學習筆記實例概述代碼如下:
- class TestTransportChannel :
- ChannelBase,IInputChannel { protected EndpointAddress localAddress;
- public TestTransportChannel(TestTransportChannelListener parent, EndpointAddress address) :
- base(parent) { ... ... this.localAddress = address; }
在IInputChannel中有兩個關鍵的方法,WaitForMessage和Receive方法。當一個消息出現(xiàn)時,WaitForMessage返回true。然后Receive獲得了這個消息。下面的使用其中一個協(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方法返回一個Message對象。Message對象將被傳遞到WCF的各個層。接下來,讓我們來看看ChannelListener的實現(xiàn)。