RTT RA2L1 MQTT网络温湿度采集

1、添加uart0,波特率为默认的115200。串口回调函数为默认的user_uart_callbakc,TXD、RXD 为P101、P100，刚好适配PMOD2（J7),来接DA16200。

2、添加AT—client包

3、打开uart0:

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
  #include
  #include
  #include
  // #ifndef ULOG_USING_SYSLOG
  //#define LOG_TAG "AT_DA16200"
  //#define LOG_LVL LOG_LVL_DBG
  //#include
  //#else
  //#include
  //#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_f100)%100,(int)humi_f,(int)(humi_f100)%100);
da16200_mqtt_pub(mqtt_send_buf);
// rt_kprintf("HUMI: %d.%2dn", (int)humi_f, (int)(humi_f100)%100);
// rt_kprintf("HUMI: %d.%2dn", (int)temp_f, (int)(temp_f100)%100);
}
}

实现在的效果：

打开mqtt客户端，收到数据

【项目总结】

作为国产的RT-Thread 实时操作系统，生态系统越来越丰富。同时也有自己的RT-Thread Studio IDE来实现图形化的配置，特别是集合了RASC的图形化配置系统。使得入门非常容易。

【有待改善的地方】

1、FSP的更新不向前兼容，导致会出现很多问题，这样新入门的朋友，可能被难倒在起点之处。
2、包更新后会覆盖掉原来的一起代码，如果不做备份，非常麻烦。
总之，通过这次DIY项目，加深了瑞萨+RT-Thread的编程印象，以后会经常关注RTT，同时也会贡献自己的力量。