框架其實(shí)就是一種規(guī)范的流程，它可以讓我們的流程很清晰，代碼更規(guī)范。下面我們就來(lái)介紹一下WCF框架中發(fā)布-訂閱的實(shí)現(xiàn)流程。我并不只是提供了發(fā)布-訂閱服務(wù)以及客戶(hù)端的實(shí)例，而且還提供了一個(gè)通用的框架，能夠自動(dòng)實(shí)現(xiàn)發(fā)布-訂閱服務(wù)，以及增加對(duì)所有應(yīng)用程序的支持。若要構(gòu)建這樣的框架，首先需要分解管理發(fā)布-訂閱的接口，然后為臨時(shí)訂閱和持久訂閱以及發(fā)布提供單獨(dú)的契約。

#T#WCF框架閱者類(lèi)型

我們甚至可以定義兩種類(lèi)型的訂閱者：臨時(shí)訂閱者是在內(nèi)存中運(yùn)行的訂閱者；持久訂閱者則是持久化到磁盤(pán)的訂閱者，它們代表了服務(wù)對(duì)發(fā)生事件的調(diào)用時(shí)間。對(duì)于臨時(shí)訂閱者，可以使用雙向回調(diào)機(jī)制，通過(guò)它將回調(diào)引用傳遞到正在運(yùn)行的服務(wù)。持久訂閱者則需要將訂閱者地址當(dāng)作引用進(jìn)行記錄。當(dāng)事件發(fā)生時(shí)，發(fā)布服務(wù)會(huì)調(diào)用持久訂閱者的地址，然后將事件傳遞給它。兩種訂閱類(lèi)型還有另外一個(gè)顯著區(qū)別，就是我們可以將持久訂閱者存儲(chǔ)在磁盤(pán)或數(shù)據(jù)庫(kù)中。這樣就能夠在關(guān)閉應(yīng)用程序或機(jī)器崩潰或重啟的時(shí)候，持久化訂閱者。這一過(guò)程允許以管理方式對(duì)訂閱進(jìn)行配置。顯然，在關(guān)閉應(yīng)用程序時(shí)，我們不能存儲(chǔ)臨時(shí)訂閱，而需要在每次應(yīng)用程序啟動(dòng)時(shí)，明確地創(chuàng)建臨時(shí)訂閱。

WCF框架管理臨時(shí)訂閱

可以使用我定義的ISubscriptionService接口管理臨時(shí)訂閱，定義如例所示。例 管理臨時(shí)訂閱者的ISubscriptionService接口

[ServiceContract]   
public interface ISubscriptionService   
{   
[OperationContract]   
void Subscribe(string eventOperation);   
 
[OperationContract]   
void Unsubscribe(string eventOperation);   
}   

注意，ISubscriptionService接口無(wú)法識(shí)別實(shí)現(xiàn)了它所期待的終結(jié)點(diǎn)的回調(diào)契約。作為一個(gè)通用的接口，它與特定的回調(diào)契約無(wú)關(guān)。定義這些回調(diào)契約取決于如何使用應(yīng)用程序。通過(guò)繼承ISubscriptionService接口，可以在應(yīng)用程序中提供回調(diào)接口，并指定所需的回調(diào)契約：

interface IMyEvents   
{   
[OperationContract(IsOneWay = true)]   
void OnEvent1( );   
 
[OperationContract(IsOneWay = true)]   
void OnEvent2(int number);   
[OperationContract(IsOneWay = true)]   
void OnEvent3(int number,string text);   
}   
 
[ServiceContract(CallbackContract = typeof(IMyEvents))]   
interface IMySubscriptionService : ISubscriptionService   
{}