5-python库之-paho mqtt通讯

Python027

5-python库之-paho mqtt通讯,第1张

连接调用connect接口,然后调用loop_forever后就开始跑了

connect的第三个参数为mqtt的心跳时间

on_connect 和 on_disconnect 为连接成功和断开的回掉函数

添加证书,只需要在调用connect函数之前,添加下面两条内容即可。

设置账号密码,在调用connect函数之前,添加下面一条内容即可。

设置WILL主题,在调用connect函数之前,使用will_set接口设置,添加will主题和will主题的payload

主题的订阅使用subscribe接口,一般在on_connect回调函数里面设置

订阅完主题,我们的目的就是要收到订阅的数据,所以需要设置接收数据的回调函数on_message

,只要有数据发送过来on_message就会收到。

发布使用publish接口,如下

配置文件路径 /etc/mosquitto/mosquitto.conf

启动服务进程mosquitto,除了可能用命令行参数,还要以通过配置文件,配置文件更为详细。

可以指定ip地址和端口,还可以使用用户名和密码!