c# 代碼操作ftp伺服器文件

来源:https://www.cnblogs.com/INetIMVC/p/18025336
-Advertisement-
Play Games

好久不見,我又回來了。 給大家分享一個我最近使用c#代碼操作ftp伺服器的代碼示例: 1 public abstract class FtpOperation 2 { 3 /// <summary> 4 /// FTP伺服器地址 5 /// </summary> 6 private string f ...


好久不見,我又回來了。

給大家分享一個我最近使用c#代碼操作ftp伺服器的代碼示例:

 

 1  public abstract class FtpOperation
 2     {
 3         /// <summary>
 4         /// FTP伺服器地址
 5         /// </summary>
 6         private string ftpServer;
 7 
 8         /// <summary>
 9         /// 用戶名
10         /// </summary>
11         private string userName;
12 
13         /// <summary>
14         /// 密碼
15         /// </summary>
16         private string passWord;
17 
18         /// <summary>
19         /// FTPHelper類的構造函數
20         /// </summary>
21         /// <param name="ftpServer">FTP伺服器地址</param>
22         /// <param name="userName">用戶名</param>
23         /// <param name="passWord">密碼</param>
24         public FtpOperation(string ftpServer, string userName, string passWord)
25         {
26             this.ftpServer = ftpServer;
27             this.userName = userName;
28             this.passWord = passWord;
29         }
30 
31         /// <summary>
32         /// 執行FTP操作的方法
33         /// </summary>
34         /// <param name="action">要執行的操作</param>
35         private void ExecuteFtpOperation(Action action)
36         {
37             try
38             {
39                 action.Invoke();
40             }
41             catch (WebException ex)
42             {
43                 if (ex.Status == WebExceptionStatus.Timeout)
44                 {
45                     Console.WriteLine("連接超時。");
46                 }
47                 else
48                 {
49                     Console.WriteLine("發生錯誤 WebException: {0}", ex.Message);
50                 }
51             }
52             catch (Exception ex)
53             {
54                 Console.WriteLine("發生錯誤: {0}", ex.Message);
55             }
56         }
57  }
58 }
基礎類的構造函數和屬性
  1        /// <summary>
  2         /// 執行FTP操作的方法
  3         /// </summary>
  4         /// <param name="action">要執行的操作</param>
  5         private void ExecuteFtpOperation(Action action)
  6         {
  7             try
  8             {
  9                 action.Invoke();
 10             }
 11             catch (WebException ex)
 12             {
 13                 if (ex.Status == WebExceptionStatus.Timeout)
 14                 {
 15                     Console.WriteLine("連接超時。");
 16                 }
 17                 else
 18                 {
 19                     Console.WriteLine("發生錯誤 WebException: {0}", ex.Message);
 20                 }
 21             }
 22             catch (Exception ex)
 23             {
 24                 Console.WriteLine("發生錯誤: {0}", ex.Message);
 25             }
 26         }
 27 
 28         #region 文件查詢
 29 
 30         /// <summary>
 31         /// 遞歸查詢FTP伺服器上所有文件和目錄
 32         /// </summary>
 33         /// <param name="ftpDirectoryPath">要查詢的目錄路徑</param>
 34         public virtual List<FileInfo> RecursiveQueryAll(string ftpDirectoryPath = "")
 35         {
 36             List<FileInfo> list = new List<FileInfo>();
 37             ExecuteFtpOperation(() =>
 38             {
 39                 List<FileInfo> currentList = QueryAll(ftpDirectoryPath);
 40                 list.AddRange(currentList);
 41 
 42                 foreach (var fileInfo in currentList)
 43                 {
 44                     if (fileInfo.FileType == "Folder")
 45                     {
 46                         // 如果是文件夾,遞歸查詢
 47                         List<FileInfo> subList = RecursiveQueryAll(ftpDirectoryPath + "/" + fileInfo.FileName);
 48                         list.AddRange(subList);
 49                     }
 50                 }
 51             });
 52             return list;
 53         }
 54 
 55         /// <summary>
 56         /// 查詢FTP伺服器上所有文件和目錄
 57         /// </summary>
 58         /// <param name="ftpDirectoryPath">要查詢的目錄路徑</param>
 59         public virtual List<FileInfo> QueryAll(string ftpDirectoryPath = "")
 60         {
 61             List<FileInfo> list = new List<FileInfo>();
 62             ExecuteFtpOperation(() =>
 63             {
 64                 FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + ftpDirectoryPath);
 65                 request.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
 66                 request.Credentials = new NetworkCredential(userName, passWord);
 67                 request.Timeout = 5000;
 68 
 69                 using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
 70                 {
 71                     //Console.WriteLine("狀態: {0}", response.StatusDescription);
 72 
 73                     using (var responseStream = response.GetResponseStream())
 74                     {
 75                         if (responseStream != null)
 76                         {
 77                             using (var reader = new StreamReader(responseStream))
 78                             {
 79                                 string line = reader.ReadLine();
 80                                 while (!string.IsNullOrEmpty(line))
 81                                 {
 82                                     list.AddRange(ParseFTPFileList(line));
 83                                     line = reader.ReadLine();
 84                                 }
 85                             }
 86                         }
 87                     }
 88                 }
 89             });
 90             return list;
 91         }
 92 
 93         /// <summary>
 94         /// 解析FTP伺服器返回的文件列表信息,將其轉換為FileInfo對象列表
 95         /// </summary>
 96         /// <param name="ftpFileList">FTP伺服器返回的文件列表信息</param>
 97         /// <returns>包含文件信息的FileInfo對象列表</returns>
 98         public virtual List<FileInfo> ParseFTPFileList(string ftpFileList)
 99         {
100             // 解析FTP返回的文件列表信息並返回FileInfo對象列表
101             List<FileInfo> filesInfo = new List<FileInfo>();
102 
103             // 按行分割FTP文件列表信息
104             string[] lines = ftpFileList.Split(new[] { "\r\n", "\r", "\n" }, StringSplitOptions.RemoveEmptyEntries);
105 
106             foreach (string line in lines)
107             {
108                 // 按空格分割行信息
109                 string[] parts = line.Split(new[] { ' ' }, StringSplitOptions.RemoveEmptyEntries);
110 
111                 if (parts.Length >= 4)
112                 {
113 
114                     string lastModifiedDateStr = parts[0] + " " + parts[1];
115                     string format = "MM-dd-yy hh:mmtt"; // 指定日期時間的確切格式
116                     DateTime lastModifiedDate;
117                     DateTime.TryParseExact(lastModifiedDateStr, format, System.Globalization.CultureInfo.InvariantCulture, System.Globalization.DateTimeStyles.None, out lastModifiedDate);
118 
119                     // 提取文件大小信息
120                     string fileSizeStr = parts[2];
121                     long fileSize;
122                     string fileType = "Folder";
123                     string fileName = string.Join(" ", parts, 3, parts.Length - 3);
124                     if (fileSizeStr.Contains("DIR"))
125                     {
126 
127                         fileSize = 0;
128                     }
129                     else
130                     {
131                         fileType = Path.GetExtension(fileName);
132                         fileSize = Convert.ToInt64(fileSizeStr);
133                     }
134 
135 
136                     FileInfo fileInfo = new FileInfo(lastModifiedDate, fileSize, fileType, fileName);
137 
138                     filesInfo.Add(fileInfo);
139                 }
140             }
141 
142             return filesInfo;
143         }
144         #endregion
145 
146         #region 判斷FTP伺服器上是否存在指定文件夾 && 在FTP伺服器上創建文件夾 &&刪除FTP伺服器上的空文件夾
147         /// <summary>
148         /// 判斷FTP伺服器上是否存在指定文件夾
149         /// </summary>
150         /// <param name="directoryPath">要檢查的文件夾路徑</param>
151         /// <returns>文件夾是否存在的布爾值</returns>
152         public virtual bool FtpDirectoryExists(string directoryPath)
153         {
154             FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + directoryPath);
155             request.Credentials = new NetworkCredential(userName, passWord);
156             request.Method = WebRequestMethods.Ftp.ListDirectory;
157 
158             try
159             {
160                 FtpWebResponse response = (FtpWebResponse)request.GetResponse();
161                 response.Close();
162                 return true;
163             }
164             catch (WebException ex)
165             {
166                 FtpWebResponse response = (FtpWebResponse)ex.Response;
167                 if (response.StatusCode == FtpStatusCode.ActionNotTakenFileUnavailable)
168                 {
169                     return false;
170                 }
171                 throw;
172             }
173         }
174 
175         /// <summary>
176         /// 在FTP伺服器上創建文件夾
177         /// </summary>
178         /// <param name="folderName">要創建的文件夾名稱</param>
179         public virtual void FtpCreateDirectory(string folderName)
180         {
181             ExecuteFtpOperation(() =>
182             {
183                 string[] pathArray = folderName.Split('/');
184                 var tempPath = "";
185                 foreach (var path in pathArray)
186                 {
187                     if (path == "")
188                     {
189                         continue;
190                     }
191                     tempPath += path + "/";
192                     if (FtpDirectoryExists(tempPath))
193                     {
194                         continue;
195                     }
196                     FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + tempPath);
197                     request.Method = WebRequestMethods.Ftp.MakeDirectory;
198                     request.Credentials = new NetworkCredential(userName, passWord);
199 
200                     using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
201                     {
202                         Console.WriteLine($"文件夾{path}創建成功。");
203                     }
204                 }
205 
206             });
207         }
208         /// <summary>
209         /// 刪除FTP伺服器上的空文件夾
210         /// </summary>
211         /// <param name="ftpFolderPath">FTP伺服器上的空文件夾路徑</param>
212         public virtual void FtpDeleteFolder(string ftpFolderPath)
213         {
214             ExecuteFtpOperation(() =>
215             {
216                 if (string.IsNullOrEmpty(ftpFolderPath))
217                 {                    
218                     return;
219                 }
220                 // 連接到 FTP 伺服器
221                 FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + ftpFolderPath);
222                 request.Credentials = new NetworkCredential(userName, passWord);
223                 request.Method = WebRequestMethods.Ftp.RemoveDirectory;
224                 using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
225                 {
226                     Console.WriteLine($"文件夾{new DirectoryInfo(ftpFolderPath).Name}刪除成功!");
227                 }
228             });
229         }
230         #endregion
231 
232         #region 文件、文件夾刪除
233         /// <summary>
234         /// 刪除FTP伺服器指定路徑下的多個文件
235         /// </summary>
236         /// <param name="directoryPath">要刪除文件的目錄路徑</param>
237         /// <param name="fileNames">要刪除的文件名數組</param>
238         public virtual void FtpDeleteFiles(string directoryPath, string[] fileNames)
239         {
240             ExecuteFtpOperation(() =>
241             {
242                 foreach (var fileName in fileNames)
243                 {
244                     FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + directoryPath + "/" + fileName);
245                     request.Method = WebRequestMethods.Ftp.DeleteFile;
246                     request.Credentials = new NetworkCredential(userName, passWord);
247 
248                     using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
249                     {
250                         Console.WriteLine($"文件 '{fileName}' 刪除成功。");
251                     }
252                 }
253             });
254         }
255 
256         /// <summary>
257         /// 遞歸刪除FTP伺服器上的文件夾及其內容
258         /// </summary>
259         /// <param name="directoryPath">要刪除的文件夾路徑</param>
260         public virtual void FtpDeleteFolders(string directoryPath)
261         {
262             ExecuteFtpOperation(() =>
263             {
264 
265                 if (!FtpDirectoryExists(directoryPath))
266                 {
267                     Console.WriteLine($"{directoryPath} 不存在!");
268                     return;
269                 }
270 
271                 // 獲取文件夾內所有文件和子文件夾
272                 var fileList = QueryAll(directoryPath);
273                 foreach (var fileInfo in fileList)
274                 {
275                     // 刪除文件
276                     FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServer + directoryPath + "/" + fileInfo.FileName);
277                     request.Method = WebRequestMethods.Ftp.DeleteFile;
278                     request.Credentials = new NetworkCredential(userName, passWord);
279 
280                     // 如果是文件夾,遞歸刪除
281                     if (fileInfo.FileType == "Folder")
282                     {
283                         FtpDeleteFolders(directoryPath + "/" + fileInfo.FileName);
284                     }
285                     else
286                     {
287                         using (FtpWebResponse response = (FtpWebResponse)request.GetResponse())
288                         {
289                             Console.WriteLine($"文件 '{fileInfo.FileName}' 刪除成功。");
290                         }
291                     }
292 
293 
294 
295                 }
296 
297                 // 刪除空文件夾
298                 FtpDeleteFolder(directoryPath);
299             });
300         }
301 
302 
303         #endregion
304 
305         #region  文件移動
306 
307         /// <summary>
308         /// 移動FTP伺服器上的多個文件
309         /// </summary>
310         /// <param name="sourceDirectoryPath">	   

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 在 Java 中,LocalDateTime、Date 和 Instant 分別代表了不同的日期時間類型,它們之間有一些區別和適用場景。 Date: java.util.Date 是 Java 早期的日期時間類,它包含了日期和時間信息,但是在設計上存在一些問題,因此並不推薦在新的代碼中使用。 Dat ...
  • 序言 在數字時代,圖像生成技術正日益成為人工智慧領域的熱點。 本討論將重點聚焦於兩個備受矚目的模型:DALL-E和其他主流AI繪圖方法。 我們將探討它們的優勢、局限性以及未來的發展方向。通過比較分析,我們期望能夠更全面地瞭解這些技術,為未來的研究和應用提供啟示。 Q: 介紹一下 dall-e Ope ...
  • 簡介 git-commit-id-maven-plugin 是一個maven 插件,用來在打包的時候將git-commit 信息打進jar中。 這樣做的好處是可以將發佈的某版本和對應的代碼關聯起來,方便查閱和線上項目的維護。至於它的作用,用官方說法,這個功能對於大型分散式項目來說是無價的。 功能 你 ...
  • 1、下載安裝包首先、進入官網下載安裝包網址:https://www.python.org/downloads/windows/下載步驟:進入下載地址,根據自己的電腦系統選擇相應的python版本 選擇適配64位操作系統的版本(查看自己的電腦操作系統版本), 點擊下載安裝包 也可以下載我百度雲分享的安 ...
  • 在上篇文章中,我們介紹到在多線程環境下,如果編程不當,可能會出現程式運行結果混亂的問題。出現這個原因主要是,JMM 中主記憶體和線程工作記憶體的數據不一致,以及多個線程執行時無序,共同導致的結果。 ...
  • 本文分享自華為雲社區《Go併發範式 流水線和優雅退出 Pipeline 與 Cancellation》,作者:張儉。 介紹 Go 的併發原語可以輕鬆構建流數據管道,從而高效利用 I/O 和多個 CPU。 本文展示了此類pipelines的示例,強調了操作失敗時出現的細微之處,並介紹了乾凈地處理失敗的 ...
  • 自己製作的一個基於Entity Framework Core 的資料庫操作攔截器,可以列印資料庫執行sql,方便開發調試,代碼如下: /// <summary> /// EF Core 的資料庫操作攔截器,用於在資料庫操作過程中進行日誌記錄和監視。 /// </summary> /// <remar ...
  • 一:背景 1. 講故事 過年喝了不少酒,腦子不靈光了,停了將近一個月沒寫博客,今天就當新年開工寫一篇吧。 去年年初有位朋友找到我,說他們的系統會偶發性崩潰,在網上也發了不少帖子求助,沒找到自己滿意的答案,讓我看看有沒有什麼線索,看樣子這是一個牛皮蘚的問題,既然對方有了dump,那就分析起來吧。 二: ...
一周排行
    -Advertisement-
    Play Games
  • 隨著Aspire發佈preview5的發佈,Microsoft.Extensions.ServiceDiscovery隨之更新, 服務註冊發現這個屬於老掉牙的話題解決什麼問題就不贅述了,這裡主要講講Microsoft.Extensions.ServiceDiscovery(preview5)以及如何 ...
  • 概述:通過使用`SemaphoreSlim`,可以簡單而有效地限制非同步HTTP請求的併發量,確保在任何給定時間內不超過20個網頁同時下載。`ParallelOptions`不適用於非同步操作,但可考慮使用`Parallel.ForEach`,儘管在非同步場景中謹慎使用。 對於併發非同步 I/O 操作的數量 ...
  • 1.Linux上安裝Docken 伺服器系統版本以及內核版本:cat /etc/redhat-release 查看伺服器內核版本:uname -r 安裝依賴包:yum install -y yum-utils device-mapper-persistent-data lvm2 設置阿裡雲鏡像源:y ...
  • 概述:WPF界面綁定和渲染大量數據可能導致性能問題。通過啟用UI虛擬化、非同步載入和數據分頁,可以有效提高界面響應性能。以下是簡單示例演示這些優化方法。 在WPF中,當你嘗試綁定和渲染大量的數據項時,性能問題可能出現。以下是一些可能導致性能慢的原因以及優化方法: UI 虛擬化: WPF提供了虛擬化技術 ...
  • 引言 上一章節介紹了 TDD 的三大法則,今天我們講一下在單元測試中模擬對象的使用。 Fake Fake - Fake 是一個通用術語,可用於描述 stub或 mock 對象。 它是 stub 還是 mock 取決於使用它的上下文。 也就是說,Fake 可以是 stub 或 mock Mock - ...
  • 為.net6在CentOS7上面做準備,先在vmware虛擬機安裝CentOS 7.9 新建CentOS764位的系統 因為CentOS8不更新了,所以安裝7;簡單就一筆帶過了 選擇下載好的操作系統的iso文件,下載地址https://mirrors.aliyun.com/centos/7.9.20 ...
  • 經過前面幾篇的學習,我們瞭解到指令的大概分類,如:參數載入指令,該載入指令以 Ld 開頭,將參數載入到棧中,以便於後續執行操作命令。參數存儲指令,其指令以 St 開頭,將棧中的數據,存儲到指定的變數中,以方便後續使用。創建實例指令,其指令以 New 開頭,用於在運行時動態生成並初始化對象。方法調用指... ...
  • LiteDB 是一個輕量級的嵌入式 NoSQL 資料庫,其設計理念與 MongoDB 類似,但它是完全使用 C# 開發的,因此與 C# 應用程式的集成非常順暢。與 SQLite 相比,LiteDB 提供了 NoSQL(即鍵值對)的數據存儲方式,並且是一個開源且免費的項目。它適用於桌面、移動以及 We ...
  • 1 開源解析和拆分文檔 第三方的工具去對文件解析拆分,去將我們的文件內容給提取出來,並將我們的文檔內容去拆分成一個小的chunk。常見的PDF word mark down, JSON、HTML。都可以有很好的一些模塊去把這些文件去進行一個東西去提取。 優勢 支持豐富的文檔類型 每種文檔多樣化選擇 ...
  • OOM是什麼?英文全稱為 OutOfMemoryError(記憶體溢出錯誤)。當程式發生OOM時,如何去定位導致異常的代碼還是挺麻煩的。 要檢查OOM發生的原因,首先需要瞭解各種OOM情況下會報的異常信息。這樣能縮小排查範圍,再結合異常堆棧、heapDump文件、JVM分析工具和業務代碼來判斷具體是哪 ...