Ubuntu上MQTT服务器搭建与Python客户端连接实践指南

在物联网和分布式系统中，MQTT 作为轻量级消息协议，越来越受到开发者的青睐。本文将介绍如何在 Ubuntu 上搭建 MQTT 服务器（使用 Mosquitto），并在 Windows 上利用 Python 编写客户端连接和测试消息传输的全过程。

一、在 Ubuntu 上安装与配置 Mosquitto

1. 安装 Mosquitto 服务

首先，更新系统后安装 Mosquitto 及其客户端工具：

sudo apt update
sudo apt upgrade
sudo apt install mosquitto mosquitto-clients

安装完成后，Mosquitto 服务会自动启动。你可以用下面的命令查看服务状态：

sudo systemctl status mosquitto

2. 配置 Mosquitto

编辑主配置文件 /etc/mosquitto/mosquitto.conf，示例如下：

pid_file /run/mosquitto/mosquitto.pid

persistence true
persistence_location /var/lib/mosquitto/

log_dest file /var/log/mosquitto/mosquitto.log

include_dir /etc/mosquitto/conf.d

# 监听端口
listener 1883

# 区分测试和生产环境
allow_anonymous true  # 测试环境开放匿名访问
# 如果需要使用用户名密码认证，请使用下面的配置，并删除上面的 allow_anonymous true
# allow_anonymous false
# password_file /etc/mosquitto/passwd

注意： 配置文件中出现了重复的匿名访问设置（例如先 allow_anonymous true 后又设置 allow_anonymous false），后者会覆盖前者。如果是生产环境，建议关闭匿名访问，启用密码认证，并用命令生成密码文件：

sudo mosquitto_passwd -c /etc/mosquitto/passwd your_username

修改配置文件后，记得重启 Mosquitto 服务：

sudo systemctl restart mosquitto

如果需要开放远程访问，请确保 Ubuntu 防火墙允许 1883 端口：

sudo ufw allow 1883/tcp

二、使用 Python 客户端连接 MQTT 服务器

在 Windows 上，我们采用 Python 的 paho-mqtt 库进行 MQTT 客户端开发。

1. 安装 paho-mqtt 库

在命令提示符中执行：

pip install paho-mqtt

2. 编写 Python 客户端代码

新版 paho-mqtt（2.x）使用新版回调 API，回调函数需要多一个 properties 参数。下面是一个简单的示例：

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc, properties=None):
    print("Connected with result code:", rc)
    # 连接成功后订阅 test/topic
    client.subscribe("test/topic")
    # 同时发布测试消息
    client.publish("test/topic", "Hello MQTT")

def on_message(client, userdata, msg):
    print("Received message:")
    print("Topic:", msg.topic)
    print("Payload:", msg.payload.decode())

broker_address = "192.168.116.3"  # 替换为你的 Ubuntu 服务器 IP
port = 1883

# 创建客户端实例
client = mqtt.Client(client_id="WindowsClient")
client.on_connect = on_connect
client.on_message = on_message

client.connect(broker_address, port, keepalive=60)
client.loop_forever()

在上述代码中：

on_connect 回调： 成功连接后，客户端订阅了 test/topic，并立即发布一条 "Hello MQTT" 的消息。

on_message 回调： 收到消息后，打印主题和消息内容。