1.1.1 • Published 4 years ago
@majexh/message-client-1149 v1.1.1
nodejs message SDK
安装
npm i --zmq-external # 有 libzmq 环境
npm i # 无 libzmq 环境
usage
const Client = require('@majexh/message-client-1149')
// config can be json or json file path
let client = new Client(config)
// it will register itself with center server and regularly send heartbeats message, it's async
client.start()
// when need to receive the message
// just listen to the `message` event
client.on('message', (array) => {
// consume the incoming message
const message = procedure()
// array[2] uid array[0] clientId
client.sendResult(array[2], array[0], message)
})
config definition
{
"instance": {},
"client": {
"maxRetry": 5,
"retryDelta": 0.1,
"timeout": 1000, // milliseconds
"hearbeatInterval": 5000 // milliseconds
}
}
- instance 字段必须包含
name
,instance字段会在运行时动态的添加status字段作为现在的状态 - client字段定义了一些简单时间约束,控制心跳包等的行为
- 在client中添加交互的uri,即message访问的地址,即添加brokerUrl
- 监听client的'message'消息,获取