thingsboard的规则引擎。项目启动怎么加载的？数据过来了，怎么运行的？相关代码入口分别在哪里？

ThingsBoard的规则引擎是通过一个独立的进程运行的，并且与主服务器相分离。在项目启动过程中，规则引擎会自动加载并开始运行。数据进入到规则引擎的处理流程如下：数据接入：数据通过消息代理或其他数据接入端点进入ThingsBoard。数据解析：数据经过解析模块的处理，以便将其转换为规则引擎能够理解的格式。规则链匹配：解析后的数据将被传递给规则链进行匹配，规则链是按优先级排序的规则的集合。规则评估

在thingsboard项目中org.thingsboard.server.gen.transport.xx相关的类在哪里?

org.thingsboard.server.gen.transport.TransportProtos.CredentialsDataProto这个类在thingsboard项目中哪里？org.thingsboard.server.gen.transport.TransportProtos.CredentialsDataProto是一个自动生成的Protobuf类，它是在Thingsboard项

Actor 模型入门与Akka-SpringBoot集成

在当今的数据处理和数据流水线系统中，将数据从源流传输到接收器是一项非常琐碎的任务。因此，有许多[流媒体]解决方案，例如：KafkaStream，SparkStreaming，ApacheFlink等。Akka流在这场战斗中脱颖而出，并具有完全由应用程序驱动的优势。Akka流是在Akka著名的Actor模型(实际上是受Erlang的actor模型启发)的基础上构建的。因此，Akka流可以利用其经过战

Actors模型与Akka介绍

任何在过去做过多线程开发的人都不会否认维护多线程应用程序是多么难和头疼的一件事！我这里说的是维护，因为多线程开发开始的时候很简单，当你看到性能的提升对你来说是件多么高兴的一件事。然而，当你看到在子任务中很难找到容易的方法来从错误中恢复；或者是存在僵尸进程的bug很难重现；或者你的监控程序显示你的线程浪费大量的时间来等待共享状态而阻塞的时候对你来说是多么头疼！什么是ACTORAkkaActors遵循

Actors模型与Akka介绍

任何在过去做过多线程开发的人都不会否认维护多线程应用程序是多么难和头疼的一件事！我这里说的是维护，因为多线程开发开始的时候很简单，当你看到性能的提升对你来说是件多么高兴的一件事。然而，当你看到在子任务中很难找到容易的方法来从错误中恢复；或者是存在僵尸进程的bug很难重现；或者你的监控程序显示你的线程浪费大量的时间来等待共享状态而阻塞的时候对你来说是多么头疼！什么是ACTORAkkaActors遵循

ThingsBoard二次开发之源码分析1- 基础知识

预备知识JDK1.8注解ProtobufGuavaJDK1.8Lambda表达式方法引用方法引用的唯一用途是支持Lambda表达式的简写，调用方法的时候使用::，对于一些单个参数，可以自动推断；ConsumerConsumer的作用是给定义一个参数,对其进行(消费)处理,处理的方式可以是任意操作，无返回值；Predicate断言接口，根据传入的Lambda表达式返回boolean;Supplier

thingsboard actor消息处理流程

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

Thingsboard3.4-OTA升级

背景在做设备端对接thingsboard平台得时候，去研究设备端对接平台的过程中，花了不少时间，在此之前也没有找到相关的文档，于是出于减少大家去研究的时间，写了这篇博客，希望大家能够点赞和收藏。注意：OTA功能是从3.3版本才开始支持的。参考英文文档地址：https://thingsboard.io/docs/user-guide/ota-updates/1.设备事先订阅这些topic主题v1/d

Thingsboard使用gateway网关

简介：本次是想测试一下thingsboard网关的使用，实现通过网关+mqtt+thingsboard+emqx实现间接设备创建和数据传输前期准备：thingsboard平台thingsboard网关emqx平台MQTTX工具详细过程：1：thingsboard平台搭建关于thingsboard平台搭建这里就不多介绍了，主要是编译难，这个之前可以看我发布的文章，所以直接跳过。2：创建网关设备打开t

ThingsBoard源码解析-数据订阅与规则链数据处理

前言结合本篇对规则链的执行过程进行探讨根据之前对MQTT源码的学习，我们由消息的处理入手//org.thingsboard.server.transport.mqtt.MqttTransportHandler void processRegularSessionMsg(ChannelHandlerContext ctx, MqttMessage m