开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > P2P编程 > 查看源码
HttpRequest.cpp
资源名称：p2p_vod.rar　[点击查看]
上传用户：liguizhu
上传日期：2015-11-01
资源大小：2422k
文件大小：17k
源码类别：

P2P编程

开发平台：

Visual C++

HttpRequest.cpp：源码内容
  1. /*
  2.  *  Openmysee
  3.  *
  4.  *  This program is free software; you can redistribute it and/or modify
  5.  *  it under the terms of the GNU General Public License as published by
  6.  *  the Free Software Foundation; either version 2 of the License, or
  7.  *  (at your option) any later version.
  8.  *
  9.  *  This program is distributed in the hope that it will be useful,
  10.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  11.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12.  *  GNU General Public License for more details.
  13.  *
  14.  *  You should have received a copy of the GNU General Public License
  15.  *  along with this program; if not, write to the Free Software
  16.  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  17.  *
  18.  */
  19. // HttpDownload.cpp: implementation of the HttpDownload class.
  20. //
  21. //////////////////////////////////////////////////////////////////////
  23. #include "stdafx.h"
  24. #include <LIMITS.H>
  25. #include <TCHAR.H>
  26. #include "HttpRequest.h"
  27. #include <stdlib.h>
  28. #include <stdio.h>
  30. #ifdef _MYDEBUG
  31. #undef THIS_FILE
  32. static TCHAR THIS_FILE[]=__FILE__;
  33. #define new DEBUG_NEW
  34. #endif
  36. //////////////////////////////////////////////////////////////////////
  37. // Construction/Destruction
  38. //////////////////////////////////////////////////////////////////////
  40. BOOL  HttpRequest::GetCookieEx(LPCTSTR lpszUrlName, LPCTSTR lpszCookieDataName, LPTSTR lpszCookieData, LPDWORD lpdwSize)
  41. {
  42.     DWORD   len = 0;
  43.     InternetGetCookie(lpszUrlName, NULL, NULL, &len);
  44.     if(len == 0)
  45.     {
  46.         return FALSE;   //no cookie exist
  47.     }
  49.     len += 10;
  50.     LPTSTR   bufcookiedata = new TCHAR[len];
  51.     memset(bufcookiedata, 0, sizeof(TCHAR)*len);
  52.     if(InternetGetCookie(lpszUrlName, NULL, bufcookiedata, &len) != TRUE)
  53.     {
  54.         delete[] bufcookiedata;
  55.         return FALSE;
  56.     }
  58.     bool    parseOK = false;
  60.     while(1)
  61.     {    
  62.         LPTSTR datastart = _tcsstr(bufcookiedata, lpszCookieDataName);
  63.         if(datastart == NULL)
  64.             return FALSE;
  66.         LPTSTR indexspace = NULL;
  67.         LPTSTR indexequal = NULL;
  69.         indexequal = _tcschr(datastart, _T('='));
  70.         if(indexequal == NULL)
  71.             break;
  72.         indexequal++;
  74.         indexspace = _tcschr(datastart, _T(';'));
  75.         if(indexspace == NULL)  //这是最后一个data
  76.             indexspace = _tcschr(datastart, 0);
  78.         assert(indexspace > indexequal);
  80.         DWORD m_actuallen = indexspace - indexequal + 1;    //len + null terminnal
  82.         assert(lpdwSize != NULL);
  83.         if(lpszCookieData == NULL || *lpdwSize < m_actuallen)
  84.         {
  85.             *lpdwSize = m_actuallen;
  86.         }
  87.         else
  88.         {
  89.             memset(lpszCookieData, 0, sizeof(TCHAR)*(*lpdwSize));
  90.             _tcsncpy(lpszCookieData, indexequal, indexspace - indexequal);
  91.         }
  93.         parseOK = true;
  94.         break;
  95.     }
  97.     delete[] bufcookiedata;
  99.     if(!parseOK)
  100.     {
  101.         return FALSE;
  102.     }
  103.     else
  104.         return TRUE;
  105. }
  107. //HTTP信标
  108. #define HTTP_REQUEST_LIMIT_NAME _T("_GAOV_HTTP_REQUEST_LIMIT")
  110. static HANDLE m_hSemaphore = CreateSemaphore(NULL, 5, 5, HTTP_REQUEST_LIMIT_NAME);
  111. int HttpRequest::b_useproxy = 0;
  112. TCHAR HttpRequest::m_proxystr[256] = _T("");
  114. #define INTERNET_CONNECT_ADAGENT _T("Mysee_Client")
  116. void HttpRequest::SetProxyName(LPCWSTR s)
  117. {
  118. #ifdef _UNICODE
  119. wcscpy(m_proxystr, s);
  120. #else
  121. char* m_innerbufferA = new char[1024];
  122. WideCharToMultiByte(CP_ACP, 0, s, -1, m_innerbufferA, 1024, NULL, NULL);
  123. strcpy(m_proxystr, m_innerbufferA);
  124. delete[] m_innerbufferA;
  125. #endif
  126. }
  128. void HttpRequest::SetProxyName(LPCSTR s)
  129. {
  130. #ifdef _UNICODE
  131. WCHAR* m_innerbufferW = new WCHAR[1024];
  132. MultiByteToWideChar(CP_ACP, 0, s, -1, m_innerbufferW, 1024);
  133. wcscpy(m_proxystr, m_innerbufferW);
  134. delete[] m_innerbufferW;
  135. #else
  136. strcpy(m_proxystr, s);
  137. #endif
  138. }
  140. HttpRequest::HttpRequest()
  141. {
  142. Connect_timeout = 60000;
  143. Request_timeout = 120000;
  144. recvBuf = NULL;
  145. // HSO = NULL;
  146. m_hInternet = NULL;
  147. errorcode = 0;
  148. // InitializeCriticalSection(&m_hSync);
  149. for(int j = 0; j<EVENT_SERIES; j++)
  150. m_hEvent[j] = CreateEvent(NULL, TRUE, FALSE, NULL);
  151. ResetEvent(m_hEvent[0]);
  152. fWide = FALSE;
  153. }
  155. BOOL HttpRequest::Create(UINT cto, UINT rto, BOOL wide)
  156. {
  157. // b_userStop = FALSE;
  158. fWide = wide;
  159. h_File = NULL;
  160. Connect_timeout = cto;
  161. Request_timeout = rto;
  162. errorcode = 0;
  163. m_dwOffset = m_dwOffsetEnd = UINT_MAX;
  164. // DWORD wtmp;
  166. // ResetEvent(m_hEvent[0]);
  167. // ::CreateThread(NULL, 0, InitialCallback, this, 0, &wtmp);
  168. // WaitForSingleObject(m_hEvent[0], INFINITE);
  169. // if(errorcode != 0)return FALSE;
  170. return TRUE;
  171. }
  173. HttpRequest::~HttpRequest()
  174. {
  175. for(int j = 0; j<EVENT_SERIES;j++)
  176. CloseHandle(m_hEvent[j]);
  177. // DeleteCriticalSection(&m_hSync);
  178. if(recvBuf)delete[] recvBuf;
  179. }
  181. void HttpRequest::SetStopRequest()
  182. {
  183. SetEvent(m_hEvent[0]);
  184. }
  186. void HttpRequest::ResumeStopRequest()
  187. {
  188. ResetEvent(m_hEvent[0]);
  189. }
  191. UINT HttpRequest::WaitingEvent(DWORD timeout)
  192. {
  193. if((errorcode = GetLastError()) != ERROR_IO_PENDING)
  194. {
  195. return 1;
  196. }
  198. DWORD result = WaitForMultipleObjects(EVENT_SERIES, m_hEvent, 
  199. FALSE, timeout);
  200. switch(result)
  201. {
  202. case WAIT_OBJECT_0: //外部中止
  203. errorcode = USER_STOP;
  204. return 1;
  205. case WAIT_OBJECT_0 + 1: //内部中止
  206. if(errorcode)
  207. return 1;
  208. else
  209. return 0;
  210. case WAIT_TIMEOUT: //连接超时
  211. errorcode = 32808;
  212. return 1;
  213. case WAIT_FAILED: //严重错误
  214. errorcode = ERROR_STOP;
  215. return 1;
  216. }
  217. return 1;
  218. }
  220. void HttpRequest::HDResetEvent()
  221. {
  222. for(int i = 1; i< EVENT_SERIES; i++)
  223. ResetEvent(m_hEvent[i]); 
  224. }
  226. int  HttpRequest::ReadStringEx()
  227. {
  228. if(recvBuf == NULL)return -1;
  229. if(readstrpos >= buflength)return -1;
  230. int oldpos = -1;
  232. if(fWide)
  233. {
  234. WCHAR* head = (WCHAR*) recvBuf;
  236. for(UINT i = readstrpos; (i*sizeof(WCHAR))<buflength; i++)
  237. {
  238. if(*(head + i) == L'n')break;
  239. }
  240. oldpos = readstrpos;
  241. readstrpos = i+1;
  242. if(i != readstrpos && *(head + i - 1) == L'r')
  243. *(head + i - 1) = L'';
  244. *(head + i) = L'';
  245. }
  246. else
  247. {
  248. char* head = (char*) recvBuf;
  250. for(UINT i = readstrpos; i<buflength; i++)
  251. {
  252. if(*(head + i) == 'n')break;
  253. }
  254. oldpos = readstrpos;
  255. readstrpos = i+1;
  256. if(i != readstrpos && *(head + i - 1) == 'r')
  257. *(head + i - 1) = '';
  258. *(head + i) = '';
  259. }
  260. return oldpos;
  261. }
  263. BOOL HttpRequest::ReadString(LPWSTR readstr)
  264. {
  265. int pos = HttpRequest::ReadStringEx();
  266. if(pos == -1)return FALSE;
  268. if(fWide)
  269. wcscpy(readstr,(LPCWSTR) recvBuf + pos);
  270. else
  271. {
  272. MultiByteToWideChar(CP_ACP, 0, (LPCSTR) recvBuf + pos, -1, readstr, 2048);
  273. }
  275. return TRUE;
  276. }
  278. BOOL HttpRequest::ReadString(LPSTR readstr)
  279. {
  280. int pos = HttpRequest::ReadStringEx();
  281. if(pos == -1)return FALSE;
  283. if(!fWide)
  284. strcpy(readstr,(LPCSTR) recvBuf + pos);
  285. else
  286. {
  287. WideCharToMultiByte(CP_ACP, 0, (LPCWSTR) recvBuf + pos, -1, readstr, 2048, NULL, NULL);
  288. }
  290. return TRUE;
  291. }
  293. void HttpRequest::InitWrite(DWORD initialbufsize)
  294. {
  295. if(h_File)
  296. {
  297. if(GetFileSize(h_File, NULL) != -1)
  298. {
  299. m_dwOffset = 0;
  300. buflength = UINT_MAX;
  301. return; //a valid file
  302. }
  303. CloseHandle(h_File);
  304. h_File = NULL; //clear the invalid file handle and using inner buffer
  305. initialbufsize = 1024;
  306. }
  307. if(recvBuf)delete[] recvBuf;
  308. recvBuf = new BYTE[initialbufsize + 16];
  309. memset(recvBuf, 0, initialbufsize + 16);
  310. buflength = initialbufsize;
  311. m_dwOffset = 0;
  312. }
  314. BOOL HttpRequest::WriteBuffer(const BYTE* buf, const DWORD m_buflength)
  315. {
  316. if(h_File)
  317. {
  318. DWORD tmpLength = m_buflength;
  319. const BYTE* start = buf;
  320. while(tmpLength > 0)
  321. {
  322. DWORD tmp = 0;
  323. if(WriteFile(h_File, start, tmpLength, &tmp, NULL) == FALSE)
  324. {
  325. errorcode = GetLastError();
  326. return FALSE;
  327. }
  328. tmpLength -= tmp;
  329. start += tmp;
  330. }
  331. }
  332. else
  333. {
  334. if(m_dwOffset + m_buflength > buflength)
  335. {
  336. BYTE* tmp = new BYTE[buflength*3 + 16];
  337. memset(tmp, 0, buflength*3 + 16);
  338. memcpy(tmp, recvBuf, buflength);
  339. delete[] recvBuf;
  340. recvBuf = tmp;
  341. buflength = buflength* 3;
  342. }
  343. memcpy(recvBuf + m_dwOffset, buf, m_buflength);
  344. }
  345. m_dwOffset += m_buflength;
  346. return TRUE;
  347. }
  349. void HttpRequest::InternetCloseHandleAsync(HINTERNET Hcls)
  350. {
  351. if(Hcls == NULL)
  352. return;
  353. ResetEvent(m_hEvent[1]);
  354. if(!InternetCloseHandle(Hcls))
  355. {
  356. if(GetLastError() == ERROR_IO_PENDING)
  357. WaitForSingleObject(m_hEvent[1], INFINITE);
  358. }
  359. SetEvent(m_hEvent[1]);
  360. }
  362. static const TCHAR _defaultContentType[] = _T("Content-Type: application/x-www-form-urlencoded");
  364. DWORD WINAPI HttpRequest::InitialCallback(LPVOID params)
  365. {
  366. /* HttpRequest* pObj = (HttpRequest*) params;
  367. if(::InternetSetStatusCallback(pObj->HSO, AsyncInternetCallback) == INTERNET_INVALID_STATUS_CALLBACK)
  368. pObj->errorcode = 1;
  369. SetEvent(pObj->m_hEvent[0]);*/
  370. return 0;
  371. }
  373. void HttpRequest::MakeHeadMsg(BOOL post, LPTSTR buf)
  374. {
  375. LPTSTR start = buf;
  376. if(post)
  377. {
  378. _tcscpy(start, _defaultContentType);
  379. start += _tcslen(_defaultContentType);
  380. }
  381. if(h_File != NULL)
  382. {
  383. if(m_dwOffset != UINT_MAX)
  384. {
  385. _tcscpy(start, _T("rn"));
  386. if(m_dwOffsetEnd != UINT_MAX)
  387. _stprintf(start, _T("Range: bytes= %d-%d"), m_dwOffset, m_dwOffsetEnd);
  388. else
  389. _stprintf(start, _T("Range: bytes= %d-"), m_dwOffset);
  390. }
  391. }
  392. }
  394. BOOL HttpRequest::OpenRequest(LPCWSTR url, BOOL cache, LPCWSTR send)
  395. {
  397. #ifdef _UNICODE
  398. LPCWSTR purl = url;
  399. #else
  400. char* purl = new char[2048];
  401. WideCharToMultiByte(CP_ACP, 0, url, -1, purl, 2048, NULL, NULL);
  402. #endif
  404. size_t size = 0;
  405. if(send != NULL)
  406. size = wcslen(send) * sizeof(WCHAR);
  407. LPVOID pdata = (LPVOID) send;
  408. if(fWide == FALSE && send != NULL)
  409. {
  410. pdata = (LPVOID) new char[size];
  411. WideCharToMultiByte(CP_ACP, 0, send, -1, (char*) pdata, size, NULL, NULL);
  412. size = strlen((char*) pdata);
  413. }
  415. BOOL ret;
  416. ret = OpenRequestEx(purl, cache, pdata, size);
  418. #ifndef _UNICODE
  419. delete[] purl;
  420. #endif
  421. if(fWide == FALSE && send != NULL)
  422. delete[] pdata;
  423. return ret;
  424. }
  426. BOOL HttpRequest::OpenRequest(LPCSTR url, BOOL cache, LPCSTR send)
  427. {
  428. #ifndef _UNICODE
  429. LPCSTR purl = url;
  430. #else
  431. WCHAR* purl = new WCHAR[2048];
  432. MultiByteToWideChar(CP_ACP, 0, url, -1, purl, 2048);
  433. #endif
  435. DWORD size = 0;
  436. if(send != NULL)
  437. size = strlen(send);
  438. LPVOID pdata = (LPVOID) send;
  439. if(fWide != FALSE && send != NULL)
  440. {
  441. pdata = (LPVOID) new WCHAR[size];
  442. MultiByteToWideChar(CP_ACP, 0, send, -1, (WCHAR*) pdata, size);
  443. size = wcslen((WCHAR*) pdata)*sizeof(WCHAR);
  444. }
  446. BOOL ret;
  447. ret = OpenRequestEx(purl, cache, pdata, size);
  449. #ifdef _UNICODE
  450. delete[] purl;
  451. #endif
  452. if(fWide != FALSE && send != NULL)
  453. delete[] pdata;
  454. return ret;
  455. }
  457. BOOL HttpRequest::OpenRequestEx(LPCTSTR url, BOOL cache, const void* send, DWORD sendsize)
  458. {
  459. HANDLE hSemaphore = ::OpenSemaphore(SEMAPHORE_ALL_ACCESS | SEMAPHORE_MODIFY_STATE | SYNCHRONIZE
  460. , NULL, HTTP_REQUEST_LIMIT_NAME);
  462. BOOL funOK = FALSE;
  463. HINTERNET HSO = NULL; 
  464. HINTERNET HIO = NULL;
  465. HINTERNET HQO = NULL;
  466. TCHAR* p_stN = new TCHAR[256];
  467. TCHAR* p_flN = new TCHAR[2048];
  468. TCHAR* p_bufstr = new TCHAR[1024];
  469. BYTE* p_buf = new BYTE[1024];
  470. DWORD port = 80;
  472. __try{
  474. if(!ParseURL(url, p_stN, p_flN, &port))
  475. {
  476. errorcode = ERROR_INTERNET_NAME_NOT_RESOLVED;
  477. __leave;
  478. }
  480. if(hSemaphore)
  481. {
  482. DWORD ret = ::WaitForSingleObject(hSemaphore, Connect_timeout*2);
  483. if(ret == WAIT_TIMEOUT)
  484. {
  485. errorcode = 12002;
  486. __leave;
  487. }
  488. else if(ret == WAIT_ABANDONED)
  489. {
  490. errorcode = USER_STOP;
  491. __leave;
  492. }
  493. }
  495. DWORD type; LPCTSTR proxystr = NULL;
  496. switch(b_useproxy)
  497. {
  498. case 0: type = INTERNET_OPEN_TYPE_DIRECT;break;
  499. case 1: type = INTERNET_OPEN_TYPE_PRECONFIG;break;
  500. case 2: type = INTERNET_OPEN_TYPE_PROXY;
  501. proxystr = m_proxystr;
  502. break;
  503. default: type = INTERNET_OPEN_TYPE_PRECONFIG;break;
  504. }
  505. HSO = ::InternetOpen(INTERNET_CONNECT_ADAGENT, type, proxystr, NULL, INTERNET_FLAG_ASYNC);
  506. if(HSO == NULL)
  507. {
  508. errorcode = GetLastError();
  509. __leave;
  510. }
  512. if(::InternetSetStatusCallback(HSO, AsyncInternetCallback) == INTERNET_INVALID_STATUS_CALLBACK)
  513. {
  514. errorcode = GetLastError();
  515. __leave;
  516. }
  519. HDResetEvent();
  520. HIO = InternetConnect(HSO, p_stN, (WORD) port , NULL,NULL,
  521.             INTERNET_SERVICE_HTTP , 0, reinterpret_cast<DWORD>(this));
  522. if(HIO == NULL)
  523. {
  524. if(WaitingEvent(Connect_timeout))
  525. __leave;
  526. HIO = m_hInternet;
  527. }
  528.   
  529.       // 3.初始化下载请求
  530. const TCHAR AcceptType[] = _T("*/*");
  531. LPCTSTR p_FA[] = {AcceptType, NULL};
  532. TCHAR Verb[10];
  533. if(send != NULL)
  534. _tcscpy(Verb, _T("POST"));
  535. else
  536. _tcscpy(Verb, _T("GET"));
  538. if(!cache)
  539. type = INTERNET_FLAG_DONT_CACHE | INTERNET_FLAG_PRAGMA_NOCACHE | INTERNET_FLAG_RELOAD;
  540. else
  541. type = 0;
  543. HDResetEvent();
  545.     HQO = HttpOpenRequest(HIO,
  546.             Verb, // 从服务器获取数据
  547.             p_flN, // 想读取的文件的名称
  548.             _T("HTTP/1.1"), // 使用的协议
  549.             NULL,
  550.             p_FA,
  551.             type,
  552.             reinterpret_cast<DWORD>(this));
  554.       // 4.发送下载请求
  555. *p_bufstr = 0;
  556. MakeHeadMsg(send != NULL, p_bufstr);
  557. BOOL ret;
  558. if(*p_bufstr == 0)
  559. ret = HttpSendRequest(HQO, NULL, 0, NULL, 0);
  560. else if(send != NULL)
  561. ret = HttpSendRequest(HQO, p_bufstr, _tcslen(p_bufstr), (LPVOID) send, sendsize);
  562. else
  563. ret = HttpSendRequest(HQO, p_bufstr, _tcslen(p_bufstr), NULL, 0);
  565.     if(!ret)
  566. {
  567. if(WaitingEvent(Connect_timeout))
  568. __leave;
  569. }
  571. DWORD length, result;
  572. result = 32774; //ERROR_HTML
  573. length = sizeof(result);
  574. if(!::HttpQueryInfo(HQO , HTTP_QUERY_STATUS_CODE | HTTP_QUERY_FLAG_NUMBER
  575. , &result, &length, NULL))
  576. {
  577. errorcode = GetLastError();
  578. __leave;
  579. }
  580. if(result != 200 && result != 206)
  581. {
  582. errorcode = result;
  583. __leave;
  584. }
  586. result = UINT_MAX;
  588. /* TCHAR* tbuf = new TCHAR[1024];
  589. length = 1024;
  590. ::HttpQueryInfo(HQO , HTTP_QUERY_RAW_HEADERS_CRLF , tbuf, &length, NULL);*/
  592. ::HttpQueryInfo(HQO , HTTP_QUERY_CONTENT_LENGTH | HTTP_QUERY_FLAG_NUMBER, &result, &length, NULL);
  593. if(result == UINT_MAX)
  594. result = 1024;
  595. else
  596. result += 1; //避免一次无效的扩展缓冲区
  598. //downloading
  599. InitWrite(result);
  601. //**********the internetreadfileexW can't not be used for some reason *************//
  602. INTERNET_BUFFERSA i_buf = {0};
  603. i_buf.dwStructSize = sizeof(INTERNET_BUFFERSA);
  604. i_buf.lpcszHeader = NULL;
  605. i_buf.dwBufferLength = 1024;
  606. i_buf.lpvBuffer = p_buf;
  608. while(1)
  609. {
  610. HDResetEvent();
  611. if (FALSE == ::InternetReadFileExA(HQO , &i_buf, IRF_ASYNC, reinterpret_cast<DWORD>(this)))
  612. {
  613. if(WaitingEvent(Request_timeout))
  614. __leave;
  615. }
  616. else
  617. {
  618. //在网络传输速度快，步长较小的情况下，
  619. //InternetReadFileEx 经常会直接返回成功，
  620. //因此要判断是否发生了用户要求终止子线程事件。
  621. if (WAIT_OBJECT_0 == ::WaitForSingleObject(m_hEvent[0], 0))
  622. {
  623. errorcode = USER_STOP;
  624. __leave;
  625. }
  626. }
  628. if(i_buf.dwBufferLength == 0)
  629. break;
  631. if(!WriteBuffer(p_buf, i_buf.dwBufferLength))
  632. __leave;
  634. i_buf.dwBufferLength = 1024;
  635. i_buf.lpvBuffer = p_buf;
  636. }
  638. readstrpos = 0;
  639. buflength = m_dwOffset;
  640. funOK = TRUE;
  641.   }
  642.   __finally
  643.   {
  644. InternetCloseHandleAsync(HQO);
  645. InternetCloseHandleAsync(HSO);
  646. if(hSemaphore)
  647. ::ReleaseSemaphore(hSemaphore, 1, NULL);
  648. delete[] p_stN;
  649. delete[] p_flN;
  650. delete[] p_buf;
  651. delete[] p_bufstr;
  652.   }
  654.   return funOK;
  655. }
  657. BOOL HttpRequest::ParseURL(LPCTSTR src, LPTSTR stN, LPTSTR flN, DWORD* port)
  658. {
  659.    TCHAR* p_src = new TCHAR[4096];
  660.    _tcscpy(p_src, src);
  661.    TCHAR* tmp = _tcsstr(p_src, _T("http://"));
  663.    if(tmp == NULL || (p_src - tmp) != 0)
  664.    {
  665.    delete[] p_src;
  666.    return FALSE;
  667.    }
  669.    tmp = _tcschr(p_src + 7, _T('/'));
  670.    if(tmp == NULL)
  671.    {
  672.    flN[0] = 0;
  673.    _tcscpy(stN, p_src + 7);
  674.    }
  675.    else
  676.    {
  677.    *tmp = 0;
  678.    _tcscpy(stN, p_src + 7);
  679.    *tmp = _T('/');
  680.    _tcscpy(flN, tmp);
  681.    }
  682. tmp = _tcschr(stN, _T(':'));
  683. if(tmp == NULL)
  684. *port = 80;
  685. else
  686. {
  687. *tmp = 0;
  688. *port = _ttoi(tmp + 1);
  689. }
  691.    delete[] p_src;
  692.    return TRUE;
  693. }
  695. void CALLBACK HttpRequest::AsyncInternetCallback(
  696.     HINTERNET hInternet,
  697. DWORD dwContext,
  698. DWORD dwInternetStatus,
  699. LPVOID lpvStatusInformation,
  700. DWORD dwStatusInformationLength)
  701. {
  702.     HttpRequest * pObj = reinterpret_cast<HttpRequest*>(dwContext);
  704.     switch(dwInternetStatus)
  705.     {
  706.     //句柄被创建
  707.     case INTERNET_STATUS_HANDLE_CREATED:
  708.     pObj->m_hInternet = (HINTERNET)(((LPINTERNET_ASYNC_RESULT)
  709.      (lpvStatusInformation))->dwResult);
  710.     break;
  711.    //句柄被关闭
  712.    case INTERNET_STATUS_HANDLE_CLOSING:
  713. ::SetEvent(pObj->m_hEvent[1]);
  714.     break;
  715.    //一个请求完成，比如一次句柄创建的请求，或者一次读数据的请求
  716.    case INTERNET_STATUS_REQUEST_COMPLETE:
  717.    //如果发生错误，则设置子线程退出事件
  718.      //这里也是一个陷阱，经常会忽视处理这个错误，
  719.    DWORD ret;
  720.     if (( ret = ((LPINTERNET_ASYNC_RESULT) (lpvStatusInformation))->dwError) != ERROR_SUCCESS)
  721.       pObj->errorcode = ret;
  722. else
  723. pObj->errorcode = 0;
  724. ::SetEvent(pObj->m_hEvent[1]);
  725.     break;
  726. //连接中断
  727. case INTERNET_STATUS_CONNECTION_CLOSED:
  728.    break;
  729. //重定向连接
  730. case INTERNET_STATUS_REDIRECT:
  731.    break;
  732. //已连接
  733. case INTERNET_STATUS_CONNECTED_TO_SERVER:
  734.    break;
  735. //解析服务器
  736. case INTERNET_STATUS_RESOLVING_NAME:
  737. break;
  738. case INTERNET_STATUS_REQUEST_SENT:
  739.    break;
  740.    }
  742. }