Python简单试用MQTT服务器
发布时间：2019-09-13 09:24:56编辑：auto阅读（4816）
前言
经历过各种问题的磨难终于基本搭建完成了自己的MQTT服务器,接下来我就赶紧写个Python程序测试下.
安装
这里采用paho.mqtt.python编写程序,详情参阅这里
打开powershell,执行pip install paho-mqtt安装模块
程序
# coding=utf-8
import json
import threading
import paho.mqtt.client as mqtt
# 当连接上服务器后回调此函数
import time
from my_lib.code_handle.code_handle import auto_code
from windows_info.read_info import Win_psutil
class MqttClient:
client = mqtt.Client('tester')
def __init__(self, host, port):
self._host = host
self._port = port
self.client.on_connect = self._on_connect # 设置连接上服务器回调函数
self.client.on_message = self._on_message # 设置接收到服务器消息回调函数
def connect(self, username='tester', password='tester'):
self.client.username_pw_set(username, password)
self.client.connect(self._host, self._port, 60) # 连接服务器,端口为1883,维持心跳为60秒
def publish(self, topic, data):
self.client.publish(topic, data)
def loop(self, timeout=None):
thread = threading.Thread(target=self._loop, args=(timeout,))
# thread.setDaemon(True)
thread.start()
def _loop(self, timeout=None):
if not timeout:
self.client.loop_forever()
else:
self.client.loop(timeout)
def _on_connect(self, client, userdata, flags, rc):
print("\nConnected with result code " + str(rc))
client.subscribe("test-0")
def _on_message(self, client, userdata, msg): # 从服务器接受到消息后回调此函数
print "\n主题:" + auto_code(str(msg.topic)) + " 消息:" + auto_code(str(msg.payload))
def _is_json(self, data):
try:
json.loads(data)
except ValueError:
return False
return True
def publish_loop(self):
pass
if __name__ == '__main__':
host=None
client = MqttClient(host, 1883)
client.connect('tester','tester')
client.publish('test-0', '我上线啦!')
client.loop()
wp = Win_psutil()#自己定义的一个类
while True:
data_json=wp.auto_json()#方法返回一个包含CPU和进程信息的JSON字符串
client.publish('test-0',data_json)
time.sleep(2)
这里自己封装了类,主要功能是连上服务器订阅默认主题,接收到消息即打印出来.
在主程序中先实例化类,接着使用默认用户名与密码登陆,在主题"test-0上"发布信息,接着定时将打包成JSON信息的数据发布到"test-0"这个主题
上一篇： python做全文检索引擎
下一篇： Debian下如何更新Python
- openvpn linux客户端使用
52218
- H3C基本命令大全
52126
- openvpn windows客户端使用
42289
- H3C IRF原理及 配置
39156
- Python exit()函数
33659
- openvpn mac客户端使用
30615
- python全系列官方中文文档
29300
- python 获取网卡实时流量
24275
- 1.常用turtle功能函数
24167
- python 获取Linux和Windows硬件信息
22532
- LangChain 1.0-Agent中间件-实现闭环(批准-编辑-拒绝动作)
108°
- LangChain 1.0-Agent中间件-汇总消息
106°
- LangChain 1.0-Agent中间件-删除消息
114°
- LangChain 1.0-Agent中间件-消息压缩
104°
- LangChain 1.0-Agent中间件-多模型动态选择
166°
- LangChain1.0-Agent-部署/上线(开发人员必备)
324°
- LangChain1.0-Agent-Spider实战(爬虫函数替代API接口)
365°
- LangChain1.0-Agent(进阶)本地模型+Playwright实现网页自动化操作
366°
- LangChain1.0-Agent记忆管理
344°
- LangChain1.0-Agent接入自定义工具与React循环
382°
- 姓名：Run
- 职业：谜
- 邮箱：383697894@qq.com
- 定位：上海 · 松江
