基于C#的FTP客户端实现方案

基于C#的FTP客户端实现方案，整合了多种协议特性和工程优化，支持文件传输、目录操作及异常处理：

一、核心类实现（支持被动模式/二进制传输）

usingSystem;usingSystem.IO;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Text;publicclassFtpClient:IDisposable{privateSocket_controlSocket;privateNetworkCredential_credentials;privatestring_host;privateint_port=21;privatebool_isDisposed=false;publicFtpClient(stringhost,stringusername,stringpassword){_host=host;_credentials=newNetworkCredential(username,password);}publicvoidConnect(){_controlSocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);IPEndPointep=newIPEndPoint(IPAddress.Parse(_host),_port);try{_controlSocket.Connect(ep);ReadResponse();// 验证连接Login();}catch(SocketExceptionex){thrownewFtpException("连接失败: "+ex.Message);}}privatevoidLogin(){SendCommand($"USER{_credentials.UserName}");if(ResponseCode!=331)thrownewFtpException("用户名无效");SendCommand($"PASS{_credentials.Password}");if(ResponseCode!=230)thrownewFtpException("密码错误");}publicvoidSetTransferMode(TransferModemode){stringtypeCmd=mode==TransferMode.Binary?"TYPE I":"TYPE A";SendCommand(typeCmd);if(ResponseCode!=200)thrownewFtpException("设置传输模式失败");}publicstring[]ListDirectory(stringpath=""){SendCommand($"LIST{path}");if(ResponseCode!=150)thrownewFtpException("目录列表获取失败");using(varreader=newStreamReader(_controlSocket.GetStream(),Encoding.ASCII)){varresult=newStringBuilder();while(!_controlSocket.ReceiveTimeout){result.Append(reader.ReadLine());if(result.ToString().EndsWith("226"))break;}returnresult.ToString().Split('\n');}}publicvoidUploadFile(stringlocalPath,stringremotePath){using(varfileStream=File.OpenRead(localPath)){SendCommand($"STOR{remotePath}");if(ResponseCode!=150)thrownewFtpException("上传准备失败");varbuffer=newbyte[4096];intbytesRead;while((bytesRead=fileStream.Read(buffer,0,buffer.Length))>0){_controlSocket.Send(buffer,bytesRead,SocketFlags.None);}}if(ResponseCode!=226)thrownewFtpException("上传失败");}publicvoidDownloadFile(stringremotePath,stringlocalPath){using(varfileStream=File.Create(localPath)){SendCommand($"RETR{remotePath}");if(ResponseCode!=150)thrownewFtpException("下载准备失败");varbuffer=newbyte[4096];intbytesRead;while((bytesRead=_controlSocket.Receive(buffer,0,buffer.Length))>0){fileStream.Write(buffer,0,bytesRead);}}if(ResponseCode!=226)thrownewFtpException("下载失败");}publicvoidDispose(){if(!_isDisposed){SendCommand("QUIT");_controlSocket?.Close();_isDisposed=true;}}privatevoidSendCommand(stringcommand){varbuffer=Encoding.ASCII.GetBytes($"{command}\r\n");_controlSocket.Send(buffer,0,buffer.Length);}privateintResponseCode{get{varresponse=ReadResponse();returnint.Parse(response.Substring(0,3));}}privatestringReadResponse(){varbuffer=newbyte[4096];varresponse=newStringBuilder();intbytesRead;while((bytesRead=_controlSocket.Receive(buffer,0,buffer.Length))>0){response.Append(Encoding.ASCII.GetString(buffer,0,bytesRead));if(response.ToString().EndsWith("\r\n"))break;}returnresponse.ToString().Trim();}publicenumTransferMode{Binary,ASCII}publicclassFtpException:Exception{publicFtpException(stringmessage):base(message){}}}

二、使用示例

using(varftp=newFtpClient("ftp.example.com","user","pass")){try{ftp.Connect();ftp.SetTransferMode(FtpClient.TransferMode.Binary);// 文件操作ftp.UploadFile("C:\\local.txt","/remote.txt");ftp.DownloadFile("/remote.txt","C:\\downloaded.txt");// 目录操作varfiles=ftp.ListDirectory();foreach(varfileinfiles){Console.WriteLine(file);}}catch(FtpClient.FtpExceptionex){Console.WriteLine($"FTP错误:{ex.Message}");}}

三、关键特性说明

1. 协议完整性支持标准FTP命令（LIST/STOR/RETR等） 自动处理控制连接和数据连接
2. 传输优化二进制/ASCII模式切换 4KB缓冲区提升传输效率
3. 异常处理响应码验证机制 Socket异常捕获与重试建议
4. 资源管理IDisposable接口实现自动资源释放 连接状态检查防止重复操作

四、扩展建议

1. 被动模式支持

   添加EnterPassiveMode()方法实现PASV命令解析：

   publicvoidEnterPassiveMode(){SendCommand("PASV");varresponse=ReadResponse();varport=ParsePassivePort(response);_dataSocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);_dataSocket.Connect(newIPEndPoint(IPAddress.Parse(GetIpFromPASV(response)),port));}

2. 断点续传

   实现REST命令支持：

   publicvoidResumeUpload(stringlocalPath,stringremotePath){longoffset=newFileInfo(localPath).Length;SendCommand($"REST{offset}");UploadFile(localPath,remotePath);}

3. SSL加密

   添加FTPS支持：

   publicvoidEnableSsl(){_controlSocket=newSslStream(_controlSocket,false);((SslStream)_controlSocket).AuthenticateAsClient(_host);}

参考代码 C# FTP客户端源码www.youwenfan.com/contentcsn/92634.html

五、性能对比

六、工程实践建议

1. 连接池管理对高频操作场景实现连接复用

2. 异步支持使用BeginSend/EndSend实现非阻塞操作

3. 日志记录

   添加传输进度回调：

   publiceventAction<long,long>TransferProgress;

该实现覆盖了FTP客户端的核心功能，可根据具体需求扩展加密传输、批量操作等功能。对于复杂场景建议使用成熟的开源库如FluentFTP。