织梦CMS - 轻松建站从此开始！
高级搜索|网站地图|TAG标签RSS订阅[设为首页] [加入收藏]

罗索

搜索

热门标签:

当前位置: 主页>嵌入式开发>Windows CE>

拥有超时能力的HTTP下载

jackyhwei 发布于 2010-06-19 10:07 点击:次 
相信大家都知道WM为了节约，大量的功能都给势弃了，最混帐的就是连接，下载或者上传竟然没有超时功能，这个在客户的投诉里就混蛋了； 所以自写了一个下载，上传，代理的C++代码
TAG:

相信大家都知道WM为了节约，大量的功能都给势弃了，最混帐的就是连接，下载或者上传竟然没有超时功能，这个在客户的投诉里就混蛋了； 所以自写了一个下载，上传，代理的C++代码，当然，有人讲，何必重新写，用WINNET不就OK了吗？ 问题是用系统接口，毕竟难以实现我们更理想的需求，如下载到中途，我想做一些小工作，可以暂停或者之类的！我自己写了一个完整的东西，本来是用来玩多套接字HTTP，我现在只给出一点吧，WM还不需要用得着这么复杂的功能。

老生常谈：头文件

  1. #pragma comment(lib,"note_prj.lib") 
  2.  
  3. #include <Cfgmgrapi.h> 
  4. #include <connmgr.h> 
  5. #include       <wininet.h > 
  6. #pragma comment(lib,"wininet.lib") 
  7. #pragma comment(lib, "Aygshell.lib") 
  8. #pragma comment(lib, "cellcore.lib") 

哪个有用哪个没用，我懒得整理了；

建立CHttp.h

  1. #pragma once 
  2.  
  3. #define HTTP_MAX_RECV 6000 
  4.  
  5. #define HTTP_STRING_V "GET %s HTTP/1.0\r\nHost:%s\r\nReferer:%s\r\n 
  6. Cache-Control: no-cache\r\nUser-Agent:Windows Mobile\r\n 
  7. PlatForm:Musicholic(WM)\r\nConnection: Keep-Alive\r\n\r\n" 
  8.  
  9. #define HTTP_PORT    80 
  10.  
  11. typedef struct HttpString 
  12. { 
  13.         char* Buffer; 
  14.         size_t Count; 
  15.         HttpString(const char* value,size_t v) 
  16.         { 
  17.                 Buffer=new char[v]; 
  18.                 memcpy(Buffer,value,v); 
  19.                 Count=v; 
  20.         } 
  21.  
  22.         ~HttpString() 
  23.         { 
  24.                 if(Buffer!=NULL) 
  25.                         delete[] Buffer; 
  26.         } 
  27.  
  28. }HTTP_STRING,*PHTTP_STRING; 
  29.  
  30. typedef struct Httpp_Status 
  31. { 
  32.         SOCKET Socket; 
  33.         short Count; 
  34.         BOOL Status; 
  35.         Httpp_Status() 
  36.         { 
  37.                 memset(this,0,sizeof(Httpp_Status)); 
  38.                 Socket=INVALID_SOCKET; 
  39.                 Status=TRUE; 
  40.         } 
  41.  
  42.         void CloseSocket() 
  43.         { 
  44.                 if(Socket!=INVALID_SOCKET) 
  45.                 { 
  46.                         closesocket(Socket); 
  47.                         Socket=INVALID_SOCKET; 
  48.                 } 
  49.         } 
  50.  
  51.         ~Httpp_Status() 
  52.         { 
  53.                 CloseSocket(); 
  54.         } 
  55. }HTTP_STATUS,*PHTTP_STATUS; 
  56.  
  57. class CHttp 
  58. { 
  59. public: 
  60.         CList<PHTTP_STATUS>* List; 
  61.  
  62. private: 
  63.  
  64.         CRITICAL_SECTION Section; 
  65. public: 
  66.         CHttp(void); 
  67.         ~CHttp(void); 
  68.  
  69.  
  70. public: 
  71.  
  72.         ///<summary> 
  73.         ///检查能否连接 
  74.         ///<summary> 
  75.         BOOL GetConnectionState(); 
  76.  
  77.         ///<summary> 
  78.         ///GPRS连接 
  79.         ///<summary> 
  80.         BOOL GPRSRasic(BOOL create); 
  81.  
  82.         ///<summary> 
  83.         ///获取下载地址的详细信息 
  84.         ///<summary> 
  85.         void getUrlMessage(const char* url,char* host,
  86. char* httpbuf,short* port); 
  87.  
  88.         ///<summary> 
  89.         ///文件下载(用free()去释放内存) 
  90.         ///<summary> 
  91.         char* Download(const char* url); 
  92.  
  93.  
  94.         ///<summary> 
  95.         ///线程 
  96.         ///<summary> 
  97.         static DWORD CALLBACK Run(LPVOID lpVoid); 
  98. }; 

建立CHttp.CPP

  1. CHttp::CHttp(void) 
  2. { 
  3.         ::InitializeCriticalSection(&Section); 
  4.  
  5.         WSADATA* wsaData=new WSADATA; 
  6.         WSAStartup(MAKEWORD(1,1),wsaData); 
  7.         delete wsaData; 
  8.  
  9.         List=new CList<PHTTP_STATUS>(); 
  10.  
  11.         HANDLE thread=CreateThread(NULL,0,Run,this,0,0); 
  12.         CloseHandle(thread); 
  13. } 
  14.  
  15. CHttp::~CHttp(void) 
  16. { 
  17. } 
  18.  
  19.  
  20. DWORD CALLBACK CHttp::Run(LPVOID lpVoid) 
  21. { 
  22.         CHttp* object=(CHttp*)lpVoid; 
  23.         CList<PHTTP_STATUS>* List=object->List; 
  24.  
  25.         int index=0; 
  26.         POSITION pos=NULL; 
  27.  
  28.         Sleep(1500); 
  29.         while(TRUE) 
  30.         { 
  31.                 index=0; 
  32.                 pos=NULL; 
  33.                 while(index<List->GetCount()) 
  34.                 { 
  35.                         pos=List->FindIndex( index ); 
  36.                         PHTTP_STATUS obj=List->GetAt( pos ); 
  37.                         if(!obj->Status || obj->Count>10) 
  38.                         { 
  39.                                 Sleep(500); 
  40.                                 delete obj; 
  41.                                 List->RemoveAt(pos); 
  42.                         } 
  43.                         else 
  44.                         { 
  45.                                 obj->Count++; 
  46.                                 index++; 
  47.                         } 
  48.                 } 
  49.                 ::Sleep(3000); 
  50.         } 
  51. } 
  52.  
  53.   
  54.  
  55. BOOL CHttp::GetConnectionState() 
  56. { 
  57.         int index=0; 
  58.         BOOL create=FALSE; 
  59.  
  60.         SOCKADDR_IN* addr=new SOCKADDR_IN; 
  61.  
  62.         while(index<2)//首先检测网络状态 
  63.         { 
  64. addr->sin_family=AF_INET; 
  65. addr->sin_port=htons(80); 
  66. addr->sin_addr.s_addr = inet_addr ("64.233.189.104");
  67. //这是google的地址 
  68.                 
  69. PHTTP_STATUS sockStatus=new HTTP_STATUS; 
  70. sockStatus->Socket=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
  71. //建立套接字 连接套接字 
  72. List->AddTail(sockStatus); 
  73. if( connect(sockStatus->Socket,(SOCKADDR*)addr,sizeof(SOCKADDR_IN))
  74. !=SOCKET_ERROR ) 
  75. { 
  76. sockStatus->Status=FALSE; 
  77. delete addr; 
  78. return TRUE; 
  79. } 
  80. sockStatus->Status=FALSE; 
  81.                 
  82. if(!create) 
  83. { 
  84. ::EnterCriticalSection(&Section); 
  85. create=GPRSRasic(create); 
  86. ::LeaveCriticalSection(&Section); 
  87. } 
  88. if(create) 
  89. { 
  90. Sleep(3000); 
  91. WSADATA* wsaData=new WSADATA; 
  92. WSAStartup(MAKEWORD(1,1),wsaData); 
  93. delete wsaData; 
  94. } 
  95. index++; 
  96. } 
  97. delete addr; 
  98.  
  99. return FALSE; 
  100. } 
  101.  
  102.  
  103. BOOL CHttp::GPRSRasic(BOOL create) 
  104. { 
  105.         if(create) return TRUE; 
  106.         HANDLE m_hConnMgr=NULL; 
  107.         m_hConnMgr = ConnMgrApiReadyEvent(); 
  108.         if (!m_hConnMgr) 
  109.                 return FALSE; 
  110.         DWORD dwResult = WaitForSingleObject(m_hConnMgr, 3000); 
  111.         // 关闭 
  112.         if (m_hConnMgr) 
  113.         { 
  114.                 CloseHandle(m_hConnMgr); 
  115.                 m_hConnMgr = NULL; 
  116.         } 
  117.         if (dwResult != WAIT_OBJECT_0)    //找到了,GPRS可以用 
  118.         { 
  119.                 return TRUE; 
  120.         } 
  121.  
  122.         DWORD dwTimeout = 15000;
  123. // 连接超时时间 
  124.         BOOL bEstaCon = TRUE; 
  125.         // 获得网络的GUID值 
  126.         GUID guidNetworkObject; 
  127.         DWORD dwIndex = 0; 
  128.  
  129. if (ConnMgrMapURL(L"http://www.google.com", &guidNetworkObject, &dwIndex)
  130.  == E_FAIL) 
  131. { 
  132. bEstaCon = TRUE; 
  133. } 
  134. if(bEstaCon) 
  135. { 
  136. // 建立连接 
  137. CONNMGR_CONNECTIONINFO* ccInfo=new CONNMGR_CONNECTIONINFO; 
  138. memset(ccInfo, 0, sizeof(CONNMGR_CONNECTIONINFO)); 
  139. ccInfo->cbSize = sizeof(CONNMGR_CONNECTIONINFO); 
  140. ccInfo->dwParams = CONNMGR_PARAM_GUIDDESTNET; 
  141. ccInfo->dwFlags = CONNMGR_FLAG_PROXY_HTTP;
  142. //HTTP的也可以加入WAP等 
  143. ccInfo->dwPriority = CONNMGR_PRIORITY_USERINTERACTIVE; 
  144. ccInfo->bExclusive = FALSE; 
  145. ccInfo->guidDestNet = guidNetworkObject;//网络地址映射的GUID
  146. //开始连接
  147. DWORD dwStatus=0;
  148. if (ConnMgrEstablishConnectionSync
  149. (ccInfo, &m_hConnMgr,dwTimeout,&dwStatus) != E_FAIL)
  150. bEstaCon=TRUE;
  151. else
  152. bEstaCon=FALSE;
  153. delete ccInfo;
  154. }
  155. if(m_hConnMgr != NULL)
  156. ConnMgrReleaseConnection(m_hConnMgr, TRUE);
  157. // 第2个参数决定是否缓存连接,默认缓存连接时间为60秒        
  158. Sleep(15000); 
  159. return TRUE; 
  160. } 
  161.  
  162. void CHttp::getUrlMessage(const char* url,
  163. char* host,char* httpbuf,short* port) 
  164. { 
  165.         char* tmpUrl=new char[strlen(url)+1]; 
  166.         strcpy(tmpUrl,url); 
  167.         char* purl=tmpUrl; 
  168.         purl+=7;          //除去http:// 
  169.         char* tpHost=purl; 
  170.         while(*purl && *purl++!=0x2f){} //0x2f ==/ 
  171.         purl--; 
  172.         *purl=0; 
  173.         strcpy(host,tpHost); 
  174.  
  175.         *purl=0x2f; 
  176.  
  177.         if(httpbuf!=NULL) 
  178.         { 
  179.                 char* pRefener=tmpUrl+strlen(url)-1; 
  180.                 while(*pRefener!=0x2f){pRefener--;} 
  181.                 pRefener++; 
  182.                 *pRefener=0; 
  183.                 pRefener=NULL; 
  184.                 sprintf(httpbuf,HTTP_STRING_V,url,host,tmpUrl); 
  185.                 delete[] tmpUrl; 
  186.         } 
  187.         tpHost=host; 
  188.         tpHost=strstr(host,":"); 
  189.         if(tpHost!=NULL) 
  190.         { 
  191.                 *tpHost=NULL; 
  192.                 *tpHost++; 
  193.                 *port=atoi(tpHost); 
  194.         }
  195. }
  196.  
  197. char* CHttp::Download(const char* url) 
  198. { 
  199.         if(url==NULL || strlen(url)<10)return NULL; 
  200.  
  201.         if(!GetConnectionState() )return NULL;//先判断下网络状态 
  202.  
  203.         char* host=new char[50]; 
  204.         char* httpbuf=new char[700]; 
  205.         short port=HTTP_PORT; 
  206.         memset(host,0,50); 
  207.         memset(httpbuf,0,700); 
  208.  
  209.         getUrlMessage(url,host,httpbuf,&port); 
  210.         
  211.         DWORD dwIPAddr=inet_addr(host); 
  212.         hostent* phostent=NULL; 
  213.         if(dwIPAddr==INADDR_NONE) 
  214.                 phostent=gethostbyname(host); 
  215.  
  216.         delete[] host; 
  217.         
  218.         //如果主机解析错误或者连接不到服务器，则返回false 
  219.         if (phostent==NULL && dwIPAddr==INADDR_NONE) 
  220.         { 
  221.                 delete[] httpbuf; 
  222.                 return NULL; 
  223.         } 
  224.  
  225.         SOCKADDR_IN addr; 
  226.         addr.sin_family=AF_INET; 
  227.         addr.sin_port=htons(port); 
  228.         if(dwIPAddr==INADDR_NONE) 
  229. memmove(&addr.sin_addr,phostent->h_addr_list[0],
  230. sizeof(phostent->h_addr_list[0])); 
  231.         else 
  232. addr.sin_addr.S_un.S_addr=dwIPAddr;
  233.  
  234.         PHTTP_STATUS sockStatus=new HTTP_STATUS; 
  235.         sockStatus->Socket=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
  236. //建立套接字 连接套接字 
  237.  
  238.         List->AddTail(sockStatus);//不用多讲，放入列表 
  239.  
  240.         if (sockStatus->Socket==INVALID_SOCKET
  241.  || connect(sockStatus->Socket,(SOCKADDR*)&addr,sizeof(addr))==SOCKET_ERROR
  242.  || !sockStatus->Status) 
  243.         { 
  244.                 sockStatus->Status=FALSE; 
  245.                 delete[] httpbuf; 
  246.                 return NULL; 
  247.         } 
  248.  
  249.         sockStatus->Count=0; 
  250.  
  251.         //发送头标识 
  252.         int sen=send(sockStatus->Socket,httpbuf,strlen(httpbuf)+1,0); 
  253.  
  254.         delete[] httpbuf; 
  255.  
  256.         char* rcvbuf=new char[HTTP_MAX_RECV]; 
  257.         int nRcv=recv(sockStatus->Socket,rcvbuf,HTTP_MAX_RECV,0); 
  258.         if (nRcv < 100 || !sockStatus->Status) 
  259.         { 
  260.                 delete[] rcvbuf; 
  261.                 return false; 
  262.         } 
  263.  
  264.         sockStatus->Count=0; 
  265.         //去掉返回的头标识 
  266.         char* p=rcvbuf+20; 
  267.         int startChar=20; 
  268.         int removeInt=1; 
  269.         while(*p++) 
  270.         { 
  271.           startChar++; 
  272.           if (*(p-3)=='\r' && *(p-2)=='\n' && *(p-1)=='\r' && *p=='\n') 
  273.           { 
  274.             p++; 
  275.             break; 
  276.           } 
  277.         }
  278.  
  279.         CList<PHTTP_STRING>* string=new CList<PHTTP_STRING>();
  280.         string->AddTail( new HTTP_STRING(p,nRcv-startChar-removeInt));
  281.         size_t litCount=nRcv-startChar-removeInt; 
  282.  
  283.         //写入接收到的字节 
  284.         while(sockStatus->Status) 
  285.         { 
  286.                 memset(rcvbuf,0,HTTP_MAX_RECV); 
  287.                 nRcv=recv(sockStatus->Socket,rcvbuf,HTTP_MAX_RECV,0); 
  288.                 sockStatus->Count=0; 
  289.  
  290.                 if (nRcv<1)break; 
  291.  
  292.                 litCount+=nRcv; 
  293.                 string->AddTail( new HTTP_STRING(rcvbuf,nRcv) ); 
  294.         } 
  295.         delete[] rcvbuf; 
  296.         
  297.         char* Buffer =(char*)malloc(sizeof(char) * litCount); 
  298.         p=Buffer; 
  299.         for(POSITION pos=string->GetHeadPosition();pos!=NULL;string->GetNext(pos)) 
  300.         { 
  301.                 PHTTP_STRING obj=string->GetAt(pos); 
  302.                 memcpy(p,obj->Buffer,obj->Count); 
  303.                 p+=obj->Count; 
  304.                 delete obj; 
  305.         } 
  306.         string->RemoveAll(); 
  307.         delete string; 
  308.         sockStatus->Status=FALSE; 
  309.  
  310.         return Buffer; 
  311. } 

使用：

  1. CHttp http; 
  2. char* buffer=http.Download("http://www.rosoo.net/"); 
  3. free(buffer); 

内存方面我尽量做到自我释放，我发现玩WM的C++，对内存的使用真的要十分小心

(yanql)
本站文章除注明转载外，均为本站原创或编译欢迎任何形式的转载，但请务必注明出处，尊重他人劳动，同学习共成长。转载请注明：文章转载自：罗索实验室 [http://www.rosoo.net/a/201006/9668.html]
本文出处：yanql.blog.51cto.com　作者：yanql
顶一下
(0)
0%
踩一下
(0)
0%
------分隔线----------------------------
相关文章
发表评论
请自觉遵守互联网相关的政策法规，严禁发布色情、暴力、反动的言论。
评价:
表情:
用户名: 验证码:点击我更换图片
最新评论 进入详细评论页>>
栏目列表
将本文分享到微信
织梦二维码生成器
推荐内容
热点内容