RTT RA2L1 MQTT网络温湿度采集-德赢Vwin官网网

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);
}
}