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
  }
}

1. instance 字段必须包含name，instance字段会在运行时动态的添加status字段作为现在的状态
2. client字段定义了一些简单时间约束，控制心跳包等的行为
3. 在client中添加交互的uri，即message访问的地址，即添加brokerUrl
4. 监听client的'message'消息，获取