牽著老婆滿街逛

嚴以律己,寬以待人. 三思而后行.
GMail/GTalk: yanglinbo#google.com;
MSN/Email: tx7do#yahoo.com.cn;
QQ: 3 0 3 3 9 6 9 2 0 .

統計

隨筆 - 1513
文章 - 45
評論 - 907
引用 - 0

公告

言論：
1.每日自省；
2.享受人生；
3.盡力而為；
4.堅持不懈；
5.切莫急躁；
6.慎言敏行；
7.動心忍性；
8.上善若水。

常用鏈接

留言簿(11)

隨筆分類(466)

隨筆檔案(1513)

文章分類(46)

文章檔案(45)

相冊

收藏夾(39)

搜索

積分與排名

積分 - 2528451
排名 - 2

閱讀排行榜

使用libcurl實現的上傳器

頭文件

/**********************************************************************

*

* 文件名稱: Uploader_LibCurl.h

* 摘要: 上傳器 - LibCurl實現

*

* 作者: yanglinbo,

* 修改: 查看文件最下方.

*

***********************************************************************/

#ifndef __Uploader_LibCurl_H__

#define __Uploader_LibCurl_H__

#include <curl/curl.h>

#include <fstream>

#include <string>

class CUploader

{

public:

CUploader(void);

virtual ~CUploader(void);

public:

/// 線程入口函數

virtual bool run();

/// 啟動上傳

virtual bool start(const std::string& strUrl, const std::string& strLocalFile);

/// 停止上傳

virtual bool stop();

/// 是否運行狀態

bool isRunning() const;

protected:

/// 讀取回調

static size_t handleRead(void *buffer, size_t size, size_t nmemb, void *userp);

/// 進度回調

static size_t handleProgress(void *buffer, double dltotal, double dlnow, double ultotal, double ulnow);

protected:

/// 讀取回調

size_t onUpload(void *buffer, size_t size, size_t nmemb);

/// 進度回調

size_t onProgress(const double& ultotal, const double& ulnow);

/// 上傳回調

void onUpload();

protected:

/// 設置libcurl選項

bool setOption();

/// 清除數據

void clear();

protected:

CURL* m_pCurl; ///< libcurl句柄

FILE* m_pFile; ///< 文件指針

bool m_bRunning; ///< 運行標志

std::string m_strRemoteUrl; ///< 遠程鏈接

std::string m_strLocalFilePath; ///< 本地文件路徑

size_t m_nLocalFileSize; ///< 本地文件大小

};

#endif

實現文件

/**********************************************************************

*

* 文件名稱: Uploader_LibCurl.cpp

* 摘要: 上傳器 - LibCurl實現

*

* 作者: yanglinbo,

* 修改: 查看文件最下方.

*

***********************************************************************/

#include "StdAfx.h"

#include "Uploader.h"

#include <sys/stat.h>

#include <fcntl.h>

CUploader::CUploader(void)

: m_pCurl(NULL)

, m_pFile(NULL)

, m_bRunning(false)

, m_nLocalFileSize(0)

{

}

CUploader::~CUploader(void)

{

stop();

}

bool CUploader::run()

{

onUpload();

return true;

}

bool CUploader::isRunning() const

{

return m_bRunning;

}

void CUploader::clear()

{

if (m_pFile)

{

fclose(m_pFile);

m_pFile = NULL;

}

if (m_pCurl)

{

curl_easy_cleanup(m_pCurl);

m_pCurl = NULL;

curl_global_cleanup();

}

m_strRemoteUrl.clear();

m_strLocalFilePath.clear();

m_nLocalFileSize = 0;

}

bool CUploader::setOption()

{

// 遠程URL，支持 http, https, ftp

curl_easy_setopt(m_pCurl, CURLOPT_URL, m_strRemoteUrl.c_str());

curl_easy_setopt(m_pCurl, CURLOPT_INFILESIZE_LARGE, (curl_off_t)m_nLocalFileSize);

// 設置User-Agent

std::string useragent = _T("Mozilla/5.0 (Windows NT 6.1; WOW64; rv:13.0) Gecko/20100101 Firefox/13.0.1");

curl_easy_setopt(m_pCurl, CURLOPT_USERAGENT, useragent.c_str());

// 設置重定向的最大次數

curl_easy_setopt(m_pCurl, CURLOPT_MAXREDIRS, 5);

// 設置301、302跳轉跟隨location

curl_easy_setopt(m_pCurl, CURLOPT_FOLLOWLOCATION, 1);

curl_easy_setopt(m_pCurl, CURLOPT_UPLOAD, TRUE);

curl_easy_setopt(m_pCurl, CURLOPT_NOSIGNAL, 1L);

curl_easy_setopt(m_pCurl, CURLOPT_POST, TRUE);

curl_easy_setopt(m_pCurl, CURLOPT_FORBID_REUSE, TRUE);

// 上傳內容回調函數

curl_easy_setopt(m_pCurl, CURLOPT_READFUNCTION, handleRead);

curl_easy_setopt(m_pCurl, CURLOPT_READDATA, this);

// 進度回調函數

curl_easy_setopt(m_pCurl, CURLOPT_NOPROGRESS, 0);

curl_easy_setopt(m_pCurl, CURLOPT_PROGRESSDATA, this);

curl_easy_setopt(m_pCurl, CURLOPT_PROGRESSFUNCTION, handleProgress);

// 跳過服務器SSL驗證，不使用CA證書

curl_easy_setopt(m_pCurl, CURLOPT_SSL_VERIFYPEER, 0L);

// 驗證服務器端發送的證書，默認是 2(高)，1（中），0（禁用）

curl_easy_setopt(m_pCurl, CURLOPT_SSL_VERIFYHOST, 0L);

return true;

}

bool CUploader::start(const std::string& strUrl, const std::string& strLocalFile)

{

if (strUrl.empty()) return false;

if (m_bRunning == true) return true;

clear();

m_strRemoteUrl = strUrl;

m_strLocalFilePath = strLocalFile;

// 打開文件

m_pFile = fopen(m_strLocalFilePath.c_str(), "rb");

if (m_pFile == NULL)

{

return false;

}

// 獲取文件大小

struct stat file_info;

if (fstat(fileno(m_pFile), &file_info) != 0)

{

return false;

}

m_nLocalFileSize = file_info.st_size;

// 初始化libcurl

m_pCurl = curl_easy_init();

if (m_pCurl == NULL)

{

return false;

}

// 設置libcurl的選項

setOption();

m_bRunning = true;

return true;

}

bool CUploader::stop()

{

clear();

m_bRunning = false;

return true;

}

size_t CUploader::handleRead( void *buffer, size_t size, size_t nmemb, void *userp )

{

CUploader* pDownloader = (CUploader*) userp;

if (pDownloader)

{

return pDownloader->onUpload(buffer, size, nmemb);

}

return 0;

}

size_t CUploader::handleProgress( void *buffer, double dltotal, double dlnow, double ultotal, double ulnow )

{

CUploader* pDownloader = (CUploader*) buffer;

if (pDownloader)

{

pDownloader->onProgress(ultotal, ulnow);

}

return 0;

}

size_t CUploader::onProgress( const double& ultotal, const double& ulnow )

{

TRACE("%.2f / %.2f (%.2g %%)\n", ulnow, ultotal, ulnow*100.0/ultotal);

return 0;

}

size_t CUploader::onUpload( void *buffer, size_t size, size_t nmemb )

{

size_t return_size = fread(buffer, size, nmemb, m_pFile);

return return_size;

}

void CUploader::onUpload()

{

// 執行上傳

CURLcode return_code = CURLE_OK;

return_code = curl_easy_perform(m_pCurl);

// 關閉文件

if (m_pFile)

{

fclose(m_pFile);

m_pFile = NULL;

}

// 上傳失敗

if (return_code != CURLE_OK)

{

return;

}

// 獲取狀態碼

int response_code = 0;

curl_easy_getinfo(m_pCurl, CURLINFO_RESPONSE_CODE, &response_code);

}

示例代碼：

CUploader uploader

uploader.start("ftp://upload:upload@127.0.0.1/hello.exe", "C:\\fly.exe");

uploader.run();

posted on 2014-04-01 23:23 楊粼波閱讀(1257) 評論(0) 編輯收藏引用所屬分類: 網絡編程、C++

只有注冊用戶登錄后才能發表評論。


相關文章: 使用libcurl實現的上傳器剖析 epoll ET/LT 觸發方式的性能差異誤解（定性分析）網頁游戲分線到不分線 Google開源實時通信項目WebRTC IOCP+UDP收包的時候:報0xC000000005，讀取0x00000010錯誤的問題 udp丟包又是udp丟包糊涂窗口綜合癥和Nagle算法 UDP_CORK,TCP_CORK以及TCP_NODELAY Chromium Embedded Framework中文文檔之(基本使用) 在Windows下編譯最新版本的Libjingle

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

牽著老婆滿街逛

導航

統計

公告

常用鏈接

留言簿(11)

隨筆分類(466)

隨筆檔案(1513)

文章分類(46)

文章檔案(45)

相冊

收藏夾(39)

工具官網

技術網站

開源網站

其他窩點

收藏網站

銀行官網

友情鏈接

資源共享

搜索

積分與排名

最新評論

閱讀排行榜

使用libcurl實現的上傳器