牽著老婆滿街逛

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

使用libcurl實(shí)現(xiàn)的上傳器

頭文件

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

* 文件名稱: Uploader_LibCurl.h

* 摘要: 上傳器 - LibCurl實(shí)現(xiàn)

* 作者: 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:

/// 線程入口函數(shù)

virtual bool run();

/// 啟動(dòng)上傳

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

/// 停止上傳

virtual bool stop();

/// 是否運(yùn)行狀態(tài)

bool isRunning() const;

protected:

/// 讀取回調(diào)

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

/// 進(jìn)度回調(diào)

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

protected:

/// 讀取回調(diào)

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

/// 進(jìn)度回調(diào)

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

/// 上傳回調(diào)

void onUpload();

protected:

/// 設(shè)置libcurl選項(xiàng)

bool setOption();

/// 清除數(shù)據(jù)

void clear();

protected:

CURL* m_pCurl; ///< libcurl句柄

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

bool m_bRunning; ///< 運(yùn)行標(biāo)志

std::string m_strRemoteUrl; ///< 遠(yuǎn)程鏈接

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

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

};

#endif

實(shí)現(xiàn)文件

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

* 文件名稱: Uploader_LibCurl.cpp

* 摘要: 上傳器 - LibCurl實(shí)現(xiàn)

* 作者: 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()

{

// 遠(yuǎn)程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);

// 設(shè)置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());

// 設(shè)置重定向的最大次數(shù)

curl_easy_setopt(m_pCurl, CURLOPT_MAXREDIRS, 5);

// 設(shè)置301、302跳轉(zhuǎn)跟隨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);

// 上傳內(nèi)容回調(diào)函數(shù)

curl_easy_setopt(m_pCurl, CURLOPT_READFUNCTION, handleRead);

curl_easy_setopt(m_pCurl, CURLOPT_READDATA, this);

// 進(jìn)度回調(diào)函數(shù)

curl_easy_setopt(m_pCurl, CURLOPT_NOPROGRESS, 0);

curl_easy_setopt(m_pCurl, CURLOPT_PROGRESSDATA, this);

curl_easy_setopt(m_pCurl, CURLOPT_PROGRESSFUNCTION, handleProgress);

// 跳過服務(wù)器SSL驗(yàn)證，不使用CA證書

curl_easy_setopt(m_pCurl, CURLOPT_SSL_VERIFYPEER, 0L);

// 驗(yàn)證服務(wù)器端發(fā)送的證書，默認(rèn)是 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;

}

// 設(shè)置libcurl的選項(xiàng)

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()

{

// 執(zhí)行上傳

CURLcode return_code = CURLE_OK;

return_code = curl_easy_perform(m_pCurl);

// 關(guān)閉文件

if (m_pFile)

{

fclose(m_pFile);

m_pFile = NULL;

}

// 上傳失敗

if (return_code != CURLE_OK)

{

return;

}

// 獲取狀態(tài)碼

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 楊粼波閱讀(1244) 評(píng)論(0) 編輯收藏引用所屬分類: 網(wǎng)絡(luò)編程、C++

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

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

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

牽著老婆滿街逛

導(dǎo)航

統(tǒng)計(jì)

公告

常用鏈接

留言簿(11)

隨筆分類(466)

隨筆檔案(1513)

文章分類(46)

文章檔案(45)

相冊(cè)

收藏夾(39)

工具官網(wǎng)

技術(shù)網(wǎng)站

開源網(wǎng)站

其他窩點(diǎn)

收藏網(wǎng)站

銀行官網(wǎng)

友情鏈接

資源共享

搜索

積分與排名

最新評(píng)論

閱讀排行榜

使用libcurl實(shí)現(xiàn)的上傳器