规则引擎
2020-12-22 15:02:31 0 举报
AI智能生成
ThingsBoard规则引擎
作者其他创作
大纲/内容
DefaultActorService
@PostConstruct
创建DefaultTbActorSystem
创建AppActor
@EventListener(ApplicationReadyEvent.class)
appActor发布AppInitMsg消息
调用appActor的doProcess方法,initTenantActors()
查询所有tenant,创建TenantActor
调用TenantActor的init()初始化actor
initRuleChains()方法创建RuleChainActor
创建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 条评论
回复 删除
下一页