C#socket方式FTP上传下载方法集

C#socket方式FTP上传下载方法集类使用FTP myftp=new FTP（［ftp主机］,［主机目录］,［ftp用户名］,［ftp用户密码］,［ftp端口］）;myftp.Put（［本地文件全路径］）;〃上传到服务器中myftp.Get（［ftp文件名称（可以是通配符表示）］,［本地存放路径］）;〃下载到本地择自互联网csdn网站.C#codeusing System;using System.Net;using System.Net.Sockets;using System.Text;using System.10;public classFTP{private stringstrRemoteHost;private intstrRemotePort;private stringstrRemotePath;private stringstrRemoteUser;private stringstrRemotePass;private BooleanbConnected;#region内部变量///summary///服务器返回的应答信息（包含应答码）bConnected=true;//切换到目录ChDirstrRemotePath;}///summary///关闭连接////summarypublic voidDisconnect{if socketControl!=null{SendCommand，ZQUIT/Z;}CloseSocketConnect;}ftendregion^region传输模式///summary///设置传输模式////summary///param name二〃ttType”〉传输模式〈/parampublic voidSetTransferTypeTransferType ttTypeifttType==TransferType.BinarySendCommandTYPE I〃；“binary类型传输else{SendCommandCTYPE A〃;〃ASCH类型传输}if iReplyCode!=200{throw newlOException strReply.Substring4;}else{trType=ttType;}}///summary///获得传输模式////summary///〈returns〉传输模式〈/returns〉public TransferTypeGetTransferTypereturn trType;ftendregionftregion文件操作///〈summary〉///获得文件列表////summary///param name=〃strMask〃文件名的匹配字符串/param///returns/returnspublic string[]Dirstring strMask{//建立链接if IbConnected{Connect;}〃建立进行数据连接的socketSocket socketData=CreateDataSocket;〃传送命令SendCommand Z/NLST〃+strMask;〃分析应答代码if!iReplyCode==150|iReplyCode==125||iReplyCode==226{throw newlOException strReply.Substring4;〃获得结果strMsg=;while true{int iBytes=socketData.Receivebuffer,buffer.Length,0;strMsg+=ASCII.GetStringbuffer,0,iBytes;if iBytesbuffer.Length{break;}}chart]seperator={\n};string[]strsFileList=strMsg.Splitseperator;socketData.Close;〃数据socket关闭时也会有返回码if iReplyCode!=226{ReadReply;if iReplyCode!=226throw newlOExceptionstrReply.Substring4;}}return strsFileList;///获取文件大小///〈/summary〉///param name=z，strFileName〃文件名/param///〈returns〉文件大小〈/returns〉private longGetFileSize string strFileName{if IbConnected{Connect;}SendCommandz/SIZE〃+Path.GetFileNamestrFileName;long ISize=0;if iReplyCode==213{ISize=Int

64.ParsestrReply.Substring4;}else{throw newlOException strReply.Substring4;}return ISize;}///summary///〈/summary〉///param name二〃strFi leName〃待删除文件名/parampublic voidDelete stringstrFileName{if IbConnected{Connect;}SendCommand/ZDELE〃+strFileName;if iReplyCode!=250{throw newlOException strReply.Substring4;}}///summary///重命名如果新文件名与已有文件重名，将覆盖已有文件///〈/summary〉///param name二〃strOldFileName〃旧文件名/param///param name二〃strNewFileName”〉新文件名/parampublic voidRename stringstrOldFileName,string strNewFileName{if IbConnectedSendCommand/ZRNFR〃+strOldFileName;if iReplyCode!=350{throw newlOExceptionstrReply.Substring4;}//如果新文件名与原有文件重名，将覆盖原有文件SendCommand，ZRNTO〃+strNewFileName;if iReplyCode!=250{throw newlOExceptionstrReply.Substring4;}}#endregionftregion上传和下载///summary///下载一批文件///〈/summary〉///param name二〃strFileNameMask〃》文件名的匹配字符串/param///param name=〃strFolder”〉本地目录不得以、结束〈/param》public voidGet stringstrFi1eNameMask,string strFolderif IbConnectedConnect;string[]strFiles=DirstrFileNameMask;foreach stringstrFile instrFilesifIstrFile.Equals〃〃〃一般来说strFiles的最后一个元素可能是空字符串GetstrFile,strFolder,strFile;///summary///下载一个文件////summary///param name=z，strRemoteFileName〃要下载的文件名/param///param name=〃strFolder〃本地目录不得以、结束/param///param name二〃strLocalFileName”〉保存在本地时的文件名/parampublic voidGet stringstrRemoteFi1eName,string strFolder,stringstrLocalFileName{if IbConnectedSetTransferTypeTransferType.Binary;if strLocalFileName.Equals{strLocalF i1eName=strRemoteFileName;}if!File.ExistsstrLocalFileName{Stream st=File.CreatestrLocalFileName;st.Close;}FileStream output=newFileStreamstrFolder+〃\\〃+strLocalFileName,FileMode.Create;Socket socketData=CreateDataSocket;SendCommand/ZRETR〃+strRemoteFileName;if!iReplyCode二二150||iReplyCode二二125||iReplyCode二二226||iReplyCode二二250throw newlOExceptionstrReply.Substring4;}while true{int iBytes=socketData.Receivebuffer,buffer.Length,0;output.Write buffer,0,iBytes;if iBytes=0break;}}output.Close;if socketData.Connected{socketData.Close;}if!iReplyCode==226||iReplyCode==250{ReadReply;if!iReplyCode==226||iReplyCode==250{throw newlOException strReply.Substring4;///summary///上传一批文件///〈/summary///param name=〃strFolder”〉本地目录不得以、结束/param////suminaryprivate stringstrMsg;///summary///服务器返回的应答信息（包含应答码）////summaryprivate stringstrReply;///summary///服务器返回的应答码////summaryprivate intiReplyCode;///summary///进行控制连接的socket////summaryprivate Socket socketControl;///summary〃/传输模式///〈/summary〉private TransferTypetrType;///summary///传输模式:二进制类型、ASCH类型///〈/summary〉public enumTransferType///paramname二〃strFileNameMask〃文件名匹配字符可以包含*和？/parampublic voidPut stringstrFolder,stringstrFi1eNameMask{string[]strFiles=Directory.GetFiles strFolder,strFileNameMask;foreach stringstrFile instrFiles{〃strFile是完整的文件名包含路径PutstrFile;}///summary///上传一个文件////summary///param name二〃strFileName”〉本地文件名/parampublic voidPut stringstrFileName{if IbConnected{Connect;}Socket socketData=CreateDataSocket;SendCommand/ZSTOR+Path.GetFileNamestrFileName;if!iReplyCode二二125||iReplyCode二二150throw newlOExceptionstrReply.Substring4;FileStream input=newFileStreamstrFileName,FileMode.Open;int iBytes=0;while iBytes=input.Readbuffer,0,buffer.Length0{socketData.Send buffer,iBytes,0;}input.Close;if socketData.ConnectedsocketData.Close;}if!iReplyCode==226||iReplyCode==250{ReadReply;if!iReplyCode==226||iReplyCode==250{throw newlOExceptionstrReply.Substring4;ftendregionftregion目录操作///summary///创建目录////summary///param name二〃strDirName〃目录名/parampublic voidMkDirstring strDirName{ifIbConnected{Connect;}SendCommand Z/MKD〃+strDirName;if iReplyCode!=257{throw newlOException strReply.Substring4;}}///summary///删除目录///〈/summary〉///param name=strDirName”〉目录名/parampublic voidRmDirstring strDirNameif IbConnectedConnect;}SendCommand Z/RMD〃+strDirName;if iReplyCode!=250{throw newlOException strReply.Substring4;}}///summary///改变目录////summary///param name二〃strDirName〃新的工作目录名〈/parampublic voidChDirstring strDirName{if strDirName-Equals〃・〃||strDirName.Equals〃〃return;}ifIbConnectedConnect;SendCommand，ZCWD〃+strDirName;if iReplyCode!=250{throw newlOException strReply.Substring4;}this.strRemotePath=strDirName;}#endregion///summary///将一行应答字符串记录在strReply和strMsg///应答码记录在iReplyCode////summaryprivate voidReadReply{strMsg=〃〃；strReply=ReadLine;iReplyCode=Int

32.ParsestrReply.Substring0,3;}///summary///建立进行数据连接的socket////summary///〈returns〉数据连接socket〈/returnsSendCommand〃PASV〃;if iReplyCode!=227{throw newlOException strReply.Substring4;}int indexl=strReply.IndexOf C;int index2=strReply.IndexOf;string ipData=strReply.Substringindexl+1,index2-indexl-1;int[]parts=new int

[6];int len=ipData.Length;int partCount=0;string buf=〃〃；for inti=0;ilenpartCount=6;i++{char ch=Char.ParseipData.Substringi,1;if Char.IsDigit chbuf+=ch;else if ch!=,{throw newlOException^Malformed PASVstrReply:〃+strReply;}ifch=,||i+1=lentry parts[partCount++]=Int

32.Parsebuf;buf=〃〃；}catch Exception{throw newlOException^Malformed PASVstrReply:〃+strReply;}}}string ipAddress=parts

[0]+〃.〃+parts

[1]+〃.〃+parts

[2]+〃・〃+parts

[3];int port=parts

[4]8+parts

[5];Sockets=newSocketAddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp;IPEndPoint ep=newIPEndPointIPAddress.ParseipAddress,port;try s.Connect ep;catch Exceptionthrow newlOExceptionCant connectto remote server;}return s;}///summary///关闭socket连接用于登录以前///〈/summary〉private voidCloseSocketConnect{if socketControl!=null{socketControl.Close;socketControl=null;}bConnected=false;}///summary///读取Socket返回的所有字符串////summary///〈returns》包含应答码的字符串行〈/returns》while trueintiBytes=socketControl.Receive buffer,buffer.Length,0;strMsg+=ASCII.GetString buffer,0,iBytes;if iBytesbuffer.Length{break;}}chart]seperator={\n};string[]mess=strMsg.Splitseperator;if strMsg.Length2{strMsg=mess[mess.Length-2];〃seperator

[0]是10,换行符是由13和0组成的，分隔后10后面虽没有字符串，〃但也会分配为空字符串给后面也是最后一个字符串数组，〃所以最后一个mess是没用的空字符串〃但为什么不直接取mess

[0],因为只有最后一行字符串应答码与信息之间有空格}elsestrMsg=mess

[0];if!strMsg.Substring3,

1.Equals〃〃〃返回字符串正确的是以应答码如220开头，后面接一空格,再接问候字符串{return ReadLine;}return strMsg;///summary///发送命令并获取应答码和最后一行应答字符串////summary///param name二〃strComniand〉命令〈/paramprivate voidSendCommandstring strCommand{Byte[]cmdBytes=ASCII.GetBytesstrCommand+〃\r\n〃.ToCharArray;socketControl.Send cmdBytes,cmdBytes.Length,0;ReadReply;ftendregion///Binary////summaryBinary,///summary///ASCII///〈/summary〉ASCII};///summary///接收和发送数据的缓冲区////summaryprivate staticint BLOCKSIZE=3072;Byte[]buffer=new Byte[BLOCK_SIZE];///summary///编码方式///〈/summaryEncoding ASCII二Encoding.Default;ftendregionftregion内部函数^region构造函数///summary///缺省构造函数////summarystrRemoteHost=strRemotePath二;strRemoteUser=〃〃;strRemotePass=〃〃;strRemotePort=21;bConnected=false;}*////summary///构造函数////summary///param name=/zremoteHost/z/param///param name=〃remotePath〃〉〈/param///param name=〃remoteUser〃X/param///param name=z/remotePassz//param///param name=〃remotePort“〉〈/parampublic FTPstring remoteHost,string remotePath,string remoteUser,string remotePass,int remotePortstrRemoteHost=remotellost;strRemotePath=remotePath;strRemoteUser=remoteUser;strRemotePass=remotePass;strRemotePort二remotePort;Connect;}ftendregion#region登陆///summary///FTP服务器IP地址///〈/summary〉public stringRemoteHost{get{return strRemoteHost;}set{strRemoteHost=value;}}///summary///FTP服务器端口////summaryget returnstrRemotePort;}set{strRemotePort=value;}///summary///当前服务器目录///〈/summary〉public stringRemotePath{get{return strRemotePath;}set{strRemotePath=value;///sunimary///登录用户账号///〈/summary〉public stringRemoteUser{set{strRemoteUser=value;}///summary///用户登录密码///〈/summary〉public stringRemotePass{set{strRemotePass二value;}}///summary///是否登录///〈/summarygetreturn bConnected;}}ftendregion^region链接///summary///建立连接////summarypublic voidConnect{socketControl二new SocketAddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp;IPEndPoint ep=new IPEndPointIPAddress.ParseRemoteHost,strRemotePort;//链接try{socketControl.Connect ep;}catch ExceptionLhrownew lOExcepLion^Couldrf LcormecL toremoteserver;//获取应答码ReadReply;if iReplyCode!=220Disconnect;throw newlOExceptionstrReply.Substring4;}//登陆SendCommand，ZUSER〃+strRemoteUser;if!iReplyCode==331||iReplyCode==230{CloseSocketConnect;〃关闭连接throw newlOExceptionstrReply.Substring4;}if iReplyCode!=230{SendCommand，ZPASS〃+strRemotePass;if!iReplyCode==230|iReplyCode==202{CloseSocketConnect;〃关闭连接throw newlOException strReply.Substring4;。