手把手教你搭建MQTT服务器，从入门到精通

本文将手把手教你搭建MQTT服务器，从基础知识到高级技巧，涵盖从入门到精通的全方位教程，助你轻松掌握MQTT服务器的搭建与运维。

随着物联网技术的不断发展，MQTT（Message Queuing Telemetry Transport）作为一种轻量级的消息传输协议，被广泛应用于物联网设备之间进行通信，搭建MQTT服务器是物联网项目中不可或缺的一环，本文将为你详细讲解如何从零开始搭建一个MQTT服务器,让你轻松掌握MQTT服务器搭建的技巧。

准备工作

1. 硬件环境：一台运行Linux操作系统的服务器，推荐配置为：CPU 2.0GHz以上，内存2GB以上,硬盘100GB以上。

   

   图片来源于网络，如有侵权联系删除

2. 软件环境：安装以下软件：

   • 操作系统：CentOS 7/8
   • 编译器：gcc
   • 数据库：MySQL（可选,用于存储用户和权限信息）

安装MQTT服务器

安装Eclipse Paho MQTT客户端库

我们需要安装Eclipse Paho MQTT客户端库,以便后续测试MQTT服务器。

# 安装gcc编译器
yum install -y gcc
# 安装Eclipse Paho MQTT客户端库
wget https://github.com/eclipse/paho.mqtt.golang/releases/download/v1.2.1/mqtt.go.tar.gz
tar -zxvf mqtt.go.tar.gz
cd mqtt.go
go get -v -u github.com/eclipse/paho.mqtt.golang

安装mosquitto MQTT服务器

我们需要安装mosquitto MQTT服务器，mosquitto是一款开源的MQTT服务器,支持多种协议和客户端。

# 安装mosquitto
yum install -y mosquitto mosquitto-clients
# 启动mosquitto服务
systemctl start mosquitto
# 设置mosquitto服务开机自启
systemctl enable mosquitto

配置mosquitto

在安装过程中，mosquitto会生成一个默认的配置文件/etc/mosquitto/mosquitto.conf，我们可以在该文件中修改一些配置项,以满足我们的需求。

# 修改认证方式
# 将下面的行注释掉，取消注释下面的行
# allow_anonymous false
# password_file /etc/mosquitto/passwd
# 设置日志级别
# log_dest file /var/log/mosquitto/mosquitto.log
# log_dest stderr
# log_dest format %Y-%m-%d %H:%M:%S %p %c %m

创建用户和权限

图片来源于网络，如有侵权联系删除

为了提高安全性,我们可以为MQTT服务器创建用户和权限。

# 创建用户
mosquitto_useradd -c "用户描述" -p "密码" 用户名
# 设置用户权限
mosquitto_acl_add -i 用户名 -p "允许的主题" -r "订阅权限" -w "发布权限" -a "保留消息权限"

测试MQTT服务器

使用客户端连接服务器

使用mosquitto-clients中的mosquitto_sub和mosquitto_pub命令测试MQTT服务器。

# 订阅主题
mosquitto_sub -h 服务器地址 -t "主题1" -u 用户名 -P 密码
# 发布消息
mosquitto_pub -h 服务器地址 -t "主题1" -m "消息内容" -u 用户名 -P 密码

使用Paho MQTT客户端库测试

使用Paho MQTT客户端库中的MqttClient类连接服务器,并订阅和发布消息。

package main
import (
    "fmt"
    "log"
    mqtt "github.com/eclipse/paho.mqtt.golang"
)
func main() {
    // 创建MQTT客户端
    client := mqtt.NewClient(mqtt.NewClientOptions().AddBroker("服务器地址").SetClientID("客户端ID"))
    // 连接服务器
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        log.Fatal(token.Error())
    }
    // 订阅主题
    if token := client.Subscribe("主题1", 0, nil); token.Wait() && token.Error() != nil {
        log.Fatal(token.Error())
    }
    // 发布消息
    if token := client.Publish("主题1", 0, false, "消息内容"); token.Wait() && token.Error() != nil {
        log.Fatal(token.Error())
    }
    // 断开连接
    client.Disconnect(100)
}

通过以上步骤，你已经成功搭建了一个MQTT服务器，在实际项目中，你可以根据需求调整配置，例如增加用户、权限、主题等，希望本文能帮助你更好地理解MQTT服务器搭建过程,为你的物联网项目提供助力。