技术栈:Golang、MQTT、Flink、Kafka、Redis、PostgreSQL、Docker
负责工业物联网数据网关开发,对接现场 PLC、传感器等设备,实现设备实时数据采集、协议解析、数据清洗、上报入库。利用 Golang 高并发轻协程优势,单机稳定维持数万设备长连接;适配标准 MQTT 协议,完成设备上下线监听、心跳保活、异常重连机制。将结构化设备数据实时推送至 Kafka 消息队列,交由 Flink 进行实时计算与异常研判,最终落地到时序业务库。统一封装设备消息重试、去重、容错机制,解决工业数据抖动、断连、乱序问题。项目适配智能制造生产线,数据上报成功率 99.95%,为设备故障预警、能耗分析、智能运维提供稳定数据底座。