本教程深入讲解如何使用C#语言搭建和操作FTP服务器，涵盖协议基础、代码实现及安全配置等内容。
```csharp
using System;
using System.Net.Sockets;
using System.IO;
namespace CustomFTPClientServer
{
public class FTPHandler
{
private void AddInfo(string message)
{
// Method to add information logs (implementation details not shown here).
}
#region Command Handlers
// 处理LIST命令，列出目录和文件列表。
public void HandleListCommand(User user)
{
string sendString = ;
foreach (string file in Directory.GetFiles(user.currentDirectory))
sendString += FILE + Path.GetFileName(file) + \n;
foreach (string dir in Directory.GetDirectories(user.currentDirectory))
sendString += DIR + Path.GetFileName(dir) + \n;
SendByUserSession(user, sendString);
}
// 处理RETR命令，用于下载文件。
public void HandleRetrCommand(User user)
{
string filePath = Path.Combine(user.currentDirectory, user.requestedFileName);
if (File.Exists(filePath))
SendFileByUserSession(user, new FileStream(filePath, FileMode.Open));
else
// 处理错误情况：请求的文件不存在。
RepleyErrorToUser(user);
}
// 处理STOR命令，用于上传文件到服务器。
public void HandleStorCommand(User user)
{
string filePath = Path.Combine(user.currentDirectory, user.requestedFileName);
ReadFileByUserSession(user, new FileStream(filePath, FileMode.Create));
}
#endregion
private void RepleyErrorToUser(User user)
{
// 方法用于向用户发送错误信息。
AddInfo(向用户发送错误：[...]);
try
{
string errorMessage = 500 Error: Requested file does not exist.;
user.dataSession.streamWriter.WriteLine(errorMessage);
AddInfo(发送完毕);
}
finally
{
user.dataSession.Close();
}
}
#region Data Session Management
// 初始化数据连接。
private void InitDataSession(User user)
{
TcpClient client = null;
if (user.isPassive)
{
AddInfo(采用被动模式返回LIST目录和文件列表);
client = user.dataListener.AcceptTcpClient();
}
else
{
AddInfo(采用主动模式向用户发送LIST目录和文件列表);
client = new TcpClient();
client.Connect(user.remoteEndPoint);
}
user.dataSession = new UserSeesion(client);
}
// 使用数据连接发送字符串。
private void SendByUserSession(User user, string sendString)
{
AddInfo(向用户发送(字符串信息)：[ + sendString + ]);
try
{
user.dataSession.streamWriter.WriteLine(sendString);
AddInfo(发送完毕);
}
finally
{
user.dataSession.Close();
}
}
// 使用数据连接发送文件流（客户端请求下载文件时）。
private void SendFileByUserSession(User user, FileStream fs)
{
AddInfo(向用户发送(文件流)：[...]);
try
{
if (user.isBinary)
{
byte[] bytes = new byte[1024];
BinaryReader binaryReader = new BinaryReader(fs);
int count;
while ((count = binaryReader.Read(bytes, 0, bytes.Length)) > 0)
user.dataSession.binaryWriter.Write(bytes, 0, count);
}
else
{
StreamReader streamReader = new StreamReader(fs);
string line;
while ((line = streamReader.ReadLine()) != null)
user.dataSession.streamWriter.WriteLine(line);
}
AddInfo(...]发送完毕！);
}
finally
{
user.dataSession.Close();
fs.Close();
}
}
// 使用数据连接接收文件流（客户端请求上传文件时）。
private void ReadFileByUserSession(User user, FileStream fs)
{
AddInfo(接收用户上传数据（文件流）：[...]);
try
{
if (user.isBinary)
{
byte[] bytes = new byte[1024];
while (user.dataSession.binaryReader.Read(bytes, 0, bytes.Length) > 0)
fs.Write(bytes, 0, user.dataSession.binaryReader.ReadCount);
}
else
{
StreamWriter streamWriter = new StreamWriter(fs);
string line;
while ((line = user.dataSession.streamReader.ReadLine()) != null)
streamWriter.WriteLine(line);
streamWriter.Flush();
}
AddInfo(...]接收完毕);
}
finally
{
user.dataSession.Close();
fs.Close();
}
}
#endregion
}
}
```
5星
