MQTT配合mysql使用报错AttributeError: 'NoneType' object has no attribute 'read'猜测是多线程的原因,多个线程共享了一个数据库连接解决方法执行sql时加上互斥锁import threading lock = threading.Lock() lock.acquire() cursor.execute(command,data) ...
注意MQTT协议中有三种身份:发布者(Publish)、代理(Broker)(服务器)、订阅者(Subscribe)。首先必须要需要搭建MQTT服务器,才能进行后续发布和订阅代码操作。搭建MQTT服务器ActiveMQ 5 下载地址:http://activemq.apache.org/index.html下载后进入apache-activemq-5.16.0-bin\apache-acti...