C# FTP删除文件以及文件夹

1.FTP文件操作类   FtpClient

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Net;
using System.Xml.Serialization;
using System.Threading;
using System.Data;
using System.Data.SqlClient;
using System.Xml;
using System.Xml.Linq;

namespace XMDD.NewWeb
{
    public class FtpClient
    {
        private string _ftpServerIp;
        private string _ftpRemotePath;

        public string FtpRemotePath
        {
            get { return _ftpRemotePath; }
            set 
            { 
                _ftpRemotePath = value;
                if (!string.IsNullOrWhiteSpace(_ftpRemotePath))
                    this._ftpUri = "ftp://" + _ftpServerIp + "/" + _ftpRemotePath + "/";
                else
                    this._ftpUri = "ftp://" + _ftpServerIp + "/";
            }
        }
        private string _ftpUserId;
        private string _ftpPassword;
        private string _localSavePath;
        private string _ftpUri;

        public void InitFtp(string ftpServerIp, string ftpRemotePath, string ftpUserId, string ftpPassword, string localSavePath)
        {
            this._ftpServerIp = ftpServerIp;
            this._ftpUserId = ftpUserId;
            this._ftpPassword = ftpPassword;
            this._localSavePath = localSavePath;

            FtpRemotePath = ftpRemotePath;
            if (!string.IsNullOrWhiteSpace(this._localSavePath) && !Directory.Exists(this._localSavePath))
            {
                try
                {
                    Directory.CreateDirectory(this._localSavePath);
                }
                catch { }
            }
        }

        public void InitFtp(string ftpServerIp, string ftpUserId, string ftpPassword, string localSavePath)
        {
           InitFtp(ftpServerIp,"",ftpUserId,ftpPassword,localSavePath);
        }

        /// <summary>
        /// 上传
        /// </summary>
        /// <param name="filename"></param>
        public void Upload(string filename)
        {
            FileInfo fileInf = new FileInfo(filename);
            string uri = _ftpUri + fileInf.Name;
            FtpWebRequest reqFTP;
 
            reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
            reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
            reqFTP.KeepAlive = false;
            reqFTP.Method = WebRequestMethods.Ftp.UploadFile;
            reqFTP.UseBinary = true;
            reqFTP.ContentLength = fileInf.Length;
            int buffLength = 2048;
            byte[] buff = new byte[buffLength];
            int contentLen;
            FileStream fs = null;
            try
            {
                fs = fileInf.OpenRead();
                Stream strm = reqFTP.GetRequestStream();
                contentLen = fs.Read(buff, 0, buffLength);
                while (contentLen != 0)
                {
                    strm.Write(buff, 0, contentLen);
                    contentLen = fs.Read(buff, 0, buffLength);
                }
                strm.Close();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                if(fs!=null)
                    fs.Close();
            }
        }

        public void Upload(byte[] buffer, string filename)
        {
            string uri = _ftpUri + filename;
            FtpWebRequest reqFTP;

            reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
            reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
            reqFTP.KeepAlive = false;
            reqFTP.Method = WebRequestMethods.Ftp.UploadFile;
            reqFTP.UseBinary = true;
            reqFTP.ContentLength = buffer.Length;
            try
            {
                Stream strm = reqFTP.GetRequestStream();
                strm.Write(buffer, 0, buffer.Length);
                strm.Close();
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        public void Upload(string ftpUri,string ftpUserId,string ftpPassword, string filename)
        {
            FileStream fs = null;
            try
            {
                FileInfo fileInf = new FileInfo(filename);
                string uri = ftpUri + fileInf.Name;
                FtpWebRequest reqFTP;

                reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
                reqFTP.Credentials = new NetworkCredential(ftpUserId, ftpPassword);
                reqFTP.KeepAlive = false;
                reqFTP.Method = WebRequestMethods.Ftp.UploadFile;
                reqFTP.UseBinary = true;
                reqFTP.ContentLength = fileInf.Length;
                int buffLength = 2048;
                byte[] buff = new byte[buffLength];
                int contentLen;
                fs = fileInf.OpenRead();
           
                Stream strm = reqFTP.GetRequestStream();
                contentLen = fs.Read(buff, 0, buffLength);
                while (contentLen != 0)
                {
                    strm.Write(buff, 0, contentLen);
                    contentLen = fs.Read(buff, 0, buffLength);
                }
                strm.Close();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                if (fs != null)
                    fs.Close();
            }
        }
 
        /// <summary>
        /// 下载
        /// </summary>
        /// <param name="filePath"></param>
        /// <param name="fileName"></param>
        public string Download(string fileName)
        {
            if (string.IsNullOrEmpty(fileName))
                return null;

            FtpWebRequest reqFTP;
            FileStream outputStream=null;
            FileStream fs = null;
            string content = "";
            try
            {
                outputStream = new FileStream(_localSavePath + "\" + fileName, FileMode.Create);

                reqFTP = (FtpWebRequest)WebRequest.Create(new Uri(_ftpUri + fileName));

                reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                var response = (FtpWebResponse)reqFTP.GetResponse();
                var ftpStream = response.GetResponseStream();
                var cl = response.ContentLength;
                var bufferSize = 2048;
                int readCount;
                byte[] buffer = new byte[bufferSize];
 
                readCount = ftpStream.Read(buffer, 0, bufferSize);
                while (readCount > 0)
                {
                    outputStream.Write(buffer, 0, readCount);
                    readCount = ftpStream.Read(buffer, 0, bufferSize);
                }
 
                ftpStream.Close();
                outputStream.Close();
                response.Close();
                //Buffer.Log(string.Format("Ftp文件{1}下载成功！" , DateTime.Now.ToString(), fileName));

                fs = new FileStream(_localSavePath + "\" + fileName, FileMode.Open);
                var sr = new StreamReader(fs);

                content = sr.ReadToEnd();

                sr.Close();
                fs.Close();

                Delete(fileName);
            }
            catch (Exception ex)
            {
                if (outputStream != null)
                    outputStream.Close();
                if (fs != null)
                    fs.Close();
                throw ex;
            }

            return content;

        }

        public byte[] DownloadByte(string fileName)
        {
            if (string.IsNullOrEmpty(fileName))
                return null;

            FtpWebRequest reqFTP;
            byte[] buff = null; 
            try
            {

                reqFTP = (FtpWebRequest)WebRequest.Create(new Uri(_ftpUri + fileName));

                reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                var response = (FtpWebResponse)reqFTP.GetResponse();
                var ftpStream = response.GetResponseStream();

                MemoryStream stmMemory = new MemoryStream();
                byte[] buffer = new byte[64 * 1024];
                int i;
                while ((i = ftpStream.Read(buffer, 0, buffer.Length)) > 0)
                {
                    stmMemory.Write(buffer, 0, i);
                }
                buff = stmMemory.ToArray();
                stmMemory.Close();
                ftpStream.Close();
                response.Close();
            }
            catch (Exception ex)
            {
                throw ex;
            }

            return buff;

        }

        /// <summary>
        /// 删除文件
        /// </summary>
        /// <param name="fileName"></param>
        public void Delete(string fileName)
        {
            try
            {
                string uri = _ftpUri + fileName;
                FtpWebRequest reqFTP;
                reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));

                reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                reqFTP.KeepAlive = false;
                reqFTP.Method = WebRequestMethods.Ftp.DeleteFile;
 
                string result = String.Empty;
                FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
                long size = response.ContentLength;
                Stream datastream = response.GetResponseStream();
                StreamReader sr = new StreamReader(datastream);
                result = sr.ReadToEnd();
                sr.Close();
                datastream.Close();
                response.Close();
                //Buffer.Log(string.Format("Ftp文件{1}删除成功！", DateTime.Now.ToString(), fileName));
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
 
        /// <summary>
        /// 删除文件夹（只针对空文件夹）
        /// </summary>
        /// <param name="folderName"></param>
        public void RemoveDirectory(string folderName)
        {
            try
            {
                string uri = _ftpUri + folderName;
                FtpWebRequest reqFTP;
                reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));

                reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                reqFTP.KeepAlive = false;
                reqFTP.Method = WebRequestMethods.Ftp.RemoveDirectory;
 
                string result = String.Empty;
                FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
                long size = response.ContentLength;
                Stream datastream = response.GetResponseStream();
                StreamReader sr = new StreamReader(datastream);
                result = sr.ReadToEnd();
                sr.Close();
                datastream.Close();
                response.Close();
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 删除文件夹以及其下面的所有内容
        /// </summary>
        /// <param name="ftp">ftp</param>
        public void DeleteFtpDirWithAll(FtpClient ftp)
        {
            string[] fileList = ftp.GetFileList("");//获取所有文件列表（仅文件）
            //1.首先删除所有的文件
            if (fileList != null && fileList.Length > 0)
            {
                foreach (string file in fileList)
                {
                    ftp.Delete(file);
                }
            }

            //获取所有文件夹列表（仅文件夹）
            string[] emptyDriList = ftp.GetDirectoryList();
            foreach (string dir in emptyDriList)
            {
                //有时候会出现空的子目录，这时候要排除
                if (string.IsNullOrWhiteSpace(dir))
                {
                    continue;
                }

                string curDir = "/" + dir;
                ftp.FtpRemotePath = ftp.FtpRemotePath + curDir;
                //是否有子文件夹存在
                if (ftp.GetDirectoryList() != null && ftp.GetDirectoryList().Length > 0)
                {
                    DeleteFtpDirWithAll(ftp);//如果有就继续递归
                }
                ftp.FtpRemotePath = ftp.FtpRemotePath.Replace(curDir, "");//回退到上级目录以删除其本身
                ftp.RemoveDirectory(dir);//删除当前文件夹
            }
        }

        /// <summary>
        /// 获取当前目录下明细(包含文件和文件夹)
        /// </summary>
        /// <returns></returns>
        public string[] GetFilesDetailList()
        {
            //string[] downloadFiles;
            try
            {
                StringBuilder result = new StringBuilder();
                FtpWebRequest ftp;
                ftp = (FtpWebRequest)FtpWebRequest.Create(new Uri(_ftpUri));
                ftp.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                ftp.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
                WebResponse response = ftp.GetResponse();
                StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.Default);

                //while (reader.Read() > 0)
                //{

                //}
                string line = reader.ReadLine();
                //line = reader.ReadLine();
                //line = reader.ReadLine();

                while (line != null)
                {
                    result.Append(line);
                    result.Append("
");
                    line = reader.ReadLine();
                }
                if (result.Length == 0)
                    return null;
                result.Remove(result.ToString().LastIndexOf("
"), 1);
                reader.Close();
                response.Close();
                return result.ToString().Split('
');
            }
            catch (Exception ex)
            {
                

                return null;
            }
        }
 
        /// <summary>
        /// 获取当前目录下文件列表(仅文件)
        /// </summary>
        /// <returns></returns>
        public string[] GetFileList(string mask)
        {
            string[] downloadFiles=null;
            StringBuilder result = new StringBuilder();
            FtpWebRequest reqFTP;
            try
            {
                reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(_ftpUri));
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                reqFTP.Method = WebRequestMethods.Ftp.ListDirectory;
                WebResponse response = reqFTP.GetResponse();
                StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.Default);
 
                string line = reader.ReadLine();
                while (line != null)
                {
                    if (mask.Trim() != string.Empty && mask.Trim() != "*.*")
                    {
 
                        string mask_ = mask.Substring(0, mask.IndexOf("*"));
                        if (line.Substring(0, mask_.Length) == mask_)
                        {
                            result.Append(line);
                            result.Append("
");
                        }
                    }
                    else
                    {
                        result.Append(line);
                        result.Append("
");
                    }
                    line = reader.ReadLine();
                }
                if (result.Length == 0)
                    return new string[]{};
                result.Remove(result.ToString().LastIndexOf('
'), 1);
                reader.Close();
                response.Close();
                downloadFiles= result.ToString().Split('
');
            }
            catch (Exception ex)
            {
                return new string[] { };
            }

            if (downloadFiles == null)
                downloadFiles = new string[] { };
            return downloadFiles;
        }

        public string GetSingleFile()
        {
            var list = GetFileList("*.*");

            if (list != null && list.Length > 0)
                return list[0];
            else
                return null;
        }
 
        /// <summary>
        /// 获取当前目录下所有的文件夹列表(仅文件夹)
        /// </summary>
        /// <returns></returns>
        public string[] GetDirectoryList()
        {
            string[] drectory = GetFilesDetailList();
            if (drectory == null)
                return null;
            string m = string.Empty;
            foreach (string str in drectory)
            {
                int dirPos = str.IndexOf("<DIR>");
                if (dirPos>0)
                {
                    /*判断 Windows 风格*/
                    m += str.Substring(dirPos + 5).Trim() + "
";
                }
                else if (str.Trim().Substring(0, 1).ToUpper() == "D")
                {
                    /*判断 Unix 风格*/
                    string dir = str.Substring(54).Trim();
                    if (dir != "." && dir != "..")
                    {
                        m += dir + "
"; 
                    }
                }
            }
 
            char[] n = new char[] { '
' };
            return m.Split(n);
        }
 
        /// <summary>
        /// 判断当前目录下指定的子目录是否存在
        /// </summary>
        /// <param name="RemoteDirectoryName">指定的目录名</param>
        public bool DirectoryExist(string RemoteDirectoryName)
        {
            string[] dirList = GetDirectoryList();
            if (dirList != null)
            {
                foreach (string str in dirList)
                {
                    if (str.Trim() == RemoteDirectoryName.Trim())
                    {
                        return true;
                    }
                }
            }
            return false;
        }
 
        /// <summary>
        /// 判断当前目录下指定的文件是否存在
        /// </summary>
        /// <param name="RemoteFileName">远程文件名</param>
        public bool FileExist(string RemoteFileName)
        {
            string[] fileList = GetFileList("*.*");
            foreach (string str in fileList)
            {
                if (str.Trim() == RemoteFileName.Trim())
                {
                    return true;
                }
            }
            return false;
        }
 
        /// <summary>
        /// 创建文件夹
        /// </summary>
        /// <param name="dirName"></param>
        public void MakeDir(string dirName)
        {
            FtpWebRequest reqFTP;
            try
            {
                // dirName = name of the directory to create.
                reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(_ftpUri + dirName));
                reqFTP.Method = WebRequestMethods.Ftp.MakeDirectory;
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
                Stream ftpStream = response.GetResponseStream();
 
                ftpStream.Close();
                response.Close();
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
 
        /// <summary>
        /// 获取指定文件大小
        /// </summary>
        /// <param name="filename"></param>
        /// <returns></returns>
        public long GetFileSize(string filename)
        {
            FtpWebRequest reqFTP;
            long fileSize = 0;
            try
            {
                reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(_ftpUri + filename));
                reqFTP.Method = WebRequestMethods.Ftp.GetFileSize;
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
                Stream ftpStream = response.GetResponseStream();
                fileSize = response.ContentLength;
 
                ftpStream.Close();
                response.Close();
            }
            catch (Exception ex)
            {
                //throw new Exception("FtpWeb:GetFileSize Error --> " + ex.Message);
            }
            return fileSize;
        }
 
        /// <summary>
        /// 改名
        /// </summary>
        /// <param name="currentFilename"></param>
        /// <param name="newFilename"></param>
        public void ReName(string currentFilename, string newFilename)
        {
            FtpWebRequest reqFTP;
            try
            {
                reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(_ftpUri + currentFilename));
                reqFTP.Method = WebRequestMethods.Ftp.Rename;
                reqFTP.RenameTo = newFilename;
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(_ftpUserId, _ftpPassword);
                FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
                Stream ftpStream = response.GetResponseStream();
 
                ftpStream.Close();
                response.Close();
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
 
        /// <summary>
        /// 移动文件
        /// </summary>
        /// <param name="currentFilename"></param>
        /// <param name="newFilename"></param>
        public void MovieFile(string currentFilename, string newDirectory)
        {
            ReName(currentFilename, newDirectory);
        }
 
    }
}

2.调用 DictionaryDelete

  //获取FTP配置信息
        string ftpServerIP = System.Configuration.ConfigurationManager.AppSettings["ConfigFTPAddress"].ToString();//FTP地址
        string ftpUserName = System.Configuration.ConfigurationManager.AppSettings["ConfigFTPLoginName"].ToString();//FTP登录用户名
        string ftpUserPwd = System.Configuration.ConfigurationManager.AppSettings["ConfigFTPLoginPwd"].ToString();//FTP登录密码
        string dirName = "10.6.1.140";//这个IP地址只是一个文件夹的名称

        /// <summary>
        /// 删除文件夹
        /// </summary>
        private void DictionaryDelete() 
        {        
            FtpClient ftp = new FtpClient();
            ftp.InitFtp(ftpServerIP, ftpUserName, ftpUserPwd, "");
            ftp.FtpRemotePath = dirName;
            ftp.DeleteFtpDirWithAll(ftp);
        }

        /// <summary>
        /// 创建文件夹
        /// </summary>
        private void DictionaryCreate() 
        {
            FtpClient ftp = new FtpClient();
            ftp.InitFtp(ftpServerIP, ftpUserName, ftpUserPwd, "");
            if (!ftp.DirectoryExist(dirName))
            {
                ftp.MakeDir(dirName);
            }
        }

3.说明，主要方法是  FtpClient 类中的 DeleteFtpDirWithAll 方法

删除前：

删除后：