#Angler
功能说明:
使用Angler进行消息队列获取消息后的数据的处理
##数据库配置
dbs.mongoDB({
default: 'mongodb://localhost:27017/test',
session: 'mongodb://localhost:27017/session',
watcher: 'mongodb://localhost:27017/watcher',
},
require('./tables')
);
##Angler配置 Angler说明:
const angler = new Angler({
source: new WebSocket(8080),
protocol: JsonProtocol
});
//增加过滤器
angler.filter(require('../angler/filters/permissions/index'));
//增加消息
angler.event(require('../angler/events/mongo/index'));
angler.event(require('../angler/events/watcher/index'));
angler.event(require('./events/user/index'));
angler.event(remoting);
//开始运行
angler.start();
filter 过滤器
过滤器用于对消息的过滤,符合规则的消息可被event处理器执行。
event 事件说明
事件处理器,用于事件处理
#Event