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,同时也会贡献自己的力量。
-
PIN管
+关注
关注
0文章
36浏览量
6324 -
回调函数
+关注
关注
0文章
87浏览量
11554 -
MQTT协议
+关注
关注
0文章
97浏览量
5362 -
Uart串口
+关注
关注
0文章
29浏览量
6811 -
RTThread
+关注
关注
8文章
132浏览量
40861
发布评论请先 登录
相关推荐
评论