【7天rtos网络编程】day6~7-风雨潇潇

发布于 2018-10-24 23:35:28 浏览：1648 订阅该版

* 本帖最后由 风雨潇潇 于 2018-10-30 23:39 编辑 *

**题目：**正常获取并运行示例程序，运用所学的知识，获取实时的日期、时间、天气，并把获取的数据通过在 OneNet 云平台创建应用展示出来。

**思路：**
在env里面配置OneNet的选项，并开启MQTT服务和JSON。
![7.png](/uploads/201810/24/232558f8ax39k5ea8fk3e3.png)
![2.png](/uploads/201810/24/231127n33a3z7tu76skkkk.png)
![3.png](/uploads/201810/24/231127zviwh98ymwweztse.png)

**实施步骤：**
在配置完成后更新包并编译工程。运行qemu后，运用示例代码的命令**weather **可以得到相应城市的时间和天气，
![4.png](/uploads/201810/24/231634xg5muzha97z5s4sa.png)

连接OneNet物联网平台，先要注册然后添加设备
![5.png](/uploads/201810/24/232203ld4v8ac5mooor8r7.png)
![6.png](/uploads/201810/24/232212e1z5r69qdnddepde.png)

在env里面配置已经在云端出创立的设备信息
![7.png](/uploads/201810/24/232558f8ax39k5ea8fk3e3.png)

运行qemu后先初始化mqtt，在利用cycle的命令循环发送信息给云端。
![8.png](/uploads/201810/24/233106t7h0n3xoa8xyo3y2.png)
![9.png](/uploads/201810/24/233113a1rbmzwemos3z0le.png)

在云端的设备管理里面查找对应的设备可以看到传输的数据曲线

![10.png](/uploads/201810/24/233257ompmtwxp4qsspyww.png)

![11.png](/uploads/201810/24/233510q1yyts5nyg5t5jd1.png)
```/* 
 * File      : httpclient.c
 *
 * Copyright (c) 2006-2018, RT-Thread Development Team 
 * 
 * SPDX-License-Identifier: Apache-2.0 
 * 
 * Change Logs: 
 * Date             Author      Notes
 * 2018-07-20     flybreak     first version
 * 2018-09-05     flybreak     Upgrade API to webclient latest version
 */

#include <webclient.h> /* 使用 HTTP 协议与服务器通信需要包含此头文件 */
#include <sys/socket.h> /* 使用BSD socket，需要包含socket.h头文件 */
#include <netdb.h>
#include <cJSON.h>
#include <finsh.h>

#include <stdlib.h>

#include <onenet.h>

#define GET_HEADER_BUFSZ        1024        //头部大小
#define GET_RESP_BUFSZ          1024        //响应缓冲区大小
#define GET_URL_LEN_MAX         256         //网址最大长度
#define GET_URI                 "http://mobile.weather.com.cn/data/sk/%s.html" //获取天气的 API
#define AREA_ID                 "101220301" //上海浦东地区 ID

struct msg{
	char cityName[20];
	char wd[20];
	int ws;
	char sd[20];
	int temp;
	char data[20];
	char time[20];
};
static struct msg weather_msg;

/* 天气数据解析 */
void weather_data_parse(rt_uint8_t *data, struct msg *p_msg)
{
    cJSON *root = RT_NULL, *object = RT_NULL, *item = RT_NULL;

root = cJSON_Parse((const char *)data);
 if (!root)
 {
 rt_kprintf("No memory for cJSON root! ");
 return;
 }
 object = cJSON_GetObjectItem(root, "sk_info");

item = cJSON_GetObjectItem(object, "cityName");
	strncpy(p_msg->cityName, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" cityName:%s ", p_msg->cityName);

item = cJSON_GetObjectItem(object, "temp");
	p_msg->temp = atoi(item->valuestring);
 rt_kprintf(" temp :%s ", p_msg->temp);

item = cJSON_GetObjectItem(object, "wd");
	strncpy(p_msg->wd, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" wd :%s ", p_msg->wd);

item = cJSON_GetObjectItem(object, "ws");
	p_msg->ws = atoi(item->valuestring);
 rt_kprintf(" ws :%s ", p_msg->ws);

item = cJSON_GetObjectItem(object, "sd");
	strncpy(p_msg->sd, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" sd :%s ", p_msg->sd);

item = cJSON_GetObjectItem(object, "date");
	strncpy(p_msg->data, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" date :%s", p_msg->data);

item = cJSON_GetObjectItem(object, "time");
	strncpy(p_msg->time, item->valuestring, strlen(item->valuestring));
 rt_kprintf(" time :%s ", p_msg->time);

if (root != RT_NULL)
        cJSON_Delete(root);
}
void weather_f()
{
    rt_uint8_t *buffer = RT_NULL;
    int resp_status;
    struct webclient_session *session = RT_NULL;
    char *weather_url = RT_NULL;
    int content_length = -1, bytes_read = 0;
    int content_pos = 0;

/* 为 weather_url 分配空间 */
 weather_url = rt_calloc(1, GET_URL_LEN_MAX);
 if (weather_url == RT_NULL)
 {
 rt_kprintf("No memory for weather_url! ");
 goto __exit;
 }
 /* 拼接 GET 网址 */
 rt_snprintf(weather_url, GET_URL_LEN_MAX, GET_URI, AREA_ID);

/* 创建会话并且设置响应的大小 */
 session = webclient_session_create(GET_HEADER_BUFSZ);
 if (session == RT_NULL)
 {
 rt_kprintf("No memory for get header! ");
 goto __exit;
 }

/* 发送 GET 请求使用默认的头部 */
 if ((resp_status = webclient_get(session, weather_url)) != 200)
 {
 rt_kprintf("webclient GET request failed, response(%d) error. ", resp_status);
 goto __exit;
 }

/* 分配用于存放接收数据的缓冲 */
 buffer = rt_calloc(1, GET_RESP_BUFSZ);
 if(buffer == RT_NULL)
 {
 rt_kprintf("No memory for data receive buffer! ");
 goto __exit;
 }

content_length = webclient_content_length_get(session);
 if (content_length < 0)
 {
 /* 返回的数据是分块传输的. */
 do
 {
 bytes_read = webclient_read(session, buffer, GET_RESP_BUFSZ);
 if (bytes_read <= 0)
 {
 break;
 }
 } while (1);
 }
 else
 {
 do
 {
 bytes_read = webclient_read(session, buffer, 
 content_length - content_pos > GET_RESP_BUFSZ ?
 GET_RESP_BUFSZ : content_length - content_pos);
 if (bytes_read <= 0)
 {
 break;
 }
 content_pos += bytes_read;
 } while (content_pos < content_length);
 }

/* 天气数据解析 */
    weather_data_parse(buffer, &weather_msg);

__exit:
    /* 释放网址空间 */
    if (weather_url != RT_NULL)
        rt_free(weather_url);
    /* 关闭会话 */
    if (session != RT_NULL)
        webclient_close(session);
    /* 释放缓冲区空间 */
    if (buffer != RT_NULL)
        rt_free(buffer);
}

MSH_CMD_EXPORT(weather_f, Get weather_f by webclient);

/*------------------------------------*/

/* upload random value to temperature*/
static void onenet_upload_entry_f(void *parameter)
{
    weather_f();

while (1)
 {
		//cityName
 if (onenet_mqtt_upload_string("cityName", weather_msg.cityName) < 0)
 {
 log_e("upload has an error, stop uploading");
 break;
 }
 else
 {
 log_d("buffer : {\"cityName\":%s}", weather_msg.cityName);
 }
		//temp
		if (onenet_mqtt_upload_digit("temp", weather_msg.temp) < 0)
 {
 log_e("upload has an error, stop uploading");
 break;
 }
 else
 {
 log_d("buffer : {\"temp\":%s}", weather_msg.temp);
 }
		//wd
		 if (onenet_mqtt_upload_string("sd", weather_msg.wd) < 0)
 {
 log_e("upload has an error, stop uploading");
 break;
 }
 else
 {
 log_d("buffer : {\"sd	\":%s}", weather_msg.wd);
 }
		//ws
		 if (onenet_mqtt_upload_digit("ws", weather_msg.ws) < 0)
 {
 log_e("upload has an error, stop uploading");
 break;
 }
 else
 {
 log_d("buffer : {\"ws	\":%s}", weather_msg.ws);
 }
		//sd
		 if (onenet_mqtt_upload_string("sd", weather_msg.sd) < 0)
 {
 log_e("upload has an error, stop uploading");
 break;
 }
 else
 {
 log_d("buffer : {\"sd	\":%s}", weather_msg.sd);
 }
		//data
		 if (onenet_mqtt_upload_string("data", weather_msg.data) < 0)
 {
 log_e("upload has an error, stop uploading");
 break;
 }
 else
 {
 log_d("buffer : {\"data\":%s}", weather_msg.data);
 }
		//time
		 if (onenet_mqtt_upload_string("time", weather_msg.time) < 0)
 {
 log_e("upload has an error, stop uploading");
 break;
 }
 else
 {
 log_d("buffer : {\"time\":%s}", weather_msg.time);
 }

rt_thread_delay(rt_tick_from_millisecond(5 * 1000));
    }
}

int onenet_upload_cycle_f(void)
{
    rt_thread_t tid;

tid = rt_thread_create("onenet_send",
                           onenet_upload_entry_f,
                           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_f, send data to OneNET cloud cycle);

```![1.png](/uploads/201810/30/233521hja5jmb0jj8dthat.png)
![2.png](/uploads/201810/30/233943o2uruue44946hyhj.png)

根据几位大神的帖子，勉强写了代码，可是好像一次只能显示一个参数，为什么啊？？？

哪位大神能指点下代码吗，还有天气的URL....:funk::funk::funk: