彭彭自用包：abler-messenger

基于REDIS实现的消息订阅/发布系统

安装

npm i abler-db
npm i abler-messenger

引用

const Messenger = require("abler-messenger");

const msgChannel = "my_app_name";
messenger = await RedisMessenger.create(appConfig, appErrCfg, msgChannel)
    .then(instance =>
	    instance.subscribe(msgChannel)
    );
...	
messenger.publish(message, msgChannel);
...

更新日志

1.1.0

node-redis 从v3升级到v5后，消息发布订阅系统API发生了巨大变化，为此重构了Messenger，增加了工厂方法来创建实例

引用

const Messenger = require("abler-messenger");

messenger = await RedisMessenger.create(appConfig, appErrCfg, msgChannel)
    .then(instance =>
	    instance.subscribe(msgChannel)
    );
...	
messenger.publish(message, msgChannel);
...

1.0.x

引用

const Messenger = require("abler-messenger");

messenger = new Messenger({conf})
	.setMessageHandle(messageHandle, msgChannel)
	.subscribe(msgChannel);
...	
messenger.publish(message, msgChannel);
...