Rocket.Chat接收消息流程

Rocket的消息接收分两类：

一个是通过Rocket节点之间直连进行消息收发，消息本身不持久化，比如typing事件消息；

另一个是通过MongoDB的oplog tailing机制进行触发，这类消息会持久化，比如普通文本消息；

下面梳理一下oplog tailing机制触发的基本流程和调用关系：

,1，在这个文件中meteor:\\?app\packages\mongo\oplog_tailing.js，如果MongoDB有数据变动，包括增删改查会触发回调通知

originalCallback(notification);      

2，_BaseDb.js      

调用processOplogRecord(action)函数；      

3，D:\Rocket\Rocket.Chat-1.2.1\server\stream\messages.js      

Messages.on('change', function({ clientAction, id, data/* , oplog*/ })      

4,

function publishMessage(type, record)       

5,msgStream.emitWithoutBroadcast(record.rid, record);
根据订阅关系发送消息