MQTT 服务器

### 如何搭建和配置 MQTT 服务器 #### 使用 Docker 搭建 EMQX MQTT 服务器 可以通过 Docker 快速部署 EMQX MQTT 服务器。以下是具体操作： 1. 安装 Docker 并拉取 EMQX 镜像： ```bash docker pull emqx/emqx:v4.4.7 ``` 2. 启动容器并运行 EMQX： ```bash docker run -d --name emqx \ -p 1883:1883 \ -p 8083:8083 \ -p 8883:8883 \ -p 18083:18083 \ -p 8084:8084 \ -p 8884:8884 \ emqx/emqx:v4.4.7 ``` 上述命令会将 EMQX 的多个端口映射到主机上，其中 `1883` 是标准的 MQTT 端口[^3]。 3. 登录管理界面： 打开浏览器访问 `http://<your-server-ip>:18083`，使用默认账户名 `admin` 和密码 `public` 进行登录[^4]。建议首次登录后立即更改管理员密码以提高安全性。 --- #### 使用 Mosquitto 搭建 MQTT 服务器 Mosquitto 是另一种流行的开源 MQTT 组件，适合小型项目或学习用途。 1. 安装 Mosquitto： 对于 Ubuntu 或 Debian 系统，执行以下命令安装 Mosquitto 及其工具包： ```bash sudo apt update && sudo apt install mosquitto mosquitto-clients -y ``` 2. 创建自定义服务文件（如果未自动创建）： 如果系统中缺少 Mosquitto 服务文件，则可以手动创建 `/etc/systemd/system/mosquitto.service` 文件，并写入相关内容[^5]： ```ini [Unit] Description=Mosquitto MQTT Broker Documentation=man:mosquitto.conf(5) man:mosquitto(8) After=network.target [Service] ExecStart=/usr/sbin/mosquitto -c /etc/mosquitto/mosquitto.conf Restart=on-failure User=mosquitto Group=mosquitto [Install] WantedBy=multi-user.target ``` 3. 加载新服务文件并启动 Mosquitto： ```bash sudo systemctl daemon-reload sudo systemctl start mosquitto sudo systemctl enable mosquitto ``` 4. 测试服务器状态： 使用以下命令查看 Mosquitto 是否正常工作： ```bash sudo systemctl status mosquitto ``` 5. 调试日志： 若遇到问题，可通过以下方式检查错误日志： ```bash sudo tail -f /var/log/mosquitto/mosquitto.log ``` --- #### 基本配置说明 无论是 EMQX 还是 Mosquitto，在完成基本安装之后都需要进一步调整配置文件以满足实际需求。 - **EMQX 配置**：主要通过编辑 `/opt/emqx/etc/emqx.conf` 来设置监听端口、认证机制等内容。 - **Mosquitto 配置**：位于 `/etc/mosquitto/mosquitto.conf` 中，默认情况下启用了匿名连接支持。为了增强安全性和权限控制，可以在该文件中添加用户验证规则。 例如，启用基于用户名和密码的身份校验： ```plaintext allow_anonymous false password_file /etc/mosquitto/passwd ``` 随后利用 `mosquitto_passwd` 工具生成密码文件条目： ```bash sudo mosquitto_passwd -c /etc/mosquitto/passwd test1 ``` --- #### 设备接入示例 假设已成功架设好 MQTT 服务器，下面展示一个简单的 Python 客户端程序用于发送消息至指定主题。 ```python import paho.mqtt.client as mqtt def on_connect(client, userdata, flags, rc): if rc == 0: print("Connected successfully.") else: print(f"Bad connection Returned code={rc}") client = mqtt.Client() client.username_pw_set(username="test1", password="12345678") # 设置凭证 client.on_connect = on_connect broker_address = "122.112.225.194" port = 1883 topic = "AAA/1" try: client.connect(broker_address, port) except Exception as e: print(e) message = {"msg": "我是AAA设备"} client.publish(topic, str(message)) client.disconnect() ``` 此脚本实现了向目标主题推送 JSON 数据的功能[^2]。 ---