利用Internet协议实现各种文件的下载

﹏ヽ暗。殇╰゛Y 2022-01-14 08:57 178阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

头文件：///
    #ifndef  _HTTP_H
    #define _HTTP_H
    #include<windows.h>
    #include<Wininet.h>
    #include<string>
    #include<tchar.h>
    using namespace std;
    #define MAX_ZIP  3
    #define ZIP_PATH_URL 256
    class HttpFile
    {
    public:
    	HttpFile();
    	bool User_interface();
    	~HttpFile();
    private:
    	bool HttpConnection(LPCTSTR lpszUrl, 
    	 								 LPCTSTR lpszHeaders, 
    									 const void* pPostData, 
    									 int nLen,
    									 std::string &strResult,
    									 char *zipname);
    	bool SendAnalyseResult(LPCTSTR lpszUrl,  LPCTSTR lpszHeaders,const void* pPostData, int nLen,  std::string &strResult);	
    	bool RecvFileUrl();
    	bool RecvFileZip();
    public:
    	HINTERNET hOpen ;
    	HINTERNET hConnect ;
    	HINTERNET hRequest ;
    	LPCTSTR lpszHeaders;
    	LPCTSTR zipDirUrl;
    	LPCTSTR zipDownloadzUrl;
    	LPCTSTR zipUploadUrl;
    	DWORD dwFlags;	
    	BOOL bRet;
    	string strResult;
    	const void* pPostData;	
    
    	unsigned short reportid_label;
    	unsigned short count_label;
    	unsigned short file1_label;
    	unsigned short file2_label;
    	unsigned short file3_label;
    	unsigned short tmp_reportid[11];
    	unsigned short tmp_count[11];
    	unsigned short tmp_file1[11];
    	unsigned short tmp_file2[11];
    	unsigned short tmp_file3[11];
    	char *p_vid;
    	char *p_reportid;
    	char *p_count;
    	char *p_file1;
    	char *p_file2;
    	char *p_file3;					
    	string  str_reportid;
    	string  str_count ;
    	wstring  str_file1;
    	wstring  str_file2;
    	wstring  str_file3;
    
    	struct UrlInformation
    	{
    		unsigned short vid;
    		unsigned short type;
    		unsigned short day;
    		unsigned long reportid;
    		unsigned short count;
    		LPCTSTR productkey;
    		LPCTSTR version;
    		TCHAR *zipurl[MAX_ZIP];
    	}s_Url;
    	UrlInformation u_url[10];	 	
    };
    #endif
    .cpp文件//
    #include "stdafx.h"
    #include"httpfile.h"
    #include<assert.h>
    #include<stdlib.h>
    #include<tchar.h>
    #include<string>
    #include<iostream>
    using namespace std;
    #include "ETCompressInterface.h"
    #include "ETZipCompress.h"
    
    void DemoCompressProgressCallback(LPCTSTR pTargetZipFile,
    								  LPCTSTR pCurrentFile,
    								  UINT64 u64FileCount,
    								  UINT64 u64FileIndex,
    								  UINT64 u64AllFileTotalSize,
    								  UINT64 u64AllFileDeflatedSize,
    								  UINT64 u64FileTotalSize,
    								  UINT64 u64FileDeflatedSize,
    								  BOOL   isLastTime
    										) 
    {
    	//8字节的UINT64，是无法直接格式化的，直接格式化只支持四个字节的整数
    	_tprintf(_T("CF->%s,Index->%d,ToSize->%d\n"),pCurrentFile,(int)u64FileIndex,(int)u64AllFileDeflatedSize);
    }
    void DemoDecompressProgressCallback(LPCTSTR pTargetZipFile,
    									LPCTSTR pCurrentFile,
    									UINT64 u64FileCount,
    									UINT64 u64FileIndex,
    									UINT64 u64FileTotalSize,
    									UINT64 u64FileDeflatedSize,
    									BOOL   isLastTime
    									) 
    {
    	_tprintf(_T("CF->%s,Index->%d,FileSize->%d,DefSize->%d\n"),pCurrentFile,(int)u64FileIndex,(int)u64FileTotalSize,(int)u64FileDeflatedSize);
    }
    /************************************************************************/
    /* User_interface是留给用户的唯一接口*/
    /************************************************************************/
    bool HttpFile::User_interface()
    {		
    	bool flag_recieive = false;	
    	bool flag_test = false;
    	flag_recieive = RecvFileUrl();		
    	if (flag_recieive)
    	{
    		flag_test = RecvFileZip();
    		cout<<"download success!"<<endl;
    	}
    	else 
    	{
    		cout<<"please check the RecvFileUrl function !"<<endl;
    	}
    	CETCompressInterface* pCompress = new CETZipCompress();	
    	for (int i = 0; i<10; i++)
    	{
    		for (int j =0; j<3; j++)
    		{
    			char *path="G:/我的资料库/Documents/Visual Studio 2008/Projects/cosmos_307test/";
    			char *szPath= new char[strlen(path)+15];
    			char *uncompresspath = new char[40]; 
    
    			sprintf(szPath,"%scosmos%d.zip",path,i*10+j);
    			sprintf(uncompresspath,"D:/cosmos/cosmos%d",i*10+j);			
    			pCompress->SetTargetFile(szPath);
    			pCompress->SetTargetPath(uncompresspath);
    			bool result = false;
    			result = pCompress->Decompress();
    			if (!result)
    			{
    				cout<<"解压失败！"<<endl;
    			}
    			else
    				cout<<"解压成功！"<<endl;	
    			delete []szPath;
    			delete[]uncompresspath;
    		}
    	}
    	return true;
    }
    
    /*===========================构造函数===============================*/
    HttpFile::HttpFile()
    {
    	//WSADATA wsaData = {0};
    	//WSAStartup(MAKEWORD(2, 2), &wsaData);
    	hOpen = NULL;
    	hConnect = NULL;
    	hRequest = NULL;
    	dwFlags = INTERNET_FLAG_RELOAD | INTERNET_FLAG_NO_CACHE_WRITE;
    	bRet = FALSE;
    	strResult = "";
    	pPostData = NULL;
    	lpszHeaders = NULL;		
    	for(int i = 0; i<10; i++)
    	{
    		u_url[i].count = 0;
    		u_url[i].day = 0;
    		u_url[i].productkey = _T("");
    		u_url[i].reportid = 0;
    		u_url[i].type = 0;
    		u_url[i].version = _T("");
    		u_url[i].vid = 0;
    		for(int j = 0; j<3; j++)
    		{
    			u_url[i].zipurl[j] = new wchar_t[ZIP_PATH_URL];
    		}
    	}
    	reportid_label = 0;
    	count_label = 0;
    	file1_label = 0;
    	file2_label = 0;
    	file3_label = 0;
    	for(int i = 0; i<11; i++)
    	{
    		tmp_reportid[i] = 0;
    		tmp_count[i] = 0;
    		tmp_file1[i] = 0;
    		tmp_file2[i] = 0;
    		tmp_file3[i] = 0;
    	}
    	p_vid = NULL;
    	p_reportid =NULL;
    	p_count =NULL;
    	p_file1 =NULL;
    	p_file2 =NULL;
    	p_file3 =NULL;					
    	str_reportid = "";
    	str_count = "";
    	str_file1 = L"";
    	str_file2 = L"";
    	str_file3 = L"";
    }
    /*===========================构造函数到此结束===============================*/
    
    /*===========================upload function start==================================*/
    bool  HttpFile::SendAnalyseResult(LPCTSTR lpszUrl,  LPCTSTR lpszHeaders,
    								  const void* pPostData,  int nLen,
    								  std::string &strResult)
    {
    	cout<<"waitting"<<endl;
    	return true;
    }
    /*===========================upload function end===============================*/
    
    /*===========================download function start==================================*/
    bool HttpFile::RecvFileUrl()
    {
    	char *urlDir = "G:/我的资料库/Documents/Visual Studio 2008/Projects/cosmos_307test/cosmos3.txt";
    	zipDirUrl =_T("http://crashreport.yy.duowan.com/crashreport/get_version_top.php?productkey=YY&version=4.10.0.0&type=1&day=0");
    	HttpConnection(zipDirUrl,NULL,NULL,0,strResult,urlDir);
    
    	int tmp_vid = 0;
    	string tmpstr = "";									
    	tmp_vid = strResult.find('=',0);
    	tmp_vid++;
    	while (strResult[tmp_vid] != '\r')
    	{
    		tmpstr+= strResult[tmp_vid];
    		tmp_vid++;
    	}
    	tmp_vid +=2;
    	p_vid = new char[tmpstr.length()+1];
    	strcpy(p_vid,tmpstr.c_str());	
    
    	for (int j = 0;j<10; j++ )         
    	{
    		u_url[j].vid = atoi(p_vid);						
    	}
    	delete []p_vid;
    	p_vid =NULL;
    
    	for (int m = 1; m<11; m++)
    	{
    		tmp_reportid[m] = strResult.find("reportid",tmp_reportid[m-1]+8);//将top10的reportid每一分组的下表记录下来							
    		tmp_count[m] = strResult.find("count",tmp_reportid[m]+5);//将top10的count每一分组的下表记录下来					   
    		tmp_file1[m] = strResult.find("file",tmp_count[m]);//将top10的file1每一分组的下表记录下来						
    		tmp_file2[m] = strResult.find("file",tmp_file1[m]+4);//将top10的file2每一分组的下表记录下来					
    		tmp_file3[m] = strResult.find("file",tmp_file2[m]+4);//将top10的file3每一分组的下表记录下来						
    	}
    	for (int i = 0; i<10; i++)
    	{
    		reportid_label = strResult.find('=',tmp_reportid[i+1]);
    		count_label = strResult.find('=',tmp_count[i+1]);
    		file1_label =  strResult.find('=',tmp_file1[i+1]);
    		file2_label = strResult.find('=',tmp_file2[i+1]);
    		file3_label = strResult.find('=',tmp_file3[i+1]);
    		reportid_label++;
    		count_label++;
    		file1_label++;
    		file2_label++;
    		file3_label++;
    		while (strResult[reportid_label] != '&')
    		{
    			str_reportid += strResult[reportid_label];
    			reportid_label++;
    		}
    		p_reportid = new char[str_reportid.length()+1];
    		strcpy(p_reportid,str_reportid.c_str());	
    		u_url[i].reportid = strtoul(p_reportid,0,10);
    		delete []p_reportid;
    		p_reportid = NULL;
    
    		while (strResult[count_label] != '&')
    		{
    			str_count += strResult[count_label] ;
    			count_label++;
    		}
    		p_count = new char[str_count.length()+1];
    		strcpy(p_count,str_count.c_str());
    		u_url[i].count = strtoul(p_count, 0, 10);
    		delete []p_count;
    		p_count = NULL;
    
    		while (strResult[file1_label] != '&')
    		{
    			str_file1 += strResult[file1_label];
    			file1_label++;
    		}
    		while (strResult[file2_label] != '&')
    		{
    			str_file2 += strResult[file2_label];
    			file2_label++;
    		}
    		while (strResult[file3_label] != '\r')
    		{
    			str_file3 += strResult[file3_label];
    			file3_label++;
    		}						
    		wcscpy(u_url[i].zipurl[0],str_file1.c_str());
    		wcscpy(u_url[i].zipurl[1],str_file2.c_str());
    		wcscpy(u_url[i].zipurl[2],str_file3.c_str());
    
    		str_reportid = "";
    		str_count = "";
    		str_file1 = L"";
    		str_file2 = L"";
    		str_file3 = L"";		
    	}       
    
    	return true;
    }
    bool HttpFile::RecvFileZip()
    {
    	for (int i = 0; i<10; i++)
    	{
    		for (int j =0; j<3; j++)
    		{
    			wstring url = L"http://crashreport.yy.duowan.com";
    			url += u_url[i].zipurl[j];
    			wcscpy(u_url[i].zipurl[j],url.c_str());   
    			FILE *fp;
    			char *path="G:/我的资料库/Documents/Visual Studio 2008/Projects/cosmos_307test/";
    			char *szPath= new char[strlen(path)+15];
    			sprintf(szPath,"%scosmos%d.zip",path,i*10+j);
    			//fp=fopen(szPath, "wb+");	
    			strResult = "";
    			//const std::string U16toUTF8((wchar_t *)u_url[i].zipurl[j]);
    			HttpConnection(u_url[i].zipurl[j],NULL,NULL,0,strResult,szPath);
    			delete []szPath;			
    		}	
    	}	
    	return true;
    }
    
    /*===========================download function end ===============================*/
    bool HttpFile::HttpConnection(LPCTSTR lpszUrl, 
    							  LPCTSTR lpszHeaders, 
    							  const void* pPostData, 
    							  int nLen,
    							  std::string &strResult,char *zipname)
    {	
    	TCHAR szHostname[256] = {0};
    	URL_COMPONENTS urlcomp = {0};
    	char buf[8192] = {0};
    	urlcomp.dwStructSize = sizeof(URL_COMPONENTS);
    	urlcomp.lpszHostName = szHostname;
    	urlcomp.dwHostNameLength = sizeof(szHostname)/sizeof(TCHAR) - 1;
    	urlcomp.dwUrlPathLength = 1;
    	LPCTSTR acceptTypes[2] = {_T("*/*"), 0};
    
    	do
    	{
    		if (!InternetCrackUrl(lpszUrl, lstrlen(lpszUrl), 0, &urlcomp))
    			break;
    		hOpen = InternetOpen(_T(""), INTERNET_OPEN_TYPE_PRECONFIG, NULL, NULL, 0);
    		if (!hOpen)
    			break;
    		hConnect = InternetConnect(hOpen, szHostname, urlcomp.nPort, NULL, NULL, INTERNET_SERVICE_HTTP, 0, 0);
    		if (!hConnect)
    			break;
    		if (pPostData)
    			hRequest = HttpOpenRequest(hConnect, _T("POST"), urlcomp.lpszUrlPath, _T("HTTP/1.1"), NULL, acceptTypes, dwFlags, 0);
    		else			
    			hRequest = HttpOpenRequest(hConnect, _T("GET"), urlcomp.lpszUrlPath, _T("HTTP/1.0"), NULL, acceptTypes, dwFlags, 0);
    		if (!hRequest)
    			break;
    		if (pPostData)
    		{
    			INTERNET_BUFFERS inbuffer = {0};
    			inbuffer.dwStructSize		= sizeof(INTERNET_BUFFERS);
    			inbuffer.Next				= NULL;
    			inbuffer.lpcszHeader		= lpszHeaders;
    			inbuffer.dwHeadersLength	= lpszHeaders? lstrlen(lpszHeaders) : 0;
    			inbuffer.dwHeadersTotal		= lpszHeaders? lstrlen(lpszHeaders) : 0;
    			inbuffer.lpvBuffer			= (void *)pPostData;
    			inbuffer.dwBufferLength		= nLen;
    			inbuffer.dwBufferTotal		= nLen;
    			if (!HttpSendRequestEx(hRequest, &inbuffer, NULL, 0, 0))
    				break;
    			if (!HttpEndRequest(hRequest, NULL, 0, 0))
    				break;
    		} 
    		else
    		{
    			if (!HttpSendRequest(hRequest, lpszHeaders, lpszHeaders ? -1 : 0, NULL, 0))
    				break;
    		}
    
    		FILE *fp;
    		fp=fopen(zipname, "wb+");	
    		int byteWrite = 0;
    		DWORD dwReadBytes = 0;
    		DWORD dwStatusCode = -1;
    		while (InternetReadFile(hRequest, buf, sizeof(buf), &dwReadBytes))
    		{
    			byteWrite = fwrite(buf,sizeof(char),dwReadBytes,fp);
    
    			if (dwStatusCode == -1)
    			{
    				DWORD dwData = 0;
    				DWORD dwDataLen = sizeof(dwData);
    
    				if (HttpQueryInfo(hRequest, HTTP_QUERY_STATUS_CODE|HTTP_QUERY_FLAG_NUMBER, &dwData, &dwDataLen, NULL))
    					dwStatusCode = dwData;
    				else
    					assert(0);
    			}
    
    			if (dwReadBytes == 0) 
    			{
    				bRet = TRUE;	
    				fclose(fp);
    				return true;      
    			}
    	    	strResult.append(buf, dwReadBytes);
    		}
    			//fclose(fp);
    	} while (0);
    
    	if (hRequest)
    		InternetCloseHandle(hRequest);
    	if (hConnect)
    		InternetCloseHandle(hConnect);
    	if (hOpen) 
    		InternetCloseHandle(hOpen);
    
    	return bRet;
    
    }
    
    HttpFile::~HttpFile()
    {
    	for (int i = 0; i<10; i++)
    	{
    		for (int j = 0; j<3; j++)
    		{
    			delete []u_url[i].zipurl[j];
    		}
    	}
    }

转载于:https://my.oschina.net/u/245046/blog/49658

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220114/b4c52ce52125422daf9c4a886c335c39.png