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)