EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

这篇具有很好参考价值的文章主要介绍了EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

        EMQX是大规模分布式物联网MQTT消息服务器,除了发送接送的流量不能太大(不能用于生产!),在学习MQTT方面上有很大的优势的!

        在使用该协议时,主要需要弄懂的一个知识点就是“发布者”和“订阅者”的关系,在最简单的模型中,一般会含有以上两个角色,发布者不需要订阅任何id,只管设置自己的“话题”(Topic),当设置好话题后,订阅者则需要去订阅这个话题,便可以与发布者进行数据交互,具体框架如下所示:

EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

 我可以先来创建一个MQTT Client!

首先需要到网上下载MQTTBox,然后打开软件,点击创建Client,然后再访问官网,获取公共接口:

mqtt官方网站点击此处即可访问官网!

然后你会看到这个:

EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

 这个大家都是公用的,只需赋值Broker即可:

继续打开MQTTBox进行填写,只需要注意以下三点即可,名字(ClientName)是随意的。

EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

 创建之后就有以下界面了,EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

 其中左边为发布者,右边为订阅者,发布者只管设置话题(图中我设置为了ObjectA),然后右边就订阅该话题即可(填入相同的话题名字),然后就可以点击Subscribe按钮进行订阅。然后回到发布者的左边界面,再Payload中可以填入想要发送的内容,最后再点击Publish按钮便可以将消息发送,成功的效果图如下:

EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

 右边会有左边发布者传来的数据。

主要流程就是:发布者发布消息,然后订阅者订阅发布者的话题,双方即可实现通讯。

依据这个原理,我们可以通过python来实现这一过程,但是首先需要准备两个东西!

1.需要下载emqx的zip包zip包下载点击即可

注意:有些电脑可能下载5.0.x版本会启动失败,建议直接下载4.4.x版本。

2.python需要安装依赖库,在cmd中输入:

pip install paho-mqtt

网络也有一些镜像,可以用镜像下载更快!

准备完以上工具便可开始:

        先要在本地启动emqx的服务:只需要将上面下载的zip包解压之后,通过cmd进入该解压后的路径,然后进入到里面的/bin路径下,然后输入指令:

emqx start

         当完成流程不想再操作后,可以使用以下命令关闭该服务:

emqx stop

EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

 这样即成功!

可以打开浏览器进行查看:在输入栏中输入:127.0.0.1:18083,后输入账号密码,默认为:{账号:admin,密码:public}(可能会让你更改密码,根据提示更改即可)而后会进入以下界面:

EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

 到这里就可以开始我们的python编码了,以下为python的完整编码:

分两个板块:

1.发布者:

import random
import time
import paho.mqtt.client as mqtt_client
topic = "/python/mqtt"//创建话题,可以自定义
client_id = f'python-mqtt-{random.randint(0, 100)}'//获取随机id(可以自行选择)
def publish(client)://发布的核心方法
    msg_count = 0
    while True:
        time.sleep(1)
        msg = f"messages: {msg_count}"//发送的消息(message)
        result = client.publish(topic, msg)//调用库中方法public()进行发布,会返回一个列表
        status = result[0]//列表的第一个元素返回的是请求是否成功,然后作判断
        if status == 0:
            print(f"Send `{msg}` to topic `{topic}`")
        else:
            print(f"Failed to send message to topic {topic}")
        msg_count += 1

def connect_mqtt():
    def on_connect(client, userdata, flags, rc):
        if rc == 0:
            print("Connected to MQTT Broker!")
        else:
            print("Failed to connect, return code %d\n", rc)
    client = mqtt_client.Client(client_id)
    client.on_connect = on_connect
    client.connect(host='127.0.0.1', port=1883)//此处不需要更改,都为默认
    return client


def run():
    client = connect_mqtt()
    client.loop_start()
    publish(client)

if __name__ == '__main__':
    run()

2.订阅者

import random
from paho.mqtt import client as mqtt_client

topic = "/python/mqtt"
client_id = f'python-mqtt-{random.randint(0, 100)}'


def connect_mqtt() -> mqtt_client:
    def on_connect(client, userdata, flags, rc):
        if rc == 0:
            print("Connected to MQTT Broker!")
        else:
            print("Failed to connect, return code %d\n", rc)

    client = mqtt_client.Client(client_id)
    client.on_connect = on_connect
    client.connect(host='127.0.0.1', port=1883)
    return client


def subscribe(client: mqtt_client):
    def on_message(client, userdata, msg):
        print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")

    client.subscribe(topic)
    client.on_message = on_message


def run():
    client = connect_mqtt()//创建mqtt对象
    subscribe(client)
    client.loop_forever()//表示永久等待发布者发布消息


if __name__ == '__main__':
    run()

然后依次运行以上模块,可以看到以下结果:

发布者: 

EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

订阅者:

 EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

 还可以通过127.0.0.1:18083来看到两个接入成员:

EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程

         以上便是对emqx的一些基本操作的演示和介绍,当然通过emqx还可以实现更多方式的互联,需要我们去探索和实现。还可以是不同地设备,如树莓派,esp系列,让单片机开发的成本可以减少服务器的支出,对学习起到帮助作用。文章来源地址https://www.toymoban.com/news/detail-423542.html

到了这里,关于EMQX(MQTT)----基本用法以及使用Python程序进行模拟流程的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Java 使用 EMQX 实现物联网 MQTT 通信

    EMQX 实现物联网 MQTT 通信。物联网的 MQ 消息通信方式。 MQTT(Message Queuing Telemetry Transport, 消息队列遥测传输协议),是一种基于发布/订阅(publish/subscribe)模式的\\\"轻量级\\\"通讯协议,该协议构建于TCP/IP协议上,由IBM在1999年发布。MQTT最大优点在于,可以以极少的代码和有限的带宽,

    2024年02月03日
    浏览(39)
  • 微信小程序+MQTT(emqx)+Ngnix解决真机调试持续重新连接问题

       最近想用微信小程序订阅MQTT的消息,但是想要用MQTT,微信小程序不允许用ip去连接,必须用经过备案的域名,然后就开始了艰辛的合法域名探索之路。   我现在申请的是阿里云的免费域名,1年。实际上付费的也不贵,每年几十块的也有。详细教程参考阿里云的官方教

    2024年02月03日
    浏览(40)
  • 【Python beautifulsoup】详细介绍beautifulsoup库的使用方法,包括安装方式、基本用法、常用方法和技巧,以及结合lxml和parsel的具体使用场景和区别。

    Python beautifulsoup库是一个强大的Web抓取和解析库,它提供了丰富的功能和简单易用的API,可以帮助我们处理HTML和XML文档,从中提取数据,进行数据清洗和处理。beautifulsoup库基于Python标准库中的html.parser模块,同时还可以与第三方解析库lxml和parsel配合使用,提供更高效和灵活的

    2024年02月04日
    浏览(63)
  • MQTT协议-EMQX技术文档-spring-boot整合使用--发送接收-消费

    MQTT(Message Queuing Telemetry Transport)是一种基于发布/订阅模式的通信协议,它与MQ(Message Queue,消息队列)有一定的关联,但二者并不完全相同。 MQTT是一种轻量级的通信协议,专门为在物联网(IoT)设备之间的消息传递而设计。它运行在TCP协议之上,以“发布-订阅”模式进行

    2024年02月12日
    浏览(38)
  • pytest中conftest的用法以及钩子基本使用

    conftest是pytest进阶中的高级应用,最近正好用到这一块儿,研究之后,向大家分享该高级应用。 1.conftest代码块 以全局性使用driver为主,只启动一次浏览器: @pytest.fixture(scope=\\\'session\\\')  # 以此实现多个用例,只启动一次浏览器 def browser ():     global driver     driver = None  # 需要

    2024年02月16日
    浏览(40)
  • 使用合宙Air724UG物联网模块发送MQTT消息至EMQX服务器 MQTT如何发送消息 AIR724发送MQTT至腾讯云 腾讯云接收MQTT消息

    在上一篇关于物联网的文章中介绍了如何建立一个MQTT的EMQX服务器,有需要的同学可以点击查看。在这里服务器的作用相当于建立一个MQTT消息的中转站,消息先发送到服务器中,再在服务器进行转发消息。 那么有了一个转发的平台,如何在嵌入式终端中发送MQTT消息呢,在这

    2024年02月09日
    浏览(58)
  • STM32连接OV2640摄像头串口方式在PyQt5界面上展示视频界面 以及使用MQTT方式进行展示

    STM32连接OV2640 视频源接入到PyQt5界面中 作为AI模型的输入,视频流是非常重要的。在本文中,我们将介绍如何将STM32连接到OV2640摄像头,并将视频流接入到PyQt5界面中。 硬件连接 首先,我们需要将OV2640摄像头连接到STM32上。我们可以使用以下连接方式: OV2640 | STM32 ------|------

    2024年02月06日
    浏览(60)
  • MQTT,EMQX认识,安装,部署

    EMQX ,大规模分布式物联网 MQTT 消息服务器,高效可靠连接海量物联网设备,实时处理分发消息与事件流数据,助力构建关键业务的物联网平台与应用。是一款大规模可弹性伸缩的云原生分布式物联网 MQTT 消息服务器。MQTT 协议,是基于发布/订阅模式的物联网通信协议,凭借

    2024年02月08日
    浏览(40)
  • SpringBoot整合EMQX(MQTT协议)

    原文:springboot当中使用EMQX(MQTT协议) 1.1、MQTT简介 MQTT 全称为 Message Queuing Telemetry Transport(消息队列遥测传输),是一种基于 发布/订阅 模式的 轻量级物联网消息传输协议。IBM 公司的 安迪·斯坦福-克拉克 及 Arcom 公司的 阿兰·尼普 于 1999 年撰写了该协议的第一个版本1,之

    2024年02月08日
    浏览(37)
  • 本地MQTT服务器搭建(EMQX)

    下载地址:EMQ (emqx.com) 打开官网后,选择右边的免费试用按钮 然后单击EMQX Enterprise标签,然后选择下面的EMQX开源版,选择开源版的系统平台为Windows,单击免费下载。 在新页面下单击立即下载 将下载的emqx-5.1.6-windows-amd64.zip解压出来,解压目录不能存在中文、空格、特殊字符

    2024年02月09日
    浏览(45)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包