使用C#操作ftp服务器的示例代码
作者：我只吃饭不洗碗
这篇文章主要为大家详细介绍了使用C#操作ftp服务器的相关知识,文中的示例代码讲解详细,具有一定的借鉴价值,有需要的小伙伴可以参考下
基础类的构造函数和属性
public abstract class FtpOperation
{
/// <summary>
/// FTP服务器地址
/// </summary>
private string ftpServer;
/// <summary>
/// 用户名
/// </summary>
private string userName;
/// <summary>
/// 密码
/// </summary>
private string passWord;
/// <summary>
/// FTPHelper类的构造函数
/// </summary>
/// <param name="ftpServer">FTP服务器地址</param>
/// <param name="userName">用户名</param>
/// <param name="passWord">密码</param>
public FtpOperation(string ftpServer, string userName, string passWord)
{
this.ftpServer = ftpServer;
this.userName = userName;
this.passWord = passWord;
}
/// <summary>
/// 执行FTP操作的方法
/// </summary>
/// <param name="action">要执行的操作</param>
private void ExecuteFtpOperation(Action action)
{
try
{
action.Invoke();
}
catch (WebException ex)
{
if (ex.Status == WebExceptionStatus.Timeout)
{
Console.WriteLine("连接超时。");
}
else
{
Console.WriteLine("发生错误 WebException: {0}", ex.Message);
}
}
catch (Exception ex)
{
Console.WriteLine("发生错误: {0}", ex.Message);
}
}
}
}FtpOperation 中其他的方法
/// <summary>
/// 执行FTP操作的方法
/// </summary>
/// <param name="action">要执行的操作</param>
private void ExecuteFtpOperation(Action action)
{
try
{
action.Invoke();
}
catch (WebException ex)
{
if (ex.Status == WebExceptionStatus.Timeout)
{
Console.WriteLine("连接超时。");
}
else
{
Console.WriteLine("发生错误 WebException: { }", ex.Message);
}
}
catch (Exception ex)
{
Console.WriteLine("发生错误: { }", ex.Message);
}
}
#region 文件查询
/// <summary>
/// 递归查询FTP服务器上所有文件和目录
/// </summary>
/// <param name="ftpDirectoryPath">要查询的目录路径</param>
public virtual List<FileInfo> RecursiveQueryAll(string ftpDirectoryPath = "")
{
List<FileInfo> list = new List<FileInfo>();
ExecuteFtpOperation(() =>
{
List<FileInfo> currentList = QueryAll(ftpDirectoryPath);
list.AddRange(currentList);
foreach (var fileInfo in currentList)
{
if (fileInfo.FileType == "Folder")
{
// 如果是文件夹，递归查询
List<FileInfo> subList = RecursiveQueryAll(ftpDirectoryPath + "/" + fileInfo.FileName);
list.AddRange(subList);
}
}
});
return list;
}
/// <summary>
/// 查询FTP服务器上所有文件和目录
/// </summary>
/// <param name="ftpDirectoryPath">要查询的目录路径</param>
public virtual List<FileInfo> QueryAll(string ftpDirectoryPath = "")
{
List<FileInfo> list = new List<FileInfo>();
ExecuteFtpOperation(() =>
{
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + ftpDirectoryPath);
request.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
request.Credentials = new NetworkCredential(userName, passWord);
request.Timeout = ;
using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
{
//Console.WriteLine("状态: { }", response.StatusDescription);
using (var responseStream = response.GetResponseStream())
{
if (responseStream != null)
{
using (var reader = new StreamReader(responseStream))
{
string line = reader.ReadLine();
while (!string.IsNullOrEmpty(line))
{
list.AddRange(ParseFTPFileList(line));
line = reader.ReadLine();
}
}
}
}
}
});
return list;
}
/// <summary>
/// 解析FTP服务器返回的文件列表信息，将其转换为FileInfo对象列表
/// </summary>
/// <param name="ftpFileList">FTP服务器返回的文件列表信息</param>
/// <returns>包含文件信息的FileInfo对象列表</returns>
public virtual List<FileInfo> ParseFTPFileList(string ftpFileList)
{
// 解析FTP返回的文件列表信息并返回FileInfo对象列表
List<FileInfo> filesInfo = new List<FileInfo>();
// 按行分割FTP文件列表信息
string[] lines = ftpFileList.Split(new[] { "\r\n", "\r", "\n" }, StringSplitOptions.RemoveEmptyEntries);
foreach (string line in lines)
{
// 按空格分割行信息
string[] parts = line.Split(new[] { ' ' }, StringSplitOptions.RemoveEmptyEntries);
if (parts.Length >= )
{
string lastModifiedDateStr = parts[ ] + " " + parts[ ];
string format = "MM-dd-yy hh:mmtt"; // 指定日期时间的确切格式
DateTime lastModifiedDate;
DateTime.TryParseExact(lastModifiedDateStr, format, System.Globalization.CultureInfo.InvariantCulture, System.Globalization.DateTimeStyles.None, out lastModifiedDate);
// 提取文件大小信息
string fileSizeStr = parts[ ];
long fileSize;
string fileType = "Folder";
string fileName = string.Join(" ", parts, , parts.Length - );
if (fileSizeStr.Contains("DIR"))
{
fileSize = ;
}
else
{
fileType = Path.GetExtension(fileName);
fileSize = Convert.ToInt (fileSizeStr);
}
FileInfo fileInfo = new FileInfo(lastModifiedDate, fileSize, fileType, fileName);
filesInfo.Add(fileInfo);
}
}
return filesInfo;
}
#endregion
#region 判断FTP服务器上是否存在指定文件夹 && 在FTP服务器上创建文件夹 &&删除FTP服务器上的空文件夹
/// <summary>
/// 判断FTP服务器上是否存在指定文件夹
/// </summary>
/// <param name="directoryPath">要检查的文件夹路径</param>
/// <returns>文件夹是否存在的布尔值</returns>
public virtual bool FtpDirectoryExists(string directoryPath)
{
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + directoryPath);
request.Credentials = new NetworkCredential(userName, passWord);
request.Method = WebRequestMethods.Ftp.ListDirectory;
try
{
FtpWebResponse response = (FtpWebResponse)request.GetResponse();
response.Close();
return true;
}
catch (WebException ex)
{
FtpWebResponse response = (FtpWebResponse)ex.Response;
if (response.StatusCode == FtpStatusCode.ActionNotTakenFileUnavailable)
{
return false;
}
throw;
}
}
/// <summary>
/// 在FTP服务器上创建文件夹
/// </summary>
/// <param name="folderName">要创建的文件夹名称</param>
public virtual void FtpCreateDirectory(string folderName)
{
ExecuteFtpOperation(() =>
{
string[] pathArray = folderName.Split('/');
var tempPath = "";
foreach (var path in pathArray)
{
if (path == "")
{
continue;
}
tempPath += path + "/";
if (FtpDirectoryExists(tempPath))
{
continue;
}
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + tempPath);
request.Method = WebRequestMethods.Ftp.MakeDirectory;
request.Credentials = new NetworkCredential(userName, passWord);
using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
{
Console.WriteLine($"文件夹{path}创建成功。");
}
}
});
}
/// <summary>
/// 删除FTP服务器上的空文件夹
/// </summary>
/// <param name="ftpFolderPath">FTP服务器上的空文件夹路径</param>
public virtual void FtpDeleteFolder(string ftpFolderPath)
{
ExecuteFtpOperation(() =>
{
if (string.IsNullOrEmpty(ftpFolderPath))
{
return;
}
// 连接到 FTP 服务器
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + ftpFolderPath);
request.Credentials = new NetworkCredential(userName, passWord);
request.Method = WebRequestMethods.Ftp.RemoveDirectory;
using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
{
Console.WriteLine($"文件夹{new DirectoryInfo(ftpFolderPath).Name}删除成功！");
}
});
}
#endregion
#region 文件、文件夹删除
/// <summary>
/// 删除FTP服务器指定路径下的多个文件
/// </summary>
/// <param name="directoryPath">要删除文件的目录路径</param>
/// <param name="fileNames">要删除的文件名数组</param>
public virtual void FtpDeleteFiles(string directoryPath, string[] fileNames)
{
ExecuteFtpOperation(() =>
{
foreach (var fileName in fileNames)
{
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + directoryPath + "/" + fileName);
request.Method = WebRequestMethods.Ftp.DeleteFile;
request.Credentials = new NetworkCredential(userName, passWord);
using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
{
Console.WriteLine($"文件 '{fileName}' 删除成功。");
}
}
});
}
/// <summary>
/// 递归删除FTP服务器上的文件夹及其内容
/// </summary>
/// <param name="directoryPath">要删除的文件夹路径</param>
public virtual void FtpDeleteFolders(string directoryPath)
{
ExecuteFtpOperation(() =>
{
if (!FtpDirectoryExists(directoryPath))
{
Console.WriteLine($"{directoryPath} 不存在！");
return;
}
// 获取文件夹内所有文件和子文件夹
var fileList = QueryAll(directoryPath);
foreach (var fileInfo in fileList)
{
// 删除文件
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + directoryPath + "/" + fileInfo.FileName);
request.Method = WebRequestMethods.Ftp.DeleteFile;
request.Credentials = new NetworkCredential(userName, passWord);
// 如果是文件夹，递归删除
if (fileInfo.FileType == "Folder")
{
FtpDeleteFolders(directoryPath + "/" + fileInfo.FileName);
}
else
{
using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
{
Console.WriteLine($"文件 '{fileInfo.FileName}' 删除成功。");
}
}
}
// 删除空文件夹
FtpDeleteFolder(directoryPath);
});
}
#endregion
#region 文件移动
/// <summary>
/// 移动FTP服务器上的多个文件
/// </summary>
/// <param name="sourceDirectoryPath">源文件目录路径</param>
/// <param name="destinationDirectoryPath">目标文件目录路径</param>
/// <param name="fileNames">要移动的文件名数组</param>
public virtual void FtpMoveFiles(string sourceDirectoryPath, string destinationDirectoryPath, string[] fileNames)
{
ExecuteFtpOperation(() =>
{
if (!FtpDirectoryExists(sourceDirectoryPath))
{
Console.WriteLine($"{sourceDirectoryPath} 目录不存在！");
return;
}
if (!FtpDirectoryExists(destinationDirectoryPath))
{
FtpCreateDirectory(destinationDirectoryPath);
}
foreach (var fileName in fileNames)
{
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + sourceDirectoryPath + "/" + fileName);
request.Method = WebRequestMethods.Ftp.Rename;
request.Credentials = new NetworkCredential(userName, passWord);
request.RenameTo = destinationDirectoryPath + "/" + fileName;
using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
{
Console.WriteLine($"文件 '{fileName}' 移动成功。");
}
}
});
}
/// <summary>
/// 移动整个文件夹到目标位置
/// </summary>
/// <param name="sourceDirectoryPath">源文件夹路径</param>
/// <param name="destinationDirectoryPath">目标文件夹路径</param>
public virtual void FtpMoveFolder(string sourceDirectoryPath, string destinationDirectoryPath)
{
ExecuteFtpOperation(() =>
{
if (!FtpDirectoryExists(sourceDirectoryPath))
{
Console.WriteLine($"{sourceDirectoryPath} 目录不存在！");
return;
}
//destinationDirectoryPath = destinationDirectoryPath + "/" + new DirectoryInfo(sourceDirectoryPath).Name;//解决移动后源文件夹丢失的问题
// 创建目标文件夹
if (!FtpDirectoryExists(destinationDirectoryPath))
{
FtpCreateDirectory(destinationDirectoryPath);
}
// 获取源文件夹内所有文件和子文件夹
var fileList = QueryAll(sourceDirectoryPath);
foreach (var fileInfo in fileList)
{
// 构建源文件和目标文件的完整路径
string sourcePath = sourceDirectoryPath + "/" + fileInfo.FileName;
string destinationPath = destinationDirectoryPath + "/" + fileInfo.FileName;
// 如果是文件夹，递归移动
if (fileInfo.FileType == "Folder")
{
FtpMoveFolder(sourcePath, destinationPath);
}
else
{
// 创建源文件的FTP请求
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + sourcePath);
request.Method = WebRequestMethods.Ftp.Rename; // 使用重命名操作实现移动
request.Credentials = new NetworkCredential(userName, passWord);
request.RenameTo = destinationPath; // 设置重命名目标路径
// 发起请求并获取响应
using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
{
Console.WriteLine($"文件 '{fileInfo.FileName}' 移动成功。");
}
}
}
if (!string.IsNullOrEmpty(sourceDirectoryPath))
{
// 删除源文件夹
FtpDeleteFolder(sourceDirectoryPath);
}
});
}
#endregion
#region 文件上传【文件批量上传&&文件夹上传】
/// <summary>
/// 上传文件到FTP服务器
/// </summary>
/// <param name="filePath">要上传的文件路径</param>
/// <param name="directoryPath">目标文件夹路径</param>
public virtual void FtpUploadFile(string filePath, string directoryPath = "")
{
ExecuteFtpOperation(() =>
{
if (!FtpDirectoryExists(directoryPath))
{
FtpCreateDirectory(directoryPath);
}
using (WebClient client = new WebClient())
{
client.Credentials = new NetworkCredential(userName, passWord); ;
client.UploadFile(ftpServer + directoryPath + "/" + Path.GetFileName(filePath), WebRequestMethods.Ftp.UploadFile, filePath);
Console.WriteLine($"{filePath}文件上传成功。");
}
});
}
/// <summary>
/// 递归上传文件夹到FTP服务器
/// </summary>
/// <param name="localFolderPath">本地文件夹路径</param>
/// <param name="ftpDirectoryPath">FTP服务器目标文件夹路径</param>
public virtual void FtpUploadFolder(string localFolderPath, string ftpDirectoryPath)
{
// 检查本地文件夹是否存在
if (!Directory.Exists(localFolderPath))
{
Console.WriteLine("本地文件夹不存在。");
return;
}
// 获取文件夹名称
string folderName = new DirectoryInfo(localFolderPath).Name;
// 构建FTP服务器上的目标路径
string rootPath = (string.IsNullOrEmpty(ftpDirectoryPath) ? "" : ftpDirectoryPath + "/");
// 如果目标文件夹在FTP服务器上不存在，则创建
if (!FtpDirectoryExists(rootPath + folderName))
{
FtpCreateDirectory(rootPath + folderName);
}
// 获取文件夹中的所有文件
string[] files = Directory.GetFiles(localFolderPath);
// 逐个上传文件
foreach (string file in files)
{
FtpUploadFile(file, rootPath + folderName);
}
// 获取文件夹中的所有子文件夹
string[] subDirectories = Directory.GetDirectories(localFolderPath);
// 逐个处理子文件夹
foreach (string subDirectory in subDirectories)
{
// 递归上传子文件夹
FtpUploadFolder(subDirectory, rootPath + folderName);
}
Console.WriteLine($"{localFolderPath} 文件夹上传成功。");
}
/// <summary>
/// 上传多个文件夹到FTP服务器
/// </summary>
/// <param name="filePath">要上传的文件夹路径</param>
/// <param name="ftpDirectoryPath">目标文件夹路径</param>
public virtual void FtpUploadFolders(string[] localDirectories, string ftpDirectoryPath = "")
{
foreach (string localDirectory in localDirectories)
{
FtpUploadFolder(localDirectory, ftpDirectoryPath);
}
}
#endregion
#region 文件下载
/// <summary>
/// 从FTP服务器下载文件到本地
/// </summary>
/// <param name="remoteFilePaths">要下载的远程文件路径数组</param>
/// <param name="localDirectory">本地目录路径</param>
public virtual void FtpDownloadFile(string[] remoteFilePaths, string localDirectory)
{
ExecuteFtpOperation(() =>
{
// 检查本地路径是否存在，如果不存在则创建
if (!Directory.Exists(localDirectory))
{
Directory.CreateDirectory(localDirectory);
}
using (WebClient client = new WebClient())
{
client.Credentials = new NetworkCredential(userName, passWord);
foreach (var remoteFilePath in remoteFilePaths)
{
string fileName = remoteFilePath.Substring(remoteFilePath.LastIndexOf("/") + );
string localFilePath = Path.Combine(localDirectory, fileName);
try
{
client.DownloadFile(ftpServer + remoteFilePath, localFilePath);
Console.WriteLine($"文件 '{fileName}' 下载成功。");
}
catch (WebException ex)
{
Console.WriteLine($"下载文件 '{fileName}' 时出错: {ex.Message}");
// Handle the exception as needed
}
}
}
});
}
/// <summary>
/// 递归从FTP服务器下载文件夹到本地
/// </summary>
/// <param name="remoteDirectoryPath">要下载的远程文件夹路径</param>
/// <param name="localDirectory">本地目录路径</param>
public virtual void FtpDownloadFolder(string remoteDirectoryPath, string localDirectory)
{
ExecuteFtpOperation(() =>
{
// 检查本地路径是否存在，如果不存在则创建
if (!Directory.Exists(localDirectory))
{
Directory.CreateDirectory(localDirectory);
}
// 获取远程文件夹内所有文件和子文件夹
var fileList = QueryAll(remoteDirectoryPath);
foreach (var fileInfo in fileList)
{
string remotePath = remoteDirectoryPath + "/" + fileInfo.FileName;
string localPath = Path.Combine(localDirectory, fileInfo.FileName);
if (fileInfo.FileType == "Folder")
{
// 如果是文件夹，递归下载
string newLocalDirectory = Path.Combine(localDirectory, fileInfo.FileName);
Directory.CreateDirectory(newLocalDirectory);
FtpDownloadFolder(remotePath, newLocalDirectory);
}
else
{
// 如果是文件，下载到本地
using (WebClient client = new WebClient())
{
client.Credentials = new NetworkCredential(userName, passWord);
client.DownloadFile(ftpServer + remotePath, localPath);
Console.WriteLine($"文件 '{fileInfo.FileName}' 下载成功。");
}
}
}
});
}
#endregion
调用示例
// FTP 服务器地址
string ftpServer = "ftp://127.0.0.1:27/";
// FTP 服务器用户名
string userName = "Administrator";
// FTP 服务器密码
string password = "admin";
FtpTest ftp = new FtpTest(ftpServer, userName, password);
//ftp.QueryAll("/Template"); //查询
ftp.FtpDeleteFolders("");//删除所有
ftp.FtpUploadFolder("e:\\CoaTemplate", "");//将文件夹的内容上传到根目录
ftp.FtpUploadFolder(@"D:\GitCode\Blog.Core", "/gitCode/Blog.Core");//将本地文件夹的内容上传到指定目录
var data = ftp.RecursiveQueryAll("");//查询所有文件信息
ftp.FtpMoveFolder("/CoaTemplate", "/1/CoaTemplate");//文件夹移动
ftp.FtpDownloadFolder("/1", "d:\\1\\"); //将ftp服务器的指定文件夹下载到本地目录项目地址：https://github.com/yycb1994/FtpSiteManager
以上就是使用C#操作ftp服务器的示例代码的详细内容，更多关于C#操作ftp服务器的资料请关注脚本之家其它相关文章！