Arduino物联网库HttpPacket.h资源-CSDN下载

共3个文件

h：1个

cpp：1个

ino：1个

需积分: 50 185 浏览量 2019-03-06 20:59:59 上传评论收藏 5KB RAR 举报

在 Arduino 开发环境中，`HttpPacket.h` 是一个专门用于处理 HTTP 请求和响应的库，对于构建物联网（IoT）项目至关重要。这个库通常被用来与云服务平台进行数据交互，例如在本例中的 "Arduino物联网三步曲—（2）OneNET远程数据监控" 中，OneNET 是中国移动推出的一个 IoT 平台，它提供了设备接入、数据存储、数据处理和应用开发等功能。 `HttpPacket` 库使得 Arduino 设备能够通过 ESP8266-01 模块连接到网络，ESP8266 是一款低成本且功能强大的 Wi-Fi 模块，常用于 Arduino 的无线扩展。mega2560 是 Arduino 的一种强大控制器，拥有更多的数字和模拟输入/输出引脚，适合处理更复杂的物联网项目。使用 `HttpPacket` 库，开发者可以构建 HTTP 请求，包括设置方法（如 GET、POST）、URL、HTTP 头部和请求体。这对于向 OneNET 平台发送数据或接收平台指令至关重要。例如，你可以构造一个 POST 请求来发送传感器数据，或者构造一个 GET 请求来获取服务器上的配置信息。以下是一些 `HttpPacket` 库的基本使用步骤： 1. **包含库**：在 Arduino 代码中，首先需要包含 `HttpPacket.h` 文件。 ```cpp #include <HttpPacket.h> ``` 2. **创建对象**：创建 `HttpPacket` 类的对象，用于构建和发送 HTTP 请求。 ```cpp HttpPacket httpPacket; ``` 3. **设置请求信息**：设置请求的方法、URL、头部和数据。 ```cpp httpPacket.setMethod(HTTP_POST); httpPacket.setUrl("http://api.onenet.cn/your-endpoint"); httpPacket.setHeader("Content-Type", "application/json"); httpPacket.setData("{\"data\":\"your-sensor-data\"}"); ``` 4. **连接并发送请求**：使用 ESP8266 WiFi 库建立连接，并通过串口发送 HTTP 包。 ```cpp WiFiClient client; if (client.connect("api.onenet.cn", 80)) { httpPacket.send(client); } else { Serial.println("Failed to connect to server."); } ``` 5. **接收响应**：处理服务器返回的 HTTP 响应，可能包括状态码、头部和响应体。 ```cpp int httpCode = httpPacket.readResponse(client); if (httpCode == 200) { Serial.println("Request successful."); String responseBody = httpPacket.getBody(); // 处理响应体 } else { Serial.println("Request failed with code " + String(httpCode)); } ``` 6. **关闭连接**：完成通信后，记得关闭与服务器的连接。 ```cpp client.stop(); ``` 通过以上步骤，你可以将 Arduino 设备与物联网平台 OneNET 集成，实现远程监控和控制。在实际项目中，可能还需要处理错误情况、重试机制、数据编码解码等复杂问题，但这些基本操作是构建物联网应用的基础。在 `HttpPacket.h` 库的帮助下，即使没有深厚的网络编程经验，也能相对轻松地完成这些任务。

资源推荐

资源详情

资源评论

收起资源包目录

HttpPacket.rar （3个子文件）

HttpPacket

HttpPacket.cpp 19KB

HttpPacket.h 3KB

example

CreateHttpMessage

CreateHttpMessage.ino 3KB

/********************************************************************** * Copyright(c) 2014-2015 China Mobile M2M Company Limited. * All rights reserved. * * 文件名称: HttpPacket.cpp * 简要描述: Arduino http packets encapsulation library * * 创建日期: 2015.4.24 * 作者: Zhou Jiaxu * 说明: Arduino http packets encapsulation library * 版本: V2.0 * * 修改日期:2015.5.29 * 作者:Zhou Jiaxu * 说明:相对于V1.0修改关于批量查询数据流的函数，添加 * SDK使用示例 * * 修改日期:2015.10.30 * 作者:Zhou Jiaxu * 说明:相对于V2.0修改 * int createCmdPacket(OPS_TYPE operType, RESRC_TYPE type, JsonObject& jsonData); * 为 * int createCmdPacket(OPS_TYPE operType, RESRC_TYPE type, char* jsonData); * V2.0使用JSON库, 导致内存占用过大，可能导致程序 * 崩溃，V2.1直接使用封装好的JSON串作为输入，节省 * 内存开销，降低耦合。 **********************************************************************/ #include <HttpPacket.h> /********************************************************************** * HttpPacketHead::HttpPacketHead(void) * 功能描述: 构造函数 * * @return **********************************************************************/ HttpPacketHead::HttpPacketHead(void) { clearUrlParameter(); memset(content, 0, CMDLEN); apiKey = NULL; accessKey = NULL; hostAddress = NULL; devId = NULL; dataStreamId = NULL; triggerId = NULL; index = NULL; urlParaCnt = 0; for(int i = 0; i < URLPAPACNT; i++) { urlParaArr[i] = NULL; } } /********************************************************************** * void HttpPacketHead::setHostAddress(char* hostAddr) * 功能描述: 设置http包头主机地址 * @param param1 char* hostAddr 服务器地址字符串指针 * * @return void **********************************************************************/ void HttpPacketHead::setHostAddress(char* hostAddr) { hostAddress = hostAddr; return; } /********************************************************************** * void HttpPacketHead::updateUrlParameterWith(char* key, char* value) * 功能描述: 更新单个URL参数 * @param param1 char* key 参数名字字符串指针 * @param param2 char* value 参数的值字符串指针 * @return void **********************************************************************/ void HttpPacketHead::updateUrlParameterWith(char* key, char* value) { int tmp = urlParaIsExist(key); char* pKey = NULL; if(RET_ERR != tmp) { if((pKey = (char*)malloc(strlen(key) + strlen(value) + 5)) != NULL) { sprintf(pKey, "%s=%s", key, value); urlParaArr[tmp] = pKey; } } } /********************************************************************** * void HttpPacketHead::clearUrlParameter(void) * 功能描述: 清除所有之前设置的URL参数 * @param void * @return void **********************************************************************/ void HttpPacketHead::clearUrlParameter(void) { for(int i = 0; i < URLPAPACNT; i++) { free(urlParaArr[i]); urlParaArr[i] = NULL; } urlParaCnt = 0; } /********************************************************************** * void HttpPacketHead::removeUrlParameter(char* key) * 功能描述:删除一个之前已经存在的URL参数，如果没有这 * 个参数不做任何操作 * @param char* key 参数名称 * @return void **********************************************************************/ void HttpPacketHead::removeUrlParameter(char* key) { int i; int tmp = urlParaIsExist(key); if(RET_ERR != tmp) { free(urlParaArr[tmp]); urlParaArr[tmp] = NULL; for(i = tmp; i < urlParaCnt - 1; i++) { urlParaArr[i] = urlParaArr[i + 1]; } urlParaArr[i] = NULL; urlParaCnt--; } } /********************************************************************** * int HttpPacketHead::urlParaIsExist(char* key) * 功能描述:判断http包中是否存在某个url参数 * @param char* key 参数名称 * @return RET_ERR 参数不存在 * i 参数存在，并返回参数的index **********************************************************************/ int HttpPacketHead::urlParaIsExist(char* key) { int i; char buf[20]; sprintf(buf, "%s=", key); for(i = 0; i < urlParaCnt; i++) { if(strlen(urlParaArr[i]) && strstr(urlParaArr[i], buf) != NULL) { break; } } if(urlParaCnt <= i) //新参数 { return RET_ERR; } else { return i; } } /********************************************************************** * void HttpPacketHead::addUrlParameter(char* key, char* value) * 功能描述:添加一个url 参数http包中，如果存在该参数， * 不做任何操作. * @param1 char* key 参数名称 * @param2 char* value 参数值 * @return void **********************************************************************/ void HttpPacketHead::addUrlParameter(char* key, char* value) { int i = 0, len = 0; char buf[20]; char tmp[20]; char* p; sprintf(buf, "%s=", key); if(urlParaCnt >= URLPAPACNT) { return; } for(i = 0; i < urlParaCnt; i++) { if(strlen(urlParaArr[i]) && strstr(urlParaArr[i], buf) != NULL) { break; } } if(strstr(urlParaArr[i], "datastream_ids=") != NULL) //已有参数 { len = strlen(urlParaArr[i]) - strlen(value); p = urlParaArr[i]; p = p + len - 2; strcpy(tmp, p); sprintf(buf, ",%s", value); if(0 != strcmp(tmp, buf)) { sprintf(buf, "=%s,", value); if(NULL == strstr(urlParaArr[i], buf)) { sprintf(buf, ",%s,", value); if(NULL == strstr(urlParaArr[i], buf)) { strcat(urlParaArr[i] , ","); strcat(urlParaArr[i] , value); } } } } if(urlParaCnt <= i && urlParaCnt < URLPAPACNT) //新参数 { if(strcmp(key, "datastream_ids") == 0) { urlParaArr[i] = (char*)malloc(50); } else { urlParaArr[i] = (char*)malloc(strlen(key) + strlen(value) + 5); } if(NULL != urlParaArr[i]) { sprintf(urlParaArr[i], "%s=%s", key, value); } urlParaCnt++; } } /********************************************************************** * void HttpPacketHead::setDevId(char* Dev_Id) * 功能描述:设置http包中要要访问的设备id * @param1 char* Dev_Id 设备ID 字符串 * @return void **********************************************************************/ void HttpPacketHead::setDevId(char* Dev_Id) { devId = Dev_Id; return; } /********************************************************************** * void HttpPacketHead::setDataStreamId(char* StreamId) * 功能描述:设置http包中要要访问的数据流ID * @param1 char* StreamId 数据流ID 字符串 * @return void **********************************************************************/ void HttpPacketHead::setDataStreamId(char* StreamId) { dataStreamId = StreamId; return; } /********************************************************************** * void HttpPacketHead::setTriggerId(char* TrigId) * 功能描述:设置http包中要要访问的触发器ID * @param1 char* TrigId 触发器ID 字符串 * @return void **********************************************************************/ void HttpPacketHead::setTriggerId(char* TrigId) { triggerId = TrigId; return; } /********************************************************************** * void HttpPacketHead::setBinIdx(char* Idx) * 功能描述:设置http包中要要访问的bin文件索引 * @param1 char* Idx 文件索引 * @return void ****************************************

评论收藏

内容反馈