安装mqtt服务器EMQX

Bertha 。 2024-04-06 11:47 76阅读 0赞

1.官网：EMQX 是一款大规模可弹性伸缩的云原生分布式物联网 MQTT 消息服务器。

[EMQX: 大规模分布式物联网 MQTT 消息服务器EMQX 是一款全球下载量超千万的开源物联网 MQTT 服务器，单集群支持 1 亿物联网设备连接，消息分发时延低于 1 毫秒，助力企业构建关键业务的 IoT 平台与应用。![favicon.ico][]https://www.emqx.io/zh][EMQX_ _ MQTT _EMQX _ MQTT _ 1 _ 1 _ IoT _favicon.ico_https_www.emqx.io_zh]2.安装：[快速开始 | EMQX 5.0 文档][_ EMQX 5.0]

docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:latest

3.开放相应端口  
![67b763d10d1f471bbc3559d8cc13cf97.png][]

4.通过浏览器打开 [http://localhost:18083/ (opens new window)][http_localhost_18083_ _opens new window]（将 localhost 替换为您实际 IP 地址）以访问 [EMQX Dashboard][] 管理控制台，进行设备连接与相关指标监控管理。  
![f08b73d10e8946a393baa207f6b68ec4.png][]

![0784bde100b54a5b967ddc57537ed314.png][]

设置成中文：

![f64b0bd238534795aa460df335f102e8.png][]

5.安装桌面客户端  
[MQTT X：跨平台 MQTT 5.0 桌面客户端工具MQTT X 是 EMQ 开源的一款优雅的跨平台 MQTT 5.0 桌面客户端工具，它能运行在 macOS, Linux, Windows 上，并且支持 MQTT 消息格式转换。![favicon.ico 1][]https://mqttx.app/zh][MQTT X_ MQTT 5.0 _MQTT X _ EMQ _ MQTT 5.0 _ macOS_ Linux_ Windows _ MQTT _favicon.ico 1_https_mqttx.app_zh]![f40a2ff8984e4fd8a331a5e01e3b54b7.png][]

![5f82062d312a0aaa6f2ac70ba441b7b6.png][]

![654f0336c8294f6a93ce1a7a618532e7.png][] ![b6cac5ec4c2541c4b9c28641ae6d8955.png][] ![efb96d6149b44ed0b60510fccc01c86f.png][]

![1d9f71b1db154270b98b1151e4dc2938.png][]

6.python客户端连接[MQTT Python 客户端库 | EMQX 5.0 文档![favicon-broker.ico][]https://www.emqx.io/docs/zh/v5.0/development/python.html\#paho-python-%E4%BD%BF%E7%94%A8%E7%A4%BA%E4%BE%8B][MQTT Python _ _ EMQX 5.0 _favicon-broker.ico_https_www.emqx.io_docs_zh_v5.0_development_python.html_paho-python-_E4_BD_BF_E7_94_A8_E7_A4_BA_E4_BE_8B]

pip install paho-mqtt

import paho.mqtt.client as mqtt
    
    
    # 连接成功回调
    def on_connect(client, userdata, flags, rc):
        print('连接成功！' + str(rc))
        # 订阅Topic,如果Mqtt服务器上没有该主题，则会自动创建。
        client.subscribe('test1')
    
    
    # 消息接收回调
    def on_message(client, userdata, msg):
        print("主题:", msg.topic)
        print("负载", msg.payload.decode('utf8'))
    
    
    if __name__ == '__main__':
        client = mqtt.Client()
    
        # 指定回调函数
        client.on_connect = on_connect
        client.on_message = on_message
    
        # 建立连接
        client.connect('124.222.40.17', 1883, 60)
        # 发布消息 如果Mqtt服务器上没有该主题，则会自动创建。
        client.publish('test1', payload='Hello everybody', qos=0)
    
        client.loop_forever()

![b3cb24101a18440aa1f9962df30d3cdd.png][]

![021b8ecfc6974151af91f1d7eff1dac9.png][]

**注意：\# 发布消息和订阅主题 如果Mqtt服务器上没有该主题，则会自动创建。**

[favicon.ico]: https://www.emqx.io/favicon.ico
[EMQX_ _ MQTT _EMQX _ MQTT _ 1 _ 1 _ IoT _favicon.ico_https_www.emqx.io_zh]: https://www.emqx.io/zh
[_ EMQX 5.0]: https://www.emqx.io/docs/zh/v5.0/getting-started/getting-started.html#%E5%AE%89%E8%A3%85-emqx
[67b763d10d1f471bbc3559d8cc13cf97.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/95c449c7c61e4f48924a85125e887398.png
[http_localhost_18083_ _opens new window]: http://localhost:18083/
[EMQX Dashboard]: https://www.emqx.io/docs/zh/v5.0/getting-started/dashboard.html
[f08b73d10e8946a393baa207f6b68ec4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/a1a36642e71e4727af780ac6a2c45ff0.png
[0784bde100b54a5b967ddc57537ed314.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/973f878983544bac9be25dc41026e79c.png
[f64b0bd238534795aa460df335f102e8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/779e14da6bfb4aba959b43ca5867b82d.png
[favicon.ico 1]: https://mqttx.app/favicon.ico
[MQTT X_ MQTT 5.0 _MQTT X _ EMQ _ MQTT 5.0 _ macOS_ Linux_ Windows _ MQTT _favicon.ico 1_https_mqttx.app_zh]: https://mqttx.app/zh
[f40a2ff8984e4fd8a331a5e01e3b54b7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/eca13fec45f542d08ab3d61071ed3342.png
[5f82062d312a0aaa6f2ac70ba441b7b6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/2f64299bd8fe4e8e884abb8c4496807f.png
[654f0336c8294f6a93ce1a7a618532e7.png]: https://img-blog.csdnimg.cn/654f0336c8294f6a93ce1a7a618532e7.png
[b6cac5ec4c2541c4b9c28641ae6d8955.png]: https://img-blog.csdnimg.cn/b6cac5ec4c2541c4b9c28641ae6d8955.png
[efb96d6149b44ed0b60510fccc01c86f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/4f550c6b50a84a1aaa81231244d0e6be.png
[1d9f71b1db154270b98b1151e4dc2938.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/0499f3fee0f94670a1fa5cdebdb9abd1.png
[favicon-broker.ico]: https://www.emqx.io/docs/docs-images/favicon-broker.ico
[MQTT Python _ _ EMQX 5.0 _favicon-broker.ico_https_www.emqx.io_docs_zh_v5.0_development_python.html_paho-python-_E4_BD_BF_E7_94_A8_E7_A4_BA_E4_BE_8B]: https://www.emqx.io/docs/zh/v5.0/development/python.html#paho-python-%E4%BD%BF%E7%94%A8%E7%A4%BA%E4%BE%8B
[b3cb24101a18440aa1f9962df30d3cdd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/fb1e3782c8e343b4a48d5ab378598e6b.png
[021b8ecfc6974151af91f1d7eff1dac9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/06/0055a2af76034f03ace8697379c5e09f.png