煤炭工程 ›› 2026, Vol. 58 ›› Issue (7): 145-151.doi: 10.11799/ce202607018
唐 博,西成峰,王 辉,吴早阳
摘要:
针对煤矿智能化开采中多源数据传输实时性差、断点续传机制缺失等问题,提出一种基于消息队列的分布式数据协同传输与存储方案。通过构建Kafka与RabbitMQ混合消息队列架构,实现数据发送与接收解耦,结合事件驱动非阻塞I/O模型与多路复用机制提升并发传输能力,并设计智能断点续传模块保障数据完整性。方案整体架构包含数据源、集控采集、数据传输和数据监测平台四层,通过OPC UA等工业协议统一采集设备数据,经加密处理后分发至Kafka主题,利用ClickHouse分布式集群实现PB级数据存储。试验数据表明,该方案在十余个典型工作面应用中,单月累计采集数据超10亿条且无丢失,数据传输延迟缩短至秒级,较传统方法效率提升显著,为煤矿集团矿群数据管控提供了可靠的技术支撑。
中图分类号: