pythonqt入门教程(使用python实现mqtt的发布和订阅)
类别:脚本大全 浏览量:963
时间:2021-10-08 00:11:24 pythonqt入门教程
使用python实现mqtt的发布和订阅需要安装的python库
使用python编写程序进行测试mqtt的发布和订阅功能。首先要安装:pip install paho-mqtt
测试发布(pub)
我的mqtt部署在阿里云的服务器上面,所以我在本机上编写了python程序进行测试。
然后在shell里面重新打开一个终端,订阅一个主题为“chat” mosquitto_sub -t chat
在本机上测试远程的mqtt的发布功能就是把自己作为一个发送信息的人,当自己发送信息的时候,所有订阅过该主题(topic)的对象都将收到自己发送的信息。
|
mqtt_client.py # encoding: utf-8 import paho.mqtt.client as mqtt host = "101.200.46.138" port = 1883 def test(): client = mqtt.client() client.connect(host, port, 60 ) client.publish( "chat" , "hello liefyuan" , 2 ) # 发布一个主题为'chat',内容为‘hello liefyuan'的信息 client.loop_forever() if __name__ = = '__main__' : test() |
发布/订阅测试
|
# -*- coding: utf-8 -*- import paho.mqtt.client as mqtt mqtthost = "101.200.46.138" mqttport = 1883 mqttclient = mqtt.client() # 连接mqtt服务器 def on_mqtt_connect(): mqttclient.connect(mqtthost, mqttport, 60 ) mqttclient.loop_start() # publish 消息 def on_publish(topic, payload, qos): mqttclient.publish(topic, payload, qos) # 消息处理函数 def on_message_come(lient, userdata, msg): print (msg.topic + " " + ":" + str (msg.payload)) # subscribe 消息 def on_subscribe(): mqttclient.subscribe( "/server" , 1 ) mqttclient.on_message = on_message_come # 消息到来处理函数 def main(): on_mqtt_connect() on_publish( "/test/server" , "hello python!" , 1 ) on_subscribe() while true: pass if __name__ = = '__main__' : main() |
注解函数:
|
client.connect( self , host, port, keepalive, bind_address) client.publish( self , topic, payload, qos, retain) client.subscribe( self , topic, qos) |
测试订阅(sub)
在本机上编写程序测试订阅功能,就是让自己的程序作为一个接收者,同一个主题没有发布(pub)信息的时候,就自己一直等候。
|
# encoding: utf-8 import paho.mqtt.client as mqtt def on_connect(client, userdata, flags, rc): print ( "connected with result code " + str (rc)) client.subscribe( "chat" ) 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( "www.liefyuan.top" , 1883 , 60 ) client.loop_forever() |
总结
以上所述是小编给大家介绍的使用python实现mqtt的发布和订阅,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对开心学习网网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!原文链接:https://blog.csdn.net/xxmonstor/article/details/80479851
您可能感兴趣
- python怎么实现链表(Python实现数据结构线性链表单链表算法示例)
- python3爬虫代码(Python3爬楼梯算法示例)
- python能操作微信定时发消息(python给微信好友定时推送消息的示例)
- python数据结构全攻略(详解python数据结构和算法)
- python 串口图形化(python使用MQTT给硬件传输图片的实现方法)
- python中的reload(搞清楚 Python traceback的具体使用方法)
- python语言提供的3种基本数据类型(详解Python3 基本数据类型)
- python初学篇元组(元组列表字典莫烦python基础)
- python初学者必备函数(Python小白必备的8个最常用的内置函数推荐)
- python教程第126节(Python 学习教程之networkx)
- python3web编程基础教程(python初学者,用python实现基本的学生管理系统python3代码实例)
- python多线程多种方法(详解python多线程之间的同步一)
- pythonlist列表讲解(Python中将两个或多个list合成一个list的方法小结)
- python下的sql处理(python中aioysql异步操作MySQL的方法)
- python如何用md5作为文档名(Python生成MD5值的两种方法实例分析)
- pythonprint什么意思啊(Python中print和return的作用及区别解析)
- 一天一冲也算表 麦步,一款待机 21 天的智能手表体验评测(一天一冲也算表)
- 魅族智能手表充电座曝光 Type-C 接口,线座分离设计(魅族智能手表充电座曝光)
- 华为 Watch GT2 Pro 智能手表曝光,新增支持无线充电(华为WatchGT2)
- vivo首款智能手表来了 也有血氧饱和度监测,一次充电18天续航(vivo首款智能手表来了)
- 你知道 七夕 的真正含义吗(你知道七夕的真正含义吗)
- 七夕的寓意(七夕的寓意)
热门推荐
- python提取json数据(Python爬取数据保存为Json格式的代码示例)
- python中怎样使用列表的sort方法(详解python中sort排序使用)
- php最好的探针(php探针不显示内存解决方法)
- dedecms目录说明(DedeCms获取当前页面URL地址的实现方法)
- phplaravel怎么优化(laravel执行php artisan migrate报错的解决方法)
- dedecms中的有些功能如何修改(Dedecms 生成速度慢 的解决办法)
- php 数据库查询并写入(PHP实现单条sql执行多个数据的insert语句方法)
- dedecms使用安装(使用dedecms搭建自己的本地网站全程图解)
- SQL SERVER中Merge语句的用法
- css用什么设置透明度(详解css透明度之rgba和opacity的区别及兼容)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9