13.6.5 MQTT测试程序上机实验
把mqtt_test、paho.mqtt.c.tar.bz2放到Ubuntu上同一个目录下。
1.编译paho库
在Ubuntu下执行如下命令：
$ tar xjf paho.mqtt.c.tar.bz2$ cd paho.mqtt.c
修改CMakeLists.txt，在最前面增加如下内容：
set(CMAKE_SYSTEM_NAME Linux)set(CMAKE_SYSTEM_PROCESSOR arm)SET(CMAKE_C_COMPILER aarch64-poky-linux-gcc)SET(CMAKE_CXX_COMPILER aarch64-poky-linux-g++)set(CMAKE_SYSROOT /opt/remi-sdk/sysroots/aarch64-poky-linux)set(CMAKE_FIND_ROOT_PATH_MODE_PROGRAM NEVER)set(CMAKE_FIND_ROOT_PATH_MODE_LIBRARY ONLY)set(CMAKE_FIND_ROOT_PATH_MODE_INCLUDE ONLY)set(CMAKE_FIND_ROOT_PATH_MODE_PACKAGE ONLY)
然后执行如下命令编译：
$ source /opt/remi-sdk/environment-setup-aarch64-poky-linux$ mkdir build$ cd build$ cmake ../ -DCMAKE_INSTALL_PREFIX=output$ make$ make install
如果一切顺利，会在build目录下生成一个output目录（有些错误信息提示权限问题，无关紧要），里面有很多库文件。内容如下：
$ ls output/bin include lib share
把头文件、库文件复制到工具链里：
$ sudo cp -rf output/include/* /opt/remi-sdk/sysroots/aarch64-poky-linux/usr/include/$ sudo cp -rfd output/lib/* /opt/remi-sdk/sysroots/aarch64-poky-linux/usr/lib64/
把output目录压缩，上传到开发板：
$ tar cjf output.tar.bz2 output/$ scp output.tar.bz2 root@192.168.5.9:/mnt
在开发板里解压output.tar.bz2文件，复制库文件到“/usr/lib64”，命令如下：
2.编译测试程序
在Ubuntu上执行如下命令：
$ source /opt/remi-sdk/environment-setup-aarch64-poky-linux$ cd mqtt_test$ make$ scp mqtt_test root@192.168.5.9:/mnt
3.测试
按照《13.6.3 PC MQTT工具使用》，先启动MQTT服务软件，然后再启动MQTTX，如下配置、连接：
在MQTTX里订阅主题为“/iot/up”的消息，发送主题为“/iot/down”的消息，如下图所示：
最后，在开发板上执行mqtt_test程序，如下：
13.7 MQTT程序开发
源码为：
13.7.1 程序流程
程序主要有2大功能：
①根据配置文件，周期性地读“点”、发布消息
②订阅消息，根据消息写“点”
这些功能可以细分如下：
①通过RPC获得MQTT信息
②通过RPC获得“点”的信息
③连接MQTT Broker
④订阅消息
⑤周期性地读“点”，发布消息
在程序运行过程中，用户可能使用前台程序修改了配置，比如修改了MQTT Broker的信息、增加、删除的点，并且程序运行过程中可能发生错误。这就需要重新运行程序：重新运行上述5个细分步骤。
本程序使用状态机来实现，有如下状态：
在main函数中，根据当前状态进行对应处理。
13.7.2 监测配置文件
前台程序会导致配置文件被修改，需要监测配置文件是否发生了变化。使用的函数在cfg.c里，它们的代码在《13.4.2 配置文件的操作》讲解过。
main.c的main函数里，调用的代码如下：
13.7.3 初始化RPC连接
需要使用RPC调用得到MQTT信息、得到点的信息。所以第1个状态代码如下：
13.7.4 获取MQTT信息
要进行MQTT连接，需要获得MQTT信息，代码如下：
13.7.5 获取点的信息
后续要读点、上报点的信息，所以需要使用RPC调用获得、记录所有点的信息，代码如下：
13.7.6 连接MQTT
代码如下：
13.7.7 订阅消息
代码如下：
13.7.8 发布消息
发布消息时，如果没有错误，则已知保存在本状态：循环发布消息。代码如下：
13.7.9 订阅消息的处理
在前面设置了MQTT回调函数，当接收到订阅的消息时，使用如下函数处理：
①解析接收到的信息，根据它找到“点”
②写点
13.7.10 错误处理
如果发生的错误累计达到10次，或则配置文件发生了变化，则重新处理：
需要产品及方案支持
请扫码登记
如您在使用瑞萨MCU/MPU产品中有任何问题，可识别下方二维码或复制网址到浏览器中打开，进入瑞萨技术论坛寻找答案或获取在线技术支持。
https://community-ja.renesas.com/zh/forums-groups/mcu-mpu/
未完待续
推荐阅读
框架设计 - RZ MPU工业控制教程连载（48）
LVGL相关与JSON-RPC相关 - RZ MPU工业控制教程连载（49）
后台程序开发相关操作 - RZ MPU工业控制教程连载（50）
需要产品及方案支持
请扫码登记
