TB-MQTT消息遥测数据消费和规则引擎处理逻辑
2021-02-03 15:19:37 0 举报mqtt遥测消息在消息队列中的消费以及流经规则引擎->规则节点和存储到数据库中的过程
作者其他创作
大纲/内容
TbQueueConsumer
规则链流经规则节点pushMsgToNode
从消息队列中拉取消息List<T> poll(long durationInMillis)
TbNode
保存遥测数据并通知和回调saveAndNotify
遥测数据消息处理节点void onMsg(）
处理转发消息doProcess(TbActorMsg msg)
RuleChainActor
TbMsgTimeseriesNode
转发给规则引擎Actor处理forwardToRuleEngineActor
接受并处理消息
RuleChainActorMessageProcessor
不断消费消息队列中的消息launchConsumer
RuleEngineTelemetryService
RuleNodeActorMessageProcessor
规则链路到规则节点处理器onRuleChainToRuleNodeMsg
队列中到规则引擎过渡消息处理onQueueToRuleEngineMsg
消息处理适配器void onMsg(）
DefaultTbRuleEngineConsumerService
0 条评论
下一页
