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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
ftpdownload.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：51k
源码类别：

模拟服务器

开发平台：

C/C++

ftpdownload.cpp：源码内容
  2. ///////////////////////////////////////////////////////////////////////////////
  3. // FtpDownload.cpp: implementation of the CFtpDownload class.
  4. ////////////////////////////////////////////////////////////////////////////////
  6. #include "stdafx.h"
  7. #include "SocksPacket.h"
  8. #include "FtpDownload.h"
  9. #include "Resource.h"
  11. #define READ_BUFFER_SIZE 10240
  12. #define DEFAULT_SAVE_DIR _T("C:\")
  13. #define Check(a,b) if((a)) return (b);
  14. //////////////////////////////////////////////////////////////////////
  15. // Construction/Destruction
  16. //////////////////////////////////////////////////////////////////////
  18. CFtpDownload::CFtpDownload()
  19. {
  20. m_strDownloadUrl = _T("");
  21. m_strSavePath = _T(""); // 可以是全路径或保存目录
  22. m_strTempSavePath = _T(""); //临时文件的路径
  24. // 停止下载
  25. m_bStopDownload = FALSE;
  26. m_hStopEvent = NULL;
  28. // 强制重新下载(不管已有的文件是否与远程文件相同)
  29. m_bForceDownload = FALSE;
  31. // 是否支持断点续传
  32. m_bSupportResume = FALSE;
  34. // PASV方式
  35. m_bPasv = TRUE;
  37. // 文件以及下载大小
  38. m_dwFileSize = 0; // 文件总的大小
  39. m_dwFileDownloadedSize = 0; // 文件总共已经下载的大小
  41. m_dwDownloadSize = 0; // 本次需要下载的大小
  42. m_dwDownloadedSize = 0; // 本次已经下载的大小
  45. // 超时TIMEOUT 连接超时、发送超时、接收超时(单位：毫秒)
  46. m_dwConnTimeout = FTP_CONN_TIMEOUT;
  47. m_dwRecvTimeout = FTP_RECV_TIMEOUT;
  48. m_dwSendTimeout = FTP_SEND_TIMEOUT;
  50. // 重试机制
  51. m_nRetryType = FTP_RETRY_NONE; //重试类型(0:不重试 1:重试一定次数 2:总是重试)
  52. m_nRetryTimes = 0; //重试次数
  53. m_nRetryDelay = 0; //重试延迟(单位：毫秒)
  54. m_nRetryMax = 0; //重试的最大次数
  56. // 错误处理
  57. m_nErrorCount = 0; //错误次数 (暂时没有作用)
  58. m_strError = _T(""); //错误信息 (暂时没有作用)
  61. // 向其他窗口发送消息
  62. m_bNotify = FALSE; // 是否向外发送通知消息
  63. m_hNotifyWnd = NULL; // 被通知的窗口
  64. m_nNotifyMessage = 0; // 被通知的消息
  65.     
  66. // 是否使用代理 
  67. m_bProxy = FALSE;
  68. m_strProxyServer = _T("");
  69. m_nProxyPort = 0;
  70. m_nProxyType = FTP_PROXY_NONE;
  72. // 代理是否需要验证
  73. m_bProxyAuthorization = FALSE;
  74. m_strProxyUsername = _T("");
  75. m_strProxyPassword = _T("");
  77. // FTP用户和口令
  78. m_bAuthorization = FALSE;
  79. m_strUsername = _T("anonymous");
  80. m_strPassword = _T("mail@unknow.com");
  82. // 下载过程中所用的变量
  83. m_strServer = _T("");
  84. m_strObject = _T("");
  85. m_strFileName = _T("");
  86. m_nPort = DEFAULT_FTP_PORT;
  88. }
  90. CFtpDownload::~CFtpDownload()
  91. {
  92. CloseControlSocket();
  93. CloseDataSocket();
  94. }
  96. //////////////////////////////////////////////////////////////////////////////////
  97. // 函数名：BOOL GetIEProxy(
  98. // CString &strProxyServer,
  99. // int &nProxyPort,
  100. // int &nProxyType ) 
  101. // 用  途：获取IE的Proxy设置
  102. // 对全局变量的影响：无
  103. // 参  数：
  104. // strProxyServer : 代理服务器地址
  105. // nProxyPort     : 代理服务器的端口
  106. // nProxyType     : 代理服务器的类型
  107. // 返回值：BOOL
  108. ////////////////////////////////////////////////////////////////////////////////
  109. BOOL CFtpDownload::GetIEProxy(CString &strProxyServer, int &nProxyPort, int &nProxyType)
  110. {
  111.     // 读取注册表
  112.     HKEY hRegKey;
  113.     DWORD dwRet = RegOpenKeyEx(
  114.         HKEY_CURRENT_USER,
  115.         "Software\Microsoft\Windows\CurrentVersion\Internet Settings",
  116.         0L,
  117.         KEY_QUERY_VALUE,&hRegKey
  118.     );
  119.     if (dwRet != ERROR_SUCCESS)
  120.         return FALSE;
  121.     
  122.     TCHAR szAddr[256] = { 0 };
  123.     DWORD dwLen = 256;
  124.     dwRet = RegQueryValueEx(hRegKey,"ProxyServer",NULL,NULL,(LPBYTE)szAddr,&dwLen);
  125.     if (dwRet != ERROR_SUCCESS)
  126.     {
  127.         RegCloseKey(hRegKey);
  128.         return FALSE;
  129.     }
  130.     RegCloseKey(hRegKey);
  131.     
  132.     // 注：可能存在所有代理同一的情况，此时无 http=...ftp=...信息
  133.     //    comment by Linsuyi, 2002/01/22  23:30
  134.     // 
  135.     // 分析Proxy的设置
  136.     //http=193.168.10.1:80;socks=192.168.10.235:1080
  137.     //193.168.10.1:1090
  138.     //ftp=193.168.10.1:1090;gopher=193.168.10.1:1090;https=193.168.10.1:1090;socks=193.168.10.2:1080
  139.     int nPos = -1;
  140.     CString strProxy = szAddr;
  141.     
  142.     if (strProxy.IsEmpty())
  143.         return FALSE;
  144.     
  145.     strProxy.MakeLower();
  146.     nProxyType = FTP_PROXY_NONE;
  147.        
  148.     nPos = strProxy.Find("socks=");
  149.     if (-1 == nPos)
  150.         return FALSE;
  151.     
  152.     strProxy = strProxy.Mid( nPos+strlen("socks="));
  153.     nProxyType = FTP_PROXY_SOCKS5;
  154.     
  155.     nPos = strProxy.Find(";");
  156.     if (nPos != -1)
  157.      strProxy = strProxy.Left(nPos);
  158.     
  159.     nPos = strProxy.Find(":");
  160.     strProxyServer = strProxy.Left(nPos);
  161.     nProxyPort = _ttoi(strProxy.Mid(nPos+1));
  162.     if (nProxyPort <= 0)
  163.         return FALSE;
  164.     
  165.     return TRUE;
  166. }
  168. // 设置代理
  169. void CFtpDownload::SetProxy(LPCTSTR lpszProxyServer,int nProxyPort, BOOL bProxy/*=TRUE*/, BOOL bProxyAuthorization /*=FALSE*/, LPCTSTR lpszProxyUsername /*=NULL*/, LPCTSTR lpszProxyPassword /*=NULL*/, int nProxyType /*=FTP_PROXY_NONE*/)
  170. {
  171.     if (bProxy && (FTP_PROXY_USEIE == nProxyType))
  172.     {
  173.         if (!GetIEProxy(m_strProxyServer,m_nProxyPort,m_nProxyType))
  174.         {
  175.             m_bProxy                = FALSE;
  176.             m_bProxyAuthorization   = FALSE;
  177.             m_nProxyPort            = 0;
  178.             m_nProxyType            = FTP_PROXY_NONE;
  179.             m_strProxyServer        = _T("");
  180.             m_strProxyUsername      = _T("");
  181.             m_strProxyPassword      = _T("");
  182.         }
  183.         else
  184.         {
  185.             m_bProxy                = TRUE;
  186.             
  187.             if (lpszProxyUsername != NULL)
  188.             {
  189.                 m_bProxyAuthorization   = TRUE;
  190.                 m_strProxyUsername      = lpszProxyUsername;
  191.                 m_strProxyPassword      = lpszProxyPassword;
  192.             }
  193.             else
  194.             {
  195.                 m_bProxyAuthorization   = FALSE;
  196.                 m_strProxyUsername      = _T("");
  197.                 m_strProxyPassword      = _T("");
  198.             }
  199.         }
  200.     }
  201.     else if (bProxy && (lpszProxyServer != NULL) && (nProxyPort != 0))
  202.     {
  203.         m_bProxy = TRUE;
  204.         m_strProxyServer = lpszProxyServer;
  205.         m_nProxyPort = nProxyPort;
  206.         m_nProxyType = nProxyType;
  207.         
  208.         if (bProxyAuthorization && lpszProxyUsername != NULL)
  209.         {
  210.             m_bProxyAuthorization = TRUE;
  211.             m_strProxyUsername = lpszProxyUsername;
  212.             m_strProxyPassword = lpszProxyPassword;
  213.         }
  214.         else
  215.         {
  216.             m_bProxyAuthorization = FALSE;
  217.             m_strProxyUsername = _T("");
  218.             m_strProxyPassword = _T("");
  219.         }
  220.     }
  221.     else
  222.     {
  223.         m_bProxy = FALSE;
  224.         m_bProxyAuthorization = FALSE;
  225.         m_nProxyPort = 0;
  226.         
  227.         m_nProxyType = FTP_PROXY_NONE;
  228.         m_strProxyServer = _T("");
  229.         m_strProxyUsername = _T("");
  230.         m_strProxyPassword = _T("");
  231.     }
  232. }
  234. // 设置是否需要发送消息给调用窗口
  235. void CFtpDownload::SetNotifyWnd(HWND hNotifyWnd, int nNotifyMsg, BOOL bNotify)
  236. {
  237.     if (bNotify && (hNotifyWnd != NULL) && ::IsWindow(hNotifyWnd) )
  238.     {
  239.         m_bNotify  = TRUE;
  240.         m_hNotifyWnd = hNotifyWnd;
  241.         m_nNotifyMessage = nNotifyMsg;
  242.     }
  243.     else
  244.     {
  245.         m_bNotify  = FALSE;
  246.         m_hNotifyWnd = NULL;
  247.         m_nNotifyMessage = 0;
  248.     }
  249. }
  251. // 设置超时
  252. void CFtpDownload::SetTimeout(DWORD dwSendTimeout, DWORD dwRecvTimeout, DWORD dwConnTimeout)
  253. {
  254. if( dwSendTimeout > 0 )
  255. m_dwSendTimeout = dwSendTimeout;
  257. if( dwRecvTimeout > 0 )
  258. m_dwRecvTimeout = dwRecvTimeout;
  260. if( dwConnTimeout > 0 )
  261. m_dwConnTimeout = dwConnTimeout;
  264. }
  265. // 设置重试的机制
  266. // nRetryType = 0  不重试 FTP_RETRY_NONE
  267. // nRetryType = 1  重试一定次数 FTP_RETRY_TIMES
  268. // nRetryType = 2  永远重试(可能陷入死循环) FTP_RETRY_ALWAYS
  269. void CFtpDownload::SetRetry(int nRetryType, int nRetryDelay, int nRetryMax)
  270. {
  271. m_nRetryType  = nRetryType;
  272. m_nRetryDelay = nRetryDelay;
  273. m_nRetryMax   = nRetryMax;
  275. // 检查一下m_nRetryMax,如果为0，设为缺省值
  276. if( (FTP_RETRY_TIMES == m_nRetryType) && (0 == m_nRetryMax) )
  277. m_nRetryMax = DEFAULT_FTP_RETRY_MAX;
  278. }
  280. // 设置用户名和口号
  281. void CFtpDownload::SetAuthorization(LPCTSTR lpszUsername, LPCTSTR lpszPassword, BOOL byAuthorization)
  282. {
  283. if( byAuthorization && lpszUsername != NULL )
  284. {
  285. m_bAuthorization = TRUE;
  286. m_strUsername  = lpszUsername;
  287. m_strPassword  = lpszPassword;
  288. }
  289. else
  290. {
  291. m_bAuthorization = FALSE;
  292. m_strUsername  = _T("anonymous");
  293. m_strPassword  = _T("hello@dont.know.com");
  294. }
  295. }
  297. // 设置PASV模式
  298. void CFtpDownload::SetPasv(BOOL bPasv /*= TRUE*/)
  299. {
  300. m_bPasv = bPasv;
  301. }
  303. // 停止下载
  304. void CFtpDownload::StopDownload()
  305. {
  306. m_bStopDownload = TRUE;
  308. if ( m_hStopEvent != NULL )
  309. SetEvent(m_hStopEvent);
  310. }
  313. // 创建控制SOCKET
  314. BOOL CFtpDownload::CreateControlSocket()
  315. {
  316. CloseControlSocket();
  317. return m_cControlSocket.Create(AF_INET,SOCK_STREAM,0,READ_BUFFER_SIZE);
  318. }
  320. // 创建数据SOCKET
  321. BOOL CFtpDownload::CreateDataSocket( SOCKET hSocket /*= INVALID_SOCKET */)
  322. {
  323. CloseDataSocket();
  324. return m_cDataSocket.Create(AF_INET,SOCK_STREAM,0,READ_BUFFER_SIZE,hSocket);
  325. }
  328. // 关闭控制SOCKET
  329. void CFtpDownload::CloseControlSocket()
  330. {
  331. m_cControlSocket.Close(TRUE);
  332. }
  334. // 关闭数据SOCKET
  335. void CFtpDownload::CloseDataSocket()
  336. {
  337. m_cDataSocket.Close(TRUE);
  338. }
  341. // 从URL里面拆分出Server和Object来
  342. BOOL CFtpDownload::ParseURL(LPCTSTR lpszURL, CString &strServer, CString &strObject,int& nPort)
  343. {
  344. CString strURL(lpszURL);
  345. strURL.TrimLeft();
  346. strURL.TrimRight();
  348. // 清除数据
  349. strServer = _T("");
  350. strObject = _T("");
  351. nPort   = 0;
  353. int nPos = strURL.Find("://");
  354. if( nPos == -1 )
  355. return FALSE;
  357. // 进一步验证是否为Ftp://
  358. CString strTemp = strURL.Left( nPos+lstrlen("://") );
  359. //strTemp.MakeLower();
  360. //if( strTemp.Compare("ftp://") != 0 )
  361.     if(strTemp.CompareNoCase("ftp://") != 0)
  362. return FALSE;
  364. strURL = strURL.Mid( strTemp.GetLength() );
  365. nPos = strURL.Find('/');
  366. if ( nPos == -1 )
  367. return FALSE;
  369. strObject = strURL.Mid(nPos);
  370. strTemp   = strURL.Left(nPos);
  372. // 查找是否有端口号
  373. nPos = strTemp.Find(":");
  374. if( nPos == -1 )
  375. {
  376. strServer = strTemp;
  377. nPort   = DEFAULT_FTP_PORT;
  378. }
  379. else
  380. {
  381. strServer = strTemp.Left( nPos );
  382. strTemp   = strTemp.Mid( nPos+1 );
  383. nPort   = (int)_ttoi((LPCTSTR)strTemp);
  384. }
  385. return TRUE;
  386. }
  389. // 从下载URL中获取文件名
  390. void CFtpDownload::GetFileName()
  391. {
  392. // 获取的文件名
  393. int nSlash = m_strObject.ReverseFind(_T('/'));
  394. if (nSlash == -1)
  395. nSlash = m_strObject.ReverseFind(_T('\'));
  397. if (nSlash != -1 && m_strObject.GetLength() > 1)
  398. m_strFileName = m_strObject.Right(m_strObject.GetLength() - nSlash - 1);
  399. else
  400. m_strFileName = m_strObject;
  401. }
  404. // 将字符串转化成时间
  405. CTime CFtpDownload::GetTime(LPCTSTR lpszTime)
  406. {
  407. CString strTime(lpszTime);
  408. CTime dTime = CTime::GetCurrentTime();
  410. int nPos = strTime.FindOneOf(" t");
  411. if( nPos == -1 )
  412. return dTime;
  414. CString strAllMonth = "jan,feb,mar,apr,may,jun,jul,aug,sep,oct,nov,dec";
  415. CString strDay,strMonth,strYear,strHour,strMinute;
  416. int nDay,nMonth,nYear,nHour,nMinute,nSecond;
  419. strMonth = strTime.Left( nPos );
  420. strTime = strTime.Mid( nPos +1 );
  421. strTime.TrimLeft();
  423. nPos = strAllMonth.Find(strMonth);
  424. if( nPos == -1 )
  425. return dTime;
  426. strMonth.Format("%d",((nPos/4)+1));
  427. nMonth = atoi(strMonth);
  429. nPos = strTime.FindOneOf(" t");
  430. if( nPos == -1 )
  431. return dTime;
  432. strDay = strTime.Left( nPos );
  433. nDay = atoi(strDay);
  435. strTime = strTime.Mid( nPos+1 );
  436. strTime.TrimLeft();
  438. nPos = strTime.FindOneOf(":");
  439. if (nPos != -1)
  440. {
  441. strHour = strTime.Left( nPos );
  442. nHour = atoi(strHour);
  444. strTime = strTime.Mid( nPos+1 );
  445. strTime.TrimLeft();
  447. nPos = strTime.FindOneOf(":");
  448. if( nPos != -1 )
  449. {
  450. strMinute = strTime.Left( nPos );
  451. nMinute = atoi(strMinute);
  453. strTime = strTime.Mid( nPos+1 );
  454. strTime.TrimLeft();
  456. nSecond = atoi(strTime);
  458. }
  459. else
  460. {
  461. nMinute = atoi(strTime);
  462. nSecond = 0;
  463. }
  466. }
  467. else
  468. {
  469. nHour = 0;
  470. nMinute = 0;
  471. nSecond = 0;
  472. }
  473. nYear = dTime.GetYear();
  475. dTime = CTime(nYear,nMonth,nDay,nHour,nMinute,nSecond);
  476. return dTime;
  477. }
  479. // 获得返回码
  480. BOOL CFtpDownload::GetReplyCode(LPCTSTR lpszResponse,DWORD& dwReplyCode,BOOL& bMultiLine)
  481. {
  482. CString strSource(lpszResponse);
  484. dwReplyCode = 0;
  485. bMultiLine = FALSE;
  487. if( strSource.GetLength() < 3 )
  488. return FALSE;
  490. dwReplyCode = (DWORD)_ttoi(strSource.Left(3));
  492. if( strSource.GetLength() >= 4 )
  493. bMultiLine = (strSource.GetAt(3) == '-' );
  494. else
  495. bMultiLine = FALSE;
  497. return TRUE;
  498. }
  500. // 获取数据通道的信息
  501. BOOL CFtpDownload::GetDataReply(CString& strReply)
  502. {
  503. char szReadBuf[1025];
  504. strReply = _T("");
  506. // 接收信息
  507. ZeroMemory(szReadBuf,1025);
  508. if( m_cDataSocket.BSDGetString(szReadBuf,1024,m_dwRecvTimeout) != SOCKET_SUCCESS )
  509. return FALSE;
  511. strReply += szReadBuf;
  513. return TRUE;
  514. }
  518. // 获得Reply信息
  519. BOOL CFtpDownload::GetReply(CString& strReply,DWORD& dwReplyCode)
  520. {
  521. char szReadBuf[1025];
  522. CString strResponse;
  523. DWORD dwStartCode;
  524. BOOL bMultiLine;
  526. strReply = _T("");
  527. dwReplyCode = 0;
  529. // 先接收一行
  530. ZeroMemory(szReadBuf,1025);
  531. if( m_cControlSocket.BSDGetString(szReadBuf,1024,m_dwRecvTimeout) != SOCKET_SUCCESS )
  532. return FALSE;
  534. strReply += szReadBuf;
  536. if( !GetReplyCode(szReadBuf,dwReplyCode,bMultiLine) )
  537. return FALSE;
  539. if( !bMultiLine )
  540. return TRUE;
  542. dwStartCode = dwReplyCode;
  543. while(TRUE)
  544. {
  545. ZeroMemory(szReadBuf,1025);
  546. if( m_cControlSocket.BSDGetString(szReadBuf,1024,m_dwRecvTimeout) != SOCKET_SUCCESS )
  547. return FALSE;
  549. strReply += szReadBuf;
  550. strReply += "rn";
  552. if( !GetReplyCode(szReadBuf,dwReplyCode,bMultiLine) )
  553. return FALSE;
  555. if( dwStartCode == dwReplyCode && !bMultiLine )
  556. break;
  557. }
  558. return TRUE;
  559. }
  562. // 发送FTP命令
  563. BOOL CFtpDownload::SendCommand(LPCTSTR lpszCmd,LPCTSTR lpszParameter)
  564. {
  565. CString strCmd(lpszCmd);
  567. if( lpszParameter != NULL && lstrlen(lpszParameter)>0 )
  568. {
  569. strCmd += " ";
  570. strCmd += lpszParameter;
  571. }
  572. strCmd += "rn";
  573.  
  574. if( m_cControlSocket.Send(strCmd,strCmd.GetLength(),m_dwSendTimeout) != strCmd.GetLength() )
  575. return FALSE;
  577. return TRUE;
  579. }
  581. // 从Pasv的返回信息中获得IP和端口
  582. BOOL CFtpDownload::GetPasvIP(LPCTSTR lpszReply,CString& strPasvIP,int& nPasvPort)
  583. {
  584. CString strReply(lpszReply);
  585. CString strPort1,strPort2;
  587. strPasvIP = _T("");
  588. nPasvPort = 0;
  590. int nPos = strReply.Find('(');
  591. if( nPos == -1 )
  592. return FALSE;
  594. strPasvIP = strReply.Mid( nPos + 1 );
  595. nPos = strPasvIP.Find(')');
  596. if( nPos == -1 )
  597. return FALSE;
  599. strPasvIP = strPasvIP.Left(nPos);
  601. nPos = strPasvIP.ReverseFind(',');
  602. if( nPos == -1)
  603. return FALSE;
  605. strPort2 = strPasvIP.Right(strPasvIP.GetLength() - nPos -1 );
  606. strPasvIP = strPasvIP.Left(nPos);
  608. nPos = strPasvIP.ReverseFind(',');
  609. if( nPos == -1 )
  610. return FALSE;
  612. strPort1 = strPasvIP.Right(strPasvIP.GetLength() - nPos -1 );
  613. strPasvIP = strPasvIP.Left(nPos);
  615. strPasvIP.Replace(',','.');
  616. nPasvPort = (int) ( atoi(strPort1)*256+atoi(strPort2) );
  617. return TRUE;
  618. }
  620. // 获取文件时间和大小
  621. BOOL CFtpDownload::GetInfo(LPCTSTR lpszReply,DWORD& dwSize,CTime& TimeLastModified)
  622. {
  623. CString strReply(lpszReply);
  625. dwSize = 0;
  626. TimeLastModified = CTime::GetCurrentTime();
  628. //-rwxr-xr-x   1 ftpuser  ftpusers  14712179 Sep 13 09:55 csmproxy50nt.exe
  629. //-r--r--r--  1 root  wheel  454454 Oct  5 10:54 /pub/socks/dante-1.1.4.tar.gz
  630. //-r-xr-xr-x   1 0        0         986400 Jun 16  1998 /pub/Networks/Socket/Winsock/ws2setup.exe
  632. strReply.TrimLeft();
  633. strReply.TrimRight();
  634. strReply.MakeLower();
  636. int nCount = 0;
  637. int nPos ;
  638. while( nCount < 4 )
  639. {
  640. nPos = strReply.FindOneOf(" t");
  641. if( nPos == -1 )
  642. return FALSE;
  644. strReply = strReply.Mid(nPos+1);
  645. strReply.TrimLeft();
  647. nCount ++;
  648. }
  650. nPos = strReply.FindOneOf(" t");
  651. if( nPos == -1 )
  652. return FALSE;
  654. CString strSize = strReply.Left(nPos);
  655. dwSize = (DWORD)_ttol(strSize);
  657. strReply = strReply.Mid(nPos+1);
  658. strReply.TrimLeft();
  660. int nPos1 = strReply.ReverseFind(' ');
  661. int nPos2 = strReply.ReverseFind('t');
  663. if( nPos1 != -1 )
  664. {
  665. if( nPos2 != -1 )
  666. {
  667. nPos = ( nPos1 <= nPos2 )? nPos1:nPos2;
  668. }
  669. else
  670. {
  671. nPos = nPos1;
  672. }
  673. }
  674. else
  675. {
  676. if( nPos2 != -1 )
  677. {
  678. nPos = nPos2;
  679. }
  680. else
  681. {
  682. return FALSE;
  683. }
  684. }
  686. strReply = strReply.Left(nPos);
  687. strReply.TrimRight();
  689. TimeLastModified = GetTime(strReply);
  690. return TRUE;
  691. }
  694. // 发送请求
  695. int CFtpDownload::SendRequest(BOOL bPasv /*= TRUE*/)
  696. {
  698. while (TRUE)
  699. {
  700. CString strSend, strReply;
  701. DWORD dwSize, dwReplyCode;
  703. // 用于保存PASV或PORT的参数
  704. CString strIP;
  705. int nPort;
  706. CString         sMes;
  708.         strIP = _T("");
  709. nPort = 0;
  712. // 非PASV 
  713. CBufSocket cListenSocket;
  715. m_dwFileDownloadedSize = 0;
  716. m_dwDownloadSize    = 0;
  718. // 创建控制套接字
  719. Check( !CreateControlSocket(), FTP_REQUEST_FAIL);
  721. // 建立控制通道
  722. Check( m_bStopDownload,FTP_REQUEST_STOP);
  723. int nRet = MakeConnection(&m_cControlSocket,m_strServer,m_nPort);
  724. Check( ( nRet != FTP_REQUEST_SUCCESS ), nRet );
  725. Check( m_bStopDownload,FTP_REQUEST_STOP);
  726. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);// 先获取服务器的Greeting信息
  727. //seawind
  728. Check( m_bStopDownload,FTP_REQUEST_STOP);
  729.         
  730.         //Removed by linsuyi 2001/01/31 16:32
  731.         // sMes.LoadString(IDS_CREATE_CHANNELS_SUCCESS);
  732.         // sMes += strReply;
  733.         // TRACE1("%s ", sMes);
  734.         
  735. // 开始发送命令
  736. // USER
  737. Check( m_bStopDownload,FTP_REQUEST_STOP);
  738. Check( !SendCommand(FTP_CMD_USER,m_strUsername) ,FTP_REQUEST_ERROR );
  739. Check( m_bStopDownload,FTP_REQUEST_STOP);
  740. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR );
  741. //seawind
  742. Check( m_bStopDownload,FTP_REQUEST_STOP);
  744.         //Removed by linsuyi 2001/01/31 16:32
  745.         // sMes.Empty();
  746.         // sMes.LoadString(IDS_USER_COMMAND_SUCCESS);
  747.         // sMes += strReply;
  748. // TRACE1("%s ", sMes);
  750. switch(dwReplyCode)
  751. {
  752. case 230:
  753. break;
  754. case 331: // Need Password
  755. // PASS
  756. Check( m_bStopDownload,FTP_REQUEST_STOP);
  757. Check( !SendCommand(FTP_CMD_PASS,m_strPassword),FTP_REQUEST_ERROR);
  758. Check( m_bStopDownload,FTP_REQUEST_STOP);
  759. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  760. //seawind
  761. Check( m_bStopDownload,FTP_REQUEST_STOP);
  762. Check( dwReplyCode != 230 ,FTP_REQUEST_FAIL);
  764.             //Removed by linsuyi 2001/01/31 16:32
  765.             // sMes.Empty();
  766.             // sMes.LoadString(IDS_PASS_COMMAND_SUCCESS);
  767.             // sMes += strReply;
  768. // TRACE1("%s ", sMes);
  770. break;
  771. default:
  772. return FTP_REQUEST_FAIL;
  773. break;
  774. }
  776. // 测试是否支持断点续传
  777. // REST 10
  778. Check( m_bStopDownload,FTP_REQUEST_STOP);
  779. Check( !SendCommand(FTP_CMD_REST,_T("10")),FTP_REQUEST_ERROR);
  780. Check( m_bStopDownload,FTP_REQUEST_STOP);
  781. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  782. //seawind
  783. Check( m_bStopDownload,FTP_REQUEST_STOP);
  784. if( dwReplyCode == 350 )
  785. m_bSupportResume = TRUE;
  786. else
  787. m_bSupportResume = FALSE;
  788.         
  789.         //Removed by linsuyi 2001/01/31 16:32
  790.         // sMes.LoadString(IDS_REST10_COMMAND_SUCCESS);
  791.         // sMes += strReply;
  792.         // TRACE1("%s ", sMes);
  793.         
  794. // 字符模式
  795. Check( m_bStopDownload,FTP_REQUEST_STOP);
  796. Check( !SendCommand(FTP_CMD_TYPE,_T("A")),FTP_REQUEST_ERROR);
  797. Check( m_bStopDownload,FTP_REQUEST_STOP);
  798. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  799. //seawind
  800. Check( m_bStopDownload,FTP_REQUEST_STOP);
  801. Check( dwReplyCode != 200 ,FTP_REQUEST_FAIL); // 必须至少支持这种模式
  803.         //Removed by linsuyi 2001/01/31 16:32
  804.         // sMes.Empty();
  805.         // sMes.LoadString(IDS_TYPEA_COMMAND_SUCCESS);
  806.         // sMes += strReply;
  807.         // TRACE1("%s ", sMes);
  809. // 是否支持PASV
  810. if( bPasv )
  811. {
  812. // PASV
  813. Check( m_bStopDownload,FTP_REQUEST_STOP);
  814. Check( !SendCommand(FTP_CMD_PASV,NULL),FTP_REQUEST_ERROR);
  815. Check( m_bStopDownload,FTP_REQUEST_STOP);
  816. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  817. //seawind
  818.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  819.         
  820.             //Removed by linsuyi 2001/01/31 16:32
  821.             // sMes.Empty();
  822.             // sMes.LoadString(IDS_PASV_COMMAND_SUCCESS);
  823.             // sMes += strReply;
  824.             // TRACE1("%s ", sMes);
  826. if( dwReplyCode == 227 )
  827. {
  828. if( GetPasvIP(strReply,strIP,nPort) )
  829. {
  830. m_bPasv = TRUE;
  831. // 建立数据通道
  832. Check( m_bStopDownload,FTP_REQUEST_STOP);
  833. Check( !CreateDataSocket(),FTP_REQUEST_FAIL);
  834. nRet = MakeConnection(&m_cDataSocket,strIP,nPort);
  835. Check( nRet != FTP_REQUEST_SUCCESS,nRet);
  836. }
  837. else
  838. m_bPasv = FALSE;
  839. }
  840. else
  841. m_bPasv = FALSE;
  842. }
  844. dwSize = 0;
  845. m_TimeLastModified = CTime::GetCurrentTime();
  847.         // 根据是否采用PASV，而有很大区别
  848.         if (bPasv && m_bPasv)   // PASV
  849.         {
  850.             // 执行LIST命令
  851.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  852.             Check( !SendCommand(FTP_CMD_LIST, m_strObject ),FTP_REQUEST_ERROR);
  853.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  854.             Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  855.             //seawind
  856.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  857.             
  858.             //Removed by linsuyi 2001/01/31 16:32
  859.             // sMes.Empty();
  860.             // sMes.LoadString(IDS_LIST_COMMAND_SUCCESS);
  861.             // sMes += strReply;
  862.             // TRACE1("%s ", sMes);
  863.             
  864.             if ((dwReplyCode == 125) || ( dwReplyCode == 150 ))
  865.             {
  866.                 //从数据通道读取信息
  867.                 Check(m_bStopDownload, FTP_REQUEST_STOP);
  868.                 if (GetDataReply(strReply))
  869.                 {
  870.                     //Removed by linsuyi 2001/01/31 16:32
  871.                     // sMes.Empty();
  872.                     // sMes.LoadString(IDS_LIST_DATA_CHANNELS);
  873.                     // sMes += strReply;
  874.                     // TRACE1("%s ", sMes);
  875.                     
  876.                     if (!GetInfo(strReply,dwSize,m_TimeLastModified))
  877.                     {
  878.                         // TODO:
  879.                     }
  880.                 }
  881.                 CloseDataSocket();
  882.                 
  883.                 //从控制通道读取信息
  884.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  885.                 Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  886.                 //seawind
  887.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  888.                 Check( dwReplyCode != 250 && dwReplyCode != 226,FTP_REQUEST_ERROR);
  889.                 
  890.                 //Removed by linsuyi 2001/01/31 16:32
  891.                 // sMes.Empty();
  892.                 // sMes.LoadString(IDS_LIST_CONTROL_CHANNELS);
  893.                 // sMes += strReply;
  894.                 // TRACE1("%s ", sMes);
  895.                 
  896.             }   //125.150 -- LIST COMMAND [PASV]
  897.             
  898.             //Bin模式
  899.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  900.             Check( !SendCommand(FTP_CMD_TYPE,_T("I")),FTP_REQUEST_ERROR);
  901.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  902.             Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  903.             //seawind
  904.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  905.             
  906.             //Removed by linsuyi 2001/01/31 16:32
  907.             // sMes.Empty();
  908.             // sMes.LoadString(IDS_TYPEI_COMMAND_SUCCESS);
  909.             // sMes += strReply;
  910.             // TRACE1("%s ", sMes);
  911.                         
  912.             if( dwReplyCode != 200 )
  913.             {
  914.                 // TODO:
  915.             }
  916.             
  917.             // PASV命令
  918.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  919.             Check( !SendCommand(FTP_CMD_PASV,NULL ),FTP_REQUEST_ERROR);
  920.             Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  921.             //seawind
  922.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  923.             Check( dwReplyCode != 227,FTP_REQUEST_ERROR);
  924.             Check( !GetPasvIP(strReply,strIP,nPort),FTP_REQUEST_ERROR);
  925.             
  926.             //Removed by linsuyi 2001/01/31 16:32
  927.             // sMes.Empty();
  928.             // sMes.LoadString(IDS_PASV_PASV_COMMAND_SUCCESS);
  929.             // sMes += strReply;
  930.             // TRACE1("%s ", sMes);
  931.             
  932.             // 建立数据通道
  933.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  934.             Check( !CreateDataSocket(),FTP_REQUEST_FAIL);
  935.             nRet = MakeConnection(&m_cDataSocket,strIP,nPort);
  936.             Check( nRet != FTP_REQUEST_SUCCESS,nRet);
  937.             
  938.             //Removed by linsuyi 2001/01/31 16:32
  939.             // sMes.Empty();
  940.             // sMes.LoadString(IDS_PASV_CREATE_DATA_CHANNELS_SUCCESS);
  941.             // sMes += strReply;
  942.             // TRACE1("%s ", sMes);
  943.         }
  944.         else    // 不采用PASV
  945.         {
  946.             
  947.             char szListenIP[128],szTemp[128];
  948.             int nListenPort;
  949.             DWORD dwListenIP;
  950.             CString strListenIP;
  951.             
  952.             // 是否为SOCKS代理
  953.             if( m_nProxyType == FTP_PROXY_SOCKS4 ||
  954.                 m_nProxyType == FTP_PROXY_SOCKS4A||
  955.                 m_nProxyType == FTP_PROXY_SOCKS5 )
  956.             {
  957.                 if( !CreateDataSocket() )
  958.                     return FTP_REQUEST_FAIL;
  959.                 
  960.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  961.                 nRet = MakeConnection( &m_cDataSocket,m_strServer,m_nPort,TRUE,&dwListenIP,&nListenPort);
  962.                 Check( nRet != FTP_REQUEST_SUCCESS,nRet);
  963.                 strListenIP.Format("%d,%d,%d,%d",(dwListenIP>>24)&0xFF,(dwListenIP>>16)&0xFF,(dwListenIP>>8)&0xFF,(dwListenIP)&0xFF);
  964.             }
  965.             else
  966.             {
  967.                 //没有代理
  968.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  969.                 Check( !cListenSocket.Create(),FTP_REQUEST_FAIL);
  970.                 Check( !cListenSocket.Bind(0), FTP_REQUEST_ERROR);
  971.                 Check( !cListenSocket.Listen(1),FTP_REQUEST_ERROR);
  972.                 
  973.                 ZeroMemory(szListenIP,128);
  974.                 Check( !m_cControlSocket.GetSockName(szListenIP,nListenPort),FTP_REQUEST_ERROR);
  975.                 
  976.                 ZeroMemory(szTemp,128);
  977.                 Check( !cListenSocket.GetSockName(szTemp,nListenPort),FTP_REQUEST_ERROR);
  978.                 
  979.                 strListenIP =  _T("");
  980.                 strListenIP += szListenIP;
  981.                 strListenIP.Replace('.',',');
  982.             }
  983.             
  984.             strSend.Format(",%d,%d",nListenPort/256,nListenPort%256);
  985.             strSend = strListenIP+strSend;
  986.             
  987.             // PORT
  988.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  989.             Check( !SendCommand(FTP_CMD_PORT,strSend ),FTP_REQUEST_ERROR);
  990.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  991.             Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  992.             //seawind
  993.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  994.             Check( dwReplyCode != 200, FTP_REQUEST_FAIL ); // 必须支持该命令
  995.             
  996.             //Removed by linsuyi 2001/01/31 16:32
  997.             // sMes.Empty();
  998.             // sMes.LoadString(IDS_NOPASV_PORT_COMMAND_SUCCESS);
  999.             // sMes += strReply;
  1000.             // TRACE1("%s ", sMes);
  1001.             
  1002.             // 执行LIST命令
  1003.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1004.             Check( !SendCommand(FTP_CMD_LIST, m_strObject),FTP_REQUEST_ERROR);
  1005.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1006.             Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  1007.             //seawind
  1008.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1009.             
  1010.             //Removed by linsuyi 2001/01/31 16:32
  1011.             // sMes.Empty();
  1012.             // sMes.LoadString(IDS_NOPASV_LIST_COMMAND_SUCCESS);
  1013.             // sMes += strReply;
  1014.             // TRACE1("%s ", sMes);
  1015.             
  1016.             if( (dwReplyCode == 125) || ( dwReplyCode == 150 ) )
  1017.             {
  1018.                 if( m_nProxyType == FTP_PROXY_SOCKS4 ||
  1019.                     m_nProxyType == FTP_PROXY_SOCKS4A||
  1020.                     m_nProxyType == FTP_PROXY_SOCKS5 )
  1021.                 {
  1022.                     CSocksPacket cSocks( &m_cDataSocket );
  1023.                     
  1024.                     switch ( m_nProxyType )
  1025.                     {
  1026.                     case FTP_PROXY_SOCKS4A:
  1027.                         Check( !cSocks.RecvPacket(PACKET_SOCKS4AREP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1028.                         Check( !cSocks.IsSocksOK(),FTP_REQUEST_FAIL);
  1029.                         break;
  1030.                     case FTP_PROXY_SOCKS4:
  1031.                         Check( !cSocks.RecvPacket(PACKET_SOCKS4REP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1032.                         Check( !cSocks.IsSocksOK(),FTP_REQUEST_FAIL);
  1033.                         break;
  1034.                     case FTP_PROXY_SOCKS5:
  1035.                         Check( !cSocks.RecvPacket(PACKET_SOCKS5REP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1036.                         Check( !cSocks.IsSocksOK(),FTP_REQUEST_FAIL);
  1037.                         break;
  1038.                     }
  1039.                 }
  1040.                 else
  1041.                 {
  1042.                     // ACCEPT
  1043.                     SOCKET hSocket = cListenSocket.Accept(NULL,0,m_hStopEvent,WSA_INFINITE);
  1044.                     Check( hSocket == INVALID_SOCKET,FTP_REQUEST_ERROR);
  1045.                     Check( !CreateDataSocket(hSocket),FTP_REQUEST_FAIL);
  1046.                 }
  1047.                 
  1048.                 // 从数据通道读取信息
  1049.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  1050.                 if (GetDataReply(strReply))
  1051.                 {
  1052.                     //Removed by linsuyi 2001/01/31 16:32
  1053.                     // sMes.Empty();
  1054.                     // sMes.LoadString(IDS_NOPASV_LIST_DATA_CHANNELS);
  1055.                     // sMes += strReply;
  1056.                     // TRACE1("%s ", sMes);
  1057.                     
  1058.                     if( !GetInfo(strReply,dwSize,m_TimeLastModified) )
  1059.                     {
  1060.                         // TODO:
  1061.                     }
  1062.                 }
  1063.                 CloseDataSocket();
  1064.                 
  1065.                 // 从控制通道读取信息
  1066.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  1067.                 Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  1068.                 //seawind
  1069.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  1070.                 Check( dwReplyCode != 250 && dwReplyCode != 226,FTP_REQUEST_ERROR);
  1071.                 
  1072.                 //Removed by linsuyi 2001/01/31 16:32
  1073.                 // sMes.Empty();
  1074.                 // sMes.LoadString(IDS_NOPASV_LIST_CONTROL_CHANNELS);
  1075.                 // sMes += strReply;
  1076.                 // TRACE1("%s ", sMes);
  1077.             } // LIST
  1078.             
  1079.             // Bin模式
  1080.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1081.             Check( !SendCommand(FTP_CMD_TYPE,_T("I")),FTP_REQUEST_ERROR);
  1082.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1083.             Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  1084.             //seawind
  1085.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1086.             
  1087.             //Removed by linsuyi 2001/01/31 16:32
  1088.             // sMes.Empty();
  1089.             // sMes.LoadString(IDS_NOPASV_TYPEI_COMMAND_SUCCESS);
  1090.             // sMes += strReply;
  1091.             // TRACE1("%s ", sMes);
  1092.             
  1093.             if (dwReplyCode != 200)
  1094.             {
  1095.                 // TODO:
  1096.             }
  1097.             
  1098.             // PORT命令
  1099.             if (
  1100.                 (m_nProxyType == FTP_PROXY_SOCKS4) ||
  1101.                 (m_nProxyType == FTP_PROXY_SOCKS4A) ||
  1102.                 (m_nProxyType == FTP_PROXY_SOCKS5)
  1103.             )
  1104.             {
  1105.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  1106.                 Check( !CreateDataSocket(),FTP_REQUEST_FAIL);
  1107.                 nRet = MakeConnection( &m_cDataSocket,m_strServer,m_nPort,TRUE,&dwListenIP,&nListenPort);
  1108.                 Check( nRet != FTP_REQUEST_SUCCESS,nRet);
  1109.                 strListenIP.Format("%d,%d,%d,%d",(dwListenIP>>24)&0xFF,(dwListenIP>>16)&0xFF,(dwListenIP>>8)&0xFF,(dwListenIP)&0xFF);
  1110.             }
  1111.             else
  1112.             {
  1113.                 Check( m_bStopDownload,FTP_REQUEST_STOP);
  1114.                 Check( !cListenSocket.Create(),FTP_REQUEST_FAIL);
  1115.                 Check( !cListenSocket.Bind(0),FTP_REQUEST_ERROR);
  1116.                 Check( !cListenSocket.Listen(1),FTP_REQUEST_ERROR);
  1117.                 
  1118.                 ZeroMemory(szListenIP,128);
  1119.                 Check( !m_cControlSocket.GetSockName(szListenIP,nListenPort),FTP_REQUEST_ERROR);
  1120.                 
  1121.                 ZeroMemory(szTemp,128);
  1122.                 Check( !cListenSocket.GetSockName(szTemp,nListenPort),FTP_REQUEST_ERROR);
  1123.                 
  1124.                 strListenIP = _T("");
  1125.                 strListenIP += szListenIP;
  1126.                 strListenIP.Replace('.',',');
  1127.             }
  1128.             
  1129.             strSend.Format(",%d,%d",nListenPort/256,nListenPort%256);
  1130.             strSend = strListenIP+strSend;
  1131.             
  1132.             // PORT
  1133.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1134.             Check( !SendCommand(FTP_CMD_PORT,strSend ),FTP_REQUEST_ERROR);
  1135.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1136.             Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  1137.             //seawind
  1138.             Check( m_bStopDownload,FTP_REQUEST_STOP);
  1139.             Check( dwReplyCode != 200, FTP_REQUEST_FAIL);// 必须支持该命令
  1140.             
  1141.             //Removed by linsuyi 2001/01/31 16:32
  1142.             // sMes.Empty();
  1143.             // sMes.LoadString(IDS_NOPASV_PORT_COMMAND_SUCCESS);
  1144.             // sMes += strReply;
  1145.             // TRACE1("%s ", sMes);
  1146.             
  1147.         }   // NO PASV
  1148.         
  1149.         // 准备下载
  1150.         if (dwSize == 0)
  1151.         {
  1152. // 试一试SIZE命令
  1153. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1154. Check( !SendCommand(FTP_CMD_SIZE, m_strObject ),FTP_REQUEST_ERROR);
  1155. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1156. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  1157. //seawind
  1158. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1160.             //Removed by linsuyi 2001/01/31 16:32
  1161.             // sMes.Empty();
  1162.             // sMes.LoadString(IDS_SIZE_COMMAND_SUCCESS);
  1163.             // sMes += strReply;
  1164.             // TRACE1("%s ", sMes);
  1165.             
  1166. if( dwReplyCode == 213 )
  1167. {
  1168. strReply.TrimLeft();
  1169. strReply.TrimRight();
  1170. int nPos = strReply.Find(' ');
  1171. if( nPos != -1 )
  1172. {
  1173. strReply = strReply.Mid( nPos + 1 );
  1174. strReply.TrimLeft();
  1175. dwSize = (DWORD)_ttol(strReply);
  1176. }
  1177. }
  1178. }
  1180. // 判断m_strSavePath是否为路径
  1181. GetFileName();
  1182. if( m_strSavePath.Right(1) == '\' )
  1183. {
  1184. m_strTempSavePath = m_strSavePath;
  1185. m_strTempSavePath += m_strFileName;
  1186. m_strTempSavePath += ".tmp";
  1187. }
  1189. CString strRange;
  1190. m_dwFileDownloadedSize = 0;
  1191. if( m_bSupportResume )
  1192. {
  1193. // 查看文件已经下载的长度
  1194. CFileStatus fileDownStatus;
  1195. if (CFile::GetStatus(m_strTempSavePath,fileDownStatus) && !m_bForceDownload )
  1196. m_dwFileDownloadedSize = fileDownStatus.m_size;
  1198. strRange.Format(_T("%d"),m_dwFileDownloadedSize );
  1200. // REST COMMAND
  1201. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1202. Check( !SendCommand(FTP_CMD_REST,strRange ),FTP_REQUEST_ERROR);
  1203. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1204. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  1205. //seawind
  1206. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1207. Check( dwReplyCode != 350,FTP_REQUEST_ERROR);
  1209.             //Removed by linsuyi 2001/01/31 16:32
  1210.             // sMes.Empty();
  1211.             // sMes.LoadString(IDS_REST_COMMAND_SUCCESS);
  1212.             // sMes += strReply;
  1213.             // TRACE1("%s ", sMes);
  1214. }
  1216. // 注意
  1217. m_dwFileSize  = dwSize;
  1218. m_dwDownloadSize = dwSize - m_dwFileDownloadedSize;
  1219. Check( m_dwDownloadSize < 0,FTP_REQUEST_FAIL);
  1221. // 发送RETR命令
  1222. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1223. Check( !SendCommand(FTP_CMD_RETR,m_strObject ),FTP_REQUEST_ERROR);
  1224. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1225. Check( !GetReply(strReply,dwReplyCode),FTP_REQUEST_ERROR);
  1226. //seawind
  1227. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1228. Check( (dwReplyCode != 125 && dwReplyCode != 150 && dwReplyCode != 110),FTP_REQUEST_FAIL);
  1229.         
  1230.         //Removed by linsuyi 2001/01/31 16:32
  1231.         // sMes.Empty();
  1232.         // sMes.LoadString(IDS_RETR_COMMAND_SUCCESS);
  1233.         // sMes += strReply;
  1234.         // TRACE1("%s ", sMes);
  1235.         
  1236.         // 非PASV方式要创建数据通道
  1237. if( !bPasv || !m_bPasv )
  1238. {
  1239. if( m_nProxyType == FTP_PROXY_SOCKS4 ||
  1240. m_nProxyType == FTP_PROXY_SOCKS4A||
  1241. m_nProxyType == FTP_PROXY_SOCKS5 )
  1242. {
  1243. CSocksPacket cSocks( &m_cDataSocket );
  1244. switch ( m_nProxyType )
  1245. {
  1246. case FTP_PROXY_SOCKS4A:
  1247. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1248. Check( !cSocks.RecvPacket(PACKET_SOCKS4AREP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1249. Check( !cSocks.IsSocksOK(),FTP_REQUEST_FAIL);
  1250. break;
  1251. case FTP_PROXY_SOCKS4:
  1252. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1253. Check( !cSocks.RecvPacket(PACKET_SOCKS4REP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1254. Check( !cSocks.IsSocksOK(),FTP_REQUEST_FAIL);
  1255. break;
  1256. case FTP_PROXY_SOCKS5:
  1257. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1258. Check( !cSocks.RecvPacket(PACKET_SOCKS5REP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1259. Check( !cSocks.IsSocksOK(),FTP_REQUEST_FAIL);
  1260. break;
  1261. }
  1262. }
  1263. else
  1264. {
  1265. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1266. SOCKET hSocket = cListenSocket.Accept(NULL,0,m_hStopEvent,WSA_INFINITE);
  1267. Check( hSocket == INVALID_SOCKET,FTP_REQUEST_ERROR);
  1268. Check( !CreateDataSocket(hSocket),FTP_REQUEST_FAIL);
  1269. }
  1270. } // NO PASV 建立数据通道
  1272. return FTP_REQUEST_SUCCESS;
  1273. }// WHILE LOOP
  1275. return FTP_REQUEST_SUCCESS;
  1276. }
  1279. // 开始下载
  1280. int CFtpDownload::Download(LPCTSTR lpszDownloadUrl,LPCTSTR lpszSavePath,BOOL bForceDownload /*= FALSE */)
  1281. {
  1282. m_bStopDownload   = FALSE;
  1283. m_bForceDownload  = bForceDownload;
  1284. m_nRetryTimes   = 0;
  1285. m_nErrorCount   = 0;
  1286. m_strTempSavePath = _T("");
  1288. // 检验要下载的URL是否为空
  1289. m_strDownloadUrl = lpszDownloadUrl;
  1290. m_strDownloadUrl.TrimLeft();
  1291. m_strDownloadUrl.TrimRight();
  1292. if( m_strDownloadUrl.IsEmpty() )
  1293. return FTP_RESULT_FAIL;
  1295. // 检验要下载的URL是否有效
  1296. if ( !ParseURL(m_strDownloadUrl, m_strServer, m_strObject, m_nPort))
  1297. {
  1298. // 在前面加上"ftp://"再试
  1299. m_strDownloadUrl = _T("ftp://") + m_strDownloadUrl;
  1300. if ( !ParseURL(m_strDownloadUrl,m_strServer, m_strObject, m_nPort) )
  1301. {
  1302. TRACE(_T("Failed to parse the URL: %sn"), m_strDownloadUrl);
  1303. return FTP_RESULT_FAIL;
  1304. }
  1305. }
  1307. // 检查本地保存路径
  1308. m_strSavePath =  lpszSavePath;
  1309. m_strSavePath.TrimLeft();
  1310. m_strSavePath.TrimRight();
  1311. if( m_strSavePath.IsEmpty() )
  1312. m_strSavePath = DEFAULT_SAVE_DIR;
  1314. if( m_strSavePath.Right(1) != '\' ) // 只有路径，没有文件名
  1315. {
  1316. m_strTempSavePath =  m_strSavePath;
  1317. m_strTempSavePath += ".tmp";
  1318. }
  1320. // 创建停止事件
  1321. if( m_hStopEvent == NULL )
  1322. {
  1323. m_hStopEvent = CreateEvent(NULL,TRUE,FALSE,NULL);
  1324. if( m_hStopEvent == NULL )
  1325. return FTP_RESULT_FAIL;
  1327. //seawind
  1328. m_cControlSocket.m_hStopEvent = m_hStopEvent;
  1329. m_cDataSocket.m_hStopEvent = m_hStopEvent;
  1330. }
  1331. ResetEvent( m_hStopEvent );
  1333. // 设置下载数据
  1334. m_dwDownloadedSize = 0;
  1335. m_dwFileDownloadedSize = 0;
  1336. m_dwFileSize = 0;
  1337. m_dwDownloadSize = 0;
  1339. BOOL bSendOnce = TRUE; // 用于控制向hWndNotify窗口发送消息
  1341. ReDownload:
  1342. int nRequestRet = SendRequest( m_bPasv ) ;
  1344. //seawind
  1345. //if (WaitForSingleObject(m_hStopEvent, 0) == WAIT_OBJECT_0)
  1346. // return HTTP_RESULT_STOP;
  1347. Check( m_bStopDownload,FTP_RESULT_STOP);
  1349. switch(nRequestRet)
  1350. {
  1351. case FTP_REQUEST_SUCCESS:
  1352. TRACE0("nn***FTP_REQUEST_SUCCESS");
  1353. break;
  1354. case FTP_REQUEST_STOP:
  1355. TRACE0("nn***FTP_REQUEST_STOP");
  1356. return FTP_RESULT_STOP;
  1357. break;
  1358. case FTP_REQUEST_FAIL:
  1359. TRACE0("nn***FTP_REQUEST_FAIL");
  1360. return FTP_RESULT_FAIL;
  1361. break;
  1362. case FTP_REQUEST_ERROR:
  1363. TRACE0("nn***FTP_REQUEST_ERROR");
  1364. // 停止下载?
  1365. Check( m_bStopDownload,FTP_RESULT_STOP);
  1367. switch( m_nRetryType )
  1368. {
  1369. case FTP_RETRY_NONE:
  1370. return FTP_RESULT_FAIL;
  1371. break;
  1372. case FTP_RETRY_ALWAYS:
  1373. if( m_nRetryDelay > 0 )
  1374. {
  1375. //为了让等待时也能退出，不能使用Sleep函数
  1376. if( WaitForSingleObject(m_hStopEvent,m_nRetryDelay) == WAIT_OBJECT_0 )
  1377. return FTP_RESULT_STOP;
  1378. }
  1379. goto ReDownload;
  1380. break;
  1381. case FTP_RETRY_TIMES:
  1382. if( m_nRetryTimes > m_nRetryMax )
  1383. return FTP_RESULT_FAIL;
  1384. m_nRetryTimes++;
  1386. if( m_nRetryDelay > 0 )
  1387. {
  1388. //为了让等待时也能退出，不能使用Sleep函数
  1389. if( WaitForSingleObject(m_hStopEvent,m_nRetryDelay) == WAIT_OBJECT_0 )
  1390. return FTP_RESULT_STOP;
  1391. }
  1393. goto ReDownload;
  1394. break;
  1395. default:
  1396. return FTP_RESULT_FAIL;
  1397. break;
  1398. }
  1399. break;
  1400. default:
  1401. return FTP_RESULT_FAIL;
  1402. break;
  1403. }
  1406. // Now Support none content-length header
  1407. //if (m_dwDownloadSize == 0)
  1408. // return FTP_RESULT_FAIL;
  1411. if( m_strSavePath.Right(1) == '\' )
  1412. m_strSavePath += m_strFileName;
  1414. if( !m_bForceDownload ) // 非强制下载，检查Last-Modified
  1415. {
  1416. CFileStatus fileStatus;
  1417. if (CFile::GetStatus(m_strSavePath,fileStatus))
  1418. {
  1419. // 可能会存在1秒的误差
  1420. if (( fileStatus.m_mtime - m_TimeLastModified <=2 && m_TimeLastModified-fileStatus.m_mtime<=2 ) && (DWORD)fileStatus.m_size == m_dwFileSize )
  1421. return FTP_RESULT_SAMEAS;
  1422. }
  1423. }
  1424. CFile fileDown;
  1425. if(! fileDown.Open(m_strTempSavePath,CFile::modeCreate|CFile::modeNoTruncate|CFile::modeWrite|CFile::shareDenyWrite) )
  1426. {
  1427. TRACE0("nn*** FILE OPEN FAILED!");
  1428. return FTP_RESULT_FAIL;
  1429. }
  1431. // 应该判断一下是否支持断点续传
  1432. if( m_bSupportResume )
  1433. {
  1434. try
  1435. {
  1436. fileDown.SeekToEnd();
  1437. }
  1438. catch(CFileException* e)                                         
  1439. {
  1440.   e->Delete();
  1441.   return FTP_RESULT_FAIL;
  1442. }
  1443. }
  1445. if( bSendOnce && m_bNotify )
  1446. {
  1447. FTPDOWNLOADSTATUS DownloadStatus;
  1449. DownloadStatus.dwFileSize  = m_dwFileSize;
  1450. DownloadStatus.strFileName = m_strFileName;
  1451. DownloadStatus.dwFileDownloadedSize  = m_dwFileDownloadedSize;
  1453. DownloadStatus.nStatusType = FTP_STATUS_FILESIZE;
  1454. if (WaitForSingleObject(m_hStopEvent, 0) != WAIT_OBJECT_0)
  1455. ::SendMessage(m_hNotifyWnd,m_nNotifyMessage,MSG_FTPDOWNLOAD_STATUS,(LPARAM)&DownloadStatus);
  1457. DownloadStatus.nStatusType = FTP_STATUS_FILENAME;
  1458. if (WaitForSingleObject(m_hStopEvent, 0) != WAIT_OBJECT_0)
  1459. ::SendMessage(m_hNotifyWnd,m_nNotifyMessage,MSG_FTPDOWNLOAD_STATUS,(LPARAM)&DownloadStatus);
  1461. DownloadStatus.nStatusType = FTP_STATUS_FILEDOWNLOADEDSIZE;
  1462. if (WaitForSingleObject(m_hStopEvent, 0) != WAIT_OBJECT_0)
  1463. ::SendMessage(m_hNotifyWnd,m_nNotifyMessage,MSG_FTPDOWNLOAD_STATUS,(LPARAM)&DownloadStatus);
  1465. bSendOnce = FALSE;
  1466. }
  1468. m_dwDownloadedSize = 0;
  1469. // 现在开始读取数据
  1470. char szReadBuf[READ_BUFFER_SIZE+1];
  1472. /////////////////////////////////////////////
  1473. // 如果m_dwDownloadSize = 0 (说明大小未知)
  1474. if( m_dwDownloadSize == 0 )
  1475. m_dwDownloadSize = 0xFFFFFFFF;
  1476. ////////////////////////////////////////////
  1478. do
  1479. {
  1480. // 停止下载?
  1481. Check( m_bStopDownload,FTP_RESULT_STOP);
  1483. ZeroMemory(szReadBuf,READ_BUFFER_SIZE+1);
  1484. int nRet = m_cDataSocket.BSDGetData(szReadBuf,READ_BUFFER_SIZE,m_dwRecvTimeout);
  1486. //seawind
  1487. Check( m_bStopDownload, FTP_RESULT_STOP);
  1489. if (nRet <= 0)
  1490. {
  1491. ////////////////////////////////////////
  1492. if( m_dwDownloadSize == 0xFFFFFFFF )
  1493. break;
  1494. ///////////////////////////////////////
  1496. fileDown.Close();
  1497. m_nErrorCount++;
  1498. goto ReDownload; //再次发送请求
  1499. }
  1501. // 将数据写入文件
  1502. try
  1503. {
  1504. fileDown.Write(szReadBuf,nRet);
  1505. }
  1506. catch(CFileException* e)
  1507. {
  1508. e->Delete();
  1509. fileDown.Close();
  1510. goto ReDownload;
  1511. }
  1513. m_dwDownloadedSize += nRet;
  1514. m_dwFileDownloadedSize += nRet;
  1516. // 通知消息
  1517. if (m_bNotify)
  1518. {
  1519. FTPDOWNLOADSTATUS DownloadStatus;
  1520.             
  1521. DownloadStatus.nStatusType = FTP_STATUS_FILEDOWNLOADEDSIZE;
  1522. DownloadStatus.dwFileDownloadedSize = m_dwFileDownloadedSize;
  1523. DownloadStatus.dwFileSize = m_dwFileSize;
  1524. DownloadStatus.strFileName = m_strFileName;
  1526. if (WaitForSingleObject(m_hStopEvent, 0) != WAIT_OBJECT_0)
  1527. ::SendMessage(m_hNotifyWnd,m_nNotifyMessage,MSG_FTPDOWNLOAD_STATUS,(LPARAM)&DownloadStatus);
  1528. }
  1529.     } while(m_dwDownloadedSize < m_dwDownloadSize);
  1530.     
  1531. TRACE0("nn***FILE DOWNLOAD SUCCESS!");
  1533. // 关闭文件
  1534. fileDown.Close();
  1536. //关闭SOCKET
  1537. CloseControlSocket();
  1538. CloseDataSocket();
  1540. // 文件改名
  1541. //首先将已有的文件删除
  1542. ::DeleteFile(m_strSavePath);
  1543.     
  1544.     //再将新下载的文件改名
  1545. ::MoveFile(m_strTempSavePath, m_strSavePath);
  1546.     
  1547.     //再将新下载的文件的时间改回去
  1548.     CFileStatus fileStatus;
  1549.     
  1550.     fileStatus.m_size = 0;
  1551.     fileStatus.m_attribute = 0;
  1552.     
  1553.     try
  1554.     {
  1555.         CFile::GetStatus(m_strSavePath, fileStatus);
  1556.         
  1557.         fileStatus.m_mtime = m_TimeLastModified;
  1558.         CFile::SetStatus(m_strSavePath,fileStatus);
  1559.     }
  1560.     catch(CFileException *e)
  1561.     {
  1562.         e->Delete();
  1563.     }
  1564.     
  1565.     // 不再进行其他操作
  1566.     return FTP_RESULT_SUCCESS;
  1567. }
  1570. // 建立连接
  1571. int CFtpDownload::MakeConnection(CBufSocket* pBufSocket,CString strServer,int nPort,BOOL bBind /*= FALSE*/ ,LPDWORD lpdwIP /*= NULL*/,LPINT lpnPort /*= NULL*/)
  1572. {
  1573. CSocksPacket cSocks( pBufSocket );
  1574. DWORD dwIP;
  1575. BYTE byAuth,byAtyp,byCmd;
  1576. SOCKSREPPACKET pack;
  1577. CString strAuth,strAddr,strIP,strDigit;
  1579. strAuth = _T("");
  1580. strAddr = _T("");
  1582. // 检查是否为BIND命令
  1583. if( bBind && ( m_nProxyType == FTP_PROXY_SOCKS4  || 
  1584. m_nProxyType == FTP_PROXY_SOCKS4A || 
  1585. m_nProxyType == FTP_PROXY_SOCKS5 ) )
  1586. {
  1587. byCmd = CMD_BIND;
  1588. if( lpdwIP == NULL || lpnPort == NULL )
  1589. return FTP_REQUEST_ERROR;
  1590. }
  1591. else
  1592. {
  1593. bBind = FALSE;
  1594. byCmd = CMD_CONNECT;
  1595. }
  1597. switch( m_nProxyType )
  1598. {
  1599. case FTP_PROXY_NONE:
  1600. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1601. Check( !pBufSocket->Connect(strServer,nPort,m_dwConnTimeout,TRUE),FTP_REQUEST_ERROR);
  1602. break;
  1603. case FTP_PROXY_SOCKS4A:
  1604. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1605. dwIP = CBufSocket::GetIP(strServer,TRUE);
  1606. if( dwIP == INADDR_NONE )
  1607. {
  1608. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1609. Check( !pBufSocket->Connect(m_strProxyServer,m_nProxyPort,m_dwConnTimeout,TRUE),FTP_REQUEST_ERROR);
  1611. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1612. Check( !cSocks.SendSocks4aReq(byCmd,nPort,strServer,m_strProxyUsername,m_dwSendTimeout),FTP_REQUEST_ERROR);
  1613. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1615. ZeroMemory(&pack,sizeof(SOCKSREPPACKET));
  1616. Check( !cSocks.RecvPacket(&pack,PACKET_SOCKS4AREP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1617. Check( !cSocks.IsSocksOK(&pack,PACKET_SOCKS4AREP),FTP_REQUEST_FAIL);// 请求有错误，重试可能是没有用的
  1619. // 如果是BIND命令
  1620. if( bBind )
  1621. {
  1622. if( pack.socks4aRep.dwDestIP == 0 )
  1623. *lpdwIP = ntohl(CBufSocket::GetIP( m_strProxyServer ));
  1624. else
  1625. *lpdwIP = pack.socks4aRep.dwDestIP;
  1627. *lpnPort= (int)pack.socks4aRep.wDestPort;
  1628. }
  1630. break;// NOTICE:如果本地能够解析域名，可以使用SOCKS4 Proxy
  1631. }
  1632. case FTP_PROXY_SOCKS4:
  1633. // 必须要得到Proxy Server的IP地址(不能为域名)
  1634. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1635. dwIP = CBufSocket::GetIP(strServer,TRUE);
  1636. Check( dwIP == INADDR_NONE ,FTP_REQUEST_ERROR);
  1638. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1639. Check( !pBufSocket->Connect(m_strProxyServer,m_nProxyPort,m_dwConnTimeout,TRUE),FTP_REQUEST_ERROR);
  1641. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1642. Check( !cSocks.SendSocks4Req( byCmd,nPort,dwIP,m_strProxyUsername,m_dwSendTimeout),FTP_REQUEST_ERROR);
  1644. ZeroMemory(&pack,sizeof(SOCKSREPPACKET));
  1645. Check( !cSocks.RecvPacket(&pack,PACKET_SOCKS4REP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1646. Check( !cSocks.IsSocksOK(&pack,PACKET_SOCKS4REP),FTP_REQUEST_FAIL); // 请求有错误，重试可能是没有用的
  1648. // 如果是BIND命令
  1649. if( bBind )
  1650. {
  1651. if( pack.socks4Rep.dwDestIP == 0 )
  1652. *lpdwIP = ntohl(CBufSocket::GetIP( m_strProxyServer) );
  1653. else
  1654. *lpdwIP = pack.socks4Rep.dwDestIP;
  1655. *lpnPort= (int)pack.socks4Rep.wDestPort;
  1656. }
  1657. break;
  1658. case FTP_PROXY_SOCKS5:
  1660. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1661. Check( !pBufSocket->Connect(m_strProxyServer,m_nProxyPort,m_dwConnTimeout,TRUE),FTP_REQUEST_ERROR);
  1663. if( m_bProxyAuthorization )
  1664. {
  1665. char ch = (char)AUTH_NONE;
  1666. strAuth += ch;
  1667. ch  = (char)AUTH_PASSWD;
  1668. strAuth += ch;
  1669. }
  1670. else
  1671. {
  1672. char ch = (char)AUTH_NONE;
  1673. strAuth += ch;
  1674. }
  1675. byAuth =(BYTE)strAuth.GetLength();
  1677. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1678. Check( !cSocks.SendSocks5AuthReq(byAuth,(LPCTSTR)strAuth,m_dwSendTimeout),FTP_REQUEST_ERROR);
  1679. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1681. ZeroMemory(&pack,sizeof(SOCKSREPPACKET));
  1682. Check( !cSocks.RecvPacket(&pack,PACKET_SOCKS5AUTHREP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1683. Check( !cSocks.IsSocksOK(&pack,PACKET_SOCKS5AUTHREP),FTP_REQUEST_FAIL); // 请求有错误，重试可能是没有用的
  1685. switch( pack.socks5AuthRep.byAuth )
  1686. {
  1687. case AUTH_NONE:
  1688. break;
  1689. case AUTH_PASSWD:
  1691. Check( !m_bProxyAuthorization ,FTP_REQUEST_FAIL);
  1692. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1693. Check( !cSocks.SendSocks5AuthPasswdReq(m_strProxyUsername,m_strProxyPassword,m_dwSendTimeout),FTP_REQUEST_ERROR);
  1694. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1696. ZeroMemory(&pack,sizeof(SOCKSREPPACKET));
  1697. Check( !cSocks.RecvPacket(&pack,PACKET_SOCKS5AUTHPASSWDREP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1698. Check( !cSocks.IsSocksOK(&pack,PACKET_SOCKS5AUTHPASSWDREP) ,FTP_REQUEST_FAIL); // 请求有错误，重试可能是没有用的
  1699. break;
  1700. case AUTH_GSSAPI:
  1701. case AUTH_CHAP:
  1702. case AUTH_UNKNOWN:
  1703. default:
  1704. return FTP_REQUEST_FAIL;
  1705. break;
  1706. }
  1708. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1709. dwIP = CBufSocket::GetIP(strServer,TRUE);
  1710. if( dwIP != INADDR_NONE )
  1711. {
  1712. byAtyp = ATYP_IPV4ADDR;
  1713. // 不需要转换字节序(已经是网络字节序)
  1714. strAddr += (char)( (dwIP    ) &0x000000ff); 
  1715. strAddr += (char)( (dwIP>>8 ) &0x000000ff); 
  1716. strAddr += (char)( (dwIP>>16) &0x000000ff); 
  1717. strAddr += (char)( (dwIP>>24) &0x000000ff); 
  1719. }
  1720. else
  1721. {
  1722. byAtyp = ATYP_HOSTNAME;
  1723. char ch = (char)strServer.GetLength();
  1724. strAddr += ch;
  1725. strAddr += strServer;
  1726. }
  1728. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1729. Check( !cSocks.SendSocks5Req(byCmd,byAtyp,strAddr,nPort,m_dwSendTimeout),FTP_REQUEST_ERROR);
  1730. Check( m_bStopDownload,FTP_REQUEST_STOP);
  1732. ZeroMemory(&pack,sizeof(SOCKSREPPACKET));
  1733. Check( !cSocks.RecvPacket(&pack,PACKET_SOCKS5REP,m_dwRecvTimeout),FTP_REQUEST_ERROR);
  1734. Check( !cSocks.IsSocksOK(&pack,PACKET_SOCKS5REP),FTP_REQUEST_FAIL); // 请求有错误，重试可能是没有用的
  1736. // 如果是BIND命令
  1737. if( bBind )
  1738. {
  1739. Check( pack.socks5Rep.byAtyp != ATYP_IPV4ADDR,FTP_REQUEST_ERROR);
  1741. strIP  = _T("");
  1743. strDigit.Format("%d",(BYTE)pack.socks5Rep.pszBindAddr[0]);
  1744. strIP += strDigit;
  1745. strIP += ".";
  1747. strDigit.Format("%d",(BYTE)pack.socks5Rep.pszBindAddr[1]);
  1748. strIP += strDigit;
  1749. strIP += ".";
  1751. strDigit.Format("%d",(BYTE)pack.socks5Rep.pszBindAddr[2]);
  1752. strIP += strDigit;
  1753. strIP += ".";
  1755. strDigit.Format("%d",(BYTE)pack.socks5Rep.pszBindAddr[3]);
  1756. strIP += strDigit;
  1758. *lpdwIP = ntohl( inet_addr(strIP) );
  1760. if( *lpdwIP == 0 )
  1761. *lpdwIP = ntohl( CBufSocket::GetIP( m_strProxyServer ) );
  1763. *lpnPort= (int)pack.socks5Rep.wBindPort;
  1764. }
  1766. break;
  1767. default:
  1768. return FTP_REQUEST_FAIL;
  1769. break;
  1770. }
  1771. return FTP_REQUEST_SUCCESS;
  1772. }
  1774. //seawind
  1775. BOOL CFtpDownload::IsUserStop()
  1776. {
  1777. ASSERT(m_hStopEvent != NULL);
  1779. if (WaitForSingleObject(m_hStopEvent, 0) == WAIT_OBJECT_0)
  1780. return TRUE;
  1781. else
  1782. return FALSE;
  1783. }