如何实现RTT RA2L1 MQTT网络温湿度采集的设计呢

　　4、编写DA16200.c的函数：
　　主要的思路是先初始化at_clinet客户端，根据da16200的mqtt命令初始化。如果注册成功，向服务器订阅与发布主题，详见代码：
　　/*
　　* Copyright （c） 2006-2021， RT-Thread Development Team
　　*
　　* SPDX-License-Identifier： Apache-2.0
　　*
　　* Change Logs：
　　* Date Author Notes
　　* 2023-02-24 Administrator the first version
　　*/
　　#include 《stdlib.h》
　　#include 《string.h》
　　#include 《rtthread.h》
　　#include 《at.h》
　　// #ifndef ULOG_USING_SYSLOG
　　//#define LOG_TAG “AT_DA16200”
　　//#define LOG_LVL LOG_LVL_DBG
　　//#include 《ulog.h》
　　//#else
　　//#include 《syslog.h》
　　//#endif /* ULOG_USING_SYSLOG */
　　/* 初始化 at_client */
　　/* 设置当前 AT 客户端最大支持的一次接收数据的长度 */
　　#define AT_CLIENT_RECV_BUFF_LEN 512
　　#define AT_CLIENT_DEVICE_NAME “uart0”
　　#define AT_WAITE_OK_MAXTIME 3000
　　#define WIFI_SSID HUAWEI-H10R9U
　　#define WIFI_PWD 18977381885@
　　#define AT_ADDR_LEN 32
　　static rt_err_t wifi_connect_state = -1;
　　char ip［AT_ADDR_LEN］ = {0};
　　char gateway［AT_ADDR_LEN］ = {0}， netmask［AT_ADDR_LEN］ = {0};
　　static void urc_conn_func（struct at_client *client ，const char *data， rt_size_t size）
　　{
　　/* WIFI 连 接 成 功 信 息 */
　　rt_kprintf（“AT Server device WIFI connect success！”）;
　　wifi_connect_state = RT_EOK;
　　}
　　static void urc_recv_func（struct at_client *client ，const char *data， rt_size_t size）
　　{
　　/* 接收到服务器发送数据 */
　　char *ptr;
　　char *p;
　　rt_kprintf（“AT Client receive AT Server data！”）;
　　rt_kprintf（“%s”，data）;
　　ptr = strtok（data， “：”）;
　　ptr = strtok（NULL， “，”）;
　　while （ptr ！= NULL） {
　　rt_kprintf（“ptr=%sn”， ptr）;
　　ptr = strtok（NULL， “，”）;
　　}
　　}
　　int da16200_mqtt_pub（char *msg）
　　{
　　int result = RT_EOK;
　　at_response_t resp = RT_NULL;
　　if（wifi_connect_state ！= RT_EOK）
　　{
　　rt_kprintf（“MQTT_client not ready！”）;
　　return -1;
　　}
　　resp = at_create_resp（256， 0， rt_tick_from_millisecond（5000））;
　　if （resp == RT_NULL）
　　{
　　rt_kprintf（“No memory for response structure！”）;
　　return -2;
　　}
　　result = at_exec_cmd（resp， “AT+NWMQMSG=‘%s’”，msg）;
　　if（resp 《 0）
　　{
　　rt_kprintf（“Pub msg ERRO！ cord：%d”， result）;
　　}
　　at_delete_resp（resp）;
　　return result;
　　}
　　static void urc_func（struct at_client *client ，const char *data， rt_size_t size）
　　{
　　/* 设备启动信息 */
　　rt_kprintf（“AT Server device startup！”）;
　　rt_kprintf（“%s”，data）;
　　}
　　static struct at_urc urc_table［］ = {
　　{“+NWMQCL:1”， “rn”， urc_conn_func}，
　　{“+NWMQMSG：”， “rn”， urc_recv_func}，
　　{“RDY”， “rn”， urc_func}，
　　};
　　int at_client_port_init（void）
　　{
　　/* 添加多种 URC 数据至 URC 列表中，当接收到同时匹配 URC 前缀和后缀的数据，执行 URC 函数 */
　　at_set_urc_table（urc_table， sizeof（urc_table） / sizeof（urc_table［0］））;
　　return RT_EOK;
　　}
　　int at_client_16200_mqtt_init（void）
　　{
　　int result = RT_EOK;
　　at_response_t resp = RT_NULL;
　　/* 创建响应结构体，设置最大支持响应数据长度为 256 字节
　　（最大响应长度用户根据实际需求自定义），响应数据行数无限制，超时时间为 5 秒 */
　　resp = at_create_resp（256， 0， rt_tick_from_millisecond（5000））;
　　if （resp == RT_NULL）
　　{
　　rt_kprintf（“No memory for response structure！”）;
　　return -2;
　　}
　　result = at_client_init（AT_CLIENT_DEVICE_NAME， AT_CLIENT_RECV_BUFF_LEN）;
　　if（result ！= RT_EOK）
　　{
　　rt_kprintf（“at_clinet init erro %d”，result）;
　　return result;
　　}
　　/* 等待AT OK */
　　result = at_client_wait_connect（AT_WAITE_OK_MAXTIME）;
　　if（result ！= RT_EOK）
　　{
　　rt_kprintf（“client to da16200 at timeout %d”，result）;
　　return result;
　　}
　　/* 设置回显 */
　　if（at_exec_cmd（resp， “ATE”） ！= RT_EOK）
　　{
　　rt_kprintf（“AT client send ATE failed，response error！”）;
　　return -RT_ERROR;
　　}
　　/* 解释返回显状态 如果返回是on 则再发一条关闭 */
　　if（at_resp_get_line_by_kw（resp， “on”） ！= NULL）
　　{
　　at_exec_cmd（resp， “ATE”）;
　　}
　　/* 设置 station模式 */
　　if（at_exec_cmd（resp， “AT+WFMODE=0”） ！= RT_EOK）
　　{
　　rt_kprintf（“AT client send AT+WFMODE failed，response error！”）;
　　return -RT_ERROR;
　　}
　　/* 连接到 ap */
　　if（at_exec_cmd（resp， “AT+WFJAPA=ssid，pwd”） ！= RT_EOK）
　　{
　　rt_kprintf（“AT client send AT+WFWFJAPA failed，response error！”）;
　　return -RT_ERROR;
　　}
　　rt_thread_delay（2000）;
　　/* 查看IP服务器 */
　　if（at_exec_cmd（resp， “AT+NWIP”） ！= RT_EOK）
　　{
　　rt_kprintf（“AT client send AT+NWIP failed，response error！”）;
　　return -RT_ERROR;
　　}
　　rt_thread_delay（1000）;
　　//LOG_D（“recv：%s，recv line：%d”，resp-》buf，resp-》line_num）;
　　if（at_resp_parse_line_args（resp，2，“%*［^，］，%［^，］”，&ip）》0）
　　{
　　rt_kprintf（“ip：%s ”，ip）;
　　}
　　else{
　　rt_kprintf（“NWIP erro”）;
　　return -RT_ERROR;
　　}
　　/* 连接MQTT服务器*/
　　if（at_exec_cmd（resp， “AT+NWMQBR=%s，%d”，“192.168.3.192”，1883） ！= RT_EOK）
　　{
　　rt_kprintf（“AT client send AT+NWMQBR failed，response error！”）;
　　return -RT_ERROR;
　　}
　　/* 设置订阅主题 */
　　if（at_exec_cmd（resp， “AT+NWMQTS=%d，%s”，1，“lugl_sub”） ！= RT_EOK）
　　{
　　rt_kprintf（“AT client send AT+NWMQTS failed，response error！”）;
　　return -RT_ERROR;
　　}
　　/* 设置发布主题 */
　　if（at_exec_cmd（resp， “AT+NWMQTP=%s”，“lugl_pub”） ！= RT_EOK）
　　{
　　rt_kprintf（“AT client send AT+NWMQTP failed，response error！”）;
　　return -RT_ERROR;
　　}
　　at_client_port_init（）;
　　/* 使能MQTT */
　　if（at_exec_cmd（resp， “AT+NWMQCL=1”） ！= RT_EOK）
　　{
　　rt_kprintf（“AT client send AT+NWMQCL failed，response error！”）;
　　return -RT_ERROR;
　　}
　　/* 删 除 服 务 器 响 应 结 构 体 */
　　at_delete_resp（resp）;
　　return RT_EOK;
　　}
　　hal_entry.c：
　　extern struct hs300x_device temp_humi_dev;
　　void hal_entry（void）
　　{
　　float temp_f，humi_f;
　　char mqtt_send_buf［128］ = {0};
　　rt_kprintf（“nHello RT-Thread！n”）;
　　rt_uint32_t led1_pin = rt_pin_get（LED1_PIN）;
　　at_client_16200_mqtt_init（）;
　　while （1）
　　{
　　rt_pin_write（led1_pin， PIN_HIGH）;
　　rt_thread_mdelay（500）;
　　rt_pin_write（led1_pin， PIN_LOW）;
　　rt_thread_mdelay（500）;
　　hs300x_read_data（&temp_humi_dev， &humi_f， &temp_f）;
　　rt_sprintf（mqtt_send_buf，“{”temp“：”%d.%2d“，”humi“：”%d.%2d“}”，（int）temp_f，（int）（temp_f*100）%100，（int）humi_f，（int）（humi_f*100）%100）;
　　da16200_mqtt_pub（mqtt_send_buf）;
　　// rt_kprintf（“HUMI： %d.%2dn”， （int）humi_f， （int）（humi_f*100）%100）;
　　// rt_kprintf（“HUMI： %d.%2dn”， （int）temp_f， （int）（temp_f*100）%100）;
　　}
　　}
　　实现在的效果：

　　打开mqtt客户端，收到数据

　　【项目总结】作为国产的RT-Thread 实时操作系统，生态系统越来越丰富。同时也有自己的RT-Thread Studio IDE来实现图形化的配置，特别是集合了RASC的图形化配置系统。使得入门非常容易。
　　【有待改善的地方】
　　1、FSP的更新不向前兼容，导致会出现很多问题，这样新入门的朋友，可能被难倒在起点之处。
　　2、包更新后会覆盖掉原来的一起代码，如果不做备份，非常麻烦。
　　总之，通过这次DIY项目，加深了瑞萨+RT-Thread的编程印象，以后会经常关注RTT，同时也会贡献自己的力量。



原作者：Lu_盼盼