@pjblog/message v1.0.4

@pjblog/message

消息通讯模块，适用于部分RPC或IPC类型通讯，比如进程通讯或者Webosocket,ws通讯，都能很好支持。 但不支持类似需要拆包的通讯协议，类似dubbo等等。 它的作用就是简单地定义通讯规范，通过request方法或者notify方法来发送通讯数据并且得到返回结果。

Installer

$ npm i @pjblog/message

Example

import { ProcessClusterMessage, Message } from '@pjblog/message';
const msg = new ProcessClusterMessage();
msg.resolve((data, attachment) => {
  // receive message and resolve it
  // return any results for sending back
})

msg.request({
  a: 1
}).then(...)

msg.on(Message.EVENT_READ, data => {
  // ... read some data
})

msg.on(Message.EVENT_WRITE, data => {
  // ... write some data
})