绝大多数连不上问题源于网络或认证配置错误：云服务器安全组/本地防火墙未放行1883或8883端口；EMQX中allow_anonymous=false时Go客户端未设置Username/Password；TLS连接缺少CA证书导致x509错误；或MQTT协议版本不兼容（如旧库不支持v5.0）。
Go 客户端连接 EMQX 时连不上，常见原因是什么
绝大多数连不上问题不是代码写错，而是网络或认证配置没对。EMQX 默认启用匿名连接（allow_anonymous = true），但生产环境通常关闭它，而 Go 客户端若没显式传用户名密码，就会被拒绝。
常见错误现象包括：connection refused（端口未开放）、connection reset by peer（TLS 配置不匹配）、not authorized（认证失败）。
- 确认云服务器安全组已放行
1883（非加密）或8883（TLS），本地防火墙也允许出站 - 检查 EMQX 配置文件中
allow_anonymous是否为false；若为false，必须在 Go 客户端的ConnectOptions中设置Username和Password - 使用 TLS 连接时，Go 客户端需加载 CA 证书（如用自签名证书），否则会报
x509: certificate signed by unknown authority - 注意 EMQX 的 MQTT 协议版本兼容性：开源版默认支持 MQTT v3.1.1 和 v5.0，但某些旧版 Go MQTT 库（如
go-mqtt/mqtt）只支持 v3.1.1，v5.0 的属性字段可能被忽略
用哪个 Go MQTT 客户端库最稳妥
推荐直接用官方维护的 emqx/go-mqtt（原 eclipse/paho.mqtt.golang 的活跃分支），它持续适配 EMQX 新特性，比如 MQTT 5.0 的响应主题（ResponseTopic）、会话过期（SessionExpiryInterval）等。
不建议用已归档的 pkg/mqtt 或轻量级但功能残缺的 uken/mqtt，它们不支持规则引擎触发后的响应消息解析，也不处理 EMQX 返回的 ReasonCode 字段。
立即学习“go语言免费学习笔记（深入）”；
-
emqx/go-mqtt支持自动重连、QoS 级别选择、Clean Start 控制，且日志可细粒度开启（SetLogger） - 初始化时务必设置
ClientOptions.SetAutoReconnect(true)，否则网络抖动后连接不会恢复 - 订阅 Topic 建议用
SubscribeMultiple而非多次单订，减少握手开销；同时注意 EMQX 默认最大订阅数为 1024，超限会返回0x86错误码
如何让 Go 微服务与 EMQX 规则引擎联动
EMQX 的规则引擎（Rule Engine）本质是 SQL 引擎，它把 MQTT 消息当作数据流处理。Go 微服务不需要主动“监听”规则结果，而是通过配置规则将数据桥接到 HTTP 服务、数据库或 Kafka —— 你只需确保 Go 服务暴露一个能接收 POST 的 endpoint。
例如，你想把所有 sensor/+/temperature 主题的消息存入 PostgreSQL：
SELECT payload.temp AS temperature, clientid AS device_id, timestamp AS ts FROM "sensor/+/temperature" WHERE payload.temp > 0
然后在规则动作里选 “HTTP Server”，填 Go 服务地址如 http://localhost:8080/api/v1/ingest。这时 Go 服务收到的是标准 JSON POST 请求，不是 MQTT 包。
- 规则引擎输出的 JSON 结构由 SQL 的
SELECT决定，不是原始 payload；若 payload 是二进制或非 UTF-8 编码，规则会失败，需先用base64_encode(payload)处理 - HTTP 动作默认超时 5 秒，若 Go 接口响应慢，EMQX 会重试（最多 3 次），可能造成重复入库，接口需幂等
- 调试规则时，可在 Dashboard 的 “规则 > 测试” 页面模拟消息输入，避免反复发设备消息
为什么 Go 微服务重启后收不到离线消息
EMQX 不会自动为 Go 客户端保留离线消息，除非你在连接时明确开启持久会话（CleanStart = false）并设置 SessionExpiryInterval（MQTT v5）或 KeepAlive + 客户端 ID 固定（v3.1.1）。
关键点在于：客户端 ID（ClientID）必须固定，且不能与其他连接冲突；否则 EMQX 认为是新会话，丢弃旧会话队列。
- v3.1.1 下：设置
ClientOptions.SetClientID("svc-temperature-processor")+SetCleanStart(false)+SetKeepAlive(60) - v5.0 下：用
SetSessionExpiryInterval(3600)替代KeepAlive，值单位是秒，设为 0 表示会话永不过期（慎用） - EMQX 默认只保留每主题最多 100 条 QoS 1/2 的离线消息，可通过配置
mqtt.max_awaiting_rel和mqtt.max_inflight调整 - 注意：如果 Go 服务用 Kubernetes Deployment 部署，多个副本共用同一
ClientID会导致踢下线——应改用 StatefulSet 或每个实例生成唯一 ID（如加 Pod 名后缀）
Subscribe 容易被忽略得多。 
