狠狠色丁香婷婷综合尤物/久久精品综合一区二区三区/中国有色金属学报/国产日韩欧美在线观看 - 国产一区二区三区四区五区tv

LOGO OA教程 ERP教程 模切知識交流 PMS教程 CRM教程 開發文檔 其他文檔  
 
網站管理員

C#開發--FTP操作方法管理

admin
2021年3月3日 11:38 本文熱度 4680
1、整理簡化了下C#的ftp操作,方便使用:
   1.支持創建多級目錄
   2.批量刪除
   3.整個目錄上傳
   4.整個目錄刪除
   5.整個目錄下載

2、調用方法展示:
var ftp = new FtpHelper("10.136.12.11", "qdx1213123", "123ddddf");//初始化ftp,創建ftp對象
ftp.DelAll("test");//刪除ftptest目錄及其目錄下的所有文件
ftp.UploadAllFile("F:\\test\\wms.zip");//上傳單個文件到指定目錄
ftp.UploadAllFile("F:\\test");//將本地test目錄的所有文件上傳
ftp.DownloadFile("test\\wms.zip", "F:\\test1");//下載單個目錄
ftp.DownloadAllFile("test", "F:\\test1");//批量下載整個目錄
ftp.MakeDir("aaa\\bbb\\ccc\\ddd");//創建多級目錄

3、FtpHelper代碼:
  1.異常方法委托,通過Lamda委托統一處理異常,方便改寫。加了個委托方便控制異常輸出;
  2.ftp的刪除需要遞歸查找所有目錄存入list,然后根據 level倒序排序,從最末級開始遍歷刪除;
  3.其他的整個目錄操作都是同上。
代碼如下:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.IO;
 
 namespace AsyncTcpServer
{
    /// <summary>
    /// ftp幫助類
    /// </summary>
    public class FtpHelper
    {
        private string ftpHostIP { get; set; }
        private string username { get; set; }
        private string password { get; set; }
        private string ftpURI { get { return $@"ftp://{ftpHostIP}/"; } }

        /// <summary>
        /// 初始化ftp參數
        /// </summary>
        /// <param name="ftpHostIP">ftp主機IP</param>
        /// <param name="username">ftp賬戶</param>
        /// <param name="password">ftp密碼</param>
        public FtpHelper(string ftpHostIP, string username, string password)
        {
            this.ftpHostIP = ftpHostIP;
            this.username = username;
            this.password = password;
        }

        /// <summary>
        /// 異常方法委托,通過Lamda委托統一處理異常,方便改寫
        /// </summary>
        /// <param name="method">當前執行的方法</param>
        /// <param name="action"></param>
        /// <returns></returns>
        private bool MethodInvoke(string method, Action action)
        {
            if (action != null)
            {
                try
                {
                    action();
                    Console.WriteLine($@"FtpHelper({ftpHostIP},{username},{password}).{method}:執行成功");
                    return true;
                }
                catch (Exception ex)
                {
                    Console.WriteLine($@"FtpHelper({ftpHostIP},{username},{password}).{method}:執行失敗:\n {ex}");
                    return false;
                }
            }
            else
            {
                return false;
            }
        }

        /// <summary>
        /// 異常方法委托,通過Lamda委托統一處理異常,方便改寫
        /// </summary>
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="method"></param>
        /// <param name="func"></param>
        /// <returns></returns>
        private T MethodInvoke<T>(string method, Func<T> func)
        {
            if (func != null)
            {
                try
                {
                    //Console.WriteLine($@"FtpHelper({ftpHostIP},{username},{password}).{method}:執行成功");
                    return func();
                }
                catch (Exception ex)
                {
                    //Console.WriteLine($@"FtpHelper({ftpHostIP},{username},{password}).{method}:執行失敗:").Line(ex);
                    return default(T);
                }
            }
            else
            {
                return default(T);
            }
        }
        private FtpWebRequest GetRequest(string URI)
        {
            //根據服務器信息FtpWebRequest創建類的對象
            FtpWebRequest result = (FtpWebRequest)WebRequest.Create(URI);
            result.Credentials = new NetworkCredential(username, password);
            result.KeepAlive = false;
            result.UsePassive = false;
            result.UseBinary = true;
            return result;
        }

        /// <summary> 上傳文件</summary>
        /// <param name="filePath">需要上傳的文件路徑</param>
        /// <param name="dirName">目標路徑</param>
        public bool UploadFile(string filePath, string dirName = "")
        {
            FileInfo fileInfo = new FileInfo(filePath);
            if (dirName != "") MakeDir(dirName);//檢查文件目錄,不存在就自動創建
            string uri = Path.Combine(ftpURI, dirName, fileInfo.Name);
            return MethodInvoke($@"uploadFile({filePath},{dirName})", () =>
            {
                FtpWebRequest ftp = GetRequest(uri);
                ftp.Method = WebRequestMethods.Ftp.UploadFile;
                ftp.ContentLength = fileInfo.Length;
                int buffLength = 2048;
                byte[] buff = new byte[buffLength];
                int contentLen;
                using (FileStream fs = fileInfo.OpenRead())
                {
                    using (Stream strm = ftp.GetRequestStream())
                    {
                        contentLen = fs.Read(buff, 0, buffLength);
                        while (contentLen != 0)
                        {
                            strm.Write(buff, 0, contentLen);
                            contentLen = fs.Read(buff, 0, buffLength);
                        }
                        strm.Close();
                    }
                    fs.Close();
                }
            });
        }

        /// <summary>
        /// 從一個目錄將其內容復制到另一目錄
        /// </summary>
        /// <param name="localDir">源目錄</param>
        /// <param name="DirName">目標目錄</param>
        public void UploadAllFile(string localDir, string DirName = "")
        {
            string localDirName = string.Empty;
            int targIndex = localDir.LastIndexOf("\\");
            if (targIndex > -1 && targIndex != (localDir.IndexOf(":\\") + 1))
                localDirName = localDir.Substring(0, targIndex);
            localDirName = localDir.Substring(targIndex + 1);
            string newDir = Path.Combine(DirName, localDirName);
            MethodInvoke($@"UploadAllFile({localDir},{DirName})", () =>
            {
                MakeDir(newDir);
                DirectoryInfo directoryInfo = new DirectoryInfo(localDir);
                FileInfo[] files = directoryInfo.GetFiles();
                //復制所有文件  
                foreach (FileInfo file in files)
                {
                    UploadFile(file.FullName, newDir);
                }
                //最后復制目錄  
                DirectoryInfo[] directoryInfoArray = directoryInfo.GetDirectories();
                foreach (DirectoryInfo dir in directoryInfoArray)
                {
                    UploadAllFile(Path.Combine(localDir, dir.Name), newDir);
                }
            });
        }

        /// <summary> 
        /// 刪除單個文件
        /// </summary>
        /// <param name="filePath"></param>
        public bool DelFile(string filePath)
        {
            string uri = Path.Combine(ftpURI, filePath);
            return MethodInvoke($@"DelFile({filePath})", () =>
            {
                FtpWebRequest ftp = GetRequest(uri);
                ftp.Method = WebRequestMethods.Ftp.DeleteFile;
                FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
                response.Close();
            });
        }

        /// <summary> 
        /// 刪除最末及空目錄
        /// </summary>
        /// <param name="dirName"></param>
        private bool DelDir(string dirName)
        {
            string uri = Path.Combine(ftpURI, dirName);
            return MethodInvoke($@"DelDir({dirName})", () =>
            {
                FtpWebRequest ftp = GetRequest(uri);
                ftp.Method = WebRequestMethods.Ftp.RemoveDirectory;
                FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
                response.Close();
            });
        }

        /// <summary> 刪除目錄或者其目錄下所有的文件 </summary>
        /// <param name="dirName">目錄名稱</param>
        /// <param name="ifDelSub">是否刪除目錄下所有的文件</param>
        public bool DelAll(string dirName)
        {
            var list = GetAllFtpFile(new List<ActFile>(), dirName);
            if (list == null) return DelDir(dirName);
            if (list.Count == 0) return DelDir(dirName);//刪除當前目錄
            var newlist = list.OrderByDescending(x => x.level);
            foreach (var item in newlist)
            {
                Console.WriteLine($@"level:{item.level},isDir:{item.isDir},path:{item.path}");
            }
            string uri = Path.Combine(ftpURI, dirName);
            return MethodInvoke($@"DelAll({dirName})", () =>
            {
                foreach (var item in newlist)
                {
                    if (item.isDir)//判斷是目錄調用目錄的刪除方法
                        DelDir(item.path);
                    else
                        DelFile(item.path);
                }
                DelDir(dirName);//刪除當前目錄
                return true;
            });
        }

        /// <summary>
        /// 下載單個文件
        /// </summary>
        /// <param name="ftpFilePath">從ftp要下載的文件路徑</param>
        /// <param name="localDir">下載至本地路徑</param>
        /// <param name="filename">文件名</param>
        public bool DownloadFile(string ftpFilePath, string saveDir)
        {
            string filename = ftpFilePath.Substring(ftpFilePath.LastIndexOf("\\") + 1);
            string tmpname = Guid.NewGuid().ToString();
            string uri = Path.Combine(ftpURI, ftpFilePath);
            return MethodInvoke($@"DownloadFile({ftpFilePath},{saveDir},{filename})", () =>
            {
                if (!Directory.Exists(saveDir)) Directory.CreateDirectory(saveDir);
                FtpWebRequest ftp = GetRequest(uri);
                ftp.Method = WebRequestMethods.Ftp.DownloadFile;
                using (FtpWebResponse response = (FtpWebResponse)ftp.GetResponse())
                {
                    using (Stream responseStream = response.GetResponseStream())
                    {
                        using (FileStream fs = new FileStream(Path.Combine(saveDir, filename), FileMode.CreateNew))
                        {
                            byte[] buffer = new byte[2048];
                            int read = 0;
                            do
                            {
                                read = responseStream.Read(buffer, 0, buffer.Length);
                                fs.Write(buffer, 0, read);
                            } while (!(read == 0));
                            responseStream.Close();
                            fs.Flush();
                            fs.Close();
                        }
                        responseStream.Close();
                    }
                    response.Close();
                }
            });
        }

        /// <summary>    
        /// 從FTP下載整個文件夾    
        /// </summary>    
        /// <param name="dirName">FTP文件夾路徑</param>    
        /// <param name="saveDir">保存的本地文件夾路徑</param>    
        public void DownloadAllFile(string dirName, string saveDir)
        {
            MethodInvoke($@"DownloadAllFile({dirName},{saveDir})", () =>
            {
                List<ActFile> files = GetFtpFile(dirName);
                if (!Directory.Exists(saveDir))
                {
                    Directory.CreateDirectory(saveDir);
                }
                foreach (var f in files)
                {
                    if (f.isDir) //文件夾,遞歸查詢  
                    {
                        DownloadAllFile(Path.Combine(dirName, f.name), Path.Combine(saveDir, f.name));
                    }
                    else //文件,直接下載  
                    {
                        DownloadFile(Path.Combine(dirName, f.name), saveDir);
                    }
                }
            });
        }

        /// <summary>
        /// 獲取當前目錄下的目錄及文件
        /// </summary>
        /// param name="ftpfileList"></param>
        /// <param name="dirName"></param>
        /// <returns></returns>
        public List<ActFile> GetFtpFile(string dirName, int ilevel = 0)
        {
            var ftpfileList = new List<ActFile>();
            string uri = Path.Combine(ftpURI, dirName);
            return MethodInvoke($@"GetFtpFile({dirName})", () =>
            {
                var a = new List<List<string>>();
                FtpWebRequest ftp = GetRequest(uri);
                ftp.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
                Stream stream = ftp.GetResponse().GetResponseStream();
                using (StreamReader sr = new StreamReader(stream))
                {
                    string line = sr.ReadLine();
                    while (!string.IsNullOrEmpty(line))
                    {
                        ftpfileList.Add(new ActFile { isDir = line.IndexOf("<DIR>") > -1, name = line.Substring(39).Trim(), path = Path.Combine(dirName, line.Substring(39).Trim()), level = ilevel });
                        line = sr.ReadLine();
                    }
                    sr.Close();
                }
                return ftpfileList;
            });


        }

        /// <summary>
        /// 獲取FTP目錄下的所有目錄及文件包括其子目錄和子文件
        /// </summary>
        /// param name="result"></param>
        /// <param name="dirName"></param>
        /// <returns></returns>
        public List<ActFile> GetAllFtpFile(List<ActFile> result, string dirName, int level = 0)
        {
            var ftpfileList = new List<ActFile>();
            string uri = Path.Combine(ftpURI, dirName);
            return MethodInvoke($@"GetAllFtpFile({dirName})", () =>
            {
                ftpfileList = GetFtpFile(dirName, level);
                result.AddRange(ftpfileList);
                var newlist = ftpfileList.Where(x => x.isDir).ToList();
                foreach (var item in newlist)
                {
                    GetAllFtpFile(result, item.path, level + 1);
                }
                return result;
            });

        }

        /// <summary>
        /// 檢查目錄是否存在
        /// </summary>
        /// <param name="dirName"></param>
        /// <param name="currentDir"></param>
        /// <returns></returns>
        public bool CheckDir(string dirName, string currentDir = "")
        {
            string uri = Path.Combine(ftpURI, currentDir);
            return MethodInvoke($@"CheckDir({dirName}{currentDir})", () =>
            {
                FtpWebRequest ftp = GetRequest(uri);
                ftp.UseBinary = true;
                ftp.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
                Stream stream = ftp.GetResponse().GetResponseStream();
                using (StreamReader sr = new StreamReader(stream))
                {
                    string line = sr.ReadLine();
                    while (!string.IsNullOrEmpty(line))
                    {
                        if (line.IndexOf("<DIR>") > -1)
                        {
                            if (line.Substring(39).Trim() == dirName)
                                return true;
                        }
                        line = sr.ReadLine();
                    }
                    sr.Close();
                }
                stream.Close();
                return false;
            });

        }

        ///  </summary>
        /// 在ftp服務器上創建指定目錄,父目錄不存在則創建
        /// </summary>
        /// <param name="dirName">創建的目錄名稱</param>
        public bool MakeDir(string dirName)
        {
            var dirs = dirName.Split('\\').ToList();//針對多級目錄分割
            string currentDir = string.Empty;
            return MethodInvoke($@"MakeDir({dirName})", () =>
            {
                foreach (var dir in dirs)
                {
                    if (!CheckDir(dir, currentDir))//檢查目錄不存在則創建
                    {
                        currentDir = Path.Combine(currentDir, dir);
                        string uri = Path.Combine(ftpURI, currentDir);
                        FtpWebRequest ftp = GetRequest(uri);
                        ftp.Method = WebRequestMethods.Ftp.MakeDirectory;
                        FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
                        response.Close();
                    }
                    else
                    {
                        currentDir = Path.Combine(currentDir, dir);
                    }
                }

            });

        }

        /// <summary>文件重命名 </summary>
        /// <param name="currentFilename">當前名稱</param>
        /// <param name="newFilename">重命名名稱</param>
        /// <param name="currentFilename">所在的目錄</param>
        public bool Rename(string currentFilename, string newFilename, string dirName = "")
        {
            string uri = Path.Combine(ftpURI, dirName, currentFilename);
            return MethodInvoke($@"Rename({currentFilename},{newFilename},{dirName})", () =>
            {
                FtpWebRequest ftp = GetRequest(uri);
                ftp.Method = WebRequestMethods.Ftp.Rename;
                ftp.RenameTo = newFilename;
                FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
                response.Close();
            });
        }
    }

    public class ActFile
    {
        public int level { get; set; } = 0;
        public bool isDir { get; set; }
        public string name { get; set; }
        public string path { get; set; } = "";
    }
}

該文章在 2021/7/7 16:14:36 編輯過
關鍵字查詢
相關文章
正在查詢...
點晴ERP是一款針對中小制造業的專業生產管理軟件系統,系統成熟度和易用性得到了國內大量中小企業的青睞。
點晴PMS碼頭管理系統主要針對港口碼頭集裝箱與散貨日常運作、調度、堆場、車隊、財務費用、相關報表等業務管理,結合碼頭的業務特點,圍繞調度、堆場作業而開發的。集技術的先進性、管理的有效性于一體,是物流碼頭及其他港口類企業的高效ERP管理信息系統。
點晴WMS倉儲管理系統提供了貨物產品管理,銷售管理,采購管理,倉儲管理,倉庫管理,保質期管理,貨位管理,庫位管理,生產管理,WMS管理系統,標簽打印,條形碼,二維碼管理,批號管理軟件。
點晴免費OA是一款軟件和通用服務都免費,不限功能、不限時間、不限用戶的免費OA協同辦公管理系統。
Copyright 2010-2025 ClickSun All Rights Reserved