冷链监控服务负责对冷藏车、冷库的温度与湿度进行持续采集，并在异常时触发告警。将这类服务容器化，不只是把程序塞进镜像，而是利用容器隔离、可移植和资源受限的特性，让监控代理能在嵌入式网关、云服务器、IDC机器上以一致方式运行。本文从架构设计、数据采集上报、可观测性三个方面说明具体做法。
一、容器化冷链监控的整体架构设计
一个典型的冷链监控系统由边缘采集端、消息中转层、存储与展示层组成。边缘端通常部署在厂区工控机或车载终端，负责读取串口或蓝牙温湿度传感器。如果直接用物理机部署，每次换设备都要重装运行库，而采用容器后，只需在终端安装好容器引擎，剩下的交给镜像。我们一般把一个采集进程、一个本地缓存组件打进同一个pod或同一台宿主的两个容器，通过共享卷交换数据。
在架构上建议把「协议解析」与「网络上报」拆开。协议解析容器只干脏活：把二进制传感器帧转成JSON。网络上报容器订阅本地MQTT，再转发到中心Broker。这样当中心网络中断时，上报容器崩溃重启不会影响解析，避免重复造连接。资源限制也要写进部署描述，比如给解析容器设200兆内存上限，防止个别坏传感器导致死循环吃光内存。
另外镜像体积要小。用多阶段构建，第一阶段用带编译器的镜像生成二进制，第二阶段只复制二进制到alpine基础镜像。这样最终镜像常能控制在15兆以内，对带宽只有几十K的上车环境很关键。下表列出两种交付方式差异：
| 维度 | 裸机部署 | 容器化部署 |
|---|---|---|
| 环境一致性 | 依赖系统库版本 | 镜像内固定 |
| 扩容速度 | 小时级 | 秒级 |
| 回滚 | 手动备份替换 | 改镜像标签即可 |
二、基于MQTT与本地缓存的数据上报实践
冷链场景网络常不稳定，直接HTTP推中心数据库容易丢点。我们选用MQTT这种轻量发布订阅协议，边缘端连本地Broker（如mosquitto），再由桥接节点转发公网。采集程序每秒发一条telemetry/temp主题消息，QoS设为1，保证至少送达一次。下面是用Python写的最小发布例子：
import paho.mqtt.client as mqtt
import json
import time
client = mqtt.Client(client_id="edge-01")
client.connect("127.0.0.1", 1883, 60)
client.loop_start()
while True:
# 模拟从传感器读取
payload = json.dumps({"temp": -18.3, "hum": 75})
# QoS=1 确保 broker 收到
client.publish("telemetry/temp", payload, qos=1)
time.sleep(1)
但本地Broker也可能挂。我们在上报容器里加一个磁盘队列：发布失败就追加到/var/lib/cache/unsent.log，网络恢复后按行重发。这样即便车载终端进隧道半小时，出隧道也能补传，监控曲线不会断档。注意文件要按天滚动，避免单文件过大拖慢读取。
对于中心侧，不要用单台Broker硬抗所有车。按区域分片，每个分片前面挂LVS，Broker集群用桥接互联。容器编排里用StatefulSet管理有状态Broker，配合PVC存消息落盘。曾经有项目为省事用无状态Deployment跑MQTT，结果Pod重建消息全丢，告警延迟了四十分钟才发现冷库升温，这个坑要避免。
三、用Prometheus与Grafana实现可观测性
容器化后最怕「看不见」。我们让每个采集容器暴露/metrics接口，输出温度值、消息发送成功数、缓存积压条数等指标。Prometheus通过服务发现自动把新起容器加入抓取列表，不用人工改配置。指标定义例子如下：
package main
import (
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promhttp"
"net/http"
)
var tempGauge = prometheus.NewGauge(prometheus.GaugeOpts{
Name: "coldchain_temp_celsius",
Help: "current temperature in celsius",
})
func main() {
prometheus.MustRegister(tempGauge)
tempGauge.Set(-18.3)
http.Handle("/metrics", promhttp.Handler())
http.ListenAndServe(":9100", nil)
}
在Grafana里接Prometheus数据源，画一张温度多线图，再配一条告警规则：当coldchain_temp_celsius大于零下十度持续两分钟就发钉钉。相比过去靠人盯Excel，现在夜班无人也能在手机收到推送。我们还把容器重启次数、内存占用也纳入看板，方便判断是不是解析容器泄漏。
最后提一句安全。边缘容器不要开特权模式，MQTT账号用只读证书挂载进容器，而不是写死在镜像。镜像仓库启用扫描，防止基础镜像里被塞进挖矿木马。把以上环节串起来，容器化冷链监控服务就能既稳又轻，在冷链这种容错极低的行业里真正替人看住那几度温差。
Docker Prometheus MQTT修改时间：2026-08-18 17:50:22