mqtt转发golang

2023-05-22 13:58

短信预约 -IT技能 免费直播动态提醒

MQTT转发Golang

随着物联网（IoT）时代的到来，设备之间的通信变得越来越重要。MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传递协议，它被设计用于跨越低带宽、高延迟或不可靠的网络连接，为无限制的设备和应用程序提供高效的数据交换机制。在这篇文章中，我们将探讨如何使用Golang创建一个MQTT转发代理服务器，使得不同的设备能够通过MQTT协议进行通信。

我们首先需要安装Golang。安装完成后，我们需要安装paho-mqtt包，它是用于Golang中与MQTT通信的主要库。我们可以通过以下命令安装：

go get github.com/eclipse/paho.mqtt.golang

完成后，我们将创建一个名为mqtt-forward的项目文件夹，它包括一个名为main.go的Golang文件。我们需要将paho-mqtt包导入到我们的代码中：

import (
    "fmt"

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

接下来，我们需要设置MQTT客户端选项：

opts := mqtt.NewClientOptions().AddBroker("tcp://broker.hivemq.com:1883").SetClientID("mqtt-forward")

在此示例中，我们连接到HiveMQ公共MQTT代理，选择TCP传输协议，端口号为1883，并且将客户端ID设置为“mqtt-forward”。我们还可以设置MQTT连接的用户名和密码。

现在，我们将建立一个MQTT客户端连接，并通过mqtt.Client类型的指针变量client引用它：

client := mqtt.NewClient(opts)
if token := client.Connect(); token.Wait() && token.Error() != nil {
    panic(token.Error())
}
defer client.Disconnect(250)

在此示例中，我们使用mqtt.NewClient（opts）方法创建一个新版本的MQTT客户端并传递选项。连接到MQTT代理服务器后，我们将关闭MQTT客户端并等待最多250毫秒，以确保连接已成功关闭。defer关键字用于在函数返回之前执行清理代码，这样可以确保我们在不需要时正确关闭MQTT客户端。

我们还需要创建一个与MQTT服务器建立连接后的处理函数，以便接收来自设备的MQTT消息。接收到的消息通过MQTT的主题进行分类。

func onMessageReceived(client mqtt.Client, message mqtt.Message) {
    fmt.Printf("Received message: %s from topic: %s
", message.Payload(), message.Topic())
}

在此示例中，我们打印所接收到的MQTT消息的有效负载（有效负载是实际传输数据的部分）和主题。

现在，我们需要订阅MQTT主题。我们可以使用以下代码向客户端添加回调函数：

if token := client.Subscribe("testtopic/#", byte(0), onMessageReceived); token.Wait() && token.Error() != nil {
    panic(token.Error())
}

在此示例中，我们订阅所有以“testtopic”开头的主题。我们将QoS设置为字节0，这意味着我们收到的消息仅发送一次。

我们完整的main函数如下：

func main() {
    opts := mqtt.NewClientOptions().AddBroker("tcp://broker.hivemq.com:1883").SetClientID("mqtt-forward")
    client := mqtt.NewClient(opts)

    if token := client.Connect(); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }
    defer client.Disconnect(250)

    if token := client.Subscribe("testtopic/#", byte(0), onMessageReceived); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }

    for {
        time.Sleep(time.Second)
    }
}

func onMessageReceived(client mqtt.Client, message mqtt.Message) {
    fmt.Printf("Received message: %s from topic: %s
", message.Payload(), message.Topic())
}

在程序启动后，我们将通过TCP在1883端口连接到MQTT代理，并添加了一个回调函数，并订阅了以“testtopic”开头的所有主题。最后，我们进入了一个无限循环中，以便我们可以保持连接状态并持续收到MQTT消息。

我们可以使用以下命令运行Golang程序：