1、首先,使用pip install paho-mqtt安装paho-mqtt程序包。
2、一个简单的使用例子如图所示,需要定义on_connect处理函数和on_message处理函数,在on_connect处理函数里可以subscribe。
3、要测试该例子,首先在本地1883端口开了一个mqtt broker。如图是mosquitto。
4、接下来,用MQTT Explorer测试程序的运行效果。如图publish一条消息。
5、可以看到,程序的on_message处理函数成功执行了。
6、如果在on_message处理函数中,publish消息到subscribe的topic下,可陷入无线循环。