介绍基于Pub/Sub模式的Demo实现。功能很简单:
从消息发布端Pub发布一个消息事件OrderCompletedEvent,多个客户端(如SubA和SubB)订阅该事件OrderCompletedEvent。那么当Pub发布消息后,SubA和SubB就能够收到该消息OrderCompletedEvent。
SubA和SubB接收到消息后,根据需要进行一定的处理。然后他们都会发布一个WorkDoneEvent事件消息。这次服务端订阅WorkDoneEvent消息。当SubA和SubB发布WorkDo...
分类:
其他好文 时间:
2014-09-28 18:01:34
阅读次数:
200
参考资料
http://faye.jcoglan.com/
Faye is a publish-subscribe messaging system based on the Bayeux protocol/CometD. It provides message servers for Node.js and Ruby, and clients for use on...
分类:
Web程序 时间:
2014-09-23 12:12:24
阅读次数:
192
项目整体结构是这样的:
通过一些设备,实时检测各种类型的数据,新的数据以消息的形式通过Shuttle ESB传输。
Shuttle 服务器接收到消息,它会按照需求要求,对数据进行一定的加工处理,然后将消息注册到消息管理器(注意:这里的消息管理器,就是观察者中的主题)。而每一个显示终端就是一个观察者,当消息注册到消息管理器时,显示终端就会自动更新最新消息,然后在根据要求,进行显示。...
分类:
其他好文 时间:
2014-09-05 14:26:31
阅读次数:
315
今天在浏览JavaScript事件时,复习了下Dean Edward大神的addEvent。突然觉得可以基于他的思路实现一个结构更好的PubSub。 思路也很简单,就是要维护一个类似如下的一个仓库结构: /*{ 'sayHello': { 0: fn0, 1: fn1, //... }, 'sayG...
分类:
其他好文 时间:
2014-07-22 22:51:35
阅读次数:
214