STOMP

    可以通过STOMP协议访问WeEvent的发布订阅相关功能。

    • 支持STOMP协议的1.11.2版本。暂时不支持消息确认ACK和事务Transaction语义。
    • 传输协议方面,同时支持STOMP Over WebSocketSTOMP Over SockJS

    前端面直接访问WeEvent,推荐使用开源库stompjs,该库支持STOMP协议的1.1、的版本。使用stompjs +sockjs的组合效果更好。

    加入Spring Boot的依赖,以gradle 为例:

    第一步:创建链接

    • 心跳说明WeEvent使用单向心跳机制,客户端发送心跳,服务端不发心跳。默认时间间隔为30s

    • 修改心跳方案。

    • 传输协议方面STOMP Over WebSocket使用ws://localhost:8080/weevent/stompSTOMP Over SockJS使用ws://localhost:8080/weevent/sockjs

    第二步:发布事件

    说明:

    • com.weevent.test。用户可以获取到Receiptable,并且通过receiptable.getReceiptId(),可以获取相应的回执。
    • weevent-format为用户自定义拓展默认以weevent-开头。可选参数。第三步:订阅事件

    说明:

    • topic 订阅的主题。支持通配符按层次订阅,参见 。
    • 配置eventId,如需要取历史数据,则需要设置。如果不设置,则默认为取最新内容。
    • weevent-format为用户自定义拓展默认以weevent-开头。可选参数。
    • StompFrameHandler ,对StompFrameStompHeaders进行处理的方法。上述样例完整的代码,请参见STOMP代码样例
    • 依赖说明