WCF中的发布-订阅服务

中国IT实验室收集整理

佚名

2008-2-21

保存本文

推荐给好友

收藏本页

欢迎进入.NET社区论坛，与200万技术人员互动交流 >>进入

订阅者类型

   我们甚至可以定义两种类型的订阅者：临时订阅者是在内存中运行的订阅者；持久订阅者则是持久化到磁盘的订阅者，它们代表了服务对发生事件的调用时间。对于临时订阅者，可以使用双向回调机制，通过它将回调引用传递到正在运行的服务。持久订阅者则需要将订阅者地址当作引用进行记录。当事件发生时，发布服务会调用持久订阅者的地址，然后将事件传递给它。两种订阅类型还有另外一个显著区别，就是我们可以将持久订阅者存储在磁盘或数据库中。这样就能够在关闭应用程序或机器崩溃或重启的时候，持久化订阅者。这一过程允许以管理方式对订阅进行配置。显然，在关闭应用程序时，我们不能存储临时订阅，而需要在每次应用程序启动时，明确地创建临时订阅。

发布-订阅框架

    本书附带的源代码中包含了完整的发布-订阅实例。我并不只是提供了发布-订阅服务以及客户端的实例，而且还提供了一个通用的框架，能够自动实现发布-订阅服务，以及增加对所有应用程序的支持。若要构建这样的框架，首先需要分解管理发布-订阅的接口，然后为临时订阅和持久订阅以及发布提供单独的契约。

管理临时订阅

   可以使用我定义的ISubscriptionService接口管理临时订阅，定义如例B-1所示。

   例B-1 管理临时订阅者的ISubscriptionService接口


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

[OperationContract] 
void Unsubscribe(string eventOperation); 
}

注意，ISubscriptionService接口无法识别实现了它所期待的终结点的回调契约。作为一个通用的接口，它与特定的回调契约无关。定义这些回调契约取决于如何使用应用程序。通过继承ISubscriptionService接口，可以在应用程序中提供回调接口，并指定所需的回调契约：

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 
{}