Golang 协程中的 MQTT 连接断开：优雅退出

在 Go 语言的协程中使用 MQTT 连接时，可以通过设置一个信号通道来控制连接的断开。在主程序结束时，向这个信号通道发送信号，触发 MQTT 连接的断开操作。

具体实现步骤如下：

在协程中创建 MQTT 连接，并启动一个无限循环，用于监听 MQTT 消息和处理业务逻辑。
在主程序中创建一个信号通道，并将其传递给协程。
在主程序结束时，向信号通道发送一个信号，例如一个关闭信号。协程通过监听这个信号，收到信号后执行 MQTT 连接的断开操作。

示例代码如下：

package main

import (
    "fmt"
    "os"
    "os/signal"
    "syscall"

    MQTT "github.com/eclipse/paho.mqtt.golang"
)

func main() {
    // 创建一个 MQTT 客户端连接
    opts := MQTT.NewClientOptions().AddBroker("tcp://localhost:1883")
    client := MQTT.NewClient(opts)

    // 创建一个信号通道
    sigChan := make(chan os.Signal, 1)
    signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)

    // 启动一个协程处理 MQTT 消息
    go func() {
        if token := client.Connect(); token.Wait() && token.Error() != nil {
            panic(token.Error())
        }
        defer client.Disconnect(250)

        for {
            select {
            case <-sigChan:
                // 接收到信号，执行 MQTT 连接的断开操作
                fmt.Println("收到关闭信号，断开 MQTT 连接")
                return
            // 处理其他业务逻辑
            }
        }
    }()

    // 主程序等待信号通道收到信号
    <-sigChan
    fmt.Println("收到关闭信号，退出程序")
}

在上面的示例代码中，通过创建一个 MQTT 客户端连接和一个信号通道，启动一个协程处理 MQTT 消息，并在主程序中等待信号通道收到信号。当收到关闭信号时，协程会执行 MQTT 连接的断开操作，并退出循环，主程序也会退出。