FTP操作类

  /// </summary>
    public class FTPTransmission
    {
        #region 上传文件到FTP服务器
        /// <summary>
        /// 上传文件到FTP服务器
        /// </summary>
        /// <param name="strPath"></param>
        /// <param name="strUser"></param>
        /// <param name="strPass"></param>
        /// <param name="strServerIP"></param>
        /// <returns></returns>
        public void UploadFileToFTP(string localFile, string ftpFile, string strUser, string strPass, string strServerIP)
        {
            try
            {
                FileInfo FInfo = new FileInfo(localFile);

                FtpWebRequest request = (FtpWebRequest)WebRequest.Create("ftp://" + strServerIP + "/" + ftpFile);

                request.Method = WebRequestMethods.Ftp.UploadFile;

                request.Credentials = new NetworkCredential(strUser, strPass);

                request.ContentLength = FInfo.Length;

                // 缓冲大小设置为2kb=======[网上评论：]缓冲的大小为2kb，无论上传大文件还是小文件，这都是一个合适的大小。
                int buffLength = 2048;

                byte[] buff = new byte[buffLength];

                int contentLen;

                // 打开一个文件流 (System.IO.FileStream) 去读上传的文件
                FileStream fs = FInfo.OpenRead();

                // 把上传的文件写入流
                Stream strm = request.GetRequestStream();

                // 每次读文件流的2kb
                contentLen = fs.Read(buff, 0, buffLength);

                // 流内容没有结束
                while (contentLen != 0)
                {
                    // 把内容从file stream 写入 upload stream
                    strm.Write(buff, 0, contentLen);

                    contentLen = fs.Read(buff, 0, buffLength);
                }

                // 关闭两个流
                strm.Close();
                fs.Close();

            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion

        #region 从FTP服务器上下载文件
        /// <summary>
        /// 从FTP服务器上下载文件
        /// </summary>
        /// <param name="localFile"></param>
        /// <param name="ftpFile">FTP上的文件路径</param>
        /// <param name="ftpUserID"></param>
        /// <param name="ftpPassword"></param>
        /// <param name="ftpServerIP"></param>
        /// <returns></returns>
        public void DownloadFileFromFTP(string localFile, string ftpFile, string ftpUserID, string ftpPassword, string ftpServerIP)
        {
            try
            {
                //如果文件夹不存在,则创建文件夹
                CreateNotExistsFolder(localFile);

                FileStream outputStream = new FileStream(localFile, FileMode.Create);

                FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" + ftpFile));

                reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;

                reqFTP.UseBinary = true;

                reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);

                FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();

                Stream ftpStream = response.GetResponseStream();

                long cl = response.ContentLength;

                int 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();

            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion

        #region 创建文件夹
        /// <summary>
        /// CreateNotExistsFolder
        /// </summary>
        /// <param name="strPathName">完全路径包括文件名</param>
        public void CreateNotExistsFolder(string strPathName)
        {
            FileInfo FInfo = new FileInfo(strPathName);
            //如果文件夹不存在,则创建文件夹
            if (!Directory.Exists(FInfo.DirectoryName))
                Directory.CreateDirectory(FInfo.DirectoryName);
        }
        #endregion

        #region 获得FTP目录下符合要求的文件列表
        /// <summary>
        /// GetFileList
        /// <param name="strFile">FTP目标文件夹[根目录下则传入“”]</param>
        /// <param name="strUser">用户名</param>
        /// <param name="strPasswd">密码</param>
        /// <param name="strSeverIP">FTP服务器IP</param>
        /// <param name="strRemark">FTP的目标文件名（模糊查询；例如：找.lok后缀的文件，则输入参数为“.lok”）</param>
        /// <returns>返回找到的文件名称列表[含.lok]，没有找到则返回“”</returns>
        /// </summary>
        /// <param name="strSubPath"></param>
        /// <param name="strUser"></param>
        /// <param name="strPasswd"></param>
        /// <param name="strSeverIP"></param>
        /// <param name="strRemark"></param>
        /// <returns></returns>
        public Dictionary<object, string> GetFileList(string strSubPath, string strUser, string strPasswd, string strSeverIP, string strRemark)
        {
            Dictionary<object, string> dict = new Dictionary<object, string>();
            string strPath = string.Empty;
            if (strSubPath.Trim().Equals(string.Empty)) strPath = "ftp://" + strSeverIP + "/";
            else strPath = "ftp://" + strSeverIP + "/" + strSubPath + "/";
            try
            {
                FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(strPath));
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(strUser, strPasswd);
                reqFTP.Method = WebRequestMethods.Ftp.ListDirectory;
                WebResponse response = reqFTP.GetResponse();
                StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.Default, true);
                string strline = string.Empty;

                for (int i = 0; (strline = reader.ReadLine()) != null; i++)
                {
                    //strline = reader.ReadLine();
                    //if (line == null) continue;
                    //if (line.Contains(strRemark))
                    //{
                    //    reader.Close();
                    //    response.Close();
                    //    return line;
                    //}
                    if (strline.ToUpper().Contains(strRemark.ToUpper()))
                    {
                        dict.Add(strline, strline);
                    }
                }
                
                return dict;
            }
            catch (Exception ex)
            {
                throw new Exception(ex.Message);
            }
            
        }
        #endregion

        #region 获得已有文件列表
        public Dictionary<object, string> GetExistsFile(string strFile, string strUser, string strPasswd, string strSeverIP, string strRemark)
        {
            Dictionary<object, string> dict = new Dictionary<object, string>();
            string strPath = string.Empty;
            if (strFile.Trim().Equals(string.Empty)) strPath = "ftp://" + strSeverIP + "/";
            else strPath = "ftp://" + strSeverIP + "/" + strFile + "/";

            try
            {
                FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(strPath));
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(strUser, strPasswd);
                reqFTP.Method = WebRequestMethods.Ftp.ListDirectory;
                WebResponse response = reqFTP.GetResponse();
                StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.Default, true);
                string strline = string.Empty;

                for (int i = 0; (strline = reader.ReadLine()) != null; i++)
                {
                    if (strline.Equals(strRemark))
                    {
                        dict.Add(strline, strline);
                        reader.Close();
                        response.Close();
                        return dict;
                    }
                }
                reader.Close();
                response.Close();
                return dict;
            }
            catch
            {
                return dict;
            }
        }
        #endregion

        #region 根据传入参数获得FTP上符合要求的文件
        /// <summary>
        /// 根据传入参数获得FTP上符合要求的文件
        /// </summary>
        /// <param name="strPath"></param>
        /// <param name="strUser"></param>
        /// <param name="strPasswd"></param>
        /// <param name="strSeverIP"></param>
        /// <param name="strRemark"></param>
        /// <returns></returns>
        public string GetFile(string strPath, string strUser, string strPasswd, string strSeverIP, string strRemark)
        {
            Dictionary<object, string> dict = new Dictionary<object, string>();
            dict = GetFileList(strPath, strUser, strPasswd, strSeverIP, strRemark);
            //dict = GetExistsFile(strPath, strUser, strPasswd, strSeverIP, strRemark);
            if (dict.Count < 1) return string.Empty;
            else
            {
                foreach (KeyValuePair<object, string> Kvp in dict)
                {
                    if (Kvp.Key.ToString().ToUpper().Contains(strRemark)) return Kvp.Value;
                }
                return string.Empty;
            }
        }
        #endregion

        #region 根据传入参数删除FTP上的对应文件
        /// <summary>
        /// DelFile
        /// </summary>
        /// <param name="strFile">传入所需删除文件的全路径</param>
        /// <param name="strUser">用户名</param>
        /// <param name="strPasswd">密码</param>
        /// <param name="strSeverIP">FTP地址</param>
        /// <returns></returns>
        public bool DelFile(string strFile, string strUser, string strPasswd, string strSeverIP)
        {
            try
            {
                FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + strSeverIP + "/" + strFile));
                reqFTP.Method = WebRequestMethods.Ftp.DeleteFile;
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(strUser, strPasswd);
                WebResponse response = (FtpWebResponse)reqFTP.GetResponse();
                response.Close();
                return true;
            }
            catch
            {
                return false;
            }
        }
        #endregion

        #region 在FTP上创建所需目录
        /// <summary>
        /// CreateDirectory
        /// </summary>
        /// <param name="strFile"></param>
        /// <param name="strUser"></param>
        /// <param name="strPasswd"></param>
        /// <param name="strSeverIP"></param>
        public void CreateFTPDirectory(string strDirectory, string strUser, string strPasswd, string strSeverIP)
        {
            if (strDirectory.Equals(string.Empty)) throw new Exception("没有传入文件夹！");
            string strPath = "ftp://" + strSeverIP + "/" + strDirectory;
            string strCheckPath = strPath.Remove(strPath.LastIndexOf("/") + 1);
            string strDircetory = strPath.Substring(strPath.LastIndexOf("/") + 1);

            try
            {
                #region check exists
                FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(strCheckPath));
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(strUser, strPasswd);
                reqFTP.Method = WebRequestMethods.Ftp.ListDirectory;
                WebResponse response = reqFTP.GetResponse();
                StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.Default, true);
                string strline = string.Empty;

                for (int i = 0; (strline = reader.ReadLine()) != null; i++)
                {
                    if (strline.Equals(strDircetory))
                    {
                        reader.Close();
                        response.Close();
                        return;
                    }
                }
                reader.Close();
                response.Close();
                #endregion

                #region Create Directory
                reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(strPath));
                reqFTP.UseBinary = true;
                reqFTP.Credentials = new NetworkCredential(strUser, strPasswd);
                reqFTP.Method = WebRequestMethods.Ftp.MakeDirectory;
                response = reqFTP.GetResponse();
                response.Close();
                #endregion
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion

    }