python中的mqtt/udp实现

mqttudp的Python项目详细描述


mqtt/udp python(3.x)实现

您还可以检查其他语言的实现-https://github.com/dzavalishin/mqtt_udp

dirs

python语言中的mqtt udp-mqtt/udp库

示例-库使用示例

sh-启动双向mqtt/udp到mqtt代理网关的shell脚本 mqttudpgate.service-网关的Unix SystemCtl服务定义

示例

pub.py-发送一条消息

dump.py-打印所有mqtt/udp通信量 listen.py-仅在内容更改时打印数据包

mqtt_udp_to_openhab.py-将所有数据转换为openhab rest api openhab_to_udp.py-将所有数据从openhab rest api(默认站点地图)转换为mqtt/udp

seq_storm_send.py-尽快发送按顺序编号的数据包 seq_storm_check.py-检查数据包的顺序性和计算速度

py-在mqtt/udp和传统mqtt之间转换数据 mqtt_broker_to_udp.py-单向,到mqtt/udp mqtt_udp_to_broker.py-单向,来自mqtt/udp

random_to_udp.py-使用随机数生成流量

ping.py-发送ping并打印回复。并不是所有的实现都响应ping。

可能的要求

一些代码示例可能需要paho mqtt和websocket客户机

用法

发送数据:

importmqttudp.engineif__name__=="__main__":mqttudp.engine.send_publish("test_topic","Hello, world!")

监听数据:

importmqttudp.enginedefrecv_packet(ptype,topic,value,pflags,addr):ifptype!="publish":print(ptype+", "+topic+"\t\t"+str(addr))returnprint(topic+"="+value+"\t\t"+str(addr))if__name__=="__main__":mqttudp.engine.listen(recv_packet)

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java play框架内容类型拆分   java在Hibernate 5中实现NamingStrategy(使自动生成的列名大写)   java Grails智能地获取war baseUrl?   java如何在listview布局中显示结果?   为什么通过python调用my api会给出无效的日期格式,而在java中则不会(使用相同的字符串)   java如何模拟多端口异常   java gradle正在从artifactory下载旧版本的jars,而不是最新版本   java类导入到jsp并创建对象问题   java如何改进对日志文件的数据处理   摇摆系统。在java中退出(0)   如何在SeleniumWebDriverJava中从文件夹上载图像   python如何使用Jython向java应用程序发送击键   java应用程序在尝试打开google地图时已停止   通过HTTP代理socketJava TCP数据包   在LWJGL中启用照明时,java面为黑色/黑色   web服务Java在端点中找不到接口   使用EJB的java Spring安全性   将hibernate 3更新为hibernate 5后发生java SQLQuery列表强制转换异常