一种基于TDengine的时序消息队列系统及方法

本发明涉及物联网与大数据技术领域，具体是一种基于TDengine的时序消息队列系统及方法，所述系统采用分布式架构，包含消息生产者、基于TDengine的消息存储层（设超级表‑子表结构，超级表对应队列、子表存消息）、消息消费者及管理监控模块；消息以批量方式写入存储，消费者每100ms轮询拉取待消费消息，处理后更新状态，通过写入确认、读取确认及msg_id保障数据一致性，其峰值写入速率达3万条/秒，单节点CPU峰值52%，消费积压<0.2秒，解决现有系统性能瓶颈、存储扩展性不足及时序优化缺失问题，满足大规模实时时序数据处理需求。