工作小总结&小工具类 Redis AI相关 MQTT Maven mybatis ChatGPT uniapp zookeeper Thymeleaf语法 POI-TL sa-token PowerDesigner16.5 taos数据库 frp echarts Actor模型及Akka thingsboard 大疆无人机对接 CI/CD 教师资格证小任务面试其他职场淘宝客支付宝支付 HBuilder X Flink Java集合类多线程 ES Ribbon eureka Docker java游戏网络通信 Nacos 芋道管理系统 Solr 分布式相关 Dubbo 数据结构 EasyPOI Drools RocketMQ JS 七天深入MySQL实战营书籍 kafka spring Java基础 java web 若依(ruoyi) 分布式事务面试宝典 mysql java8新特性 spring cloud ElasticSearch学习系列 HM_leadnews 即时通讯并发思维&学习 VUE 宝塔面板算法刷题设计模式 RabbitMQ学习系列教程 P3C规范 JVM学习系列反射自定义注解网络美文 PHP源码经验分享资源 git项目 websocket 网赚数据库读写分离测试相关其他随笔 shiro学习系列 fremarker学习系列学习笔录-spring boot 网络文章工作小总结

简介 Actor模型在异步处理中使用广泛，尤其是scala语言中actor框架的使用。本篇主要介绍thingsboard中其自主实现的actor模型，及在数据传输中的使用。

🔔🔔🔔好消息!好消息!🔔🔔🔔

有需要的朋友👉:联系凯哥微信号 kaigejava2022

Actor由状态(state)、行为(Behavior)和邮箱(mailBox)三部分组成

通过测试类来跟踪源码，是学习源码非常有效的方式。我们也从测试类ActorSystemTest开始跟踪actor实现的过程。首先运行测试方法test1actorsAnd100KMessages()，体验一下actor模型处理的速度。

模型本身用到的类比较少，下面对每个类的的功能做一个描述：

与经典的Actor模型对应关系为：

如下图所示，tb针对不同场景实现了不同的actor对象，actor对象里通过processor来处理业务逻辑。

注：idea默认快捷键(Ctrl+H)可显示抽象类或接口的所有实现子类

DefaultTbRuleEngineConsumerService在消费队列时，如果存在actorMsg，就执行ActorSystemContext.tellWithHighPriority()处理。执行流程如图：

下面分析一下AbstractConsumerService类，其在spring初始化完成后会启动线程来消费actor的队列数据，具体的实现在rule-engine中分析。

tb是使用actor模型处理接收到的message，有效的隔离了消息的接收和处理过程。并且actor对消息处理的过程进行了隔离，不用考虑资源的并发处理问题。Mailbox中的actor对象处理消息的速度是非常快的，处理完后直接tell给下游childActor。