RT-Thread-RTT RA2L1 MQTT网络温湿度采集RT-Thread问答社区

RTT RA2L1 MQTT网络温湿度采集

发布于 2023-02-24 21:37:37 浏览：583 订阅该版

https://club.rt-thread.org/ask/article/4083cfdf3ad1c4a9.html
在这一篇的基础之上，添加串口，AT-Client软件包
1、添加uart0,波特率为默认的115200。串口回调函数为默认的user_uart_callbakc,TXD、RXD 为P101、P100，刚好适配PMOD2（J7),来接DA16200。
![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230224/692a9bec2566ce43e3bc799a601097ce.png.webp)
2、添加AT—client包
![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230224/02dc3f594bfd523b439ccc381f046bd6.png.webp)
3、打开uart0:
![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230224/7f97de81d8a88d26750ab497d743657f.png)
4、编写DA16200.c的函数：
主要的思路是先初始化at_clinet客户端，根据da16200的mqtt命令初始化。如果注册成功，向服务器订阅与发布主题，详见代码：

```c
/*
 * 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=%s\n", 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",            "\r\n", urc_conn_func},
    {"+NWMQMSG:",         "\r\n",  urc_recv_func},
  {"RDY",              "\r\n",  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:

```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.%2d\n", (int)humi_f, (int)(humi_f*100)%100);
//        rt_kprintf("HUMI: %d.%2d\n", (int)temp_f, (int)(temp_f*100)%100);
    }
}
```
实现在的效果：

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20230224/a539d7a59feddbc636ed088990d6716c.png.webp)
打开mqtt客户端，收到数据

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