STOMP
可以通过STOMP
协议访问WeEvent
的发布订阅相关功能。
- 支持STOMP协议的
1.1
、1.2
版本。暂时不支持消息确认ACK
和事务Transaction
语义。 - 传输协议方面,同时支持
STOMP Over WebSocket
和STOMP Over SockJS
。
前端面直接访问WeEvent
,推荐使用开源库stompjs,该库支持STOMP协议的1.1
、的版本。使用stompjs
+sockjs
的组合效果更好。
加入Spring Boot
的依赖,以gradle
为例:
第一步:创建链接
心跳说明
WeEvent
使用单向心跳机制,客户端发送心跳,服务端不发心跳。默认时间间隔为30s
。修改心跳方案。
- 传输协议方面
STOMP Over WebSocket
使用ws://localhost:8080/weevent/stomp
STOMP Over SockJS
使用ws://localhost:8080/weevent/sockjs
第二步:发布事件
说明:
- 为
com.weevent.test
。用户可以获取到Receiptable
,并且通过receiptable.getReceiptId()
,可以获取相应的回执。 weevent-format
为用户自定义拓展默认以weevent-
开头。可选参数。第三步:订阅事件
说明:
topic
订阅的主题。支持通配符按层次订阅,参见 。- 配置
eventId
,如需要取历史数据,则需要设置。如果不设置,则默认为取最新内容。 weevent-format
为用户自定义拓展默认以weevent-
开头。可选参数。StompFrameHandler
,对StompFrame
和StompHeaders
进行处理的方法。上述样例完整的代码,请参见STOMP代码样例 。
- 依赖说明