物联网与车联网数据接入平台产品系统

面向定位、车辆、消杀、净化、环卫等设备的数据接入与运维平台，支持MQTT、HTTP、TCP/Netty等多协议接入，结
合Kafka、线程池、Redis、ClickHouse等组件处理高频设备上报、指令下发、告警规则、轨迹查询和运行看板。

基于Spring IntegrationMQTT搭建设备接入链路，实现生产/消费通道分离、QoS配置；用ReentrantLock保证动态Topic订阅/
移除的并发安全，ConcurrentHashMap维护Topic与设备映射，支持设备上线自动订阅、下线自动移除，并通过MqttGateway下
发指令。
·使用Redissetnx对MQTT接收消息做短时去重（TTL内幂等），避免重复消息触发重复处理；按设备编号维护协议映射，支持快速
定位设备连接信息与协议类型。
·以策略模式（MqttTopicStrategy接口+枚举路由）适配多厂商设备的Topic格式、消息解析和指令格式，新增厂商只需实现策略
·解析设备上报的定位、状态、传感器、耗材、告警、心跳等数据，按厂商/型号/设备号动态创建ClickHouseMergeTree表并写
入，支撑历史轨迹、运行状态和告警趋势查询。
·负责设备档案、设备类型、网络协议、空间区域、设备模板、耗材管理、导入导出、消杀/维修工单、规则参数模板、告警记录等
后台能力。
·实现设备告警规则处理，命中阈值后通过线程池异步发送告警、生成告警记录/自动工单，并通过WebSocket推送大屏告警。
·针对车联网早高峰车辆上报量过大、下游接口处理能力不足导致丢数据的问题，参与Kafka削峰缓冲与线程池异步消费方案，提
升吞吐与稳定性。

基于Spring IntegrationMQTT搭建设备接入链路，实现生产/消费通道分离、QoS配置；用ReentrantLock保证动态Topic订阅/
移除的并发安全，ConcurrentHashMap维护Topic与设备映射，支持设备上线自动订阅、下线自动移除，并通过MqttGateway下
发指令。
·使用Redissetnx对MQTT接收消息做短时去重（TTL内幂等），避免重复消息触发重复处理；按设备编号维护协议映射，支持快速
定位设备连接信息与协议类型。
·以策略模式（MqttTopicStrategy接口+枚举路由）适配多厂商设备的Topic格式、消息解析和指令格式，新增厂商只需实现策略
·解析设备上报的定位、状态、传感器、耗材、告警、心跳等数据，按厂商/型号/设备号动态创建ClickHouseMergeTree表并写
入，支撑历史轨迹、运行状态和告警趋势查询。
·负责设备档案、设备类型、网络协议、空间区域、设备模板、耗材管理、导入导出、消杀/维修工单、规则参数模板、告警记录等
后台能力。
·实现设备告警规则处理，命中阈值后通过线程池异步发送告警、生成告警记录/自动工单，并通过WebSocket推送大屏告警。
·针对车联网早高峰车辆上报量过大、下游接口处理能力不足导致丢数据的问题，参与Kafka削峰缓冲与线程池异步消费方案，提
升吞吐与稳定性。