golang MQTT 订阅

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，最初由IBM开发，用于物联网设备之间的消息通信。它具有简单、低开销、易扩展等特点，被广泛应用于物联网、传感器网络、移动应用等领域。在golang中，我们可以使用paho.mqtt.golang库来实现MQTT订阅功能。

连接到MQTT代理

在开始使用Golang实现MQTT订阅之前，我们首先需要连接到MQTT代理。MQTT代理是一个中间层，用于接收和转发消息，将发布者（Publisher）和订阅者（Subscriber）连接起来。在Golang中，我们可以使用paho.mqtt.golang库提供的Connect函数来连接到MQTT代理。下面是一个示例代码：

opts := MQTT.NewClientOptions().AddBroker("tcp://localhost:1883")
client := MQTT.NewClient(opts)
if token := client.Connect(); token.Wait() && token.Error() != nil {
    log.Fatal(token.Error())
}

定义消息处理函数

在连接到MQTT代理之后，我们需要定义一个消息处理函数，用于处理接收到的消息。这个函数将作为参数传递给paho.mqtt.golang库提供的Subscribe函数。下面是一个示例代码：

func messageHandler(client MQTT.Client, msg MQTT.Message) {
    topic := msg.Topic()
    payload := string(msg.Payload())
    log.Printf("Received message on topic: %s, Payload: %s\n", topic, payload)
}

订阅消息

通过调用paho.mqtt.golang库提供的Subscribe函数，我们可以订阅指定主题（Topic）的消息。下面是一个示例代码：

if token := client.Subscribe("topic/example", 0, messageHandler); token.Wait() && token.Error() != nil {
    log.Fatal(token.Error())
}

在上述代码中，第一个参数为要订阅的主题，第二个参数为服务质量等级（QoS），第三个参数为消息处理函数。服务质量等级包括0、1和2三种级别，分别表示至多一次、至少一次和刚好一次的消息传递。

Golang MQTT订阅的实现就是这么简单。通过连接到MQTT代理，定义消息处理函数，并订阅消息，我们就可以接收到来自MQTT发布者的消息。当然，在实际开发中，我们还可以进一步处理接收到的消息，比如解析JSON、存储到数据库等。