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

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

2015-08-18 1523
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 前言: 上节用纯linux的函数实现了和云端通讯, 本节开始利用传说中的神器libcurl话说一个网络程序员对书法十分感兴趣，退休后决定在这方面有所建树。 于是花重金购买了上等的文房四宝。    一日，饭后突生雅兴，一番磨墨拟纸，  并点上了上好的檀香，颇有王羲之风范，  又具颜真卿气势，定神片刻，泼墨挥毫，    郑重地写下一行字：libcurl.

前言: 上节用纯linux的函数实现了和云端通讯, 本节开始利用传说中的神器libcurl

话说一个网络程序员对书法十分感兴趣，退休后决定在这方面有所建树。 于是花重金购买了上等的文房四宝。    
一日，饭后突生雅兴，一番磨墨拟纸，  并点上了上好的檀香，颇有王羲之风范，  又具颜真卿气势，定神片刻，泼墨挥毫，    
郑重地写下一行字：libcurl.

由此可知libcurl的刻骨铭心!
官方文档请参考这里  http://curl.haxx.se/libcurl/c/curl_easy_setopt.html

刚接触 libcurl的时候, 自然的想到按照常规的思路来连接云端: 先连接Web, 再发送请求, 然后等待接受返回数据. 
这样思路的代码如下

点击(此处)折叠或打开

  1. /*----------------------------------------------------------------------------------------------------
  2. 名称: http_cloud_curl_simple.c
  3. 功能: 利用libcurl的API顺序实现云端通讯, 未利用回调机制
  4. -----------------------------------------------------------------------------------------------------*/
  5. #include <stdio.h>
  6. #include <stdlib.h>
  7. #include <string.h>
  8. #include <curl/curl.h>
  9. #include <assert.h>
  11. #include "../http_cloud.h"
  13. #define DBG printf
  15. //-----------------------------------------------------------------------------------------
  16. static void get_local_time(char *pc_str)
  17. {
  18.     time_t now;
  19.     struct tm *timenow;
  21.     assert(pc_str != NULL);
  23.     time(&now);
  24.     timenow = localtime(&now);
  25.     sprintf(pc_str, "%04d-%02d-%02dT%02d:%02d:%02d", timenow->tm_year+1900, timenow->tm_mon+1, timenow->tm_mday,
  26.                     timenow->tm_hour, timenow->tm_min, timenow->tm_sec);
  27. }
  29. /* Auxiliary function that waits on the socket. */
  30. static int wait_on_socket(curl_socket_t sockfd, int for_recv, long timeout_ms)
  31. {
  32.   struct timeval tv;
  33.   fd_set infd, outfd, errfd;
  34.   int res;
  36.   tv.tv_sec = timeout_ms / 1000;
  37.   tv.tv_usec= (timeout_ms % 1000) * 1000;
  39.   FD_ZERO(&infd);
  40.   FD_ZERO(&outfd);
  41.   FD_ZERO(&errfd);
  43.   FD_SET(sockfd, &errfd); /* always check for error */
  45.   if(for_recv) {
  46.     FD_SET(sockfd, &infd);
  47.   }
  48.   else {
  49.     FD_SET(sockfd, &outfd);
  50.   }
  52.   /* select() returns the number of signalled sockets or -1 */
  53.   res = select(sockfd + 1, &infd, &outfd, &errfd, &tv);
  54.   return res;
  55. }
  57. static char connect_cloud(char *pc_ret, const char *host_addr, const int portno, const char *request)
  58. {
  59.     CURL *curl;
  60.   CURLcode res;
  61.   /* Minimalistic http request */
  62.   //const char *request = "GET / HTTP/1.0\r\nHost: example.com\r\n\r\n";
  63.   //char request[1024] = "";
  64.   curl_socket_t sockfd; /* socket */
  65.   long sockextr;
  66.   size_t iolen;
  67.   curl_off_t nread;
  68.   int iLen = 0;
  69.   char cRet = 0;
  71.   assert((pc_ret != NULL) && (host_addr != NULL) && (request != NULL));
  73.   //curl_global_init(CURL_GLOBAL_DEFAULT);
  74.   curl = curl_easy_init();
  75.   if (!curl)    return 0;
  77.   //curl_easy_setopt(curl, CURLOPT_URL, "http://example.com");
  78.   curl_easy_setopt(curl, CURLOPT_URL, host_addr);
  79.   /* Do not do the transfer - only connect to host */
  80.   curl_easy_setopt(curl, CURLOPT_CONNECT_ONLY, 1L);
  81.   res = curl_easy_perform(curl);
  82.   if(CURLE_OK != res) {
  83.     printf("Error: %s\n", strerror(res));
  84.     return -1;
  85.   }
  87.   /* Extract the socket from the curl handle - we'll need it for waiting.
  88.    * Note that this API takes a pointer to a 'long' while we use
  89.    * curl_socket_t for sockets otherwise.
  90.    */
  91.   res = curl_easy_getinfo(curl, CURLINFO_LASTSOCKET, &sockextr);
  92.   if(CURLE_OK != res) {
  93.     printf("Error: %s\n", curl_easy_strerror(res));
  94.     return -2;
  95.   }
  97.   sockfd = sockextr;
  98.   /* wait for the socket to become ready for sending */
  99.   if(!wait_on_socket(sockfd, 0, 60000L)) {
  100.     printf("Error: timeout.\n");
  101.     return -3;
  102.   }
  104.   /* Send the request. Real applications should check the iolen
  105.    * to see if all the request has been sent */
  106.   res = curl_easy_send(curl, request, strlen(request), &iolen);
  107.   if(CURLE_OK != res) {
  108.     printf("Error: %s\n", curl_easy_strerror(res));
  109.     return -4;
  110.   }
  112.   /* read the response */
  113.   char buf[1024];
  114.   while(1) {
  115.     wait_on_socket(sockfd, 1, 60000L);
  116.     res = curl_easy_recv(curl, buf, 1024, &iolen);
  118.     if(CURLE_OK != res)
  119.       break;
  121.     nread = (curl_off_t)iolen;
  122.   }
  123.   buf[nread] = '\0';
  124.   DBG("Received (%" CURL_FORMAT_CURL_OFF_T "), %s\n", nread, buf);
  126.   /* always cleanup */
  127.   curl_easy_cleanup(curl);
  129.   pc_ret = strstr(buf, "\r\n\r\n");
  130.     if (pc_ret) {
  131.         pc_ret += 4;
  132.         DBG("ret = %s\n", pc_ret);
  133.     }
  135.   return 1;
  136. }
  138. #if (YEELINK == 1)
  139. int yeelink_create_data(const int device_id, const int sensor_id, const float device_value)
  140. {
  141.     char pc_ret[200], request[1024], pc_json[100], pc_time[30], pc_host_file[100], pc_header[100], ret;
  142.     int len;
  144.     sprintf(pc_host_file, "v1.0/device/%d/sensor/%d/datapoints", device_id, sensor_id);
  145.     sprintf(pc_header, "U-ApiKey: %s", YEELINK_API_KEY);
  147.     get_local_time(pc_time);
  148.     sprintf(pc_json, "{\"timestamp\":\"%s\",\"value\":%.2f}", pc_time, device_value);
  149.     len = strlen(pc_json);
  151.     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",
  152.         pc_host_file, YEELINK_HOST, pc_header, len, pc_json);
  153.     DBG("request = %s\n", request);
  155.     ret = connect_cloud(pc_ret, YEELINK_HOST, YEELINK_PORT, request);
  157.     return(ret);
  158. }
  159. #endif
  161. #if (LEWEI50 == 1)
  162. //curl --request POST http://www.lewei50.com/api/V1/Gateway/UpdateSensors/01 --data "[{\"Name\":\"T1\",\"Value\":\"23.08\"}]" --header "userkey:36be8ff22f794f1e8a0bee3336eef237"
  163. int lewei50_create_data(const char *device_id, const float device_value)
  164. {
  165.     char pc_ret[200], request[1024], pc_json[100], pc_header[100], ret;
  166.     int len;
  168.     assert(device_id != NULL);
  170.     sprintf(pc_header, "userkey: %s", LEWEI50_USER_KEY);
  171.     sprintf(pc_json, "[{\"Name\":\"%s\",\"Value\":\"%.2f\"}]", device_id, device_value);
  172.     len = strlen(pc_json);
  174.     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",
  175.         LEWEI50_HOST_FILE, LEWEI50_HOST, pc_header, len, pc_json);
  176.     DBG("request = %s\n", request);
  178.     ret = connect_cloud(pc_ret, LEWEI50_HOST, LEWEI50_PORT, request);
  180.     return(ret);
  181. }
  182. #endif
  184. //-------------------------------------------------------------------
  185. int main(void)
  186. {
  187.     float f_value = 15.02;
  188.     int i_tmp;
  190.     time_t t;
  191.   srand((unsigned)time(&t));    //初始化随机种子, 否则随机数不随机
  193.     i_tmp = rand();
  194.     i_tmp -= (i_tmp >> 4 << 4);
  195.   f_value += i_tmp;
  197. #if (YEELINK == 1)
  198.     yeelink_create_data(YEELINK_DEVICE_ID, YEELINK_SENSOR_ID, f_value);
  199. #endif
  201. #if (LEWEI50 == 1)
  202.     lewei50_create_data(LEWEI50_DEVICE_ID, f_value);
  203. #endif
  205.     return 1;
  206. }


Makefile: 注意openwrt的连接参数要多加的, 为了这几个字母, 折腾了好长时间

点击(此处)折叠或打开

  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
  6.     LFLAGS += -lcurl -lcrypto -lz -lssl
  8. else
  9.     CC = gcc
  10.     LFLAGS += -lcurl
  11. endif
  13. CFLAGS += -Wall -O2
  14. #CFLAGS += -g
  16. #可执行文件名和相关的obj文件
  17. APP_BINARY = http_cloud
  18. SRCS += http_cloud_curl_simple.c
  19. OBJS = $(SRCS:.c=.o)
  21. all: APP_FILE
  23. APP_FILE: $(OBJS)
  24.     $(CC) $(CFLAGS) $(OBJS) -o $(APP_BINARY) $(LFLAGS)
  26. .PHONY: clean
  27. clean:
  28.     @echo "cleanning project"
  29.     $(RM) *.a $(OBJS) *~ *.so *.lo $(APP_BINARY)
  30.     @echo "clean completed"

openwrt下的运行结果如下
root@OpenWrt:/xutest# ./http_cloud_libcurl
yeelini ret = HTTP/1.1 200 OK
Server: nginx/1.1.19
Date: Thu, 07 Nov 2013 00:56:56 GMT
Content-Type: text/html
Transfer-Encoding: chunked
Connection: close
X-Powered-By: PHP/5.3.10-1ubuntu3.6
Set-Cookie: CAKEPHP=dfvacsdpb8ls802dulnt695kk2; expires=Fri, 15-Nov-2013 08:56:56 GMT; path=/
P3P: CP="NOI ADM DEV PSAi COM NAV OUR OTRo STP IND DEM"

lewei50 ret = HTTP/1.1 200 OK
Date: Thu, 07 Nov 2013 00:56:56 GMT
Content-Type: application/json; charset=utf-8
Content-Length: 44
Connection: close
Cache-Control: private
Set-Cookie: SERVERID=a4a5b2bbca16d8c8b2ba6d5b6e55f36e|1383785816|1383785816;Path=/

{"Successful":true,"Message":"Successful. "}

root@OpenWrt:/xutest# 

这仅仅是libcurl最最简单的应用, 本着'师夷长技以制夷'的原则, 继续看官方文档中......

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

热门文章

最新文章

  • 1
    Ubuntu 14.04 更换阿里云源
  • 2
    Ubuntu 18.04 网络配置介绍
  • 3
    Ubuntu安装JDK与环境变量配置
  • 4
    ubuntu 内核升级
  • 5
    还在用Alpine作为你Docker的Python开发基础镜像？其实Ubuntu更好一点
  • 6
    ubuntu 下非交互式执行远程shell命令
  • 7
    Ubuntu 调查发现，大部分人从不更新他们的物联网设备
  • 8
    Ubuntu SDL lib 安装
  • 9
    Ubuntu shell 使用命令大全
  • 10
    Linux桌面版横评：五、Ubuntu 7.04
  • 1
    FFmpeg开发笔记（三十六）Linux环境安装SRS实现视频直播推流
    97
  • 2
    如何在 Linux 中检查和设置时区？
    60
  • 3
    如何在 Linux 中使用 systemd 安排定期任务？
    93
  • 4
    古希腊掌管Linux运维の神
    70
  • 5
    Linux系统之nice命令的基本使用
    75
  • 6
    linux常见的coredump原因都有哪些？
    249
  • 7
    Ubuntu/linux系统环境变量配置详解
    240
  • 8
    Linux学习之Ubuntu 20中OpenResty的nginx目录里内容和配置文件
    73
  • 9
    Gem在Kali Linux中运行wpscan时的加载错误
    80
  • 10
    Linux EXPORT_SYMBOL宏详解
    31

    • 相关课程

    更多
  • Linux MySQL服务器搭建与应用
  • Linux服务器运维基本操作
  • Linux基本命令
  • Linux企业运维实战 - 入门及常用命令
  • Linux Shell 编程入门与实战
  • Linux网络进阶 - TCP/IP协议及OSI七层模型

    • 相关电子书

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

    • 相关实验场景

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

    • 推荐镜像

    更多
  • mxlinux-iso
  • archlinuxarm
  • archlinuxcn
    • 下一篇
    DataWorks售前咨询