5-python库之-paho mqtt通讯

Posted 2023-04-24

参考技术A 连接调用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接口，如下

[MQTT] 通过阿里云服务器实现MQTT通讯

最近想实现手机app控制一个4G设备操作一个gpio

简单记录步骤如下：

1、打开阿里云官网https://www.aliyun.com/，注册并登录->打开控制台-物联网平台

 

2、创建产品,中间步骤参考如下产品信息

 

 

 

 

3、设置功能定义

 

4、创建两个设备MqttPublish和MqttSubscribe，分别用来手机app连接阿里云服务器发布消息和阿里云服务器对4G设备订阅消息

5、创建完设备后需要分别测试一下，可以用工具mqttfx-1.7.1-windows-x64.exe来实现

 

 

mqttfx-1.7.1-windows-x64.exe地址：

链接：https://pan.baidu.com/s/1Rn3G2zPA21lqXCjK49mixA   提取码：zbxa
MQTT_Password.7z地址：

链接：https://pan.baidu.com/s/17pT68F9-y15nx01e4ojzkw    提取码：5el7

6、使用mqttfx测试

 

 

点击Publish和Subscribe分别设置如下：

/a17zQFxrTGN/MqttPublish/user/update 发布
/a17zQFxrTGN/MqttPublish/user/get 订阅

/sys/a17zQFxrTGN/MqttSubscribe/thing/event/property/post 发布
/sys/a17zQFxrTGN/MqttSubscribe/thing/service/property/set 订阅

 

 7、分别测试成功后，要想两个设备间发送和接收消息，还需要设置“云产品流转”，创建规则为如下即可

 

 8、可以两台电脑分别使用mqttfx，连接设备MqttPublish发布消息，连接MqttSubscribe的订阅消息测试

9、生成设备端代码可以在4G模块中进行测试，我的这个4G设备中已经有mqtt测试代码，这里就不具体说明

 

注意事项：配置工具mqttfx一定要注意字符串别写错，特别是hmacsha1，因为把最后一个1看出l导致折腾了好久，最好直接复制！！！