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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Ftp客户端 > 查看源码
MyFtpClient.cpp
资源名称：FTP总集.rar　[点击查看]
上传用户：tjfeida
上传日期：2013-03-10
资源大小：1917k
文件大小：12k
源码类别：

Ftp客户端

开发平台：

Visual C++

MyFtpClient.cpp：源码内容
  1. #include "StdAfx.h"
  2. #include ".myftpclient.h"
  3. #include "MyFtpClient.h"
  4. #include "Afxsock.h"
  5. #include <stdio.h>
  6. #include <tchar.h>
  7. #include <process.h>
  8. #include "tchar.h"
  10. MyFtpClient::MyFtpClient(void)
  12. {
  14.  m_pControlRarchive=NULL;
  15.  m_pControlTarchive=NULL;
  16.  m_pControlSocketFile=NULL;
  17.  m_pControlSocket=NULL;
  18.  m_pFireWallCheck=2;
  19. }
  22. //向服务器发出命令并得到响应的函数
  23. BOOL MyFtpClient::FTPCommand(CString command)
  24. {   
  26. if(command!=""&&!WriteString(command))
  27. return FALSE;
  28. if((!(ReadString1()))||(m_pFireWallCheck!=2))
  30. return FALSE;
  32. return TRUE;
  34. }
  36. MyFtpClient::~MyFtpClient(void)
  37. {
  38. CloseControlChannel();
  39. }
  42. //上传或者下载文件
  44. BOOL MyFtpClient::MoveFile(CString RemoteFile, CString LocalFile, bool Pasv, bool GetfFile)
  45. {
  47. CString LeftServer,temp,RightServer;
  49. UINT LocalSocket,ServerSocket,i,j;
  51. CFile File_data;
  53. CSocket Socket_server;
  55. CAsyncSocket Channel_data;
  57. int Number,ReadNumber,SendNumber;
  59. const int BUFFERSIZE=4096;
  61. char CurrentBuffer[BUFFERSIZE];
  63. DWORD IpArgument=0;
  65. if(!File_data.Open(LocalFile,(GetfFile?CFile::modeWrite|CFile::modeCreate:CFile::modeRead)))
  66. {
  67.        
  68. m_strRetmsg.LoadString(58113);
  69. return FALSE;
  70. }
  72. if(!FTPCommand("TYPE I"))
  73. return FALSE;
  76. if(Pasv)
  77. {
  78. if(!FTPCommand("PASV"))
  80. return FALSE;
  82. if((i=m_strRetmsg.Find("("))==-1||(j=m_strRetmsg.Find(")")))
  83. return FALSE;
  85.            //获取IP地址，和端口号的字符段
  86. temp=m_strRetmsg.Mid(i+1,(j-i)-1);
  87. //将端口转化成整形变量
  88. //低字节
  89. i=temp.ReverseFind(',');
  90. ServerSocket=atol(temp.Right(temp.GetLength()-(i+1)));
  91. //高字节
  92. temp=temp.Left(i);
  93. i=temp.ReverseFind(',');
  94. ServerSocket+=256*atol(temp.Right(temp.GetLength()-(i+1)));
  95. //获得IP地址
  96. RightServer=temp.Left(i);
  97. while(1)
  98. {
  99. if((i=RightServer.Find(','))==-1)
  100. break;
  101. RightServer.SetAt(i,'.');
  102. }
  103. }
  105. //通过以上处理此时temp里面放的是以点分隔的ip地址
  106. else
  107. {
  108. m_strRetmsg.LoadString(106);//消息处理
  111. //获得本地的连接ip地址以及端口号信息
  113.             if(!m_pControlSocket->GetSockName(LeftServer,LocalSocket))
  114. return FALSE;
  115.             
  116.            
  117. //将本地的ip地址转化为，分隔的
  118. while(1)
  119. {
  120. if((i=LeftServer.Find('.'))==-1)
  121.    break;
  122.    LeftServer.SetAt(i,',');
  123. }
  125.  
  126. //建立连接或者侦听连接
  129. if((!Socket_server.Create(0,SOCK_STREAM,NULL))||(!Socket_server.Listen()))
  130. return FALSE;
  131.            //获得本地侦听进程的ip以及端口
  132. if(!Socket_server.GetSockName(temp,LocalSocket))
  133. return FALSE;
  134. //将端口转化为字节以点分隔
  135. LeftServer.Format(LeftServer+",%d,%d",LocalSocket/256,LocalSocket%256);
  137. if(!FTPCommand("PORT "+LeftServer))
  138. return FALSE;
  139. }
  140. //发送RETR/STOR/命令到服务器
  142. if(!WriteString((GetfFile?"RETR ":"SOTR ")+RemoteFile))
  143. return FALSE;
  144.           
  145. if(Pasv)
  146. {   
  147. if(!Channel_data.Create())
  148. {
  149.  
  150. AfxMessageBox("建立线程连接失败");
  151. m_strRetmsg.LoadString(106);
  152.                     return FALSE;
  153. }
  154. Channel_data.Connect(RightServer,ServerSocket);
  155. }
  158. if(!ReadString1()||m_pFireWallCheck!=1)
  159. return FALSE;
  161. if(!Pasv&&!Socket_server.Accept(Channel_data))
  162. return FALSE;
  163. if((!Channel_data.AsyncSelect(0))||(Channel_data.IOCtl(FIONBIO,&IpArgument)))
  164. {
  165. AfxMessageBox("建立线程连接失败");
  166. m_strRetmsg.LoadString(106);
  167. return FALSE;
  168. }
  171. while(1)
  172. {
  173. TRY
  174. {
  175. if(GetfFile)
  176. {
  177. if(!(Number=Channel_data.Receive(CurrentBuffer,BUFFERSIZE,0))||Number==SOCKET_ERROR)
  178. break;
  179. else(File_data.Write(CurrentBuffer,Number));
  180. }
  181. else
  182. {
  183. if(!(ReadNumber=File_data.Read(CurrentBuffer,BUFFERSIZE)))
  184. break;
  185. if((SendNumber=Channel_data.Send(CurrentBuffer,ReadNumber,0))==SOCKET_ERROR)
  186. break;
  188. if(ReadNumber!=SendNumber)
  189. File_data.Seek(SendNumber-ReadNumber,CFile::current);
  190. }
  191. }
  192. CATCH(CException,pEx)
  193. {
  194. m_strRetmsg.LoadString(105);
  195. return FALSE;
  196. }
  197. END_CATCH
  198. }
  200. Channel_data.Close();
  201. File_data.Close();
  202. if(!FTPCommand(""))
  203. return FALSE;
  205. return TRUE;
  206. }
  211. void MyFtpClient::LogOffServer(void)
  212. {
  214. WriteString("断开连接");
  215. CloseControlChannel();
  216. WSACleanup();
  218. }
  221. BOOL MyFtpClient::LogOntoServer(CString ServerName, int ServerPort, CString UserName, 
  222. CString PassWord, CString Accept, CString FireWallServer,
  223. CString FireWallUserName, CString FireWallPassWord, 
  224. int FireWordPort, int LogOnType)
  226. {   
  228.      
  230. int nPort,LogOnPoint=0;
  231. const int LogSuccess=-2,LogError=-1;
  232. CString buffer,temp;
  233. const int LOGONNUMBER=9;
  236. int LogonSequence[LOGONNUMBER][100] = {
  237. // 下面的数组保存了针对不同防火墙的登录序列
  238. {0,LogSuccess,3, 1,LogSuccess,6, 2,LogSuccess,LogError}, // 没有防火墙
  239. {3,6,3, 4,6,LogError, 5,LogError,9, 0,LogSuccess,12, 1,LogSuccess,15, 2,LogSuccess,LogError}, // 主机名
  240. {3,6,3, 4,6,LogError, 6,LogSuccess,9, 1,LogSuccess,12, 2,LogSuccess,LogError}, // USER 后跟主机信息的
  241. {7,3,3, 0,LogSuccess,6, 1,LogSuccess,9, 2,LogSuccess,LogError}, //有代理
  242. {3,6,3, 4,6,LogError, 0,LogSuccess,9, 1,LogSuccess,12, 2,LogSuccess,LogError}, // Transparent
  243. {6,LogSuccess,3, 1,LogSuccess,6, 2,LogSuccess,LogError}, // USER with no logon
  244. {8,6,3, 4,6,LogError, 0,LogSuccess,9, 1,LogSuccess,12, 2,LogSuccess,LogError}, //USER fireID@remotehost
  245. {9,LogError,3, 1,LogSuccess,6, 2,LogSuccess,LogError}, //USER remoteID@remotehost fireID
  246. {10,LogSuccess,3, 11,LogSuccess,6, 2,LogSuccess,LogError} // USER remoteID@fireID@remotehost
  247.                                 };
  249. if(LogOnType<0||LogOnType>=LOGONNUMBER)
  250. return  FALSE;
  251.   
  252. //没有防火墙的
  253.        if(!LogOnType)
  254.    {
  255.    temp=ServerName;
  256.    nPort=ServerPort;
  257.    }
  258.       //有防火墙的
  259.    else
  260.    {
  261.    temp=FireWallServer;
  262.    nPort=FireWordPort;
  263.    }
  264.    if(ServerPort!=21)
  265.    ServerName.Format(ServerName+":%d",ServerPort);
  266.    //打开控制通道
  267.    if(!OpenControlChannel(temp,nPort))
  268.    return false;
  269.    
  270.    //发出命令以得到服务器的响应
  271.    if(!FTPCommand(""))
  272.    return false;
  273.    
  274.    
  275.      //各种不同形式的登录
  276.    while(1)
  277.    {
  278.    switch(LogonSequence[LogOnType][LogOnPoint])
  279.    {
  280.    case 0:
  281. temp="USER "+UserName;
  282. break;
  283. case 1:
  284. temp="PASS "+PassWord;
  285. break;
  286. case 2:
  287. temp="ACCT "+Accept;
  288. break;
  289. case 3:
  290. temp="USER "+FireWallUserName;
  291. break;
  292. case 4:
  293. temp="PASS "+FireWallPassWord;
  294. break;
  295. case 5:
  296. temp="SITE "+ServerName;
  297. break;
  298. case 6:
  299. temp="USER "+UserName+"@"+ServerName;
  300. break;
  301. case 7:
  302. temp="OPEN "+ServerName;
  303. break;
  304. case 8:
  305. temp="USER "+FireWallUserName+"@"+ServerName;
  306. break;
  307. case 9:
  308. temp="USER "+UserName+"@"+ServerName+" "+FireWallUserName;
  309. break;
  310. case 10:
  311. temp="USER "+UserName+"@"+FireWallUserName+"@"+ServerName;
  312. break;
  313. case 11:
  314. temp="PASS "+PassWord+"@"+FireWallPassWord;
  315. break;
  316. }
  317.            
  318.    if(!WriteString(temp))
  319.              return FALSE;
  321.    if(!ReadString1())
  322.                return FALSE;
  323.  // AfxMessageBox("ok");
  324.  
  325.    if(m_pFireWallCheck!=2&&m_pFireWallCheck!=3)
  326.    return FALSE;
  327.    
  328.    LogOnPoint=LogonSequence[LogOnType][LogOnPoint+m_pFireWallCheck-1];
  329.    
  330.    switch(LogOnPoint)
  331.    {
  332.    case LogError:
  333.    m_strRetmsg.LoadString(108);
  334.    return FALSE;
  335.    case LogSuccess:
  336.                    return TRUE;
  337.    }
  338.    
  339.    }
  340.                             
  342. }
  345. //获得服务器的响应函数
  347. BOOL MyFtpClient::ReadString1(void)
  348. {
  349. int RetCode;
  350. if(!ReadString2())
  351. return FALSE;
  352.  
  353. if(m_strRetmsg.GetLength()<4||m_strRetmsg.GetAt(3)!='-')
  355. return TRUE;
  356.  
  358. RetCode=atol(m_strRetmsg);
  360. while(1)
  361. {
  362. if(m_strRetmsg.GetLength()>3&&(m_strRetmsg.GetAt(3)==' '&&atol(m_strRetmsg)==RetCode))
  363. return TRUE;
  364. if(!ReadString2())
  365. return FALSE;
  366. }
  367. }
  370. //写命令到服务器
  371. BOOL MyFtpClient::WriteString(CString OutPutString)
  372. {
  373. m_strRetmsg.LoadString(106);
  374. TRY
  375. {
  376. m_pControlTarchive->WriteString(OutPutString+"rn");
  377. m_pControlTarchive->Flush();
  378. }
  379. CATCH(CException,e)
  380. {  
  381. return FALSE;
  382. }
  383. END_CATCH
  384. return TRUE;
  387. }
  388. //列出文件列表
  389. BOOL MyFtpClient::List(void)
  390. {    
  391.    CString LeftServer,temp,RightServer;
  393.    UINT LocalSocket,i;
  394.    CFile File_data;
  396.    CSocket Socket_server;
  397.    CAsyncSocket Channel_data;
  399.    int Number,sum;
  400.    const int BUFFERSIZE=4096;
  401.    DWORD IpArgument=0;
  403.    m_strBuffer.RemoveAll();
  404.    m_strBuffer.SetSize(BUFFERSIZE);
  405.    
  406.    //向FTP发控制命令
  408.    if(!FTPCommand("TYPE I"))
  409.    return FALSE;
  410.    m_strRetmsg.LoadString(106);
  411.    //获得本地主机的ip及端口信息
  412.    if(!m_pControlSocket->GetSockName(LeftServer,LocalSocket))
  413.    return FALSE;
  414.   //将.转化为，
  415.    while(1)
  416.    {
  417.    if((i=LeftServer.Find('.'))==-1)
  418.    break;
  419.    LeftServer.SetAt(i,',');
  420.    }
  422.    if((!Socket_server.Create(0,SOCK_STREAM,NULL))||(!Socket_server.Listen()))
  423.    return FALSE;
  425.    if(!Socket_server.GetSockName(temp,LocalSocket))
  426.    return FALSE;
  427.    LeftServer.Format(LeftServer+",%d,%d",LocalSocket/256,LocalSocket%256);
  429.    if(!FTPCommand("PORT "+LeftServer))
  430.    return FALSE;
  431.    if(!WriteString("LIST"))
  432.    return FALSE;
  433.    if(!ReadString1())
  434.    return FALSE;
  436.    if(!Socket_server.Accept(Channel_data))
  437.    return FALSE;
  438.    if((!Channel_data.AsyncSelect(0))||(!Channel_data.IOCtl(FIONBIO,&IpArgument)))
  439.    {
  440.    m_strRetmsg.LoadString(106);
  441.    return FALSE;
  442.    }
  443.    sum=0;
  444.    while(1)
  445.    {
  446. TRY
  447.    {
  448.    if(!(Number=Channel_data.Receive(m_strBuffer.GetData()+sum,BUFFERSIZE,0))||Number==SOCKET_ERROR)
  449.    break;
  451.    TRACE("Received :%dn",Number);
  452.    Sleep(0);
  453.    sum+=Number;
  454.    m_strBuffer.SetSize(sum+BUFFERSIZE);
  455.    }
  456.    CATCH(CException,e)
  457.    {
  458.    m_strRetmsg.LoadString(105);
  460.    return FALSE;
  461.    }
  462.    END_CATCH
  463.    }
  464.    Channel_data.Close();
  465.    
  466.                  
  468. }
  472. BOOL MyFtpClient::GetLine(int& index)
  473. {
  475. m_strLine.Empty();
  476. int nBytes=m_strBuffer.GetSize();
  477. BOOL bLine=FALSE;
  478. while((bLine==FALSE)&&(index<nBytes))
  479. {
  480. char ch=(char)(m_strBuffer.GetAt(index));
  481. switch(ch)
  482. {
  483. case 'n':
  484. bLine=TRUE;
  485. break;
  486. default:
  487. m_strLine+=ch;
  488. break;
  489. }
  490. ++index;
  491. }
  492. m_strLine=m_strLine.Left(m_strLine.GetLength()-1);
  493. return bLine;
  494. }
  497. //从服务器控制通道获取一行的响应
  498. BOOL MyFtpClient::ReadString2(void)
  499. {    
  500.    
  503. if(!m_pControlRarchive->ReadString(m_strRetmsg))
  504. {
  505. m_strRetmsg.LoadString(106);
  507. return FALSE;
  508. }
  512. if(m_strRetmsg.GetLength()>0)
  513.    m_pFireWallCheck=m_strRetmsg.GetAt(0)-48;
  514.    return TRUE;
  517. }
  519. //打开控制通道
  521. BOOL MyFtpClient::OpenControlChannel(CString serverAddress, int serverPort)
  522. {  
  525. m_strRetmsg.LoadString(104);
  527. if(!(m_pControlSocket=new CSocket))
  528. return FALSE;
  529.    
  531. if(!(m_pControlSocket->Create()))
  532.      return FALSE;
  533.  
  534. m_strRetmsg.LoadString(103);
  536. if(!(m_pControlSocket->Connect(serverAddress,serverPort)))
  537. return FALSE;
  538.  
  539. m_strRetmsg.LoadString(104);
  540. if(!(m_pControlSocketFile=new CSocketFile(m_pControlSocket)))
  541. return FALSE;
  543. if(!(m_pControlRarchive=new CArchive(m_pControlSocketFile,CArchive::load)))
  544. return FALSE;
  546. if(!(m_pControlTarchive=new CArchive(m_pControlSocketFile,CArchive::store)))
  547. return FALSE;
  548. return TRUE;
  553. }
  555. void MyFtpClient::CloseControlChannel(void)
  556. {
  558. if(m_pControlTarchive)
  559. delete m_pControlTarchive;
  560. m_pControlTarchive=NULL;
  561. if(m_pControlRarchive)
  562. delete m_pControlRarchive;
  563. m_pControlRarchive=NULL;
  564. if(m_pControlSocketFile)
  565. delete m_pControlSocketFile;
  566. m_pControlSocketFile=NULL;
  567. if(m_pControlSocket)
  568. delete m_pControlSocket;
  569. m_pControlSocket=NULL;
  570. return;
  572. }