文件名称:Publish-Subscribe-demo:学院项目
文件大小:4KB
文件格式:ZIP
更新时间:2024-07-23 12:03:21
Java
发布订阅服务
这是用于流式数据的发布-订阅服务的简单实现。 所有数据都是在发布时生成的随机浮点数。 主类EventBus实现以下功能:
subscribe < s> - 将与此消息关联的订阅者注册为流s的订阅者;
unsubscribe - 从流s的订阅者列表中删除与此消息关联的订阅者;
list - 向与消息关联的订阅者发送可用于订阅的流的完整列表;
publish - 将与消息关联的 IP/Socket 注册为流s的发布者;
unpublish < s> - 删除与作为流s发布者的消息关联的 IP/Socket;
转发- 发布到此 IP/套接字是其发布者的所有流,并将数据发送给订阅者。
forward < s> - 将数据发布到流s并将数据发送到订阅者..
【文件预览】:
Publish-Subscribe-demo-master
----Publisher.java(4KB)
----EventBus.java(11KB)
----README.md(1KB)