发布订阅发布者-订阅者系统使用RMI和异步通信在分布式系统中传递消息。这是使用Java远程方法调用(RMI)的分布式发布者-订阅者系统的实现。它使用多线程和thread-per-request并且不会阻塞发送或接收。服务器和客户端都有一个命令行界面,用于发布事件、广告事件、订阅主题或关键字以及查看过去收到的事件。系统支持基于主题和基于内容的事件过滤,其中内容过滤基于关键字参数。它们的关键字可以由Topic定义,也可以由Event定义,如果此关键字与客户端的订阅关键字匹配,则客户端将收到消息。使用PubSub系统,还有一个股票市场的小型实现,买家和卖家通过Pub-Sub相互交流,然后使用RMI来完成买卖。
暂无评论