pubsub:发布者-订阅者系统使用 RMI 和异步通信在分布式系统中传递消息

时间:2021-07-07 23:05:01
【文件属性】:
文件名称:pubsub:发布者-订阅者系统使用 RMI 和异步通信在分布式系统中传递消息
文件大小:26KB
文件格式:ZIP
更新时间:2021-07-07 23:05:01
Java 发布订阅 发布者-订阅者系统使用 RMI 和异步通信在分布式系统中传递消息。 这是使用 Java 远程方法调用 (RMI) 的分布式发布者-订阅者系统的实现。 它使用多线程和 thread-per-request 并且不会阻塞发送或接收。 服务器和客户端都有一个命令行界面,用于发布事件、广告事件、订阅主题或关键字以及查看过去收到的事件。 系统支持基于主题和基于内容的事件过滤,其中内容过滤基于关键字参数。 它们的关键字可以由 Topic 定义,也可以由 Event 定义,如果此关键字与客户端的订阅关键字匹配,则客户端将收到消息。 使用 PubSub 系统,还有一个股票市场的小型实现,买家和卖家通过 Pub-Sub 相互交流,然后使用 RMI 来完成买卖。 要运行 PubSub 程序,请先提取源文件,然后打开 shell 并键入: $ rmiregistry [port] & //por
【文件预览】:
pubsub-master
----EventServer.java(3KB)
----PubSubAgent.java(18KB)
----Topic.java(2KB)
----EventManager.java(11KB)
----topics.dat(201B)
----TopicContainer.java(4KB)
----Event.java(4KB)
----PubSubClient.java(4KB)
----stockmarket()
--------Buyer.java(6KB)
--------StockMarketManager.java(2KB)
--------Seller.java(6KB)
----README(1KB)
----interfaces()
--------Publisher.java(816B)
--------BuySell.java(652B)
--------Subscriber.java(2KB)
--------EventManInterface.java(4KB)
----.gitignore(637B)
----README.md(2KB)
----.gitattributes(483B)

网友评论