C#操作FTP, FTPHelper和SFTPHelper

花蜻宽

　　1. FTPHelper





  1 using System;
  2 using System.Collections.Generic;
  3 using System.IO;
  4 using System.Net;
  5 using System.Text;
  6
  7 public class FTPHelper
  8     {
  9         ///
10         /// 上传文件
11         ///
12         /// 需要上传的文件
13         /// 目标路径
14         /// ftp地址
15         /// ftp用户名
16         /// ftp密码
17         public static void UploadFile(FileInfo fileinfo, string targetDir, string hostname, string username, string password)
18         {
19             //1. check target
20             string target;
21             if (targetDir.Trim() == "")
22             {
23                 return;
24             }
25             string filename = fileinfo.Name;
26             if (!string.IsNullOrEmpty(filename))
27                 target = filename;
28             else
29                 target = Guid.NewGuid().ToString();  //使用临时文件名
30
31             string URI = "FTP://" + hostname + "/" + targetDir + "/" + target;
32             ///WebClient webcl = new WebClient();
33             System.Net.FtpWebRequest ftp = GetRequest(URI, username, password);
34
35             //设置FTP命令 设置所要执行的FTP命令，
36             //ftp.Method = System.Net.WebRequestMethods.Ftp.ListDirectoryDetails;//假设此处为显示指定路径下的文件列表
37             ftp.Method = System.Net.WebRequestMethods.Ftp.UploadFile;
38             //指定文件传输的数据类型
39             ftp.UseBinary = true;
40             ftp.UsePassive = true;
41
42             //告诉ftp文件大小
43             ftp.ContentLength = fileinfo.Length;
44             //缓冲大小设置为2KB
45             const int BufferSize = 2048;
46             byte[] content = new byte[BufferSize - 1 + 1];
47             int dataRead;
48
49             //打开一个文件流 (System.IO.FileStream) 去读上传的文件
50             using (FileStream fs = fileinfo.OpenRead())
51             {
52                 try
53                 {
54                     //把上传的文件写入流
55                     using (Stream rs = ftp.GetRequestStream())
56                     {
57                         do
58                         {
59                             //每次读文件流的2KB
60                             dataRead = fs.Read(content, 0, BufferSize);
61                             rs.Write(content, 0, dataRead);
62                         } while (!(dataRead < BufferSize));
63                         rs.Close();
64                     }
65
66                 }
67                 catch (Exception ex) { }
68                 finally
69                 {
70                     fs.Close();
71                 }
72
73             }
74
75             ftp = null;
76         }
77
78         ///
79         /// 下载文件
80         ///
81         /// 下载至本地路径
82         /// ftp目标文件路径
83         /// 从ftp要下载的文件名
84         /// ftp地址即IP
85         /// ftp用户名
86         /// ftp密码
87         public static void DownloadFile(string localDir, string FtpDir, string FtpFile, string hostname, string username, string password)
88         {
89             string URI = "FTP://" + hostname + "/" + FtpDir + "/" + FtpFile;
90             string tmpname = Guid.NewGuid().ToString();
91             string localfile = localDir + @"\" + tmpname;
92
93             System.Net.FtpWebRequest ftp = GetRequest(URI, username, password);
94             ftp.Method = System.Net.WebRequestMethods.Ftp.DownloadFile;
95             ftp.UseBinary = true;
96             ftp.UsePassive = false;
97
98             using (FtpWebResponse response = (FtpWebResponse)ftp.GetResponse())
99             {
100                 using (Stream responseStream = response.GetResponseStream())
101                 {
102                     //loop to read & write to file
103                     using (FileStream fs = new FileStream(localfile, FileMode.CreateNew))
104                     {
105                         try
106                         {
107                             byte[] buffer = new byte[2048];
108                             int read = 0;
109                             do
110                             {
111                                 read = responseStream.Read(buffer, 0, buffer.Length);
112                                 fs.Write(buffer, 0, read);
113                             } while (!(read == 0));
114                             responseStream.Close();
115                             fs.Flush();
116                             fs.Close();
117                         }
118                         catch (Exception)
119                         {
120                             //catch error and delete file only partially downloaded
121                             fs.Close();
122                             //delete target file as it's incomplete
123                             File.Delete(localfile);
124                             throw;
125                         }
126                     }
127
128                     responseStream.Close();
129                 }
130
131                 response.Close();
132             }
133
134
135
136             try
137             {
138                 File.Delete(localDir + @"\" + FtpFile);
139                 File.Move(localfile, localDir + @"\" + FtpFile);
140
141
142                 ftp = null;
143                 ftp = GetRequest(URI, username, password);
144                 ftp.Method = System.Net.WebRequestMethods.Ftp.DeleteFile;
145                 ftp.GetResponse();
146
147             }
148             catch (Exception ex)
149             {
150                 File.Delete(localfile);
151                 throw ex;
152             }
153
154             // 记录日志 "从" + URI.ToString() + "下载到" + localDir + @"\" + FtpFile + "成功." );
155             ftp = null;
156         }
157
158
159         ///
160         /// 下载文件
161         ///
162         /// 下载至本地路径
163         /// ftp目标文件路径
164         /// 从ftp要下载的文件名
165         /// ftp地址即IP
166         /// ftp用户名
167         /// ftp密码
168         public static byte[] DownloadFileBytes(string localDir, string FtpDir, string FtpFile, string hostname, string username, string password)
169         {
170             byte[] bts;
171             string URI = "FTP://" + hostname + "/" + FtpDir + "/" + FtpFile;
172             string tmpname = Guid.NewGuid().ToString();
173             string localfile = localDir + @"\" + tmpname;
174
175             System.Net.FtpWebRequest ftp = GetRequest(URI, username, password);
176             ftp.Method = System.Net.WebRequestMethods.Ftp.DownloadFile;
177             ftp.UseBinary = true;
178             ftp.UsePassive = true;
179
180             using (FtpWebResponse response = (FtpWebResponse)ftp.GetResponse())
181             {
182                 using (Stream responseStream = response.GetResponseStream())
183                 {
184                     //loop to read & write to file
185                     using (MemoryStream fs = new MemoryStream())
186                     {
187                         try
188                         {
189                             byte[] buffer = new byte[2048];
190                             int read = 0;
191                             do
192                             {
193                                 read = responseStream.Read(buffer, 0, buffer.Length);
194                                 fs.Write(buffer, 0, read);
195                             } while (!(read == 0));
196                             responseStream.Close();
197
198                             //---
199                             byte[] mbt = new byte[fs.Length];
200                             fs.Read(mbt, 0, mbt.Length);
201
202                             bts = mbt;
203                             //---
204                             fs.Flush();
205                             fs.Close();
206                         }
207                         catch (Exception)
208                         {
209                             //catch error and delete file only partially downloaded
210                             fs.Close();
211                             //delete target file as it's incomplete
212                             File.Delete(localfile);
213                             throw;
214                         }
215                     }
216
217                     responseStream.Close();
218                 }
219
220                 response.Close();
221             }
222
223             ftp = null;
224             return bts;
225         }
226
227         ///
228         /// 搜索远程文件
229         ///
230         ///
231         ///
232         ///
233         ///
234         ///
235         ///
236         public static List ListDirectory(string targetDir, string hostname, string username, string password, string SearchPattern)
237         {
238             List result = new List();
239             try
240             {
241                 string URI = "FTP://" + hostname + "/" + targetDir + "/" + SearchPattern;
242
243                 System.Net.FtpWebRequest ftp = GetRequest(URI, username, password);
244                 ftp.Method = System.Net.WebRequestMethods.Ftp.ListDirectory;
245                 ftp.UsePassive = true;
246                 ftp.UseBinary = true;
247
248
249                 string str = GetStringResponse(ftp);
250                 str = str.Replace("\r\n", "\r").TrimEnd('\r');
251                 str = str.Replace("\n", "\r");
252                 if (str != string.Empty)
253                     result.AddRange(str.Split('\r'));
254
255                 return result;
256             }
257             catch { }
258             return null;
259         }
260
261         private static string GetStringResponse(FtpWebRequest ftp)
262         {
263             //Get the result, streaming to a string
264             string result = "";
265             using (FtpWebResponse response = (FtpWebResponse)ftp.GetResponse())
266             {
267                 long size = response.ContentLength;
268                 using (Stream datastream = response.GetResponseStream())
269                 {
270                     using (StreamReader sr = new StreamReader(datastream, System.Text.Encoding.Default))
271                     {
272                         result = sr.ReadToEnd();
273                         sr.Close();
274                     }
275
276                     datastream.Close();
277                 }
278
279                 response.Close();
280             }
281
282             return result;
283         }
284
285         /// 在ftp服务器上创建目录
286         ///
287         /// 创建的目录名称
288         /// ftp地址
289         /// 用户名
290         /// 密码
291         public void MakeDir(string dirName, string ftpHostIP, string username, string password)
292         {
293             try
294             {
295                 string uri = "ftp://" + ftpHostIP + "/" + dirName;
296                 System.Net.FtpWebRequest ftp = GetRequest(uri, username, password);
297                 ftp.Method = WebRequestMethods.Ftp.MakeDirectory;
298
299                 FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
300                 response.Close();
301             }
302             catch (Exception ex)
303             {
304                 throw new Exception(ex.Message);
305             }
306         }
307
308         ///
309         /// 删除文件
310         ///
311         /// 创建的目录名称
312         /// ftp地址
313         /// 用户名
314         /// 密码
315         public static void delFile(string dirName, string filename, string ftpHostIP, string username, string password)
316         {
317             try
318             {
319                 string uri = "ftp://" + ftpHostIP + "/";
320                 if (!string.IsNullOrEmpty(dirName)) {
321                     uri += dirName + "/";
322                 }
323                 uri += filename;
324                 System.Net.FtpWebRequest ftp = GetRequest(uri, username, password);
325                 ftp.Method = WebRequestMethods.Ftp.DeleteFile;
326                 FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
327                 response.Close();
328             }
329             catch (Exception ex)
330             {
331                 throw new Exception(ex.Message);
332             }
333         }
334
335         ///
336         /// 删除目录
337         ///
338         /// 创建的目录名称
339         /// ftp地址
340         /// 用户名
341         /// 密码
342         public void delDir(string dirName, string ftpHostIP, string username, string password)
343         {
344             try
345             {
346                 string uri = "ftp://" + ftpHostIP + "/" + dirName;
347                 System.Net.FtpWebRequest ftp = GetRequest(uri, username, password);
348                 ftp.Method = WebRequestMethods.Ftp.RemoveDirectory;
349                 FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
350                 response.Close();
351             }
352             catch (Exception ex)
353             {
354                 throw new Exception(ex.Message);
355             }
356         }
357
358         ///
359         /// 文件重命名
360         ///
361         /// 当前目录名称
362         /// 重命名目录名称
363         /// ftp地址
364         /// 用户名
365         /// 密码
366         public void Rename(string currentFilename, string newFilename, string ftpServerIP, string username, string password)
367         {
368             try
369             {
370
371                 FileInfo fileInf = new FileInfo(currentFilename);
372                 string uri = "ftp://" + ftpServerIP + "/" + fileInf.Name;
373                 System.Net.FtpWebRequest ftp = GetRequest(uri, username, password);
374                 ftp.Method = WebRequestMethods.Ftp.Rename;
375
376                 ftp.RenameTo = newFilename;
377                 FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
378
379                 response.Close();
380             }
381             catch (Exception ex)
382             {
383                 throw new Exception(ex.Message);
384             }
385         }
386
387         private static FtpWebRequest GetRequest(string URI, string username, string password)
388         {
389             //根据服务器信息FtpWebRequest创建类的对象
390             FtpWebRequest result = (FtpWebRequest)FtpWebRequest.Create(URI);
391             //提供身份验证信息
392             result.Credentials = new System.Net.NetworkCredential(username, password);
393             //设置请求完成之后是否保持到FTP服务器的控制连接，默认值为true
394             result.KeepAlive = false;
395             return result;
396         }
397
398         /*
399         ///
400         /// 向Ftp服务器上传文件并创建和本地相同的目录结构
401         /// 遍历目录和子目录的文件
402         ///
403         ///
404         private void GetFileSystemInfos(FileSystemInfo file)
405         {
406             string getDirecName = file.Name;
407             if (!ftpIsExistsFile(getDirecName, "192.168.0.172", "Anonymous", "") && file.Name.Equals(FileName))
408             {
409                 MakeDir(getDirecName, "192.168.0.172", "Anonymous", "");
410             }
411             if (!file.Exists) return;
412             DirectoryInfo dire = file as DirectoryInfo;
413             if (dire == null) return;
414             FileSystemInfo[] files = dire.GetFileSystemInfos();
415
416             for (int i = 0; i < files.Length; i++)
417             {
418                 FileInfo fi = files as FileInfo;
419                 if (fi != null)
420                 {
421                     DirectoryInfo DirecObj = fi.Directory;
422                     string DireObjName = DirecObj.Name;
423                     if (FileName.Equals(DireObjName))
424                     {
425                         UploadFile(fi, DireObjName, "192.168.0.172", "Anonymous", "");
426                     }
427                     else
428                     {
429                         Match m = Regex.Match(files.FullName, FileName + "+.*" + DireObjName);
430                         //UploadFile(fi, FileName+"/"+DireObjName, "192.168.0.172", "Anonymous", "");
431                         UploadFile(fi, m.ToString(), "192.168.0.172", "Anonymous", "");
432                     }
433                 }
434                 else
435                 {
436                     string[] ArrayStr = files.FullName.Split('\\');
437                     string finame = files.Name;
438                     Match m = Regex.Match(files.FullName, FileName + "+.*" + finame);
439                     //MakeDir(ArrayStr[ArrayStr.Length - 2].ToString() + "/" + finame, "192.168.0.172", "Anonymous", "");
440                     MakeDir(m.ToString(), "192.168.0.172", "Anonymous", "");
441                     GetFileSystemInfos(files);
442                 }
443             }
444         }
445          * */
446
447         ///
448         /// 判断ftp服务器上该目录是否存在
449         ///
450         ///
451         ///
452         ///
453         ///
454         ///
455         private bool ftpIsExistsFile(string dirName, string ftpHostIP, string username, string password)
456         {
457             bool flag = true;
458             try
459             {
460                 string uri = "ftp://" + ftpHostIP + "/" + dirName;
461                 System.Net.FtpWebRequest ftp = GetRequest(uri, username, password);
462                 ftp.Method = WebRequestMethods.Ftp.ListDirectory;
463
464                 FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
465                 response.Close();
466             }
467             catch (Exception)
468             {
469                 flag = false;
470             }
471             return flag;
472         }
473     }
View Code 　　
2. SFTPHelper
　　SFTPHelper采用第三方的Tamir.SharpSSH.dll
　　下载地址: http://www.tamirgal.com/blog/page/SharpSSH.aspx





  1 using System;
  2 using Tamir.SharpSsh.jsch;
  3 using System.Collections;
  4
  5
  6 public class SFTPHelper
  7 {
  8     private Session m_session;
  9     private Channel m_channel;
10     private ChannelSftp m_sftp;
11
12     //host:sftp地址   user：用户名   pwd：密码        
13     public SFTPHelper(string host, string user, string pwd)
14     {
15         string[] arr = host.Split(':');
16         string ip = arr[0];
17         int port = 22;
18         if (arr.Length > 1) port = Int32.Parse(arr[1]);
19
20         JSch jsch = new JSch();
21         m_session = jsch.getSession(user, ip, port);
22         MyUserInfo ui = new MyUserInfo();
23         ui.setPassword(pwd);
24         m_session.setUserInfo(ui);
25
26     }
27
28     //SFTP连接状态        
29     public bool Connected { get { return m_session.isConnected(); } }
30
31     //连接SFTP        
32     public bool Connect()
33     {
34         try
35         {
36             if (!Connected)
37             {
38                 m_session.connect();
39                 m_channel = m_session.openChannel("sftp");
40                 m_channel.connect();
41                 m_sftp = (ChannelSftp)m_channel;
42             }
43             return true;
44         }
45         catch
46         {
47             return false;
48         }
49     }
50
51     //断开SFTP        
52     public void Disconnect()
53     {
54         if (Connected)
55         {
56             m_channel.disconnect();
57             m_session.disconnect();
58         }
59     }
60
61     //SFTP存放文件        
62     public bool Put(string localPath, string remotePath)
63     {
64         try
65         {
66             Tamir.SharpSsh.java.String src = new Tamir.SharpSsh.java.String(localPath);
67             Tamir.SharpSsh.java.String dst = new Tamir.SharpSsh.java.String(remotePath);
68             m_sftp.put(src, dst);
69             return true;
70         }
71         catch
72         {
73             return false;
74         }
75     }
76
77     //SFTP获取文件        
78     public bool Get(string remotePath, string localPath)
79     {
80         try
81         {
82             Tamir.SharpSsh.java.String src = new Tamir.SharpSsh.java.String(remotePath);
83             Tamir.SharpSsh.java.String dst = new Tamir.SharpSsh.java.String(localPath);
84             m_sftp.get(src, dst);
85             return true;
86         }
87         catch
88         {
89             return false;
90         }
91     }
92     //删除SFTP文件
93     public bool Delete(string remoteFile)
94     {
95         try
96         {
97             m_sftp.rm(remoteFile);
98             return true;
99         }
100         catch
101         {
102             return false;
103         }
104     }
105
106     //获取SFTP文件列表        
107     public ArrayList GetFileList(string remotePath, string fileType)
108     {
109         try
110         {
111             Tamir.SharpSsh.java.util.Vector vvv = m_sftp.ls(remotePath);
112             ArrayList objList = new ArrayList();
113             foreach (Tamir.SharpSsh.jsch.ChannelSftp.LsEntry qqq in vvv)
114             {
115                 string sss = qqq.getFilename();
116                 if (sss.Length > (fileType.Length + 1) && fileType == sss.Substring(sss.Length - fileType.Length))
117                 { objList.Add(sss); }
118                 else { continue; }
119             }
120
121             return objList;
122         }
123         catch
124         {
125             return null;
126         }
127     }
128
129
130     //登录验证信息        
131     public class MyUserInfo : UserInfo
132     {
133         String passwd;
134         public String getPassword() { return passwd; }
135         public void setPassword(String passwd) { this.passwd = passwd; }
136
137         public String getPassphrase() { return null; }
138         public bool promptPassphrase(String message) { return true; }
139
140         public bool promptPassword(String message) { return true; }
141         public bool promptYesNo(String message) { return true; }
142         public void showMessage(String message) { }
143     }
144
145
146 }
View Code