（轉）利用libcurl獲取新浪股票接口, ubuntu和openwrt實驗成功(三)

時間  2019-12-14
標籤 利用 libcurl 獲取 新浪 股票 接口 ubuntu openwrt 實驗 成功 欄目 Ubuntu 简体版
原文   原文鏈接

1.  利用 CURLOPT_WRITEFUNCTION 設置回調函數, 利用 CURLOPT_WRITEDATA 獲取數據指針 

官網文檔以下
javascript

CALLBACK OPTIONS

 

CURLOPT_WRITEFUNCTION css

Pass a pointer to a function that matches the following prototype: size_t function( char *ptr, size_t size, size_t nmemb, void *userdata); This function gets called by libcurl as soon as there is data received that needs to be saved. The size of the data pointed to by ptr is size multiplied with nmemb, it will not be zero terminated. Return the number of bytes actually taken care of. If that amount differs from the amount passed to your function, it'll signal an error to the library. This will abort the transfer and return CURLE_WRITE_ERROR. html

From 7.18.0, the function can return CURL_WRITEFUNC_PAUSE which then will cause writing to this connection to become paused. See curl_easy_pause(3) for further details. java

This function may be called with zero bytes data if the transferred file is empty. linux

Set this option to NULL to get the internal default function. The internal default function will write the data to the FILE * given with CURLOPT_WRITEDATA. 程序員

Set the userdata argument with the CURLOPT_WRITEDATA option. app

The callback function will be passed as much data as possible in all invokes, but you cannot possibly make any assumptions. It may be one byte, it may be thousands. The maximum amount of body data that can be passed to the write callback is defined in the curl.h header file: CURL_MAX_WRITE_SIZE (the usual default is 16K). If you however have CURLOPT_HEADER set, which sends header data to the write callback, you can get up to CURL_MAX_HTTP_HEADER bytes of header data passed into it. This usually means 100K. curl

CURLOPT_WRITEDATA 函數

Data pointer to pass to the file write function. If you use the CURLOPT_WRITEFUNCTION option, this is the pointer you'll get as input. If you don't use a callback, you must pass a 'FILE *' (cast to 'void *') as libcurl will pass this to fwrite() when writing data. By default, the value of this parameter is unspecified. this

The internal CURLOPT_WRITEFUNCTION will write the data to the FILE * given with this option, or to stdout if this option hasn't been set.

If you're using libcurl as a win32 DLL, you MUST use the CURLOPT_WRITEFUNCTION if you set this option or you will experience crashes.

This option is also known with the older name CURLOPT_FILE, the name CURLOPT_WRITEDATA was introduced in 7.9.7.


2. 完整代碼以下:

點擊(此處)摺疊或打開

  1. /*------------------------------------------------------------------------------------------
  2. 名稱: http_sina_curl_callbak.c
  3. 功能: 利用libcurl的回調機制實現sina股票接口. http://curl.haxx.se/libcurl/c/curl_easy_setopt.html
  5. http://hq.sinajs.cn/list=sz150013
  6. http://hq.sinajs.cn/list=sh601318
  8. #libcurl的調試信息
  9. * About to connect() to hq.sinajs.cn port 80 (#0)
  10. * Trying 219.142.78.242...
  11. * connected
  12. * Connected to hq.sinajs.cn (219.142.78.242) port 80 (#0)
  13. > GET /list=sz150001 HTTP/1.1
  14. Host: hq.sinajs.cn
  15. Accept: * *
  17. < HTTP/1.1 200 OK
  18. < Cache-Control: no-cache
  19. < Content-Length: 250
  20. < Connection: Keep-Alive
  21. < Content-Type: application/x-javascript; charset=GBK
  22. <
  23. * Connection #0 to host hq.sinajs.cn left intact
  24. * Closing connection #0
  26. #運行結果:
  27. root@OpenWrt:/xutest# ./http_sina_stock
  28. sz150001: dq = 0.724, jg = 0.730, jd = 0.722, jk = 0.729
  29. sz150013: dq = 0.886, jg = 0.893, jd = 0.885, jk = 0.889
  30. sz150100: dq = 0.981, jg = 0.982, jd = 0.979, jk = 0.980
  31. sz150152: dq = 0.964, jg = 0.967, jd = 0.964, jk = 0.965
  32. sz150018: dq = 0.958, jg = 0.960, jd = 0.957, jk = 0.960
  33. root@OpenWrt:/xutest#
  34. -------------------------------------------------------------------------------------------*/
  35. #include <stdio.h>
  36. #include <stdlib.h>
  37. #include <string.h>
  38. #include <curl/curl.h>
  39. #include <assert.h>
  41. #define HTTP_GET "GET"
  42. #define HTTP_PUT "PUT"
  43. #define HTTP_HEAD "HEAD"
  44. #define HTTP_POST "POST"
  45. #define HTTP_DELETE "DELETE"
  46. #define HTTP_RET_OK "HTTP/1.1 200 OK\r\n"
  48. #define SINA_HOST "hq.sinajs.cn"
  49. #define SINA_PORT 80
  51. #define ARRAY_COUNT(x) (sizeof(x) / sizeof(x[0]))
  53. typedef struct {
  54.     float price_dq;    //當前價, 取拼音的首字母
  55.     float price_zs;    //昨收價
  56.     float price_jk;    //今開價
  57.     float price_jg;    //今高價
  58.     float price_jd;    //今低價
  59. } stock_info_t;
  61. #define DBG //printf
  62. #define CURL_DBG (0)    //1=開啓curl的調試
  64. //-----------------------------------------------------------------------------------------
  65. static void delay_ms(int msec)
  66. {
  67.     struct timeval timeout;
  69.     memset(&timeout, 0, sizeof(struct timeval));
  70.     timeout.tv_sec    = msec / 1000;
  71.     timeout.tv_usec    = (msec % 1000) * 1000;
  72.     select(0, NULL, NULL, NULL, &timeout);
  73. }
  75. size_t callback_get_head(void *ptr, size_t size, size_t nmemb, void *userp)
  76. {
  77.     strcat(userp, ptr);
  79.     return size * nmemb; //必須返回這個大小, 不然只回調一次
  80. }
  82. static char connect_cloud(char *pc_ret, const char *host_addr, const int portno,
  83.     const char *pc_method, struct curl_slist *http_headers)
  84. {
  85.     CURL *curl;
  86.     CURLcode res = CURLE_GOT_NOTHING;
  88.   assert((pc_ret != NULL) && (host_addr != NULL) && (pc_method != NULL));
  90.   //curl_global_init(CURL_GLOBAL_DEFAULT);
  91.   curl = curl_easy_init();
  92.   if (!curl)    {
  93.       fprintf(stderr, "--- curl init Error!\n");
  94.       return 0;
  95.   }
  97.   curl_easy_setopt(curl, CURLOPT_URL, host_addr);
  98.   curl_easy_setopt(curl, CURL_HTTP_VERSION_1_1, 1L);    //HTTP 1.1
  99.   curl_easy_setopt(curl, CURLOPT_TIMEOUT, 3);     //設置超時, 單位爲秒.
  100.     curl_easy_setopt(curl, CURLOPT_NOSIGNAL, 1L);     //屏蔽其它信號, makes libcurl NOT ask the system to ignore SIGPIPE signals
  101.     curl_easy_setopt(curl, CURLOPT_HEADER, 1L);         //下載數據包括HTTP頭部, The default value for this parameter is 0.
  102.     //curl_easy_setopt(curl, CURLOPT_NOPROGRESS, 0);    //The default value for this parameter is 1
  104. #if (CURL_DBG == 1)
  105.   curl_easy_setopt(curl, CURLOPT_VERBOSE, 1L);    //調試用: 顯示交互明細,
  106.     //curl_easy_setopt(curl, CURLOPT_HEADER, 1L);    //調試用: 只顯示頭行的返回
  107. #endif
  109. #if 1
  110.     curl_easy_setopt(curl, CURLOPT_CUSTOMREQUEST, pc_method);
  112.     curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, callback_get_head); //下載數據的回調函數
  113.     curl_easy_setopt(curl, CURLOPT_WRITEDATA, pc_ret);                                //下載數據的指針
  115.     curl_easy_setopt(curl, CURLOPT_HTTPHEADER, http_headers);    //多行的HTTP頭部
  116. #endif
  118.   res = curl_easy_perform(curl);
  119.   if(res != CURLE_OK)
  120.       fprintf(stderr, "curl_easy_perform() failed: %s\n", curl_easy_strerror(res));
  122.     curl_easy_cleanup(curl);
  124.   return 1;
  125. }
  127. int sina_get_stock(char *pc_ret, const char *pc_stockid)
  128. {
  129.     char pc_url[200], ret;
  131.     //組織請求頭部, 自動末尾添加'\r\n'
  132.     struct curl_slist *http_headers = NULL;
  133.     http_headers = curl_slist_append(http_headers, "Accept: */*");
  134.     //http_headers = curl_slist_append(http_headers, "Connection: Close");
  136.     //發送請求, 再判斷返回值
  137.     //url = hq.sinajs.cn/list=sz150013
  138.     sprintf(pc_url, "%s/list=%s", SINA_HOST, pc_stockid);
  139.     ret = connect_cloud(pc_ret, pc_url, SINA_PORT, HTTP_GET, http_headers);
  140.     //DBG("cloud ret = %s\n", pc_ret);
  142.     //釋放 http_headers資源
  143.     curl_slist_free_all(http_headers);
  145.     return(ret);
  146. }
  148. #if 0
  149. /*字符串不一樣含義的數據用逗號隔開了，按照程序員的思路，順序號從0開始。
  150. 0：」大秦鐵路」，股票名字；
  151. 1：」27.55″，今日開盤價；
  152. 2：」27.25″，昨日收盤價；
  153. 3：」26.91″，當前價格；
  154. 4：」27.55″，今日最高價；
  155. 5：」26.20″，今日最低價；
  156. 6：」26.91″，競買價，即「買一」報價；
  157. 7：」26.92″，競賣價，即「賣一」報價；
  158. 8：」22114263″，成交的股票數，因爲股票交易以一百股爲基本單位，因此在使用時，一般把該值除以一百；
  159. 9：」589824680″，成交金額，單位爲「元」，爲了一目瞭然，一般以「萬元」爲成交金額的單位，因此一般把該值除以一萬；
  160. 10：」4695″，「買一」申請4695股，即47手；
  161. 11：」26.91″，「買一」報價；
  162. 12：」57590″，「買二」
  163. 13：」26.90″，「買二」
  164. 14：」14700″，「買三」
  165. 15：」26.89″，「買三」
  166. 16：」14300″，「買四」
  167. 17：」26.88″，「買四」
  168. 18：」15100″，「買五」
  169. 19：」26.87″，「買五」
  170. 20：」3100″，「賣一」申報3100股，即31手；
  171. 21：」26.92″，「賣一」報價
  172. (22, 23), (24, 25), (26,27), (28, 29)分別爲「賣二」至「賣四的狀況」
  173. 30：」2008-01-11″，日期；
  174. 31：」15:05:32″，時間；*/
  175. #endif
  177. void stock_parse(stock_info_t *stock, const char *pc_data)
  178. {
  179.     char *pc_str, *pc_str1;
  180.     int i;
  182.     assert((stock != NULL) &&(pc_data != NULL));
  184.     //DBG("data = %s\n", pc_data);
  185.     pc_str = strstr(pc_data, HTTP_RET_OK);
  186.     if (pc_str) {
  187.         pc_str += strlen(HTTP_RET_OK);
  189.         pc_str = strstr(pc_str, "\r\n\r\n");
  190.         pc_str += 4;
  191.         DBG("valid str = %s\n", pc_str);
  193.         //解析數據, var hq_str_sz150013="???B,0.899,0.906,0.897,0.903,0.895,0.897,0.898,9739979,8751058.780,2200,0.897,143548,0.896,572900,0.895,625300,0.894,167300,0.893,9800,0.898,60000,0.899,362300,0.900,162500,0.901,217000,0.902,2013-11-06,10:38:44,00";
  194.         pc_str = strchr(pc_str, ',');
  195.         pc_str ++;
  197.         for (i=0; i<5; i++) {
  198.             pc_str1 = strchr(pc_str, ',');
  199.             if (pc_str1) {
  200.                 *pc_str1 = '\0';
  201.                 switch(i) {
  202.                     case 0: stock->price_jk = atof(pc_str); break;    //今開
  203.                     case 1: stock->price_zs = atof(pc_str); break;    //昨收
  204.                     case 2: stock->price_dq = atof(pc_str); break;    //當前
  205.                     case 3: stock->price_jg = atof(pc_str); break;    //今高
  206.                     case 4: stock->price_jd = atof(pc_str); break;    //今低
  207.                 }
  209.                 pc_str = pc_str1 + 1;    //指向下個有效數據
  210.             }
  211.             else break;
  212.         }
  213.     }
  214. }
  216. //-------------------------------------------------------------------------------
  217. int main(void)
  218. {
  219.     char pc_ret[1000];
  220.     int i, max;
  221.     stock_info_t stock;
  223.     char *stock_array[] = {"sz150001", "sz150013", "sz150100", "sz150152", "sz150018"};    //改爲本身的
  224.     max = ARRAY_COUNT(stock_array);
  226.     for(i=0; i<max; i++) {
  227.         memset(pc_ret, 0x00, sizeof(pc_ret));
  228.         sina_get_stock(pc_ret, stock_array[i]);
  229.         DBG("sina ret OK = %s\n", pc_ret);
  230.         stock_parse(&stock, pc_ret);
  231.         printf("%s: dq = %.3f, jg = %.3f, jd = %.3f, jk = %.3f\n",
  232.                 stock_array[i], stock.price_dq, stock.price_jg, stock.price_jd ,stock.price_jk);
  233.     }
  235.     return 1;
  236. }


3. Makefile: 

點擊(此處)摺疊或打開

  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_sina_stock
  18. SRCS += http_sina_curl_callback.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"

4. openwrt下運行結果以下root@OpenWrt:/xutest# ./http_sina_stocksz150001: dq = 0.724, jg = 0.730, jd = 0.722, jk = 0.729sz150013: dq = 0.886, jg = 0.893, jd = 0.885, jk = 0.889sz150100: dq = 0.981, jg = 0.982, jd = 0.979, jk = 0.980sz150152: dq = 0.964, jg = 0.967, jd = 0.964, jk = 0.965sz150018: dq = 0.958, jg = 0.960, jd = 0.957, jk = 0.960root@OpenWrt:/xutest#

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程