规则引擎
2020-12-22 15:02:31 0 举报AI智能生成
ThingsBoard规则引擎
作者其他创作
大纲/内容
@PostConstruct
创建DefaultTbActorSystem
创建AppActor
@EventListener(ApplicationReadyEvent.class)
appActor发布AppInitMsg消息
调用appActor的doProcess方法，initTenantActors()
查询所有tenant，创建TenantActor
调用TenantActor的init()初始化actor
initRuleChains()方法创建RuleChainActor
调用RuleChainActor的init()方法，实现类是父类ComponentActor的init()方法，再调用RuleChainActor的实现方法createProcessor()创建RuleChainActorMessageProcessor,调用RuleChainActorMessageProcessor的start()方法
创建RuleNodeActor
调用RuleNodeActor的init()方法，再调用RuleNodeActot的实现方法createProcessor()创建RuleNodeActorMessageProcessor，调用RuleNodeActorMessageProcessor的start()方法
根据RuleNode的反射创建RuleNode的type的类，反射创建的类调用init()方法初始化
@EventListener(PartitionChangeEvent.class)
appActor发布的PARTITION_CHANGE_MSG消息
将消息转给TenantActor，调用doProcess()方法
TB_RULE_ENGINE的消息
分发给RuleChainActor
分发给RuleNodeActot
TB_CORE的消息
找出系统中的deviceActor，调用stop()方法移除
0 条评论
下一页
