在物联网系统中，设备通常使用MQTT协议上传传感器数据或接收控制指令，而前端监控大屏或管理后台则运行在浏览器中，仅靠HTTP难以实现服务器主动推送。MQTT与WebSocket的组合成为经典方案——MQTT Broker同时开放TCP端口和WebSocket端口，浏览器通过WebSocket连接Broker并完成MQTT报文封装，从而实现与设备端完全一致的主题订阅与发布。将这一整套服务打包进Docker容器，能够消除环境差异，让开发、测试与生产保持一致，也便于横向扩展。
理解MQTT与WebSocket的融合方式
MQTT是一种基于TCP的发布/订阅消息协议，设计之初就瞄准低带宽、低功耗场景，非常适合嵌入式设备。而WebSocket则是在HTTP基础上建立的持久化全双工通道，被所有现代浏览器原生支持。要让浏览器直接参与MQTT消息交互，需要在传输层将WebSocket数据流转换为MQTT协议帧。这一转换逻辑通常由MQTT Broker内部实现，并不需要额外的独立网关进程。
以开源Mosquitto为例，它支持在配置文件中同时声明多个监听器，其中一个可以指定protocol websockets。此时，Broker会在内部维持两个网络模块：普通TCP监听器处理设备直连，WebSocket监听器处理来自浏览器的连接。WebSocket客户端发送的数据帧会被剥离WebSocket头部，还原成标准的MQTT报文，然后进入Broker的路由与匹配引擎，整个过程对上层发布/订阅逻辑透明。同样，推送回WebSocket客户端的消息也会自动加上WebSocket帧头，浏览器端完全无感。
对于EMQX这类企业级Broker，WebSocket支持更为完善，可以在同一个端口上混合处理MQTT over WebSocket与普通HTTP请求，并且提供丰富的认证与鉴权钩子。容器化部署时，我们只需要重点关注端口映射与配置文件挂载，无需关心内部实现差异。
使用Docker Compose一键部署MQTT+WebSocket服务
为了快速搭建一套可用的服务，我们选用Mosquitto官方镜像，并通过Docker Compose管理配置。首先创建一个mosquitto.conf文件，内容如下（注意端口与协议分离）：
# 与设备通信的TCP监听器 listener 1883 protocol mqtt # 开启WebSocket监听器，供浏览器连接 listener 9001 protocol websockets # 允许匿名连接（生产环境建议关闭） allow_anonymous true # 持久化保存消息（可选） persistence true persistence_location /mosquitto/data/
然后编写docker-compose.yml，将配置文件挂载进容器，并映射两个端口：
version: '3.8'
services:
mosquito:
image: eclipse-mosquitto:2
container_name: mqtt-ws-broker
ports:
- "1883:1883"
- "9001:9001"
volumes:
- ./mosquitto.conf:/mosquitto/config/mosquitto.conf
- ./data:/mosquitto/data
restart: unless-stopped
配置文件mosquitto.conf中，两个listener指令顺序无关紧要，但每个监听器独占一行，后续跟随其专用属性。1883端口的协议默认就是MQTT，可省略protocol mqtt，但为清晰起见保留。9001端口明确声明为websockets，这是WebSocket起效的关键。启动服务后，设备可以通过tcp://your_ip:1883接入，浏览器则使用ws://your_ip:9001/mqtt作为端点。注意路径/mqtt是Mosquitto默认的WebSocket路径，在EMQX中可能是/mqtt或/ws，需查阅对应文档。
验证服务是否正常：在宿主机上用MQTT客户端工具（如MQTTX）分别连接1883和9001端口，两个客户端应能订阅同一主题并相互收发消息。若连接失败，检查防火墙与端口占用，并确认挂载的配置文件没有语法错误。容器化部署的一大优势是可以通过Docker Compose将多个Broker节点编排成集群（如EMQX的无主集群），这部分将在后文扩展说明。
客户端接入与消息互通实战
设备端模拟一个温湿度传感器，使用Python的paho-mqtt库以MQTT TCP方式连接Broker，定时向sensor/temperature主题发布JSON数据：
import paho.mqtt.client as mqtt
import json, time, random
broker = "localhost"
port = 1883
topic = "sensor/temperature"
client = mqtt.Client()
client.connect(broker, port, 60)
while True:
payload = {
"device_id": "sensor-001",
"temperature": round(20 + random.uniform(-5, 5), 2),
"timestamp": int(time.time())
}
client.publish(topic, json.dumps(payload), qos=1)
time.sleep(5)
该脚本会保持长连接，每5秒发送一条QoS 1的消息，确保至少送达一次。QoS的选择取决于数据重要程度与网络状况，物联网场景中QoS 1较为常用，避免消息丢失又不致开销过大。
浏览器端使用MQTT.js库连接WebSocket端点，监听同一主题并实时渲染到页面。示例HTML片段：
<!DOCTYPE html>
<html>
<head>
<script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>
</head>
<body>
<div id="status">等待连接...</div>
<div id="temp"></div>
<script>
const brokerUrl = "ws://localhost:9001/mqtt";
const client = mqtt.connect(brokerUrl);
client.on("connect", () => {
document.getElementById("status").innerHTML = "已连接";
client.subscribe("sensor/temperature", { qos: 1 }, (err) => {
if (!err) console.log("订阅成功");
});
});
client.on("message", (topic, message) => {
const data = JSON.parse(message.toString());
document.getElementById("temp").innerHTML =
`设备 ${data.device_id} 温度: ${data.temperature}℃`;
});
</script>
</body>
</html>
MQTT.js会自动处理WebSocket上的MQTT协议封装，连接时的URL路径/mqtt必须与Broker配置一致。浏览器页面订阅后，每当设备端发布新数据，onMessage回调立即触发，页面实时更新，从而实现从物理世界到Web UI的无缝流转。此外，浏览器也可以主动发布控制指令到device/command主题，设备端订阅该主题并执行动作，完成双向闭环。
生产环境加固与扩展策略
匿名连接仅适用于开发调试，正式运行必须开启认证。Mosquitto可以通过密码文件和访问控制列表（ACL）来管理用户权限。仍以容器化方式实施：在宿主机创建passwd文件，用mosquitto_passwd命令添加用户，然后修改配置文件：
password_file /mosquitto/config/passwd acl_file /mosquitto/config/acl.txt
将两份文件挂载进容器即可。ACL文件可以限制用户对特定主题的读写权限，例如只允许传感器设备发布sensor/#主题，浏览器用户只能订阅而不能发布。安全方面，生产环境务必启用TLS加密，Mosquitto配置为每个监听器指定独立的证书，WebSocket升级为wss://。证书同样通过卷挂载，并在配置中添加：
listener 8883 protocol mqtt cafile /mosquitto/config/ca.crt certfile /mosquitto/config/server.crt keyfile /mosquitto/config/server.key tls_version tlsv1.2 listener 443 protocol websockets cafile /mosquitto/config/ca.crt certfile /mosquitto/config/server.crt keyfile /mosquitto/config/server.key
这样，设备端连接ssl://broker:8883，浏览器连接wss://broker:443/mqtt，所有通信被加密。容器编排时，可以将TLS相关文件放在独立目录，多实例共享。
当单节点吞吐量成为瓶颈，常见的扩展方式有：使用EMQX组建集群，配合haproxy或nginx进行四层负载，MQTT由TCP长连接承载，因此负载均衡需要配置为TCP模式，并保持源IP一致性（如使用leastconn算法）。Docker Compose可以定义多个Broker服务，再结合网络覆盖驱动与DNS发现，快速拉起一个高可用集群。同时，将消息持久化目录映射到宿主机或网络存储，避免容器重新调度时丢失数据。监控方面，Broker通常会暴露系统主题（如$SYS/#），可以编写一个简单的Node.js脚本订阅这些主题，并将指标写入Prometheus，再通过Grafana可视化，实现连接数、消息速率等关键指标的实时观测。