[cpp] view plaincopy

1. void HelloWorld::menuCallback(CCObject* pSender) {
2.     CCMenuItem *item = (CCMenuItem *)pSender;
3.     switch (item->getTag()) {
4.         case 1: // down start
5.             CCDirector::sharedDirector()->getScheduler()->scheduleSelector(schedule_selector(HelloWorld::updateUI), this, 0, false); // HttpClient中参考
6.             isStop = false;
7.             this->threadStart();
8.             break;
9.         case 2: // down stop
10.             isStop = true;
11.             break;
12.         case 3:
13.             if (isStop) {
14.                 CCLog(“downFilePath:%s”,downFilePath.c_str());
15.                 if (access(downFilePath.c_str(), 0) == 0) {
16.                     remove(downFilePath.c_str());
17.                     CCMessageBox(“删除成功”, ”温馨提示”);
18.                 }else{
19.                     CCMessageBox(“没有找到文件目录”, ”温馨提示”);
20.                 }
21.             }else{
22.                 CCMessageBox(“下载中或没有文件下载”, ”温馨提示”);
23.             }
25.             break;
26.         default:
27.             break;
28.     }
29. }

[cpp] view plaincopy

1. // 启动线程的方法
2. int HelloWorld::threadStart() {
3.     pthread_mutex_init(&g_downloadMutex, NULL);
4.     int errCode=0;
5.     pthread_t th_curlDown; // 线程初始化
6.     do {
7.         pthread_attr_t tAttr;
8.         errCode=pthread_attr_init(&tAttr);
9.         CC_BREAK_IF(errCode!=0);
10.         errCode=pthread_attr_setdetachstate(&tAttr, PTHREAD_CREATE_DETACHED);
11.         if(errCode!=0) {
12.             pthread_attr_destroy(&tAttr);
13.             break;
14.         }
15.         errCode=pthread_create(&th_curlDown, &tAttr, thread_funcation, this);
16.     } while (0);
17.     return errCode;
18. }
20. // 需要线程来完成的功能都写在这个函数里
21. void* HelloWorld::thread_funcation(void *arg) {
22.     CCLOG(“thread started…”);
23.     HelloWorld *hw = (HelloWorld*)arg;
24.     hw->ccc = new CurlDown(“http://developer.baidu.com/map/static/doc/output/BaiduMap_AndroidSDK_v2.4.0_All.zip”,hw->downFilePath);
25.     //    ccc->mDownloadUrl = ”http://developer.baidu.com/map/static/doc/output/BaiduMap_AndroidSDK_v2.4.0_All.zip”;
26.     //    int leng = ccc->getDownloadFileLenth();
27.     hw->ccc->setDelegate(hw);
28.     hw->ccc->downloadControler();
30.     return NULL;
31. }

[cpp] view plaincopy

1. void HelloWorld::onError(CurlDown::ErrorCode errorCode){
2.     CCLog(“error”);
4.     pthread_mutex_lock(&g_downloadMutex);
5.     updateStr = ”error”;
6.     pthread_mutex_unlock(&g_downloadMutex);
8.     CCDirector::sharedDirector()->getScheduler()->unscheduleSelector(schedule_selector(HelloWorld::updateUI), this);
9. }
10. void HelloWorld::onProgress(double percent, void *delegate, string filefullPath){ // 下载进度
11.     CCLog(“donw progress:%.2f%%”,percent);
13.     if (isStop) {
14.         CurlDown * cd = (CurlDown *)delegate;
15.         //        pthread_mutex_lock(&g_downloadMutex);
16.         cd->setStopDown();
17.         //        pthread_mutex_unlock(&g_downloadMutex);
18.     }
20.     pthread_mutex_lock(&g_downloadMutex);
21.     const char * per =CCString::createWithFormat(“donw progress:%.2f%%”,percent)->getCString();
22.     updateStr = per;
23.     downFilePath = filefullPath;
24.     pthread_mutex_unlock(&g_downloadMutex);
25. }
26. void HelloWorld::onSuccess(string filefullPath){
27.     CCLog(“success”);
29.     pthread_mutex_lock(&g_downloadMutex);
30.     updateStr = ”success”;
31.     downFilePath = filefullPath;
32.     pthread_mutex_unlock(&g_downloadMutex);
33. }

[cpp] view plaincopy

1. static pthread_mutex_t g_downloadMutex_1;
3. CurlDown::~CurlDown(){
4.     mFileLenth = 0;
5. }
6. CurlDown::CurlDown():isStop(false),mDownloadUrl(“”),timeout(2){ // test timeout 2 seconds. if release timeout 20 seconds
7.     mFileLenth = 0;
8.     mFilePath = ”";
9.     pthread_mutex_init(&g_downloadMutex_1, NULL);
10. }
11. CurlDown::CurlDown(string downUrl,string filePath):mFileLenth(0),isStop(false),mDownloadUrl(downUrl),timeout(2),mFilePath(filePath){  // test timeout 2 seconds. if release timeout 20 seconds
12.     mDownloadUrl = downUrl;
13.     pthread_mutex_init(&g_downloadMutex_1, NULL);
14. }
16. void CurlDown::setDelegate(CurlDownDelegate * delegate) {
17.     mDelegate = delegate;
18. }

[cpp] view plaincopy

1. void CurlDown::downloadControler() {
2.     CCLog(“–1-”);
3.     mFileLenth = getDownloadFileLenth(); // 获取远程文件大小
4.     if (mFileLenth <= 0) {
5.         cout << ”download file fail…” << endl;
6.         mDelegate->onError(kNetwork);
7.         return;
8.     }
9.     vector<string> searchPaths = CCFileUtils::sharedFileUtils()->getSearchPaths();
10.     vector<string>::iterator iter = searchPaths.begin();
11.     searchPaths.insert(iter, mFilePath);
12.     CCFileUtils::sharedFileUtils()->setSearchPaths(searchPaths);
14.     CCLog(“–2-mFileLenth:%f”,mFileLenth);
15.     mFileName = mDownloadUrl.substr(mDownloadUrl.rfind(‘/’) + 1);
16.     CCLog(“–3-”);
17.     CCLog(“mFileName:%s;”,mFileName.c_str());
18. //    mFilePath = CCFileUtils::sharedFileUtils()->getWritablePath();
19. //    CCLog(“–5-”);
20.     mFilePath = mFilePath + mFileName;
21.     CCLog(“mFilePath:%s”,mFilePath.c_str());
22.     CCLog(“–6-”);
23.     bool ret = false;
24.     while (true){ // 循环下载 每30秒进行下载 避免断网情况
25.         ret = download(); //直接下载 进行堵塞线程
26.         CCLog(“—-stop—%s——”,isStop?”true”:”false”);
27.         if (isStop) { // 如果进行停止 break
28.             CCLog(“—-stop———”);
29.             break;
30.         }
31.         if (ret ){ //下载完成
32.             break;
33.         }
34.         sleep(0.5); //每次下载中间间隔0.5秒
35.     }
37.     if (ret) {
38.         CCLog(“download ok”);
39.         mDelegate->onSuccess(mFilePath);
40.     } else {
41.         CCLog(“download fail”);
42.         mDelegate->onError(kUncompress);
43.     }
44. }

[cpp] view plaincopy

1. #pragma mark 进行下载
2. bool CurlDown::download() {
3.     FILE *fp = NULL;
4.     if(access(mFilePath.c_str(), 0)==0) { // 以二进制形式追加
5.         fp = fopen(mFilePath.c_str(), ”ab+”);
6.     } else { // 二进制写
7.         fp = fopen(mFilePath.c_str(), ”wb”);
8.     }
10.     if (fp == NULL) {// 如果文件初始化失败进行返回
11.         return false;
12.     }
14.     // 读取本地文件下载大小
15.     long localFileLenth = getLocalFileLength(); //已经下载的大小
16.     CCLog(“filePath:%s；leng:%ld”,mFilePath.c_str() , localFileLenth ); //4397779 //3377875
18.     CURL *handle = curl_easy_init();
19.     std::string packageUrl = mDownloadUrl; //下载地址+下载文件名
20.     curl_easy_setopt(handle, CURLOPT_URL, packageUrl.c_str()); // http://curl.haxx.se/libcurl/c/fopen.html
21.     curl_easy_setopt(handle, CURLOPT_TIMEOUT, timeout);
22.     curl_easy_setopt(handle, CURLOPT_WRITEFUNCTION, my_write_func);   //写文件回调方法
23.     curl_easy_setopt(handle, CURLOPT_WRITEDATA, fp); // 写入文件对象
24.     curl_easy_setopt(handle, CURLOPT_RESUME_FROM, localFileLenth);  // 从本地大小位置进行请求数据
25.     //    curl_easy_setopt(handle, CURLOPT_RESUME_FROM_LARGE, localFileLenth); // 坑
26.     curl_easy_setopt(handle, CURLOPT_NOPROGRESS, 0L);
27.     curl_easy_setopt(handle, CURLOPT_PROGRESSFUNCTION, my_progress_func ); //下载进度回调方法
28.     curl_easy_setopt(handle, CURLOPT_PROGRESSDATA, this); // 传入本类对象
30.     CURLcode res = curl_easy_perform(handle);
31.     fclose(fp);
32.     return res == CURLE_OK;
33. }

本文链接地址: coco2dx c++ 断点续传实现http://www.hongyanliren.com/2014m12/25036.html

相关文章

• esp8266(3) Arduino通过ESP8266连接和获取网站源代码
• 手机连接设备的蓝牙向其发送服务器局域网IP信息，从而esp8266与该服务器建立tcp连接
• 【Arduino】、Arduino+ESP8266上传至oneNet云
• 10大三维雕刻软件：为3D打印创建数字雕刻模型最强大的工具
• 有比UG更好，更优秀的吗？
• zbrush 是做什么用的软件？和max rhino 有什么不同么？优势是什么？
• ZBrush、犀牛、3D那种软件做工业设计计算机快速表现比较好？
• esp8266-01板的arduino烧写方式