【睿赛德 RW007 WiFi 模块试用连载】RW007 WIFI模块联网与使用（二）

ti

《嵌入式 - 模块》RW007 WIFI模块联网与使用（一）

4 DHT11获取温湿度4.1 DHT11获取温湿度

RT-Thread提供了DHT11的驱动软件包，配置如下：

DHT11默认使用的 GPIO是 GPIOB_12。当然这是可以修改的，在 dht11_sample.c 中修改以下代码：

#define DHT11_DATA_PIN GET_PIN(E, 0)

笔者这里使用PE0。

程序编译下载到板卡后，会在串口中每 1s 打印一次温湿度数据。

既然驱动有现成的，那么只需要写个相应的应用代码即可。后文需要将得到温湿度值上传至云端，应用部分的代码如下：

#include "dht11_thread.h"
/* Modify this pin according to the actual wiring situation */
#define DHT11_DATA_PIN GET_PIN(E, 0)
rt_dht11 dht11;
static void read_temp_entry(void *parameter)
{
rt_device_t dev = RT_NULL;
struct rt_sensor_data sensor_data;
rt_size_t res;
rt_uint8_t get_data_freq = 1; /* 1Hz */
dev = rt_device_find("temp_dht11");
if (dev == RT_NULL)
{
return;
}
if (rt_device_open(dev, RT_DEVICE_FLAG_RDWR) != RT_EOK)
{
rt_kprintf("open device failed!n");
return;
}
rt_device_control(dev, RT_SENSOR_CTRL_SET_ODR, (void *)(&get_data_freq));
while (1)
{
res = rt_device_read(dev, 0, &sensor_data, 1);
if (res != 1)
{
rt_kprintf("read data failed! result is %dn", res);
rt_device_close(dev);
return;
}
else
{
if (sensor_data.data.temp >= 0)
{
dht11.temp = (sensor_data.data.temp & 0xffff) >> 0; // get temp
dht11.humi = (sensor_data.data.temp & 0xffff0000) >> 16; // get humi
rt_kprintf("temp:%d, humi:%dn" ,dht11.temp, dht11.humi);
}
}
rt_thread_delay(1000);
}
}
static int dht11_thread(void)
{
rt_thread_t dht11_thread;
dht11_thread = rt_thread_create("dht_tem",
read_temp_entry,
RT_NULL,
1024,
RT_THREAD_PRIORITY_MAX / 2,
20);
if (dht11_thread != RT_NULL)
{
rt_thread_startup(dht11_thread);
}
return RT_EOK;
}
/* 导出到 msh 命令列表中 */
MSH_CMD_EXPORT(dht11_thread, dht11 thread);
static int rt_hw_dht11_port(void)
{
struct rt_sensor_config cfg;
cfg.intf.user_data = (void *)DHT11_DATA_PIN;
rt_hw_dht11_init("dht11", &cfg);
return RT_EOK;
}
INIT_COMPONENT_EXPORT(rt_hw_dht11_port);

复制代码

4.2 DHT11总结

RT-Thread包含DHT11驱动，这里就没有去造轮子了，但是作为学习者，还是要去了解DHT11的原理及具体实现。这部分内容在笔者博客的STM32系列的外设篇已详细阐述，下面就DHT11驱动在RTT中的实现做个总结。

DHT11是采用单总线通讯的传感器，有的设备没有硬件单总线，DHT11的支持包采用 GPIO 模拟单总线时序。DHT11 的一次完整读时序需要 20ms，时间过长，故无法使用关中断或者关调度的方式实现独占 CPU 以保证时序完整正确。因此可能出现读取数据失败的情况。

DHT11的典型电路如下图所示。

DATA 用于微处理器与 DHT11之间的通讯和同步,采用单总线数据格式,一次通讯时间4ms左右,数据分小数部分和整数部分,具体格式在下面说明,当前小数部分用于以后扩展,现读出为零.操作流程如下:

一次完整的数据传输为40bit，高位先出。

数据格式：8bit湿度整数数据+8bit湿度小数数据

+8bi温度整数数据+8bit温度小数数据

+8bit校验和

数据传送正确时校验和数据等于“8bit湿度整数数据+8bit湿度小数数据+8bi温度整数数据+8bit温度小数数据” 所得结果的末8位。

用户MCU发送一次开始信号后，DHT11从低功耗模式转换到高速模式，等待主机开始信号结束后，DHT11发送响应信号，送出40bit的数据，并触发一次信号采集用户可选择读取部分数据。从模式下，DHT11接收到开始信号触发一次温湿度采集，如果没有接收到主机发送开始信号，DHT11不会主动进行温湿度采集.采集数据后转换到低速模式。通讯过程如下图所示：

熟悉RT-Thread系统都知道，RT-Thread将各个模块进行抽象，为上层提供统一的操作接口，依次提高上层代码的可重用性，自然也提高了应用开发效率。RT-Thread的驱动框架：

应用程序通过 I/O 设备管理接口获得正确的设备驱动，然后通过这个设备驱动与底层 I/O 硬件设备进行数据（或控制）交互。

I/O设备模型框架位于硬件和应用程序之间，共分成三层，从上到下分别是 I/O 设备管理层、设备驱动框架层、设备驱动层。

I/O设备管理层实现了对设备驱动程序的封装。应用程序通过 I/O 设备层提供的标准接口访问底层设备，设备驱动程序的升级、更替不会对上层应用产生影响。这种方式使得设备的硬件操作相关的代码能够独立于应用程序而存在，双方只需关注各自的功能实现，从而降低了代码的耦合性、复杂性，提高了系统的可靠性。

l 设备驱动框架层是对同类硬件设备驱动的抽象，将不同厂家的同类硬件设备驱动中相同的部分抽取出来，将不同部分留出接口，由驱动程序实现。

l 设备驱动层是一组驱使硬件设备工作的程序，实现访问硬件设备的功能。它负责创建和注册 I/O 设备，

对于操作逻辑简单的设备，可以不经过设备驱动框架层，直接将设备注册到 I/O 设备管理器中。

更加详细的内容请参看RT-Thread官方手册。

这里主要讲解Sensor驱动，RT-Thread将各个Sensor进行抽象，将不同厂商的Sensor合并为Sensor设备，从而提高了代码的重用性，提高开发效率。既然是总结，这里就只说重点，先看看DHT11设备驱动的时序图：

传感器数据接收和发送数据的模式分为 3 种：中断模式、轮询模式、FIFO模式。在使用的时候，这 3 种模式只能选其一，若传感器的打开参数 oflags 没有指定使用中断模式或者 FIFO 模式，则默认使用轮询模式。

oflags 参数支持下列参数：

#define RT_DEVICE_FLAG_RDONLY 0x001 /* 标准设备的只读模式，对应传感器的轮询模式 */
#define RT_DEVICE_FLAG_INT_RX 0x100 /* 中断接收模式 */
#define RT_DEVICE_FLAG_FIFO_RX 0x200 /* FIFO 接收模式

复制代码

DHT11设备比较简单，采用的是轮询模式，其设备注册函数如下：

result = rt_hw_sensor_register(sensor, name, RT_DEVICE_FLAG_RDONLY, RT_NULL);

复制代码

硬件初始化如下：

static int rt_hw_dht11_port(void)
{
struct rt_sensor_config cfg;
cfg.intf.user_data = (void *)DHT11_DATA_PIN;
rt_hw_dht11_init("dht11", &cfg);
return RT_EOK;
}
INIT_COMPONENT_EXPORT(rt_hw_dht11_port);

复制代码

注意INIT_COMPONENT_EXPORT表示组件初始化，初始化顺序为4。

好了，DHT11就讲到这里了。

自动初始化
5数据上传到OneNET
5.1 OneNET简介

OneNET 平台是中国移动基于物联网产业打造的生态平台，具有高并发可用、多协议接入、丰富 API 支持、数据安全存储、快速应用孵化等特点，同时，OneNET 平台还提供全方位支撑，加速用户产品的开发速度。

OneNET平台是一个基于物联网产业特点打造的生态环境，可以适配各种网络环境和协议类型，现在支持的协议有LWM2M（NB-IOT）、EDP、MQTT、HTTP、MODBUS、JTT808、TCP透传、RGMP等。用户可以根据不同的应用场景选择不同的接入协议。

OneNET 软件包是 RT-Thread 系统针对 OneNET 平台连接的适配，通过这个组件包可以让设备在 RT-Thread 上非常方便的连接 OneNet 平台，完成数据的发送、接收、设备的注册和控制等功能。

OneNET 软件包数据的上传和命令的接收是基于 MQTT 实现的，OneNET 的初始化其实就是 MQTT 客户端的初始化，初始化完成后，MQTT 客户端会自动连接 OneNET 平台。数据的上传其实就是往特定的 topic 发布消息。当服务器有命令或者响应需要下发时，会将消息推送给设备。

获取数据流、数据点，发布命令则是基于 HTTP Client 实现的，通过 POST 或 GET 将相应的请求发送给 OneNET 平台，OneNET 将对应的数据返回，这样，我们就能在网页上或者手机 APP 上看到设备上传的数据了。

下图是应用显示设备上传数据的流程图：

下图是应用下发命令给设备的流程图

5.2准备工作

在 OneNET 云上注册账号

设备接入 OneNET 云之前，需要在平台注册用户账号，OneNET 云平台地址：

https://open.iot.10086.cn

创建产品

账号注册登录成功后，点击开发者中心进入开发者中心界面；

点击创建产品，输入产品基本参数，如下图所示：

产品创建成功之后，可以在开发者中心的公开协议产品中找到刚刚创建的产品，点击产品名，可以看到产品的基础信息（如产品ID，接入协议，创建时间，产品 APIkey 等，后面有用）：

接入设备

在开发者中心左侧设备管理中点击添加设备按钮添加设备。

设备名称我们填入Test。鉴权信息是为了区分每一个不同的设备，如果创建了多个设备，要确保每个设备的鉴权信息都不一样，我们这里填入202106152023，填完之后点击接入设备。

添加APIkey

接入设备之后，可以看到设备列表的界面多了一个设备，设备的右边有一些操作设备的按钮，点击查看详情按钮。

此设备的相关信息就都显示出来了，比如：设备 ID、鉴权信息、设备 APIkey，这些信息需要记下，在ENV配置时会用到。

点击按钮添加 APIkey，APIKey 的名称一般和设备相关联，我们这里填入Test_APIKey，关联设备默认为我们刚刚创建的设备Test。

到此，云端的操作暂时就完成了。

5.3开启OneNET软件包

打开 RT-ThreadSettings，开启 onenet 软件包，勾选onenet 软件包后，进入 onenet 软件包的配置菜单按下图所示配置，里面的信息依据自己的产品和设备的实际情况填写。

【配置说明】

Enable OneNETsample ：开启 OneNET 示例代码

Enable supportMQTT protocol ：开启 MQTT 协议连接 OneNET 支持

Enable OneNETautomatic register device ：开启 OneNET 自动注册设备功能

产品ID ：配置云端创建产品时获取的产品ID

主/生产 Apikey ：配置云端创建产品时获取的产品APIKey

设备ID ：配置云端创建设备时获取的设备ID

身份验证信息：配置云端创建产品时用户自定义的鉴权信息 (每个产品的每个设备唯一)

API密钥：配置云端创建设备时获取的 APIkey

5.4使用 OneNET

生成工程后，我们可以在工程的 onenet 目录下看到onenet_sample.c文件，该文件是 OneNET 软件包的示例展示，主要是展示用户如何使用 OneNET 软件包上传数据和接收命令。

在使用 OneNET 软件包之前必须要先调用onenet_mqtt_init这个命令进行初始化，初始化完成后设备会自动连接 OneNET 平台。

msh />onenet_mqtt_init
[D/onenet.mqtt] Enter mqtt_connect_callback!
[D/[mqtt] ] ipv4 address port: 6002
[D/[mqtt] ] HOST = '183.230.40.39'
[I/ONENET] RT-Thread OneNET package(V1.0.0) initialize success.
msh />[I/[mqtt] ] MQTT server connect success
[D/ onenet.mqtt] Enter mqtt_online_callback!

复制代码

5.4.1上传数据

初始化完成后，用户可以调用onenet_upload_cycle这个命令周期性的往云平台上传数据。输入这个命令后，设备会每隔 5s 向数据流 temperature 上传一个随机值。并将上传的数据打印到 shell 窗口。

msh />onenet_upload_cycle

[D/ onenet.sample] buffer : {"temperature":22}

我们打开 OneNET 平台，在设备列表界面选择刚添加的设备并进入数据流展示页面。

点击temperature数据流左边的小箭头显示数据流信息，我们就可以看到刚刚上传的数据了。

如果用户想往别的数据流发送信息，可以使用以下 API 往云平台上传数据。

onenet_mqtt_publish_digitonenet_mqtt_publish_string

命令格式如下所示：

onenet_mqtt_publish_digit数据流名称要上传的数据

onenet_mqtt_publish_string数据流名称要上传的字符串

输入命令后没有返回错误信息就表示上传成功。示例如下:

msh/>onenet_mqtt_publish_digit test 1

msh/>onenet_mqtt_publish_string test 1

msh/>onenet_mqtt_publish_digit test 2

msh/>onenet_mqtt_publish_string test 1

5.4.2接收数据

在初始化时，命令响应回调函数默认指向了空，想要接收命令，必须设置命令响应回调函数，在 shell 中输入命令onenet_set_cmd_rsp,就把示例文件里的命令响应回调函数挂载上了，这个响应函数在接收到命令后会把命令打印出来。

msh/>onenet_set_cmd_rsp

我们点击设备列表界面的下发命令按钮。

就可以在 shell 中看到云平台下发的命令了。

5.4.3温湿度数据上传

以上是如何开启和简单使用OneNET，接下来需要将前面获取的温湿度进行上传，修改onenet_sample.c的代码：

/* Includes*********************************************************************/

#include 

#include 

#include "dht11_thread.h"



#define DBG_ENABLE

#define DBG_COLOR

#define DBG_SECTION_NAME    "onenet.sample"

#if ONENET_DEBUG

#define DBG_LEVEL           DBG_LOG

#else

#define DBG_LEVEL           DBG_INFO

#endif /* ONENET_DEBUG */



#include 



#ifdef FINSH_USING_MSH

#include 



extern rt_dht11 dht11;



/* upload temperature and humidity*/

static void onenet_upload_entry(void *parameter)

{

    while (1)

    {

        //dht11

        //temperature

        if (onenet_mqtt_upload_digit("temperature", dht11.temp) < 0)

        {

            LOG_E("upload has an error, please check the network");

            break;

        }

        else

        {

            LOG_D("buffer : {"temperature":%d}", dht11.temp);

        }



        rt_thread_delay(rt_tick_from_millisecond(2 * 1000));



        //humidity

        if (onenet_mqtt_upload_digit("humidity", dht11.humi) < 0)

        {

            LOG_E("upload has an error, please check the network");

            break;

        }

        else

        {

            LOG_D("buffer : {"humidity":%d}", dht11.humi);

        }



        rt_thread_delay(rt_tick_from_millisecond(5 * 1000));

    }

}



int onenet_upload_cycle(void)

{

    rt_thread_t tid;



    tid = rt_thread_create("onenet_send",

                           onenet_upload_entry,

                           RT_NULL,

                           2 * 1024,

                           RT_THREAD_PRIORITY_MAX / 3 - 1,

                           5);

    if (tid)

    {

        rt_thread_startup(tid);

    }



    return 0;

}

MSH_CMD_EXPORT(onenet_upload_cycle, send data to OneNET cloud cycle);



int onenet_publish_digit(int argc, char **argv)

{

    if (argc != 3)

    {

        LOG_E("onenet_publish [datastream_id]  [value]  - mqtt pulish digit data to OneNET.");

        return -1;

    }



    if (onenet_mqtt_upload_digit(argv[1], atoi(argv[2])) < 0)

    {

        LOG_E("upload digit data has an error!n");

    }



    return 0;

}

MSH_CMD_EXPORT_ALIAS(onenet_publish_digit, onenet_mqtt_publish_digit, send digit data to onenet cloud);



int onenet_publish_string(int argc, char **argv)

{

    if (argc != 3)

    {

        LOG_E("onenet_publish [datastream_id]  [string]  - mqtt pulish string data to OneNET.");

        return -1;

    }



    if (onenet_mqtt_upload_string(argv[1], argv[2]) < 0)

    {

        LOG_E("upload string has an error!n");

    }



    return 0;

}

MSH_CMD_EXPORT_ALIAS(onenet_publish_string, onenet_mqtt_publish_string, send string data to onenet cloud);



/* onenet mqtt command response callback function */

static void onenet_cmd_rsp_cb(uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size)

{

    char res_buf[] = { "cmd is received!n" };



    LOG_D("recv data is %.*sn", recv_size, recv_data);



    /* user have to malloc memory for response data */

    *resp_data = (uint8_t *) ONENET_MALLOC(strlen(res_buf));



    strncpy((char *)*resp_data, res_buf, strlen(res_buf));



    *resp_size = strlen(res_buf);

}



/* set the onenet mqtt command response callback function */

int onenet_set_cmd_rsp(int argc, char **argv)

{

    onenet_set_cmd_rsp_cb(onenet_cmd_rsp_cb);

    return 0;

}

MSH_CMD_EXPORT(onenet_set_cmd_rsp, set cmd response function);



#endif /* FINSH_USING_MSH */