Python简单试用MQTT服务器
发布时间：2019-09-13 09:24:56编辑：auto阅读（4120）
前言
经历过各种问题的磨难终于基本搭建完成了自己的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客户端使用
47848
- H3C基本命令大全
46401
- openvpn windows客户端使用
37287
- H3C IRF原理及 配置
34737
- Python exit()函数
29319
- openvpn mac客户端使用
25976
- python全系列官方中文文档
24920
- 1.常用turtle功能函数
19954
- python 获取网卡实时流量
19549
- python 获取Linux和Windows硬件信息
18032
- python3-scipy-ndimage平滑
5795°
- python3-scikit-image平滑去噪
6419°
- python3-PIL非线性噪声平滑
5934°
- python3-Scipy-ndimage进行盒核与高斯核平滑比较
5964°
- python3-PIL高斯模糊滤波器平滑
7070°
- python3-PIL基于盒模糊核均值化平滑
5918°
- python3-PIL线性噪声平滑
5949°
- python3-scikit-image直方图匹配
6442°
- python3-scikit-image对比拉伸和直方图均衡化
6405°
- python3-PIL二值化
7782°
- 姓名：Run
- 职业：谜
- 邮箱：383697894@qq.com
- 定位：上海 · 松江
