使用Publish/Subscribe 设计模式达到对象间数据同步
2024-07-21 02:25:38
供稿:网友
使用publish/subscribe 设计模式达到对象间数据同步
应用程序经常需要更改和交换数据,必须传送这些更改后数据以达到对象的同步,尤其在多窗口用户界面应用程序中更要求这种数据的同步协调,在这一类应用程序中,潜在的数据更新信息一定要反映到所有被包含的子窗体中。
例如一个人员信息管理的应用程序。一次可以打开多个包含一个人名字的窗口,如果你在其中一个窗口中修改并报存了这个人的名字,你将期望对名字改变应立即显示在其它全部窗体内。可以通过使用publish/subscribe设计模式来完成这种功能。这种设计模式是observer 模式(见图一)的一种变体。observer 模式在design patterns, elements of reusable object oriented software书中有很详细的描述,在observer 模式中,一个对象(observer观察者)被注册到另一对象(主体subject),用于监听事件。观察者(observer)暗中地反映(主体subject)的变化。
图一
publish/subscribe模式(参见图二),在主体(subject)和观察者(observer)之间增加了一层间隔。 这个层移除了在观察者(observer)和主体(subject)之间的捆绑并且在这两之间建立一种松耦合的关系。 event channel 可以被描述成一个数据中心。
图二
publisher (就是在观察者(observer)模式中的主体(subject)) 向这个event channel.发布事件。event channel 的责任就是向所有的subscribers (就是在观察者(observer)模式中的观察者(observer))散布事件。一个应用程序可以包含一个或多个event channel,所以,要向每个感兴趣的subscribers来散布不同的事件。此外,在观察者(observer)模式中事件仅仅来自特殊的来源,在publish/subscribe模式中任何注意event channel的对象都可以发布事件。
这个构造移除了观察者(observer) and主体(subject)之间的依赖。结果是你可以为你的应用程序增加更多的通用设计,此外,通过要求在publisher和subscriber之间的没有直接的关系,它大大增加你的应用程序的可维护性。
使用publish/subscribe模式
通过一个简单的例子来学习publish/subscribe模式是如何实现的。eventapp. eventapp是一个拥有一个mdi窗体和很多子窗体的应用环境。(下载本文代码).
在你的程序中,你将需要创造一系列的基类来实现publish/subscribe模式。 在工程里的其他类都从这些基类派生而来(见图三)。 eventapp 应用程序有如下3 个基类:
图三
clseventchannel ----------------------为构建event channels的一个抽象类。
clsevent --------------------------为构建事件的类型使用的一个抽象类。 它暴露了4个属性:
name: 事件的名字
value: 事件的价值
extradata: 被关联那些事件的其它数据
origin: 可选择的参考鉴定事件的 publisher
frmsubscriber – 用于创建窗口、接收事件的一个抽象windows form
为了使一应用工作,你需要建立从那些基类继承的几个具体的类。 在这个例子当中,这些类是:
clsdataevents - 从clseventchannel类继承的一个具体的类。 在应用程序中,将它作为event channel来使用,它被用来向那些潜在的数据模型散布更新的信息。
clsdataevent - 从clsevent类继承并且用来创建事件,呈现潜在数据的更新的一个具体的类。 ( 要创建一个继承窗体,你可以在解决方案资源管理器中选择" 添加(add)-> 添加继承的窗体(inherited windows form)" 的快捷菜单 。
frmlist – 派生自frmsubscriber类的一个具体的类。它是mdi窗体的一个子窗体,用于显示数据列表。在这个例子中,这个窗体通过硬编码用一个listview控件显示了10条数据。
eventapp 如何工作
当eventapp 被启动时, frmmain( mdi 父窗体) 创造一个数据event channel实例-----clsdataevents:
private sub frmmain_load(byval sender as object, _
byval e as system.eventargs) handles mybase.load
mobjdataeventchannel = new clsdataevents()
me.ismdicontainer = true
me.text = "publish/subscribe event sample"
me.windowstate = formwindowstate.maximized
end sub
当mdi窗体被运行时,你可以在菜单中选择"file->new list"来创建一个frmlist类的实例。
private sub menuitem2_click(byval sender as _
system.object, byval e as system.eventargs) _
handles menuitem2.click
dim objnewform as frmlist
objnewform = new frmlist()
mobjdataeventchannel.attachsubscriber(objnewform)
objnewform.mdiparent = me
objnewform.show()
end sub
当创建了子窗体以后,它将被注册到event channel,在注册过程期间,event channel将要初始化subscriber。
public overridable sub initialize(byval token as _
string, byval eventchannel as clseventchannel)
mstrtoken = token
mobjeventchannel = eventchannel
end sub
注册会员,创建你的web开发资料库,