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

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