AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

(转)linux下和云端通讯的例程, ubuntu和openwrt实验成功(一)

2015-08-18 1326
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 一.  HTTP请求的数据流总结#上传数据, yeelink的数据流如下POST /v1.0/device/4420/sensor/9089/datapoints HTTP/1.1Host: api.yeelink.

一.  HTTP请求的数据流总结
#上传数据, yeelink的数据流如下
POST /v1.0/device/4420/sensor/9089/datapoints HTTP/1.1
Host: api.yeelink.net
U-ApiKey: 729d1ba15b26b6a48f4807ef3f2f4df4
Content-Length: 49
Content-Type: application/x-www-form-urlencoded
Connection: Close

{"timestamp":"2013-07-23T06:04:15","value":21.9}


#上传数据, lewer50的数据流如下
POST /api/V1/gateway/UpdateSensors/01 HTTP/1.1
Host: www.lewei50.com
userkey: 36be8ff22f794f1e8a0bee3336eef237
Content-Length: 31
Content-Type: application/x-www-form-urlencoded
Connection: Close

[{"Name":"T1","Value":"24.02"}]


三. 代码如下, 公用的 http_clound.h

点击(此处)折叠或打开

  1. /*----------------------------------------------------------------------------------------------------
  2. 云端查询: http://www.yeelink.net/devices/4420, http://www.lewei50.com/u/g/2375
  4. #调用例程
  5. float current_temp = 24.02;
  6. yeelink_create_data(YEELINK_DEVICE_ID, YEELINK_SENSOR_ID, current_temp);
  7. lewei50_create_data(LEWEI50_DEVICE_ID, current_temp);
  9. linux下三种方法和云端通讯:
  10. 1. 纯利用linux的网络函数
  11. 2. 利用libcurl的发送和接收函数
  12. 3. 利用libcurl的回调机制
  14. #上传数据, yeelink的字符流如下
  15. POST /v1.0/device/4420/sensor/9089/datapoints HTTP/1.1
  16. Host: api.yeelink.net
  17. U-ApiKey: 729d1ba15b26b6a48f4807ef3f2f4df4
  18. Content-Length: 49
  19. Content-Type: application/x-www-form-urlencoded
  20. Connection: Close
  22. {"timestamp":"2013-07-23T06:04:15","value":21.9}
  24. #上传数据, lewer50的字符流如下
  25. POST /api/V1/gateway/UpdateSensors/01 HTTP/1.1
  26. Host: www.lewei50.com
  27. userkey: 36be8ff22f794f1e8a0bee3336eef237
  28. Content-Length: 31
  29. Content-Type: application/x-www-form-urlencoded
  30. Connection: Close
  32. [{"Name":"T1","Value":"24.02"}]
  34. lewei50 ret = {"Successful":true,"Message":"Warning: T1\u0027s frequency limit is 10s; "}
  36. V1.0 2013-11-5 初步实现了上面三种方法的Demo.
  37.     错误: bfe06000-bfe1b000 rw-p 00000000 00:00 0 [stack], 修改: char pc_ret[200] -> char pc_ret[500]
  39. -----------------------------------------------------------------------------------------------------*/
  41. #ifndef HTTP_CLOUD_H
  42. #define HTTP_CLOUD_H
  44. //有replace的地方换成自己的参数
  45. #define YEELINK (1)    //www.yeelink.net
  46. #define LEWEI50 (1)    //www.lewei50.com
  48. #if (YEELINK == 1)
  49.     #define YEELINK_URL            "http://api.yeelink.net"
  50.     #define YEELINK_HOST        "api.yeelink.net"        //网址, 由此获得公网IP
  51.     #define YEELINK_PORT        80
  52.     #define YEELINK_API_KEY "729d1ba15b26b6a48f4807ef3f2f4df4" //replace your yeelink api key here.
  53.     #define YEELINK_DEVICE_ID                4420 //replace your device ID
  54.     #define YEELINK_SENSOR_ID                9089 //replace your sensor ID
  55. #endif
  57. #if (LEWEI50 == 1)
  58.     #define LEWEI50_GATEWAY     01        //网关号
  59.     #define LEWEI50_URL             "http://www.lewei50.com/api/V1/gateway/UpdateSensors/01"
  60.     #define LEWEI50_HOST            "www.lewei50.com"        //网址, 由此获得公网IP
  61.     #define LEWEI50_PORT            80
  62.     #define LEWEI50_HOST_FILE    "api/V1/gateway/UpdateSensors/01"
  63.     #define LEWEI50_USER_KEY     "36be8ff22f794f1e8a0bee3336eef237"    //replace your lewei50 key here.
  64.     #define LEWEI50_DEVICE_ID "T1"                                                                //replace your device ID
  65. #endif
  67. #define DATA_CREATE     (0)    //创建数据点
  68. #define DATA_MODIFY     (1)    //修改数据点
  69. #define DATA_QUERY         (2)    //查询数据点
  71. #define HTTP_GET "GET"
  72. #define HTTP_PUT "PUT"
  73. #define HTTP_HEAD "HEAD"
  74. #define HTTP_POST "POST"
  75. #define HTTP_DELETE "DELETE"
  77. #define MAX_SEND_BUFFER_SIZE            (2 * 1024 * 1024)
  78. #define MAX_RECV_BUFFER_SIZE            (2 * 1024 * 1024)
  79. #define MAX_HEADER_BUFFER_SIZE        (128 * 1024)
  81. //http请求与接受的buffer总体结构
  83. //param_buffer_t中buffer的内容
  84. typedef struct {
  85.     char *ptr; /**< 缓冲区首指针 */
  86.     FILE *fp; /**< 文件指针 */
  87.     unsigned int left; /** 缓冲区剩余大小 */
  88.     unsigned int allocated; /** 缓冲区总大小 */
  89.     unsigned short code; /**返回码 */
  90. } param_buffer_t;
  92. typedef struct {
  93.     param_buffer_t *send_buffer; /**< send buffer */
  94.     param_buffer_t *recv_buffer; /**< receive buffer */
  95.     param_buffer_t *header_buffer; /**< header buffer */
  96. } curl_request_param_t;
  98. extern int yeelink_create_data(const int device_id, const int sensor_id, const float device_value);
  99. extern int lewei50_create_data(const char *device_id, const float device_value);
  101. #endif


纯利用linux的网络函数实现的代码如下

点击(此处)折叠或打开

  1. /*----------------------------------------------------------------------------------------------------
  2. 直接利用linux的内部函数实现云端通讯, 另外可以利用libcurl的API.
  3. -----------------------------------------------------------------------------------------------------*/
  4. #include <stdio.h>
  5. #include <stdlib.h>
  6. #include <string.h>
  7. #include <sys/types.h>
  8. #include <sys/socket.h>
  9. #include <errno.h>
  10. #include <unistd.h>
  11. #include <netinet/in.h>
  12. #include <limits.h>
  13. #include <netdb.h>
  14. #include <arpa/inet.h>
  15. #include <ctype.h>
  16. #include <time.h>
  17. #include <assert.h>
  19. #include "../http_cloud.h"
  21. #define DBG printf
  23. //-----------------------------------------------------------------------------------------
  24. static void get_local_time(char *pc_str)
  25. {
  26.     time_t now;
  27.     struct tm *timenow;
  29.     assert(pc_str != NULL);
  30.     time(&now);
  31.     timenow = localtime(&now);
  32.     sprintf(pc_str, "%04d-%02d-%02dT%02d:%02d:%02d", timenow->tm_year+1900, timenow->tm_mon+1, timenow->tm_mday,
  33.                     timenow->tm_hour, timenow->tm_min, timenow->tm_sec);
  34. }
  36. //连接云端: host_addr:网址(如api.yeelink.net), portno:端口号(一般为80), request: 完整的请求
  37. //返回参数: \r\n\r\n之后的数据, 一般为有效数据, 如{"Successful":true,"Message":"Successful. "}
  38. static char connect_cloud(char *pc_ret, const char *host_addr, const int portno, const char *request)
  39. {
  40.     int sockfd = 0;
  41.     char buffer[1024] = "";
  42.     struct sockaddr_in server_addr;
  43.     struct hostent *host;
  44.     //int portno = 80;    //默认端口
  45.     int nbytes = 0;
  46.     //char host_addr[256] = "";
  47.     //char host_file[1024] = "";
  48.     char pc_tmp[1024] = "";
  49.     int send = 0, totalsend = 0;
  50.     int i = 0, iLen = 0, iRet = 0, iPos = 0, mark_num;
  52.     assert((pc_ret != NULL) && (host_addr != NULL) && (request != NULL));
  54.     //由host_addr取得主机IP地址
  55.   if((host = gethostbyname(host_addr)) == NULL) {
  56.       fprintf(stderr, "Gethostname error, %s\n ", strerror(errno));
  57.       exit(1);
  58.   }
  60.   //客户程序开始建立sockfd描述符,建立SOCKET连接
  61.   if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
  62.       fprintf(stderr, "Socket Error:%s\a\n ",strerror(errno));
  63.       exit(1);
  64.   }
  66.   //客户程序填充服务端的资料
  67.   bzero(&server_addr, sizeof(server_addr));
  68.   server_addr.sin_family = AF_INET;
  69.   server_addr.sin_port = htons(portno);
  70.   server_addr.sin_addr = *((struct in_addr*)host->h_addr);
  71.   //DBG("server_addr.sin_addr = %08X\n", server_addr.sin_addr);    //server_addr.sin_addr = CB3888CA
  73.   //客户程序发起连接请求, 连接网站
  74.   if(connect(sockfd, (struct sockaddr*)(&server_addr), sizeof(struct sockaddr)) == -1) {
  75.       fprintf(stderr, "Connect Error:%s\a\n ",strerror(errno));
  76.       exit(1);
  77.   }
  79.   //发送http请求request
  80.   send = 0;
  81.     totalsend = 0;
  82.   nbytes = strlen(request);
  83.   while(totalsend < nbytes)
  84.   {
  85.     send = write(sockfd, request+totalsend, nbytes-totalsend);
  86.     if(send == -1) {
  87.             DBG( "send error!%s\n ", strerror(errno));
  88.             exit(0);
  89.         }
  90.     totalsend += send;
  91.     //DBG("%d bytes send OK!\n ", totalsend);
  92.   }
  94.   //DBG( "\nThe following is the response header:\n");
  95.   i = 0;
  96.   mark_num = 4;        //正常=4,
  97.   //连接成功了,接收http响应
  98.   while((nbytes = read(sockfd, buffer, 1)) == 1)
  99.   {
  100.     //DBG("%c", buffer[0]);
  101.     if(i < mark_num) {
  102.         if(buffer[0] == '\r' || buffer[0] == '\n') {
  103.                 i++;
  104.                 //DBG("i = %d, ", i);
  106.                 if (iRet == 0) {
  107.                     pc_tmp[iPos] = '\0';
  108.                     if (!strcmp(pc_tmp, "HTTP/1.1 200 OK")) {
  109.                         iRet = 1;
  110.                     }
  111.                 }
  112.             }
  113.       else {
  114.                 i = 0;    //新行重新计数
  115.                 pc_tmp[iPos++] = buffer[0];
  116.             }
  117.     }
  118.     else {
  119.         pc_ret[iLen++] = buffer[0];    //获取有效数据
  120.     }
  121.   }
  122.   close(sockfd);
  124.   pc_ret[iLen] = '\0';
  125.   DBG("\nret(%d): %s\n", iLen, pc_ret);
  126.   return(iRet);
  127. }
  129. #if (YEELINK == 1)
  130. int yeelink_create_data(const int device_id, const int sensor_id, const float device_value)
  131. {
  132.     char pc_ret[200], request[1024], pc_json[100], pc_time[30], pc_host_file[100], pc_header[100], ret;
  133.     int len;
  135.     sprintf(pc_host_file, "v1.0/device/%d/sensor/%d/datapoints", device_id, sensor_id);
  136.     sprintf(pc_header, "U-ApiKey: %s", YEELINK_API_KEY);
  138.     get_local_time(pc_time);
  139.     sprintf(pc_json, "{\"timestamp\":\"%s\",\"value\":%.2f}", pc_time, device_value);
  140.     len = strlen(pc_json);
  142.     sprintf(request, "POST /%s HTTP/1.1\r\nHost: %s\r\nAccept: */*\r\n%s\r\nContent-Length: %d\r\nContent-Type: application/x-www-form-urlencoded\r\nConnection: Close\r\n\r\n%s\r\n",
  143.         pc_host_file, YEELINK_HOST, pc_header, len, pc_json);
  144.     DBG("request = %s\n", request);
  146.     ret = connect_cloud(pc_ret, YEELINK_HOST, YEELINK_PORT, request);
  148.     return(ret);
  149. }
  150. #endif
  152. #if (LEWEI50 == 1)
  153. //curl --request POST http://www.lewei50.com/api/V1/Gateway/UpdateSensors/01 --data "[{\"Name\":\"T1\",\"Value\":\"23.08\"}]" --header "userkey:36be8ff22f794f1e8a0bee3336eef237"
  154. int lewei50_create_data(const char *device_id, const float device_value)
  155. {
  156.     char pc_ret[200], request[1024], pc_json[100], pc_header[100], ret;
  157.     int len;
  159.     assert(device_id != NULL);
  161.     sprintf(pc_header, "userkey: %s", LEWEI50_USER_KEY);
  162.     sprintf(pc_json, "[{\"Name\":\"%s\",\"Value\":\"%.2f\"}]", device_id, device_value);
  163.     len = strlen(pc_json);
  165.     sprintf(request, "POST /%s HTTP/1.1\r\nHost: %s\r\nAccept: */*\r\n%s\r\nContent-Length: %d\r\nContent-Type: application/x-www-form-urlencoded\r\nConnection: Close\r\n\r\n%s\r\n",
  166.         LEWEI50_HOST_FILE, LEWEI50_HOST, pc_header, len, pc_json);
  167.     DBG("request = %s\n", request);
  169.     ret = connect_cloud(pc_ret, LEWEI50_HOST, LEWEI50_PORT, request);
  171.     return(ret);
  172. }
  173. #endif
  175. //-------------------------------------------------------------------
  176. int main(void)
  177. {
  178.     float f_value = 15.02;
  179.     int i_tmp;
  181.     time_t t;
  182.   srand((unsigned)time(&t));    //初始化随机种子, 否则随机数不随机
  184.     i_tmp = rand();
  185.     i_tmp -= (i_tmp >> 4 << 4);
  186.   f_value += i_tmp;
  188. #if (YEELINK == 1)
  189.     yeelink_create_data(YEELINK_DEVICE_ID, YEELINK_SENSOR_ID, f_value);
  190. #endif
  192. #if (LEWEI50 == 1)
  193.     lewei50_create_data(LEWEI50_DEVICE_ID, f_value);
  194. #endif
  196.     return 1;
  197. }

四. 编译, Makefile如下,
OPENWRT = 0 时目标文件运行下ubuntu下了. 

点击(此处)折叠或打开

  1. OPENWRT = 1
  3. ifeq ($(OPENWRT), 1)
  4.     CC = ~/OpenWrt-SDK-ar71xx-for-linux-i486-gcc-4.6-linaro_uClibc-0.9.33.2/staging_dir/toolchain-mips_r2_gcc-4.6-linaro_uClibc-0.9.33.2/bin/mips-openwrt-linux-gcc
  5.     CFLAGS += -I ~/openwrt-lib/include -L ~/openwrt-lib/lib
  7. else
  8.     CC = gcc
  9. endif
  11. CFLAGS += -Wall -O2
  12. #CFLAGS += -g
  14. #可执行文件名和相关的obj文件
  15. APP_BINARY = http_cloud
  16. SRCS += http_cloud.c
  17. OBJS = $(SRCS:.c=.o)
  19. all: APP_FILE
  21. APP_FILE: $(OBJS)
  22.     $(CC) $(CFLAGS) $(OBJS) -o $(APP_BINARY) $(LFLAGS)
  24. .PHONY: clean
  25. clean:
  26.     @echo "cleanning project"
  27.     $(RM) *.a $(OBJS) *~ *.so *.lo $(APP_BINARY)
  28.     @echo "clean completed"

编译过程:
xxg@xxg-desktop:~/1-wire/http_cloud/linux_only$ make
gcc -Wall -O2   -c -o http_cloud.o http_cloud.c
gcc -Wall -O2 http_cloud.o -o http_cloud 


运行结果:
xxg@xxg-desktop:~/1-wire/http_cloud/linux_only$ ./http_cloud
request = POST /v1.0/device/4420/sensor/9089/datapoints HTTP/1.1
Host: api.yeelink.net
Accept: */*
U-ApiKey: 729d1ba15b26b6a48f4807ef3f2f4df4
Content-Length: 49
Content-Type: application/x-www-form-urlencoded
Connection: Close

{"timestamp":"2013-11-05T14:32:48","value":16.02}

ret(5): 0


request = POST /api/V1/gateway/UpdateSensors/01 HTTP/1.1
Host: www.lewei50.com
Accept: */*
userkey: 36be8ff22f794f1e8a0bee3336eef237
Content-Length: 31
Content-Type: application/x-www-form-urlencoded
Connection: Close

[{"Name":"T1","Value":"16.02"}]

ret(44): {"Successful":true,"Message":"Successful. "}
xxg@xxg-desktop:~/1-wire/http_cloud/linux_only$ 

 

这个只是第一部分的实验, 后续的还有利用libcurl库的实现代码.

文章标签：
Linux
API
移动开发
Ubuntu
传感器
C语言
关键词：
Linux Ubuntu
Ubuntu Linux
Ubuntu实验
Linux实验
Linux通讯
ai物联网
目录
相关文章
shliang0603
|
4月前
|
Ubuntu Linux
查看Linux系统架构的命令，查看linux系统是哪种架构：AMD、ARM、x86、x86_64、pcc 或 查看Ubuntu的版本号
查看Linux系统架构的命令，查看linux系统是哪种架构：AMD、ARM、x86、x86_64、pcc 或 查看Ubuntu的版本号
shliang0603
950 3
江湖有缘
|
2月前
|
Ubuntu Linux 测试技术
Linux系统之Ubuntu安装cockpit管理工具
【10月更文挑战第13天】Linux系统之Ubuntu安装cockpit管理工具
江湖有缘
168 4
Linux系统之Ubuntu安装cockpit管理工具
蓝易云
|
2月前
|
Ubuntu Linux 编译器
Linux/Ubuntu下使用VS Code配置C/C++项目环境调用OpenCV
通过以上步骤，您已经成功在Ubuntu系统下的VS Code中配置了C/C++项目环境，并能够调用OpenCV库进行开发。请确保每一步都按照您的系统实际情况进行适当调整。
蓝易云
386 3
zzy的aly
|
2月前
|
并行计算 Ubuntu Linux
Ubuntu学习笔记(三):Linux下操作指令大全
Ubuntu学习笔记，介绍了Linux操作系统中常用的命令和操作，如文件管理、系统信息查看、软件安装等。
zzy的aly
47 3
shiningrise
|
2月前
|
Kubernetes 网络安全 容器
基于Ubuntu-22.04安装K8s-v1.28.2实验（一）部署K8s
基于Ubuntu-22.04安装K8s-v1.28.2实验（一）部署K8s
shiningrise
281 2
shiningrise
|
2月前
|
存储 Kubernetes 负载均衡
基于Ubuntu-22.04安装K8s-v1.28.2实验（四）使用域名访问网站应用
基于Ubuntu-22.04安装K8s-v1.28.2实验（四）使用域名访问网站应用
shiningrise
33 1
shiningrise
|
2月前
|
负载均衡 应用服务中间件 nginx
基于Ubuntu-22.04安装K8s-v1.28.2实验（二）使用kube-vip实现集群VIP访问
基于Ubuntu-22.04安装K8s-v1.28.2实验（二）使用kube-vip实现集群VIP访问
shiningrise
67 1
蓝易云
|
2月前
|
Ubuntu Linux 网络安全
如何在Ubuntu 22.04或20.04 Linux上安装MobaXterm
虽然直接在Ubuntu 22.04或20.04上安装MobaXterm是不可能的任务，因为它是专为Windows设计的，但Ubuntu系统提供了丰富的原生工具和替代方案，足以满足远程管理、文件传输等需求。如果你对MobaXterm的特定功能有强烈需求，考虑采用Windows子系统或虚拟机方案作为折衷方案，不失为一种可行之道。在追求高效工作流的同时，不妨也探索和熟悉Linux原生工具，它们往往能提供更为无缝的集成体验。
蓝易云
904 0
shiningrise
|
2月前
|
Kubernetes 容器
基于Ubuntu-22.04安装K8s-v1.28.2实验（三）数据卷挂载NFS（网络文件系统）
基于Ubuntu-22.04安装K8s-v1.28.2实验（三）数据卷挂载NFS（网络文件系统）
shiningrise
149 0
你都不懂
|
3月前
|
Ubuntu Linux 开发工具
ubuntu linux搭建lvgl
ubuntu linux搭建lvgl
你都不懂
103 6

热门文章

最新文章

  • 1
    Ubuntu 14.04 更换阿里云源
  • 2
    Ubuntu 18.04 网络配置介绍
  • 3
    ubuntu如何实现访问实际网络中windows共享文件夹
  • 4
    Ubuntu下使用命令行连接WiFi
  • 5
    ubuntu 64位android项目报错的解决方案,打开64位 Ubuntu 的32位支持功能
  • 6
    如何在ubuntu下用SVN commit
  • 7
    ubuntu-14.10 输入法切换设置
  • 8
    升级Ubuntu 12.04下的gcc到4.7
  • 9
    在Ubuntu系统上安装OpenCV C++
  • 10
    Ubuntu Linux 创建root用户并且允许远程登录
  • 1
    如何计算 Linux 上文件中的空行数？
    74
  • 2
    服务器Linux系统配置mysql数据库主从自动备份
    212
  • 3
    Linux文件系统
    59
  • 4
    Linux内核基础知识
    74
  • 5
    Linux网络编程 网络基础知识
    68
  • 6
    Linux系统编程之文件编程常用API回顾和文件编程一般步骤
    77
  • 7
    linux静态库，动态库总结
    56
  • 8
    linux守护进程介绍 | Linux的热拔插UDEV机制
    76
  • 9
    基于linux串口实现语音刷抖音
    71
  • 10
    linux下实现串口功能
    55

    • 相关课程

    更多
  • Linux高级网络应用 - 网络管理与配置实战
  • Linux MySQL服务器搭建与应用
  • Linux Web服务器Nginx搭建与配置
  • Linux企业运维实战 - 入门及常用命令
  • Linux Shell 编程入门与实战
  • Linux网络进阶 - TCP/IP协议及OSI七层模型

    • 相关电子书

    更多
  • Alibaba Cloud Linux 3 发布
  • ECS系统指南之Linux系统诊断
  • ECS运维指南 之 Linux系统诊断

    • 相关实验场景

    更多
  • 使用计算巢企业应用，一键获取专属的Linux服务器管理软件
  • 部署Linux主机管理系统WDCP
  • 部署LAMP环境（Ubuntu 20）
  • 基于Anolis OS 3快速搭建LNMP环境制作KodBox
  • 手动部署LNMP环境（Ubuntu 20）
  • 手动部署LNMP环境（Alibaba Cloud Linux 2）

    • 推荐镜像

    更多
  • ubuntu
  • ubuntu-ports
  • ubuntukylin
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月