文件名称：pubsub:发布者-订阅者系统使用 RMI 和异步通信在分布式系统中传递消息
文件大小：26KB
文件格式：ZIP
更新时间：2024-07-27 16:51:41
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)