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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 浏览器 > 查看源码
FTPDownFile.cpp
资源名称：Client.rar　[点击查看]
上传用户：szjkjd
上传日期：2022-06-27
资源大小：8968k
文件大小：23k
源码类别：

浏览器

开发平台：

Visual C++

FTPDownFile.cpp：源码内容
  1. /*! @ftpdownfile.cpp
  2. ********************************************************************************
  3. <PRE>
  4. 模块名         : FTP下载功能实现文件
  5. 文件名         : ftpdownfile.cpp
  6. 相关文件       : ftpdownfile.h
  7. 文件实现功能   : 实现文件在后头提供过FTP协议下载
  8. 作者           : 刘俊
  9. 版本           : 1.0
  10. --------------------------------------------------------------------------------
  11. 备注           : -
  12. --------------------------------------------------------------------------------
  13. 修改记录 : 
  14. 日  期          版本            修改人          修改内容 
  15. 2010/02/08      1.0             刘俊            创建
  16. </PRE>
  17. ********************************************************************************
  18. * 版权所有(c) 2010, 17JAGO, 保留所有权利
  19. *******************************************************************************/
  22. #include "StdAfx.h"
  23. #include ".ftpdownfile.h"
  25. using namespace std;
  26. // 引入winsock lib文件
  27. #pragma comment(lib,"ws2_32.lib")
  29. // 构造函数
  30. CFTPDownFile::CFTPDownFile(void)
  31. {
  32. }
  34. // 析构函数
  35. CFTPDownFile::~CFTPDownFile(void)
  36. {
  37. // 释放资源
  38. ::WSACleanup();
  39. }
  41. /*! @SetFTPinfo
  42. ********************************************************************************
  43. <PRE>
  44. 函数名   : SetFTPinfo
  45. 功能     : FTP网络信息初始化设定，包括IP,端口，用户名，密码
  46. 参数     : [IN]  pFTP_SERVER_IP : 端点服务器的IP地址
  47.    [IN]  usPort : 端点服务器FTP端口
  48.    [IN]  pUsername : 端点服务器FTP用户名
  49.    [IN]  pPwd : 端点服务器FTP密码
  50. 返回值   : 设置成功返回TRUE,失败返回FALSE
  51. 抛出异常 : -
  52. --------------------------------------------------------------------------------
  53. 备注     : 如果pUsername和pPwd都为NULL，则分别设置为匿名用户和空密码
  54. 典型用法 : -
  55. --------------------------------------------------------------------------------
  56. 作者     : 刘俊
  57. </PRE>
  58. *******************************************************************************/
  59. bool CFTPDownFile::SetFTPinfo(const char *pFTP_SERVER_IP, USHORT usPort, const char *pUsername, const char *pPwd)
  60. {
  61. // 参数检查
  62. if ((pFTP_SERVER_IP == NULL) || (0 == usPort)) 
  63. {
  64. return false;
  65. }
  66. // 删除原来的信息
  67. ZeroMemory(this->m_chFTPIP, sizeof(this->m_chFTPIP));
  68. ZeroMemory(this->m_chUserName,sizeof(this->m_chUserName));
  69. ZeroMemory(this->m_chFTPPwd, sizeof(this->m_chFTPPwd));
  71. // 写入新值
  72. strcpy(this->m_chFTPIP, pFTP_SERVER_IP);
  73. this->m_usPort = usPort;
  74. // 用户名设置
  75. if (pUsername) 
  76. {
  77. strcpy(this->m_chUserName, pUsername);
  78. }
  79. else
  80. {
  81. strcpy(this->m_chUserName, "Anonymous");
  82. }
  83. // 密码设置
  84. if (pUsername) 
  85. {
  86. strcpy(this->m_chFTPPwd, pPwd);
  87. }
  88. else
  89. {
  90. strcpy(this->m_chFTPPwd, "");
  91. }
  93. // 填充命令sockaddr_in结构
  94. this->m_sinCommand.sin_family = AF_INET;
  95. // 设定端口
  96. this->m_sinCommand.sin_port = htons(this->m_usPort);
  97. // 设定IP
  98. this->m_sinCommand.sin_addr.S_un.S_addr = inet_addr(this->m_chFTPIP);
  100. // 返回
  101. return true;
  102. }
  104. /*! @SOCKETINIT
  105. ********************************************************************************
  106. <PRE>
  107. 函数名   : SOCKETINIT
  108. 功能     : FTP网络类SOCKET版本检查初始化工作
  109. 参数     : -
  110. 返回值   : 初始化成功返回TRUE,失败返回FALSE
  111. 抛出异常 : -
  112. --------------------------------------------------------------------------------
  113. 备注     : -
  114. 典型用法 : -
  115. --------------------------------------------------------------------------------
  116. 作者     : 刘俊
  117. </PRE>
  118. *******************************************************************************/
  119. bool CFTPDownFile::SOCKETINIT()
  120. {
  121. // 定义版本号
  122. WORD wVersionRequested;
  123. // 定义WSADATA结构
  124. WSADATA wsaData;
  125. int nErr;
  127. wVersionRequested = MAKEWORD( 1, 1 );
  129. // WINSOCK初始化
  130. nErr = WSAStartup( wVersionRequested, &wsaData );
  131. if ( nErr != 0 )
  132. {
  133. return false;
  134. }
  136. // 检查版本号
  137. if ( LOBYTE( wsaData.wVersion ) != 1 || HIBYTE( wsaData.wVersion ) != 1)
  138. {
  139. return false;
  140. }
  141. //返回
  142. return true;
  143. }
  145. /*! @ConectFTPCOMMAND
  146. ********************************************************************************
  147. <PRE>
  148. 函数名   : ConectFTPCOMMAND
  149. 功能     : FTP连接命令通道
  150. 参数     : -
  151. 返回值   : 连接成功，返回TRUE，否则返回FALSE
  152. 抛出异常 : -
  153. --------------------------------------------------------------------------------
  154. 备注     : -
  155. 典型用法 : -
  156. --------------------------------------------------------------------------------
  157. 作者     : 刘俊
  158. </PRE>
  159. *******************************************************************************/
  160. bool CFTPDownFile::ConectFTPCOMMAND()
  161. {
  163. // 命令SOCKET初始化
  164. this->m_sockCOMMAND = ::socket(AF_INET, SOCK_STREAM, 0);
  165. if (this->m_sockCOMMAND == INVALID_SOCKET) 
  166. {
  167. return false;
  168. }
  169. // 进行连接
  170. if (connect(this->m_sockCOMMAND, (sockaddr*)&this->m_sinCommand, sizeof(this->m_sinCommand)) == SOCKET_ERROR) 
  171. {
  172. return false;
  173. }
  174. // 初始化接受信息BUFF
  175. ZeroMemory(this->m_chRecvFTPmessage, INTRECVMSGSIZE);
  176. // 接受FTP服务器返回的信息
  177. if (recv(this->m_sockCOMMAND, this->m_chRecvFTPmessage, INTRECVMSGSIZE, 0) < 1)
  178. {
  179. return false;
  180. }
  182. return true;
  183. }
  185. /*! @CloseCommandConect
  186. ********************************************************************************
  187. <PRE>
  188. 函数名   : CloseCommandConect
  189. 功能     : FTP命令通道关闭
  190. 参数     : -
  191. 返回值   : -
  192. 抛出异常 : -
  193. --------------------------------------------------------------------------------
  194. 备注     : -
  195. 典型用法 : -
  196. --------------------------------------------------------------------------------
  197. 作者     : 刘俊
  198. </PRE>
  199. *******************************************************************************/
  200. void CFTPDownFile::CloseCommandConect()
  201. {
  202. // 关闭命令通道SOCKET连接
  203. closesocket(this->m_sockCOMMAND);
  204. }
  206. /*! @GetFTPRecvMsg
  207. ********************************************************************************
  208. <PRE>
  209. 函数名   : GetFTPRecvMsg
  210. 功能     : 取得FTP返回的信息
  211. 参数     : -
  212. 返回值   : -FTP返回信息字符串BUF地址
  213. 抛出异常 : -
  214. --------------------------------------------------------------------------------
  215. 备注     : -
  216. 典型用法 : -
  217. --------------------------------------------------------------------------------
  218. 作者     : 刘俊
  219. </PRE>
  220. *******************************************************************************/
  221. char* CFTPDownFile::GetFTPRecvMsg()
  222. {
  223. return this->m_chRecvFTPmessage;
  224. }
  226. /*! @SendUsername
  227. ********************************************************************************
  228. <PRE>
  229. 函数名   : SendUsername
  230. 功能     : FTP命令链接发送FTP用户名
  231. 参数     : -
  232. 返回值   : 发送成功返回 >0的整数，失败返回值 =0；
  233. 抛出异常 : -
  234. --------------------------------------------------------------------------------
  235. 备注     : -
  236. 典型用法 : -
  237. --------------------------------------------------------------------------------
  238. 作者     : 刘俊
  239. </PRE>
  240. *******************************************************************************/
  241. int CFTPDownFile::SendUsername()
  242. {
  243. //存放命令的字符串
  244. char chCommand[200] = {0};
  245. int iRes = 0;
  247. // 发送FTP用户名
  248. memset(chCommand, 0, sizeof(chCommand));
  249. strcpy(chCommand, "USER ");
  250. strcat(chCommand, this->m_chUserName);
  251. strcat(chCommand, "rn");
  252. // 发送
  253. iRes = send(this->m_sockCOMMAND, chCommand, strlen(chCommand), 0);
  254. // 接受返回信息
  255. ZeroMemory(this->m_chRecvFTPmessage, INTRECVMSGSIZE);
  256. if (recv(this->m_sockCOMMAND, this->m_chRecvFTPmessage, INTRECVMSGSIZE, 0) < 1)
  257. {
  258. return 0;
  259. }
  261. return iRes;
  262. }
  264. /*! @SendPWD
  265. ********************************************************************************
  266. <PRE>
  267. 函数名   : SendPWD
  268. 功能     : FTP命令链接发送FTP用户密码
  269. 参数     : -
  270. 返回值   : 发送成功返回 >0的整数，失败返回值 =0；
  271. 抛出异常 : -
  272. --------------------------------------------------------------------------------
  273. 备注     : -
  274. 典型用法 : -
  275. --------------------------------------------------------------------------------
  276. 作者     : 刘俊
  277. </PRE>
  278. *******************************************************************************/
  279. int CFTPDownFile::SendPWD()
  280. {
  281. //存放命令的字符串
  282. char chCommand[200] = {0};
  283. int iRes = 0;
  284. // 发送密码
  285. memset(chCommand, 0, sizeof(chCommand));
  286. strcpy(chCommand, "PASS ");
  287. strcat(chCommand, this->m_chFTPPwd);
  288. strcat(chCommand, "rn");
  289. // 发送
  290. iRes = send(this->m_sockCOMMAND, chCommand, strlen(chCommand), 0);
  292. // 接受返回信息
  293. ZeroMemory(this->m_chRecvFTPmessage, INTRECVMSGSIZE);
  294. if (recv(this->m_sockCOMMAND, this->m_chRecvFTPmessage, INTRECVMSGSIZE, 0) < 1)
  295. {
  296. return 0;
  297. }
  299. return iRes;
  300. }
  302. /*! @GetFTPfilesize
  303. ********************************************************************************
  304. <PRE>
  305. 函数名   : GetFTPfilesize
  306. 功能     : 取得所要下载的文件的大小
  307. 参数     : -
  308. 返回值   : 成功返回TRUE，否则返回FALSE
  309. 抛出异常 : -
  310. --------------------------------------------------------------------------------
  311. 备注     : -
  312. 典型用法 : -
  313. --------------------------------------------------------------------------------
  314. 作者     : 刘俊
  315. </PRE>
  316. *******************************************************************************/
  317. bool CFTPDownFile::GetFTPfilesize()
  318. {
  320. //存放命令的字符串
  321. char chCommand[200] = {0};
  323. // 设置按位下载
  324. memset(chCommand, 0, sizeof(chCommand));
  325. sprintf(chCommand,"TYPE Irn");
  326. send(this->m_sockCOMMAND, chCommand, strlen(chCommand), 0);
  327. // 接受返回信息
  328. ZeroMemory(this->m_chRecvFTPmessage, INTRECVMSGSIZE);
  329. recv(this->m_sockCOMMAND, this->m_chRecvFTPmessage, INTRECVMSGSIZE, 0);
  331. // 发送获取大小命令
  332. memset(chCommand, 0, sizeof(chCommand));
  333. strcpy(chCommand, "SIZE ");
  334. strcat(chCommand, this->m_chFTPfilename);
  335. strcat(chCommand, "rn");
  336. // 发送
  337. int iRes = send(this->m_sockCOMMAND, chCommand, strlen(chCommand), 0);
  339. // 接受返回信息
  340. ZeroMemory(this->m_chRecvFTPmessage, INTRECVMSGSIZE);
  341. if (recv(this->m_sockCOMMAND, this->m_chRecvFTPmessage, INTRECVMSGSIZE, 0) < 1)
  342. {
  343. return false;
  344. }
  345. char *pchSize = NULL;
  346. pchSize = strchr(this->m_chRecvFTPmessage, ' ');
  347. pchSize++;
  348. this->m_dFTPfilesize = strtod(pchSize, NULL);
  349. // 验证取得大小是否大于0
  350. if (fabs(this->m_dFTPfilesize) < 1) 
  351. {
  352. return false;
  353. }
  354. return true;
  355. }
  357. /*! @SetFTPdownfilename
  358. ********************************************************************************
  359. <PRE>
  360. 函数名   : SetFTPdownfilename
  361. 功能     : 设置下载文件名和下载到本地的文件名，包含路径
  362. 参数     : [IN]  pchFTPfilename : 端点服务器的FTP文件路径和文件名
  363.    [IN]  pchLocalfilename : 下载到本地后的文件名，包含本地文件路径
  364. 返回值   : -
  365. 抛出异常 : -
  366. --------------------------------------------------------------------------------
  367. 备注     : pchFTPfilename是相对于FTP根目录的路径及文件名不用报还FTP:\192.168.1.100这样的地址
  368. 典型用法 : SetFTPdownfilename("test.txt", "c:\test\test.txt");
  369. --------------------------------------------------------------------------------
  370. 作者     : 刘俊
  371. </PRE>
  372. *******************************************************************************/
  373. void CFTPDownFile::SetFTPdownfilename(const char *pchFTPfilename, const char *pchLocalfilename)
  374. {
  375. // 设置FTP文件名
  376. if(!pchFTPfilename)
  377. {
  378. return;
  379. }
  380. ZeroMemory(this->m_chFTPfilename, sizeof(this->m_chFTPfilename));
  381. strcpy(this->m_chFTPfilename, pchFTPfilename);
  383. // 设置本地文件名
  384. if(!pchLocalfilename)
  385. {
  386. return;
  387. }
  388. ZeroMemory(this->m_chLocalfilename, sizeof(this->m_chLocalfilename));
  389. strcpy(this->m_chLocalfilename, pchLocalfilename);
  390. }
  392. /*! @WriteLOG
  393. ********************************************************************************
  394. <PRE>
  395. 函数名   : WriteLOG
  396. 功能     : 在程序目录生成一个log.txt,记录LOG信息
  397. 参数     : [IN]  pLog : 要打印的LOG内容
  398. 返回值   : -
  399. 抛出异常 : -
  400. --------------------------------------------------------------------------------
  401. 备注     : 
  402. 典型用法 : 
  403. --------------------------------------------------------------------------------
  404. 作者     : 刘俊
  405. </PRE>
  406. *******************************************************************************/
  407. void CFTPDownFile::WriteLOG(const char *pLog)
  408. {
  409. // 取系统当前时间
  410. CString strTime = CTime::GetCurrentTime().Format("%Y-%m-%d %H:%M:%S");
  411. // 取系统当前日期
  412. CString strDate = CTime::GetCurrentTime().Format("%Y-%m-%d");
  413. CString strLog = CString(pLog);
  414. // 记录路径用
  415. char *pchPath = new char[1024];
  416. // 取得当前路径
  417. GetCurrentDirectory(1024,pchPath);
  418. CString strPath;
  419. strPath=pchPath;
  421. strPath=strPath + "\log.txt";
  422. // 打开或创建文件
  423. CStdioFile fLog(strPath, CFile::modeCreate | CFile::modeWrite | CFile::modeNoTruncate);
  424. // 文件移到最后
  425. fLog.SeekToEnd();
  427. CString str;
  428. str += "n";
  429. str = strTime + " " + strLog + str;
  430. // 写入文件
  431. fLog.WriteString(str);
  432. // 关闭文件
  433. fLog.Close();
  435. // 释放资源
  436. strTime="";
  437. strDate="";
  438. delete [] pchPath;
  439. pchPath = NULL;
  440. strPath.Empty();
  441. strLog.Empty();
  442. }
  444. /*! @Startdown
  445. ********************************************************************************
  446. <PRE>
  447. 函数名   : Startdown
  448. 功能     : 开始下载指定的文件
  449. 参数     : [IN]  pchFTPfilename : 端点服务器的FTP文件路径和文件名
  450.    [IN]  pchLocalfilename : 下载到本地后的文件名，包含本地文件路径
  451.    [IN]  bRestart : 指定是否需要重新下载或者端点续传，TURE表示重新下载，FALSE表示断点续传
  452. 返回值   : 下载失败返回0，顺利完成下载返回1，文件已存在返回2
  453. 抛出异常 : -
  454. --------------------------------------------------------------------------------
  455. 备注     : pchFTPfilename是相对于FTP根目录的路径及文件名不用报还FTP:\192.168.1.100这样的地址
  456. 典型用法 : Startdown("test.txt", "c:\test\test.txt", false);
  457. --------------------------------------------------------------------------------
  458. 作者     : 刘俊
  459. </PRE>
  460. *******************************************************************************/
  461. short CFTPDownFile::Startdown(const char *pchFTPfilename, const char *pchLocalfilename, bool bRestart)
  462. {
  463. // 本地文件的大小
  464. double dLocalfilesize = 0.0;
  465. ULONGLONG ullLocalfilesize = 0;
  466. CFileException e;
  468. // 参数检查
  469. if(!pchFTPfilename)
  470. {
  471. return -1;
  472. }
  473. if(!pchLocalfilename)
  474. {
  475. return -1;
  476. }
  477. // 设置文件名
  478. this->SetFTPdownfilename(pchFTPfilename, pchLocalfilename);
  480. // 取得要下载文件的大小
  481. if (!this->GetFTPfilesize()) 
  482. {
  483. return 0;
  484. }
  486. // 判断文件路径是否存在,不存在的话则创建
  487. CString strLocalfilename = CString(pchLocalfilename);
  488. strLocalfilename.Replace("/", "\");
  489. this->CreatePath(strLocalfilename);
  491. // 如果重新下载
  492. if (bRestart) 
  493. {
  494. this->m_fLocalfile.Open(pchLocalfilename, CFile::modeCreate | CFile::modeWrite, &e);
  495. }
  496. // 断点续传
  497. else
  498. {
  499. this->m_fLocalfile.Open(pchLocalfilename, CFile::modeCreate | CFile::modeNoTruncate | CFile::modeWrite, &e);
  500. // 获得当地文件的大小
  501. dLocalfilesize = this->m_fLocalfile.SeekToEnd();
  502. // 如果不重新下载，且文件大小已经和服务器上医院大，则返回
  503. if (fabs(this->m_dFTPfilesize - dLocalfilesize) < 0.1) 
  504. {
  505. this->m_fLocalfile.Close();
  506. return 2;
  507. }
  508. // 如果文件大小超过FTP上的文件，则视为错误文件，重新下载
  509. else if (this->m_dFTPfilesize < dLocalfilesize) 
  510. {
  511. this->m_fLocalfile.Close();
  512. this->m_fLocalfile.Open(pchLocalfilename, CFile::modeCreate | CFile::modeWrite, &e);
  513. dLocalfilesize = 0;
  514. }
  515. else
  516. {
  517. ullLocalfilesize = dLocalfilesize;
  518. }
  520. }
  521. // 让FTP服务器进入监听状态
  522. this->SendFTPListenCommand();
  523. // 如果本地文件已有大小，且是断点续传
  524. if (1 < fabs(dLocalfilesize) && dLocalfilesize < this->m_dFTPfilesize) 
  525. {
  526. if (!bRestart) 
  527. {
  528. // 发送文件偏移指令
  529. this->SendFTPFileSeek(ullLocalfilesize);
  530. }
  531. }
  532. // 发送开始接收文件命令
  533. this->SendFTPstartsendfile();
  534. // 接收FTP文件，写入本地硬盘
  535. CWinThread *pThread = AfxBeginThread((AFX_THREADPROC)this->RevandWritefile, LPVOID(this));
  537. // 等待线程结束
  538. bool bQuit = false;
  539. while (!bQuit) 
  540. {
  541. MSG msg;
  542. int rc;
  543. // 等待下载线程结束
  544. rc = MsgWaitForMultipleObjects(1, &pThread->m_hThread, FALSE, INFINITE, QS_ALLINPUT); 
  545. if (rc == (WAIT_OBJECT_0)) 
  546. {
  547. // 下载完成，则退出
  548. break;
  549. }
  550. PeekMessage(&msg, NULL, 0, 0, PM_REMOVE);
  551. if (msg.message == WM_QUIT) 
  552. {
  553. // 停止下载
  554. this->m_bDown = false;
  555. }
  556. TranslateMessage(&msg);
  557. DispatchMessage(&msg);
  559. }
  560. // 关闭打开的文件
  561. if (this->m_fLocalfile.GetFileName() != "") 
  562. {
  563. this->m_fLocalfile.Close();
  564. }
  566. // 关闭SOCKET
  567. closesocket(this->m_sockDATA);
  568. closesocket(this->m_sockCOMMAND);
  570. return 1;
  571. }
  573. /*! @SendFTPListenCommand
  574. ********************************************************************************
  575. <PRE>
  576. 函数名   : SendFTPListenCommand
  577. 功能     : 发送FTP命令，让FTP服务器进入监听模式
  578. 参数     : -
  579. 返回值   : -
  580. 抛出异常 : -
  581. --------------------------------------------------------------------------------
  582. 备注     : 
  583. 典型用法 : 
  584. --------------------------------------------------------------------------------
  585. 作者     : 刘俊
  586. </PRE>
  587. *******************************************************************************/
  588. void CFTPDownFile::SendFTPListenCommand()
  589. {
  590. // 存放命令的字符串
  591. char chCommand[200] = {0};
  592. // 发送获取大小命令
  593. memset(chCommand, 0, sizeof(chCommand));
  594. strcpy(chCommand, "PASVrn");
  596. // 发送
  597. int iRes = send(this->m_sockCOMMAND, chCommand, strlen(chCommand), 0);
  599. // 接受返回信息
  600. ZeroMemory(this->m_chRecvFTPmessage, INTRECVMSGSIZE);
  601. recv(this->m_sockCOMMAND, this->m_chRecvFTPmessage, INTRECVMSGSIZE, 0);
  603. const char * pdir;
  604. pdir=strchr(this->m_chRecvFTPmessage,'(');
  605. pdir++;
  607. // 获取FTP服务器IP地址用
  608. union
  609. {
  610. unsigned char b[4];
  611. unsigned __int32 ui;
  612. }uip;
  613. union
  614. {
  615. unsigned char b[2];
  616. unsigned __int16 hi;
  617. }uport;
  618. unsigned __int32 u32[6];
  620. sscanf(pdir,"%u,%u,%u,%u,%u,%u",&u32[0],&u32[1],&u32[2],&u32[3],&u32[4],&u32[5],&u32[6]);
  621. uip.b[3]=(unsigned char)u32[0];
  622. uip.b[2]=(unsigned char)u32[1];
  623. uip.b[1]=(unsigned char)u32[2];
  624. uip.b[0]=(unsigned char)u32[3];
  625. uport.b[1]=(unsigned char)u32[4];
  626. uport.b[0]=(unsigned char)u32[5];
  628. // 初始化数据传输SOCKET
  629. this->m_sockDATA = socket(AF_INET,SOCK_STREAM,0);
  630. sockaddr_in myaddr;
  631. memset(&myaddr,0,sizeof(sockaddr_in));
  632. myaddr.sin_family = AF_INET;
  633. myaddr.sin_addr.S_un.S_addr = htonl(uip.ui);
  634. myaddr.sin_port = htons(uport.hi);
  636. //连接服务端
  637. iRes = 0;
  638. iRes = connect(this->m_sockDATA,(LPSOCKADDR)&myaddr,(int)sizeof(sockaddr_in));
  639. if (iRes == SOCKET_ERROR)
  640. {
  641. AfxMessageBox("建立接收数据链接失败");
  642. }
  643. }
  645. /*! @SendFTPFileSeek
  646. ********************************************************************************
  647. <PRE>
  648. 函数名   : SendFTPFileSeek
  649. 功能     : 发送文件偏移命令
  650. 参数     : [IN]  ullFilesize : 端点服务器的FTP文件偏移大小
  651. 返回值   : -
  652. 抛出异常 : -
  653. --------------------------------------------------------------------------------
  654. 备注     : -
  655. 典型用法 : -
  656. --------------------------------------------------------------------------------
  657. 作者     : 刘俊
  658. </PRE>
  659. *******************************************************************************/
  660. void CFTPDownFile::SendFTPFileSeek(ULONGLONG ullFilesize)
  661. {
  662. // 存放命令的字符串
  663. char chCommand[200] = {0};
  664. char chFilesize[100] = {0};
  666. _i64toa(ullFilesize, chFilesize, 10);
  668. // 发送获取大小命令
  669. memset(chCommand, 0, sizeof(chCommand));
  670. strcpy(chCommand, "REST ");
  671. strcat(chCommand, chFilesize);
  672. strcat(chCommand, "rn");
  674. // 发送
  675. int iRes = send(this->m_sockCOMMAND, chCommand, strlen(chCommand), 0);
  677. // 接受返回信息
  678. ZeroMemory(this->m_chRecvFTPmessage, INTRECVMSGSIZE);
  679. recv(this->m_sockCOMMAND, this->m_chRecvFTPmessage, INTRECVMSGSIZE, 0);
  680. }
  682. /*! @SendFTPstartsendfile
  683. ********************************************************************************
  684. <PRE>
  685. 函数名   : SendFTPstartsendfile
  686. 功能     : 发送开始接收文件命令
  687. 参数     : -
  688. 返回值   : -
  689. 抛出异常 : -
  690. --------------------------------------------------------------------------------
  691. 备注     : -
  692. 典型用法 : -
  693. --------------------------------------------------------------------------------
  694. 作者     : 刘俊
  695. </PRE>
  696. *******************************************************************************/
  697. void CFTPDownFile::SendFTPstartsendfile()
  698. {
  699. // 存放命令的字符串
  700. char chCommand[200] = {0};
  701. char chFilesize[100] = {0};
  704. // 发送获取大小命令
  705. memset(chCommand, 0, sizeof(chCommand));
  706. strcpy(chCommand, "RETR ");
  707. strcat(chCommand, this->m_chFTPfilename);
  708. strcat(chCommand, "rn");
  710. // 发送
  711. int iRes = send(this->m_sockCOMMAND, chCommand, strlen(chCommand), 0);
  713. // 接受返回信息
  714. ZeroMemory(this->m_chRecvFTPmessage, INTRECVMSGSIZE);
  715. recv(this->m_sockCOMMAND, this->m_chRecvFTPmessage, INTRECVMSGSIZE, 0);
  716. }
  718. /*! @RevandWritefile
  719. ********************************************************************************
  720. <PRE>
  721. 函数名   : RevandWritefile
  722. 功能     : 接收FTP文件，写入本地硬盘
  723. 参数     : [IN]  pParam : 该类的this指针
  724. 返回值   : -
  725. 抛出异常 : -
  726. --------------------------------------------------------------------------------
  727. 备注     : -
  728. 典型用法 : -
  729. --------------------------------------------------------------------------------
  730. 作者     : 刘俊
  731. </PRE>
  732. *******************************************************************************/
  733. UINT CFTPDownFile::RevandWritefile(LPVOID pParam)
  734. {
  735. // 还原this指针
  736. CFTPDownFile *pointer;  
  737. pointer   =   (CFTPDownFile*)pParam;
  739. // 设定下载缓冲区大小
  740. const int BUFFSIZE = 8*1024;
  741. char revbuf[BUFFSIZE] = {0};
  742. // 接收返回值
  743. int iresult = 0;
  744. // 设置接收状态
  745. pointer->m_bDown = true;
  746. // 接收大小初始化
  747. pointer->m_dRecv = 0;
  749. // 开始接收数据
  750. while(true)
  751. {
  752. // 重置BUFF区
  753. memset(revbuf,0,BUFFSIZE);
  754. // 重置接收返回值
  755. iresult = 0;
  756. // 接收
  757. iresult = recv(pointer->m_sockDATA , revbuf, BUFFSIZE, 0);
  758. //累加记录下载了多少字节
  759.         pointer->m_dRecv = pointer->m_dRecv + iresult;
  760. // 如果接收完毕，停止接收
  761. if(iresult == 0)
  762. {
  763. break;
  764. }
  765. // 写入文件
  766. pointer->m_fLocalfile.Write(revbuf, iresult);
  767. // 如果用户停止下载
  768. if (!pointer->m_bDown) 
  769. {
  770. // 关闭资源
  771. pointer->m_fLocalfile.Close();
  772. closesocket(pointer->m_sockDATA);
  773. closesocket(pointer->m_sockCOMMAND);
  774. break;
  775. }
  776. }
  778. return 0;
  779. }
  781. /*! @Stopdown
  782. ********************************************************************************
  783. <PRE>
  784. 函数名   : Stopdown
  785. 功能     : 停止下载
  786. 参数     : -
  787. 返回值   : -
  788. 抛出异常 : -
  789. --------------------------------------------------------------------------------
  790. 备注     : -
  791. 典型用法 : -
  792. --------------------------------------------------------------------------------
  793. 作者     : 刘俊
  794. </PRE>
  795. *******************************************************************************/
  796. void CFTPDownFile::Stopdown()
  797. {
  798. // 修改下载状态
  799. this->m_bDown = false;
  800. }
  802. // 检查文件路径是否存在，不存在的话则创建
  803. /*! @CreatePath
  804. ********************************************************************************
  805. <PRE>
  806. 函数名   : CreatePath
  807. 功能     : 检查文件路径是否存在，不存在的话则创建
  808. 参数     : [IN]  strPath : 要检查的路径
  809. 返回值   : -
  810. 抛出异常 : -
  811. --------------------------------------------------------------------------------
  812. 备注     : -
  813. 典型用法 : -
  814. --------------------------------------------------------------------------------
  815. 作者     : 刘俊
  816. </PRE>
  817. *******************************************************************************/
  818. void CFTPDownFile::CreatePath(CString strPath)
  819. {
  820. // 要检查的目录路径，从最顶级开始
  821. CString strTemp;
  822. int nPos = 1;
  823. while (nPos < strPath.GetLength()) 
  824. {
  825. nPos++;
  826. nPos = strPath.Find("\", nPos);
  828. if (-1 == nPos) 
  829. {
  830. return;
  831. }
  832. // 逐级取得路径
  833. CString strTemp = strPath.Left(nPos);
  834. // 检查是否存在该路径
  835. if (!PathFileExists(strTemp)) 
  836. {
  837. // 创建目录
  838. CreateDirectory(strTemp, NULL);
  839. }
  840. }
  841. }