ThingsBoard源码解析-消息队列

概述

消息队列是thingsboard支持集群的基础，比如使用Kafka可实现消息在整个服务集群中共同处理，提高性能。如果是内存队列，则无法再服务实例间共享消息。

定义

在module【common/cluster-api】的org.thingsboard.server.queue包定义了消息队列，其中接口

TbQueueProducer定义了生产者，实现类有：

接口TbQueueConsumer定义了消费者，实现类有：