Golang中Logrus MQTT Hook无法向指定Topic发送日志求助

针对你遇到的Logrus MQTT Hook无法发送日志到指定Topic的问题，可从以下几个方向排查修复：

1. 程序退出过早导致消息未完成投递 #

你的main函数在输出日志后直接终止，而MQTT客户端的消息发布属于异步操作，程序退出时可能消息还未完成向Broker的投递。

修复方法：在main函数末尾添加等待逻辑，或显式关闭MQTT连接以确保消息发送完成：

import "time"

func main() {
    // ... 原有代码 ...

    log.Info("Info message")
    log.WithFields(logrus.Fields{
        "name": "joe",
        "age":  42,
    }).Error("Error Message with fields")

    // 等待消息发送完成（可根据实际网络情况调整时长）
    time.Sleep(2 * time.Second)
    // 或者显式关闭hook的MQTT连接
    if err := hook.Close(); err != nil {
        log.Error("Failed to close MQTT hook: ", err)
    }
}

2. 补充MQTT客户端必要配置 #

部分MQTT Broker要求客户端提供唯一的ClientID，而logrusmqtt默认可能使用固定值或空值，导致连接异常但未抛出显性错误。同时可显式配置ClientID确保与Broker的连接规则匹配。

修复方法：在MQTTHookParams中添加唯一ClientID：

import (
    "os"
    "strconv"
)

// ... 原有代码 ...

p := logrusmqtt.MQTTHookParams{
    Hostname:   "wwww-xxx.yyyyy.zzzzzzzzzzz",
    Topic:      "logrusmqtt/log",
    Port:       8883,
    CAFilepath: "/vvv/www/xxxxx/yyyyy/zzzzz-zzzzz/ca.crt",
    ClientID:   "logrus-test-client-" + strconv.Itoa(os.Getpid()), // 基于进程ID生成唯一ClientID
}

3. 验证MQTT客户端连接状态 #

可在创建Hook后，主动检查客户端是否成功连接到Broker，排查潜在的连接问题：

hook, err := logrusmqtt.NewMQTTHook(p, logrus.DebugLevel)
if err != nil {
    panic(err)
}
// 检查MQTT客户端连接状态
if !hook.Client.IsConnected() {
    log.Error("MQTT client failed to connect to broker!")
}
log.Hooks.Add(hook)

4. 确认Topic匹配规则 #

你的订阅命令使用logrusmqtt/log/#，代码中指定的Topic为logrusmqtt/log，理论上可以正常接收，但如果Broker有特殊的Topic格式限制，可尝试将代码中的Topic调整为logrusmqtt/log/（末尾加斜杠）进行测试。

内容的提问来源于stack exchange，提问作者Shri