NSP消息订阅系统

目前该系统主要实现业务：

​ http 发送数据，websocket 订阅数据

websocket默认连接地址：

ws://127.0.0.1:8091/ws

http默认路径地址：

127.0.0.1:8090

​

websocket订阅

一、订阅主题：

发送格式json

{"type":"subscribe","topic":"topic to sub"}

订阅成功客户端将收到：

{"code":200,"tytp":"subscribe","topic":"eth_usdt","ts":1590821941}

code:200表示订阅成功 ，topic 表示订阅的主题 ， ts 时间戳

二、取消订阅主题：

发送数据：

{"type":"unsubscribe","topic":"eth_usdt"}

取消成功客户端收到

{"code":200,"tytp":"unsubscribe","topic":"eth_usdt","ts":1590822173}

三、心跳

每个隔一段时间服务器会像客户端发送心跳，客户端将收到心跳消息

{"type":"ping"}

当客户端收到心跳消息时，客户端必须给微服务端发送消息消息，否则服务器会服务器会默认为客户端已经断开连接，服务端将把该客户端剔除；回复消息如下：

{"type":"pong"}

Http向主题发送消息

POST: 127.0.0.1:8090/api/send

参数：

字段	类型	必须	备注
topic	string	是	主题
data	sting	是	发送数据必须是json字符串

发送成功：

{
    "code": 201,
    "msg": "发送成功",
    "ts": 1590823053,
    "data": null
}

错误响应：

{
    "code": 201,
    "msg": "unexpected end of JSON input",
    "ts": 0,
    "data": null
}

后期将继续跟新；有问题请留言: [email protected]