FTP协议操作
FTP协议操作代码采用MS的FTP协议封装
using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.IO;
using System.DirectoryServices.Protocols;
namespace Vancl.FileUtility
{
public class FtpCmd
{
创建文件夹#region 创建文件夹
/**////
/// 创建文件夹:不实现级联创建
/// 返回：true成功，false失败
///
/// 基Uri字符串：如ftp://192.168.1.190:21
/// 目标目录名，相对路径：如/FTF
/// 用户名
/// 用户密码
///
public static bool CreateFtpDirectory(string BaseUriStr, string AimUriStr, string UserName, string UserPwd)
{
Uri BaseUri = new Uri(BaseUriStr);
Uri AimUri = new Uri(BaseUri, AimUriStr);
FtpWebRequest FtpRequest = (FtpWebRequest)WebRequest.Create(AimUri);
FtpRequest.KeepAlive = true;
FtpRequest.Timeout = 2000;
FtpRequest.UsePassive = false;
NetworkCredential FtpCred = new NetworkCredential(UserName, UserPwd);
CredentialCache FtpCache = new CredentialCache();
FtpCache.Add(AimUri, AuthType.Basic.ToString(), FtpCred);
FtpRequest.Credentials = FtpCache;
FtpRequest.Method = WebRequestMethods.Ftp.MakeDirectory;
try
{
FtpWebResponse FtpResponse = (FtpWebResponse)FtpRequest.GetResponse();
if (FtpResponse.StatusCode == FtpStatusCode.PathnameCreated)
{
FtpResponse.Close();
return true;
}
else
{
FtpResponse.Close();
return false;
}
}
catch (WebException e)
{
FtpWebResponse FtpResponse = (FtpWebResponse)e.Response;
if (FtpResponse.StatusCode == FtpStatusCode.ActionNotTakenFileUnavailable)
{
//文件已存在，返回True
FtpResponse.Close();
return true;
}
else
{
FtpResponse.Close();
return false;
}
}
}
/**////
/// 创建文件夹:实现级联创建
/// 返回：true成功，false失败
///
/// 基Uri字符串：如ftp://192.168.1.190:21
/// 目标目录名，相对路径：如/FTF/FTF1/FTF2/FTF3
/// 用户名
/// 用户密码
///
public static bool CreateFtpListDirectory(string BaseUriStr, string AimUriStr, string UserName, string UserPwd)
{
string[] AimUriArray = AimUriStr.TrimStart('/').Split('/');
string AimUriCache = string.Empty;
for (int i = 0; i < AimUriArray.Length; i++)
{
AimUriCache += "/" + AimUriArray;
if (CreateFtpDirectory(BaseUriStr, AimUriCache, UserName, UserPwd))
{
continue;
}
else
{
if (CreateFtpDirectory(BaseUriStr, AimUriCache, UserName, UserPwd))
{
continue;
}
else
{
return false;
}
}
}
return true;
}
#endregion
删除文件夹#region 删除文件夹
/**////
/// 删除文件夹,不实现级联删除
/// 返回：true成功，false失败
///
/// 基Uri字符串：如ftp://192.168.1.190:21
/// 目标目录，相对路径：如/FTF/FTFDEL
/// 用户名
/// 用户密码
///
public static bool DeleteFtpDirectory(string BaseUriStr, string AimUriStr, string UserName, string UserPwd)
{
Uri BaseUri = new Uri(BaseUriStr);
Uri AimUri = new Uri(BaseUri, AimUriStr);
FtpWebRequest FtpRequest = (FtpWebRequest)WebRequest.Create(AimUri);
FtpRequest.KeepAlive = true;
FtpRequest.Timeout = 2000;
FtpRequest.UsePassive = false;
NetworkCredential FtpCred = new NetworkCredential(UserName, UserPwd);
CredentialCache FtpCache = new CredentialCache();
FtpCache.Add(AimUri, AuthType.Basic.ToString(), FtpCred);
FtpRequest.Credentials = FtpCache;
FtpRequest.Method = WebRequestMethods.Ftp.RemoveDirectory;
try
{
FtpWebResponse FtpResponse = (FtpWebResponse)FtpRequest.GetResponse();
if (FtpResponse.StatusCode == FtpStatusCode.FileActionOK)
{
FtpResponse.Close();
return true;
}
else
{
FtpResponse.Close();
return false;
}
}
catch (WebException e)
{
FtpWebResponse FtpResponse = (FtpWebResponse)e.Response;
//如果返回信息表示文件不可操作或不存在，表明文件夹已经被删除
if (FtpResponse.StatusCode == FtpStatusCode.ActionNotTakenFileUnavailable)
{
FtpResponse.Close();
return true;
}
else
{
//返回其他错误：可能出现问题
FtpResponse.Close();
return false;
}
}
}
/**////
/// 删除文件夹，实现级联删除
/// 返回：true成功，false失败
///
/// 基Uri字符串：如ftp://192.168.1.190:21
/// 目标目录，相对路径：如/FTF/FTFDEL
/// 用户名
/// 用户密码
///
public static bool DeleteFtpListDirectory(string BaseUriStr, string AimUriStr, string UserName, string UserPwd)
{
List DirectoryDetailList = ListFtpDirectory(BaseUriStr, AimUriStr, UserName, UserPwd);
foreach (string ListDetail in DirectoryDetailList)
{
if (ListDetail.EndsWith("|D"))
{
//删除文件夹内容
if (ListFtpDirectory(BaseUriStr, AimUriStr + "/" + ListDetail.Split('|'), UserName, UserPwd).Count == 0)
{
if (!DeleteFtpDirectory(BaseUriStr, AimUriStr + "/" + ListDetail.Split('|'), UserName, UserPwd))
{
return false;
}
}
else
{
if (!DeleteFtpListDirectory(BaseUriStr, AimUriStr + "/" + ListDetail.Split('|'), UserName, UserPwd))
{
return false;
}
}
}
if (ListDetail.EndsWith("|F"))
{
//删除文件
if (!DeleteFtpFile(BaseUriStr, AimUriStr + "/" + ListDetail.Split('|'), UserName, UserPwd))
{
return false;
}
}
}
//删除当前文件夹
if (!DeleteFtpDirectory(BaseUriStr, AimUriStr, UserName, UserPwd))
{
return false;
}
return true;
}
#endregion
获取文件夹内文件和文件夹列表信息#region 获取文件夹内文件和文件夹列表信息
/**////
/// 获取文件夹内文件信息
///
/// 基Uri：如ftp://192.168.1.190:21
/// 目标目录，相对路径：如/FTF/FTF1
/// 用户名
/// 用户密码
///
public static List ListFtpDirectory(string BaseUriStr, string AimUriStr, string UserName, string UserPwd)
{
Uri BaseUri = new Uri(BaseUriStr);
Uri AimUri = new Uri(BaseUri, AimUriStr);
FtpWebRequest FtpRequest = (FtpWebRequest)WebRequest.Create(AimUri);
FtpRequest.KeepAlive = true;
FtpRequest.ReadWriteTimeout = 10000;
FtpRequest.UsePassive = false;
NetworkCredential FtpCred = new NetworkCredential(UserName, UserPwd);
CredentialCache FtpCache = new CredentialCache();
FtpCache.Add(AimUri, AuthType.Basic.ToString(), FtpCred);
FtpRequest.Credentials = FtpCache;
FtpRequest.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
try
{
FtpWebResponse FtpResponse = (FtpWebResponse)FtpRequest.GetResponse();
StreamReader srd = new StreamReader(FtpResponse.GetResponseStream(), Encoding.GetEncoding("GB2312"));
string ResponseBackStr = srd.ReadToEnd();
srd.Close();
FtpResponse.Close();
string[] ListDetails = ResponseBackStr.Split(new string[] { "\r\n" }, StringSplitOptions.RemoveEmptyEntries);
List RtnList = new List();
foreach (string ListDetail in ListDetails)
{
if (ListDetail.StartsWith("d") && (!ListDetail.EndsWith(".")))
{
string FtpDirName = ListDetail.Substring(ListDetail.IndexOf(':') + 3).TrimStart();
RtnList.Add(FtpDirName + "|D");
}
else if (ListDetail.StartsWith("-"))
{
string FtpDirName = ListDetail.Substring(ListDetail.IndexOf(':') + 3).TrimStart();
RtnList.Add(FtpDirName + "|F");
}
}
return RtnList;
}
catch (WebException e)
{
FtpWebResponse FtpResponse = (FtpWebResponse)e.Response;
FtpResponse.Close();
return new List();
}
}
#endregion
删除指定文件#region 删除指定文件
/**////
/// 删除指定文件
///
/// 基Uri字符串，如ftp://192.168.1.190:21
/// 目标目录，相对路径：如/FTF/FTFDEL
/// 用户名
/// 用户密码
///
public static bool DeleteFtpFile(string BaseUriStr, string AimUriStr, string UserName, string UserPwd)
{
Uri BaseUri = new Uri(BaseUriStr);
Uri AimUri = new Uri(BaseUri, AimUriStr);
FtpWebRequest FtpRequest = (FtpWebRequest)WebRequest.Create(AimUri);
FtpRequest.KeepAlive = true;
FtpRequest.Timeout = 2000;
FtpRequest.UsePassive = false;
NetworkCredential FtpCred = new NetworkCredential(UserName, UserPwd);
CredentialCache FtpCache = new CredentialCache();
FtpCache.Add(AimUri, AuthType.Basic.ToString(), FtpCred);
FtpRequest.Credentials = FtpCache;
FtpRequest.Method = WebRequestMethods.Ftp.DeleteFile;
try
{
FtpWebResponse FtpResponse = (FtpWebResponse)FtpRequest.GetResponse();
if (FtpResponse.StatusCode == FtpStatusCode.FileActionOK)
{
FtpResponse.Close();
return true;
}
else
{
FtpResponse.Close();
return false;
}
}
catch (WebException e)
{
FtpWebResponse FtpResponse = (FtpWebResponse)e.Response;
if (FtpResponse.StatusCode == FtpStatusCode.ActionNotTakenFileUnavailable)
{
FtpResponse.Close();
return true;
}
else
{
FtpResponse.Close();
return false;
}
}
}
#endregion
上传文件#region 上传文件
/**////
/// 上传文件到指定位置
///
/// 基Uri字符串，如ftp://192.168.1.190:21
/// 目标位置，相对路径：如/FTF/FTFDEL/K.pdf
/// 用户名
/// 用户密码
/// 源文件位置
///
public static bool UploadFtpFile(string BaseUriStr, string AimUriStr, string UserName, string UserPwd, string SrcFilePath)
{
Uri BaseUri = new Uri(BaseUriStr);
Uri AimUri = new Uri(BaseUri, AimUriStr);
FtpWebRequest FtpRequest = (FtpWebRequest)WebRequest.Create(AimUri);
FtpRequest.KeepAlive = true;
FtpRequest.ReadWriteTimeout = 10000;
FtpRequest.UsePassive = false;
NetworkCredential FtpCred = new NetworkCredential(UserName, UserPwd);
CredentialCache FtpCache = new CredentialCache();
FtpCache.Add(AimUri, AuthType.Basic.ToString(), FtpCred);
FtpRequest.Credentials = FtpCache;
FtpRequest.Method = WebRequestMethods.Ftp.UploadFile;
try
{
Stream stm = FtpRequest.GetRequestStream();
byte[] RequestByteArray = File.ReadAllBytes(SrcFilePath);
stm.Write(RequestByteArray, 0, RequestByteArray.Length);
stm.Close();
FtpWebResponse FtpResponse = (FtpWebResponse)FtpRequest.GetResponse();
if (FtpResponse.StatusCode == FtpStatusCode.ClosingData)
{
FtpResponse.Close();
FileInfo FI = new FileInfo(SrcFilePath);
if (GetFtpFileSize(BaseUriStr, AimUriStr, UserName, UserPwd) == FI.Length)
{
return true;
}
else
{
return false;
}
}
else
{
FtpResponse.Close();
return false;
}
}
catch (WebException e)
{
FtpWebResponse FtpResponse = (FtpWebResponse)e.Response;
FtpResponse.Close();
return false;
}
}
/**////
/// 获取文件尺寸
/// 返回文件字节数
///
/// 基Uri字符串，如ftp://192.168.1.190:21
/// 目标位置，相对路径：如/FTF/FTFDEL/K.pdf
/// 用户名
/// 用户密码
///
public static int GetFtpFileSize(string BaseUriStr, string AimUriStr, string UserName, string UserPwd)
{
Uri BaseUri = new Uri(BaseUriStr);
Uri AimUri = new Uri(BaseUri, AimUriStr);
FtpWebRequest FtpRequest = (FtpWebRequest)WebRequest.Create(AimUri);
FtpRequest.KeepAlive = true;
FtpRequest.ReadWriteTimeout = 10000;
FtpRequest.UsePassive = false;
NetworkCredential FtpCred = new NetworkCredential(UserName, UserPwd);
CredentialCache FtpCache = new CredentialCache();
FtpCache.Add(AimUri, AuthType.Basic.ToString(), FtpCred);
FtpRequest.Credentials = FtpCache;
FtpRequest.Method = WebRequestMethods.Ftp.GetFileSize;
try
{
FtpWebResponse FtpResponse = (FtpWebResponse)FtpRequest.GetResponse();
long FileSize = FtpResponse.ContentLength;
FtpResponse.Close();
return Convert.ToInt32(FileSize);
}
catch
{
return -1;
}
}
#endregion
文件重命名#region 文件重命名
/**////
/// 文件重命名、文件移动
///
/// 基Uri字符串，如ftp://192.168.1.190:21
/// 源位置，相对路径：如/FTF/FTFDEL/K.pdf
/// 目标位置，相对路径：如/FTF/FTFDEL/K.pdf
/// 用户名
/// 用户密码
///
public static bool RenameFtpFile(string BaseUriStr, string SrcUriStr, string AimUriStr, string UserName, string UserPwd)
{
Uri BaseUri = new Uri(BaseUriStr);
Uri AimUri = new Uri(BaseUri, SrcUriStr);
FtpWebRequest FtpRequest = (FtpWebRequest)WebRequest.Create(AimUri);
FtpRequest.KeepAlive = true;
FtpRequest.ReadWriteTimeout = 10000;
FtpRequest.UsePassive = false;
NetworkCredential FtpCred = new NetworkCredential(UserName, UserPwd);
CredentialCache FtpCache = new CredentialCache();
FtpCache.Add(AimUri, AuthType.Basic.ToString(), FtpCred);
FtpRequest.Credentials = FtpCache;
FtpRequest.Method = WebRequestMethods.Ftp.Rename;
FtpRequest.RenameTo = AimUriStr;
try
{
FtpWebResponse FtpResponse = (FtpWebResponse)FtpRequest.GetResponse();
if (FtpResponse.StatusCode == FtpStatusCode.FileActionOK)
{
return true;
}
else
{
return false;
}
}
catch(WebException e)
{
FtpWebResponse FtpResponse = (FtpWebResponse)e.Response;
FtpResponse.Close();
return false;
}
}
#endregion
}
}
页:
[1]