关于ftp的功能类——下载，上传，断点，连接

swsrl

　　看到园子里有几篇关于c#连接ftp的文章，刚好最近刚刚完成对于这个的书写，就发出来给大家分享分享下。不会排版，第一次发，就直接贴代码了


View Code


  1 using System;
  2 using System.Collections.Generic;
  3 using System.Text;
  4 using System.Configuration;
  5 using System.Net;
  6 using System.IO;
  7
  8 namespace MirroringDownClass
  9 {
10     public class EasyononFtp
11     {
12         public  delegate void delegt(string s);
13         public static event delegt onprogressBar;
14         #region 成员
15         
16        
17         private static string ftpServer ;  //ftp服务器地址
18         private static string user;  //用户名
19         private static string pwd;  //密码
20         #endregion
21
22         FtpWebRequest reqFTP;
23         FtpWebResponse ftpResponse;
24         #region 构造函数
25         
26         public EasyononFtp()
27         {
28         }
29         public EasyononFtp(string ftpUri, string username, string password)
30         {
31             ftpServer = ftpUri;
32             user = username;
33             pwd = password;
34         }
35
36         #endregion
37         #region FTP连接
38         
39         ///
40         /// Ftp的连接
41         ///
42         /// ftp的地址
43         /// bool
44         public  bool ftpconn()
45         {
46             try
47             {
48                 reqFTP = getFTPwbRequest(ftpServer, WebRequestMethods.Ftp.ListDirectoryDetails);
49                 ftpResponse = (FtpWebResponse)reqFTP.GetResponse();
50                 return true;
51             }
52             catch (Exception ex)
53             {
54                 Common.debugPrint(ex.Message.ToString());
55             }
56             finally
57             {
58                 if (ftpResponse != null)
59                 {
60                     ftpResponse.Close();
61                 }
62             }
63             return false;
64         }
65         #endregion
66         #region 下载FTP文件函数
67        ///
68         /// 下载
69        ///
70        /// 本地文件目录
71        /// FTP服务器文件目录
72        /// 带相对路径的文件名
73        ///
74         public bool ftpGetFile(string desfilePath, string ftpfilePath, string fileName)
75         {
76             string Relative_path = fileName.Replace("\\", "/");
77             string filenamepath = ftpfilePath + "/" + Relative_path;
78             try
79             {
80                 if (ftpconn())
81                 {
82                     Common.debugPrint(filenamepath + "下载中");
83                     reqFTP = getFTPwbRequest(filenamepath, WebRequestMethods.Ftp.DownloadFile);
84                     FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
85                     Stream ftpStream = response.GetResponseStream();//FTP数据流
86                     if (outputStream(desfilePath + "\\" + fileName, ftpStream))//字符流处理方法
87                     {
88                         ftpStream.Close();
89                         response.Close();
90                         Common.debugPrint(filenamepath + "下载完成！！！");
91                         return true;
92                     }
93                     else
94                         return false;
95                 }
96                 else
97                 {
98                     Common.debugPrint("ftpconn()连接失败");
99                     return false;
100                 }
101             }
102             catch (Exception ex)
103             {
104                 Common.debugPrint(ex.Message.ToString() + "查看ftpGetFile函数");
105                 return false;
106             }
107         }
108         #endregion
109         #region 重写FTP下载函数
110       ///
111         /// 重写下载方法
112       ///
113       /// 本地文件全路径
114       /// ftp服务器文件全路径
115       ///
116         public bool ftpGetFile(string localFile, string ftpFile)
117         {
118             try
119             {
120                 if (ftpconn())
121                 {
122                     reqFTP = getFTPwbRequest(ftpFile, WebRequestMethods.Ftp.DownloadFile);
123                     FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
124                     Stream ftpStream = response.GetResponseStream();
125                     if (outputStream(localFile, ftpStream))//字符流处理方法
126                     {
127                         ftpStream.Close();
128                         response.Close();
129                         return true;
130                     }
131                     else
132                     {
133                         ftpStream.Close();
134                         response.Close();
135                         return false;
136                     }
137                 }
138                 else
139                 {
140                     Common.debugPrint("ftpconn()连接失败");
141                     return false;
142                 }
143                 
144             }
145             catch (Exception ex)
146             {
147                 Common.debugPrint(ex.Message.ToString());
148                 return false;
149             }
150         }
151        #endregion
152         #region 断点续传
153         
154         
155         ///
156         /// 断点续传(下载)
157         ///
158         /// 本地文件路径
159         /// FTP文件路径
160         /// bool
161         public bool ftpGetBrokenFile(string localFile, string ftpFile)
162         {
163             try
164             {
165                 if (File.Exists(localFile))
166                 {
167                     FileInfo fileinfo = new FileInfo(localFile);
168                     long leng = fileinfo.Length;
169                     if (ftpconn())
170                     {
171                         if (leng < GetftpFilesLength(ftpFile) && leng < 1024 * 10000)
172                         {
173                             File.Delete(localFile);//删除重传
174                             Common.debugPrint(localFile + "删除重传");
175                             return ftpGetFile(localFile, ftpFile);//调用ftpGetFile
176                         }
177                         else// 断点续传                                                     
178                         {
179                             reqFTP = getFTPwbRequest(ftpFile, WebRequestMethods.Ftp.DownloadFile);
180                             reqFTP.ContentOffset = leng;
181                             FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
182                             Stream ftpStream = response.GetResponseStream();
183                             if (outputStream(localFile, ftpStream))//字符流处理方法
184                             {
185                                 ftpStream.Close();
186                                 response.Close();
187                                 Common.debugPrint(localFile + "断点续传完成");
188                                 return true;
189                             }
190                             else
191                             {
192                                 Common.debugPrint(localFile + "断点续传失败");
193                                 return false;
194                             }
195                         }
196                     }
197                     else
198                     {
199                         Common.debugPrint("ftpconn()连接失败");
200                         return false;
201                     }
202                 }
203                 else
204                 {
205                     return ftpGetFile(localFile, ftpFile);//调用ftpGetFile
206                 }
207             }
208             catch (Exception ex)
209             {
210                 Common.debugPrint(ex.Message.ToString()+"EasyonFtp类");
211                 return false;
212             }
213         }
214         #endregion
215         #region FTP上传
216         ///
217         ///  FTP上传方法
218         ///
219         /// 本地文件全路径
220         /// 上传到ftp服务器的指定路径
221         /// 断点处
222         ///
223         public bool ftpUpload(string localFile, string ftpFile, long Breakpoint)
224         {
225             if (Breakpoint > 0)
226             {
227                 reqFTP = getFTPwbRequest(ftpFile, WebRequestMethods.Ftp.AppendFile);
228             }
229             else
230             {
231                 reqFTP = getFTPwbRequest(ftpFile, WebRequestMethods.Ftp.UploadFile);
232             }
233             FileInfo fileinfo = new FileInfo(localFile);
234             Stream strm = reqFTP.GetRequestStream();
235             try
236             {
237                 // 上传文件时通知服务器文件的大小
238                 reqFTP.ContentLength = fileinfo.Length;
239                 //这里判断是否是断点续传
240
241                 if (inputStream(localFile, strm, Breakpoint))
242                 {
243                     return true;
244                 }
245                 else
246                 {
247                     Common.debugPrint("outputStream处理异常");
248                     return false;
249                 }
250             }
251             catch (Exception ex)
252             {
253                 Common.debugPrint(ex.Message);
254             }
255             finally
256             {
257                 strm.Close();
258             }
259             return false;
260         }
261
262         ///
263         /// 创建文件夹   （1J目录）
264         ///
265         ///
266         public bool MaikDir(string ftpFile)
267         {
268             FtpWebResponse response = null;
269             try
270             {
271                 string uri = ftpFile;
272                 //Connect(uri);//连接
273                 reqFTP = getFTPwbRequest(ftpFile, WebRequestMethods.Ftp.MakeDirectory);
274                // reqFTP.Method = WebRequestMethods.Ftp.MakeDirectory;
275                response = (FtpWebResponse)reqFTP.GetResponse();      
276             }
277             catch (Exception ex)
278             {
279                 return false;
280                // MessageBox.Show(ex.Message);
281             }
282             finally
283             {
284                 if (response != null)
285                 {
286                     response.Close();
287                 }
288             }
289             return true;
290
291         }
292         #endregion
293         #region  获取ftp上文件最后修改时间
294         
295         ///
296         /// 获取ftp上文件最后修改时间
297         ///
298         ///
299         ///
300         public DateTime GetftpFileslastModifiedTime(string filename)
301         {
302             DateTime lastmodified = new DateTime();
303             try
304             {
305                 if (ftpconn())
306                 {
307                     reqFTP = getFTPwbRequest(filename, WebRequestMethods.Ftp.GetDateTimestamp);
308                     FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
309                     lastmodified = response.LastModified;
310                     response.Close();
311                 }
312             }
313             catch (Exception ex)
314             {
315                 Common.debugPrint(ex.Message + "EasyonFtp类 GetftpFileslastModifiedTime()");
316             }
317             return lastmodified;
318         }
319         #endregion
320         #region 获取FTP文件的长度
321         
322         
323         public long GetftpFilesLength(string filename)
324         {
325             long length = 0;
326             try
327             {
328                 if (ftpconn())
329                 {
330                     reqFTP = getFTPwbRequest(filename, WebRequestMethods.Ftp.GetFileSize);
331                     FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
332                     length = response.ContentLength;
333                 }
334             }
335             catch (Exception ex)
336             {
337                 Common.debugPrint(ex.Message + "EasyonFtp类 GetftpFilesLength() ");
338             }
339             return length;
340         }
341         #endregion
342         #region 获取ftp目录下文件信息
343
344         ///
345         /// 获取ftp目录下文件和文件夹信息(只获取当前目录信息)
346         ///
347         /// ftp目录
348         ///
349         public FileStruct[] ftpListFiles(string ftpFile)
350         {
351           
352             FileStruct[] list = null;
353             try
354             {
355                 if (ftpconn())
356                 {
357                     reqFTP = getFTPwbRequest(ftpFile, WebRequestMethods.Ftp.ListDirectoryDetails);
358                     FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
359                     StreamReader stream = new StreamReader(response.GetResponseStream(), Encoding.Default);
360                     string Datastring = stream.ReadToEnd();
361                     DirectoryListParser parser = new DirectoryListParser(Datastring);
362                     list = parser.FullListing;
363                     response.Close();
364                     //char[] seperator = { '\n' };
365                     //list = Datastring.Split(seperator);
366                     
367                     return list;
368                 }
369             }
370             catch (Exception ex)
371             {
372                 Common.debugPrint(ex.Message + "EasyonFtp类 GetftpFilesLength()");
373             }
374             return list;
375         }
376         #endregion
377         #region FtpWebRequest请求
378  
379         ///
380         /// 获取FtpWebRequest
381         ///
382         /// ftp文件/目录路径
383         /// WebRequestMethods.Ftp.Method
384         ///
385         public FtpWebRequest getFTPwbRequest(string ftpFilepath, string Method)
386         {
387             try
388             {
389                 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpFilepath));
390                 reqFTP.Method = Method;
391                 reqFTP.KeepAlive = true;
392                 reqFTP.UseBinary = true;
393             }
394             catch (Exception ex)
395             {
396                 Common.debugPrint(ex.Message + "EasyononFtp获取FtpWebRequest失败");
397                 return null;
398             }
399             try
400             {
401                 reqFTP.Credentials = new NetworkCredential(user, pwd);
402                 
403             }
404             catch (Exception ex)
405             {
406                 Common.debugPrint(ex.Message);
407             }
408             return reqFTP;
409
410         }
411         public FtpWebRequest getFTPwbRequest1(string ftpFilepath, string Method)
412         {
413             try
414             {
415                 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpFilepath));
416                 reqFTP.Method = Method;
417                 //reqFTP.KeepAlive = true;
418                 reqFTP.UseBinary = true;
419             }
420             catch (Exception ex)
421             {
422                 Common.debugPrint(ex.Message + "EasyononFtp获取FtpWebRequest失败");
423                 return null;
424             }
425             try
426             {
427                 reqFTP.Credentials = new NetworkCredential(user, pwd);
428
429             }
430             catch (Exception ex)
431             {
432                 Common.debugPrint(ex.Message);
433             }
434             return reqFTP;
435
436         }
437         #endregion
438         #region 下载文件流输出处理
439
440         ///
441         /// 下载文件流输出处理方法
442         ///
443         /// ftp文件路径
444         /// IO流
445         ///
446         private bool outputStream(string filePath, Stream ftpStream)
447         {
448             FileStream outputStream  = new FileStream(filePath, FileMode.Append, FileAccess.Write);
449            
450             int bufferSize = 2048*1000;
451
452             int readCount;
453
454             byte[] buffer = new byte[bufferSize];
455             try
456             {
457                 readCount = ftpStream.Read(buffer, 0, bufferSize);
458                 while (readCount > 0)
459                 {
460                     outputStream.Write(buffer, 0, readCount);
461                     readCount = ftpStream.Read(buffer, 0, bufferSize);
462                 }
463                 return true;
464             }
465             catch (Exception ex)
466             {
467                 Common.debugPrint(ex.Message.ToString() + "EasyononFtp类下载文件流输出处理方法异常");
468                 return false;
469             }
470             finally
471             {
472                 outputStream.Close();
473             }
474         }
475         #endregion
476         #region 上传文件流输出处理
477        ///
478         /// 上传文件流输出处理方法
479        ///
480        /// 文件信息
481        /// IO流
482        ///
483         private bool inputStream(string filePath, Stream ftpStream, long Breakpoint)
484         {
485            
486             // 打开一个文件流(System.IO.FileStream) 去读上传的文件
487             FileStream outputStream = new FileStream(filePath, FileMode.Open);
488            
489             // 缓冲大小设置为kb
490             int bufferSize = 2048 * 1000;
491
492             int readCount;
493
494             byte[] buffer = new byte[bufferSize];
495             try
496             {
497                 if (Breakpoint > 0)
498                 {
499                     outputStream.Seek(Breakpoint, SeekOrigin.Current);
500                     
501                    
502                 }
503                 
504                     readCount = outputStream.Read(buffer, 0, bufferSize);
505                 
506                 while (readCount > 0)
507                 {
508                     // 把内容从file stream 写入upload stream
509                     ftpStream.Write(buffer, 0, readCount);
510                     readCount = outputStream.Read(buffer, 0, bufferSize);
511                  
512                    //
513                 }
514                 
515                 return true;
516             }
517             catch (Exception ex)
518             {
519                 Common.debugPrint(ex.Message.ToString() + "上传文件流输出处理方法异常");
520                 return false;
521             }
522             finally
523             {
524                 outputStream.Close();
525             }
526         }
527         #endregion
528        
529     }
530 }
　　如果有哪位大大能给排本提供帮助，在园子逛的也蛮久了，发现很多都排的挺漂亮的。