注意MQTT协议中有三种身份：发布者（Publish）、代理（Broker）（服务器）、订阅者（Subscribe）。首先必须要需要搭建MQTT服务器，才能进行后续发布和订阅代码操作。搭建MQTT服务器ActiveMQ 5 下载地址：http://activemq.apache.org/index.html下载后进入apache-activemq-5.16.0-bin\apache-activemq-5.16.0\bin\win64，在cmd里运行activemq.bat即可启动MQTT服务器。进入http://127.0.0.1:8161/admin/ 账号密码均为admin，若能成功...
import os import time import multiprocessing from logging.handlers import TimedRotatingFileHandler from logging import FileHandler lock = multiprocessing.Lock() class SafeLog(TimedRotatingFileHandler): def __init__(self, *args, **kwargs): super(SafeLog, self).__init__(*args, **kwarg...
