mosquitto（MQTT）服务器搭建和基本使用

一、安装

搭建一个mqtt服务器，这里我们采用mosquitto

1、 下载地址：https://mosquitto.org/download/

2、 选择windows：https://mosquitto.org/files/binary/win64/mosquitto-2.0.18-install-windows-x64.exe

3、 右键安装即可

默认的安装路径在这里：C:\Program Files\mosquitto

二、修改配置文件

1、 进入mosquitto的安装目录，找到配置文件

 C:\Program Files\mosquitto\ mosquitto.conf

2、 修改mosquitto指定的监听端口

 listener 8899

3、 关闭mosquitto的匿名登录功能

allow_anonymous false

4、 修改配置用户的配置文件路径（这里要用绝对路径）

password_file D:\other\mosquitto\pwd.emample

三、启动

1、 进入windows的service。启动mqtt broker服务

2、命令行启动：mosquitto.exe -c mosquitto.conf -v

四、使用

1、用python写一个订阅者的代码

import paho.mqtt.client as mqtt


broker = ‘127.0.0.1’
port = 7788
topic = “AIOT”

# 连接的回调函数
def on_connect(client, userdata, flags, rc):
    print(f”Connected with result code {rc}”)
    client.subscribe(topic)

# 收到消息的回调函数
def on_message(client, userdata, msg):
    print(msg.topic+” “+str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect(broker, port, 60)
client.loop_forever()

我们当然也可以用命令行的方式启动订阅者，可以通过help来查询使用方法

mosquitto_sub.exe –help

2、发布者代码

import paho.mqtt.client as mqtt
import time

broker = '127.0.0.1'
port = 8899
topic = "AIOT"

def on_connect(client, userdata, flags, rc):
    print(f"Connected with result code {rc}")

client = mqtt.Client()
client.on_connect = on_connect
client.connect(broker, port, 60)
for i in range(60):
    client.publish(topic, payload=i, qos=0, retain=False)
    print(f"send {i} to a/b{topic}")
    time.sleep(1)

client.loop_forever()

当然我们可以使用命令行的方式启用生产者，可以通过help来查询使用方法

mosquitto_pub.exe –help