最近做了一個項目，需要讀取ftp服務器上的文件，于是參考了網上提供的一些幫組方法，使用過程中，出現一些小細節問題，于是本人做了一些修改，拿來分享一下
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
|
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net; using System.IO; using System.Threading;using System.Configuration; namespace FtpSyn { public class FtpHelper { //基本設置 ftp://400:[email protected]/400backup static private string path = @"ftp://" + ConfigurationManager.AppSettings["FtpServerIP"].ToString() + "/"; //目標路徑 static private string ftpip = ConfigurationManager.AppSettings["FtpServerIP"].ToString(); //ftp IP地址 static private string username = ConfigurationManager.AppSettings["FtpUserName"].ToString(); //ftp用戶名 static private string password = ConfigurationManager.AppSettings["FtpPassWord"].ToString(); //ftp密碼 //獲取ftp上面的文件和文件夾 public static string[] GetFileList(string dir) { string[] downloadFiles; StringBuilder result = new StringBuilder(); FtpWebRequest request; try { request = (FtpWebRequest)FtpWebRequest.Create(new Uri(path + dir)); request.UseBinary = true; request.Credentials = new NetworkCredential(username, password);//設置用戶名和密碼 request.Method = WebRequestMethods.Ftp.ListDirectory; request.UseBinary = true; request.UsePassive = false; //選擇主動還是被動模式 , 這句要加上的。 request.KeepAlive = false;//一定要設置此屬性，否則一次性下載多個文件的時候，會出現異常。 WebResponse response = request.GetResponse(); StreamReader reader = new StreamReader(response.GetResponseStream()); string line = reader.ReadLine(); while (line != null) { result.Append(line); result.Append("\n"); line = reader.ReadLine(); } result.Remove(result.ToString().LastIndexOf('\n'), 1); reader.Close(); response.Close(); return result.ToString().Split('\n'); } catch (Exception ex) { LogHelper.writeErrorLog("獲取ftp上面的文件和文件夾：" + ex.Message); downloadFiles = null; return downloadFiles; } } /// <summary> /// 從ftp服務器上獲取文件并將內容全部轉換成string返回 /// </summary> /// <param name="fileName"></param> /// <param name="dir"></param> /// <returns></returns> public static string GetFileStr(string fileName, string dir) { FtpWebRequest reqFTP; try { reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(path + dir + "/" + fileName)); reqFTP.Method = WebRequestMethods.Ftp.DownloadFile; reqFTP.UseBinary = true; reqFTP.Credentials = new NetworkCredential(username, password); reqFTP.UsePassive = false; //選擇主動還是被動模式 , 這句要加上的。 reqFTP.KeepAlive = false;//一定要設置此屬性，否則一次性下載多個文件的時候，會出現異常。 FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); Stream ftpStream = response.GetResponseStream(); StreamReader reader = new StreamReader(ftpStream); string fileStr = reader.ReadToEnd(); reader.Close(); ftpStream.Close(); response.Close(); return fileStr; } catch (Exception ex) { LogHelper.writeErrorLog("獲取ftp文件并讀取內容失敗：" + ex.Message); return null; } } /// <summary> /// 獲取文件大小 /// </summary> /// <param name="file">ip服務器下的相對路徑</param> /// <returns>文件大小</returns> public static int GetFileSize(string file) { StringBuilder result = new StringBuilder(); FtpWebRequest request; try { request = (FtpWebRequest)FtpWebRequest.Create(new Uri(path + file)); request.UseBinary = true; request.Credentials = new NetworkCredential(username, password);//設置用戶名和密碼 request.Method = WebRequestMethods.Ftp.GetFileSize; int dataLength = (int)request.GetResponse().ContentLength; return dataLength; } catch (Exception ex) { Console.WriteLine("獲取文件大小出錯：" + ex.Message); return -1; } } /// <summary> /// 文件上傳 /// </summary> /// <param name="filePath">原路徑（絕對路徑）包括文件名</param> /// <param name="objPath">目標文件夾：服務器下的相對路徑 不填為根目錄</param> public static void FileUpLoad(string filePath,string objPath="") { try { string url = path; if(objPath!="") url += objPath + "/"; try { FtpWebRequest reqFTP = null; //待上傳的文件 （全路徑） try { FileInfo fileInfo = new FileInfo(filePath); using (FileStream fs = fileInfo.OpenRead()) { long length = fs.Length; reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(url + fileInfo.Name)); //設置連接到FTP的帳號密碼 reqFTP.Credentials = new NetworkCredential(username, password); //設置請求完成后是否保持連接 reqFTP.KeepAlive = false; //指定執行命令 reqFTP.Method = WebRequestMethods.Ftp.UploadFile; //指定數據傳輸類型 reqFTP.UseBinary = true; using (Stream stream = reqFTP.GetRequestStream()) { //設置緩沖大小 int BufferLength = 5120; byte[] b = new byte[BufferLength]; int i; while ((i = fs.Read(b, 0, BufferLength)) > 0) { stream.Write(b, 0, i); } Console.WriteLine("上傳文件成功"); } } } catch (Exception ex) { Console.WriteLine("上傳文件失敗錯誤為" + ex.Message); } finally { } } catch (Exception ex) { Console.WriteLine("上傳文件失敗錯誤為" + ex.Message); } finally { } } catch (Exception ex) { Console.WriteLine("上傳文件失敗錯誤為" + ex.Message); } } /// <summary> /// 刪除文件 /// </summary> /// <param name="fileName">服務器下的相對路徑 包括文件名</param> public static void DeleteFileName(string fileName) { try { FileInfo fileInf = new FileInfo(ftpip +""+ fileName); string uri = path + fileName; FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri)); // 指定數據傳輸類型 reqFTP.UseBinary = true; // ftp用戶名和密碼 reqFTP.Credentials = new NetworkCredential(username, password); // 默認為true，連接不會被關閉 // 在一個命令之后被執行 reqFTP.KeepAlive = false; // 指定執行什么命令 reqFTP.Method = WebRequestMethods.Ftp.DeleteFile; FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); response.Close(); } catch (Exception ex) { Console.WriteLine("刪除文件出錯：" + ex.Message); } } /// <summary> /// 新建目錄 上一級必須先存在 /// </summary> /// <param name="dirName">服務器下的相對路徑</param> public static void MakeDir(string dirName) { try { string uri = path + dirName; FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri)); // 指定數據傳輸類型 reqFTP.UseBinary = true; // ftp用戶名和密碼 reqFTP.Credentials = new NetworkCredential(username, password); reqFTP.Method = WebRequestMethods.Ftp.MakeDirectory; FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); response.Close(); } catch (Exception ex) { Console.WriteLine("創建目錄出錯：" + ex.Message); } } /// <summary> /// 刪除目錄 上一級必須先存在 /// </summary> /// <param name="dirName">服務器下的相對路徑</param> public static void DelDir(string dirName) { try { string uri = path + dirName; FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri)); // ftp用戶名和密碼 reqFTP.Credentials = new NetworkCredential(username, password); reqFTP.Method = WebRequestMethods.Ftp.RemoveDirectory; FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); response.Close(); } catch (Exception ex) { Console.WriteLine("刪除目錄出錯：" + ex.Message); } } /// <summary> /// 從ftp服務器上獲得文件夾列表 /// </summary> /// <param name="RequedstPath">服務器下的相對路徑</param> /// <returns></returns> public static List<string> GetDirctory(string RequedstPath) { List<string> strs = new List<string>(); try { string uri = path + RequedstPath; //目標路徑 path為服務器地址 FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri)); // ftp用戶名和密碼 reqFTP.Credentials = new NetworkCredential(username, password); reqFTP.Method = WebRequestMethods.Ftp.ListDirectoryDetails; WebResponse response = reqFTP.GetResponse(); StreamReader reader = new StreamReader(response.GetResponseStream());//中文文件名 string line = reader.ReadLine(); while (line != null) { if (line.Contains("<DIR>")) { string msg = line.Substring(line.LastIndexOf("<DIR>")+5).Trim(); strs.Add(msg); } line = reader.ReadLine(); } reader.Close(); response.Close(); return strs; } catch (Exception ex) { Console.WriteLine("獲取目錄出錯：" + ex.Message); } return strs; } /// <summary> /// 從ftp服務器上獲得文件列表 /// </summary> /// <param name="RequedstPath">服務器下的相對路徑</param> /// <returns></returns> public static List<string> GetFile(string RequedstPath) { List<string> strs = new List<string>(); try { string uri = path + RequedstPath; //目標路徑 path為服務器地址 FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri)); // ftp用戶名和密碼 reqFTP.Credentials = new NetworkCredential(username, password); reqFTP.Method = WebRequestMethods.Ftp.ListDirectoryDetails; WebResponse response = reqFTP.GetResponse(); StreamReader reader = new StreamReader(response.GetResponseStream());//中文文件名 string line = reader.ReadLine(); while (line != null) { if (!line.Contains("<DIR>")) { string msg = line.Substring(39).Trim(); strs.Add(msg); } line = reader.ReadLine(); } reader.Close(); response.Close(); return strs; } catch (Exception ex) { Console.WriteLine("獲取文件出錯：" + ex.Message); } return strs; } } } |
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
