参考了网上一些代码，作了一些调整优化。
001 |
using System; |
002 |
using System.Collections.Generic; |
003 |
using System.Linq; |
004 |
using System.Text; |
005 |
using System.Net; |
006 |
using System.IO; |
007 |
008 |
public class FTPHelper |
009 |
{ |
010 |
/// <summary> |
011 |
/// FTP请求对象 |
012 |
/// </summary> |
013 |
FtpWebRequest request = null; |
014 |
/// <summary> |
015 |
/// FTP响应对象 |
016 |
/// </summary> |
017 |
FtpWebResponse response = null; |
018 |
/// <summary> |
019 |
/// FTP服务器地址 |
020 |
/// </summary> |
021 |
public string ftpURI { get; private set; } |
022 |
/// <summary> |
023 |
/// FTP服务器IP |
024 |
/// </summary> |
025 |
public string ftpServerIP { get; private set; } |
026 |
/// <summary> |
027 |
/// FTP服务器默认目录 |
028 |
/// </summary> |
029 |
public string ftpRemotePath { get; private set; } |
030 |
/// <summary> |
031 |
/// FTP服务器登录用户名 |
032 |
/// </summary> |
033 |
public string ftpUserID { get; private set; } |
034 |
/// <summary> |
035 |
/// FTP服务器登录密码 |
036 |
/// </summary> |
037 |
public string ftpPassword { get; private set; } |
038 |
039 |
/// <summary> |
040 |
/// 初始化 |
041 |
/// </summary> |
042 |
/// <param name="FtpServerIP">FTP连接地址</param> |
043 |
/// <param name="FtpRemotePath">指定FTP连接成功后的当前目录, 如果不指定即默认为根目录</param> |
044 |
/// <param name="FtpUserID">用户名</param> |
045 |
/// <param name="FtpPassword">密码</param> |
046 |
public FTPHelper(string ftpServerIP, string ftpRemotePath, string ftpUserID, stringftpPassword) |
047 |
{ |
048 |
this.ftpServerIP = ftpServerIP; |
049 |
this.ftpRemotePath = ftpRemotePath; |
050 |
this.ftpUserID = ftpUserID; |
051 |
this.ftpPassword = ftpPassword; |
052 |
this.ftpURI = "ftp://" + ftpServerIP + "/" + ftpRemotePath + "/"; |
053 |
} |
054 |
~FTPHelper() |
055 |
{ |
056 |
if (response != null) |
057 |
{ |
058 |
response.Close(); |
059 |
response = null; |
060 |
} |
061 |
if (request != null) |
062 |
{ |
063 |
request.Abort(); |
064 |
request = null; |
065 |
} |
066 |
} |
067 |
/// <summary> |
068 |
/// 建立FTP链接,返回响应对象 |
069 |
/// </summary> |
070 |
/// <param name="uri">FTP地址</param> |
071 |
/// <param name="ftpMethod">操作命令</param> |
072 |
/// <returns></returns> |
073 |
private FtpWebResponse Open(Uri uri, string ftpMethod) |
074 |
{ |
075 |
request = (FtpWebRequest)FtpWebRequest.Create(uri); |
076 |
request.Method = ftpMethod; |
077 |
request.UseBinary = true; |
078 |
request.KeepAlive = false; |
079 |
request.Credentials = new NetworkCredential(this.ftpUserID, this.ftpPassword); |
080 |
return (FtpWebResponse)request.GetResponse(); |
081 |
} |
082 |
083 |
/// <summary> |
084 |
/// 建立FTP链接,返回请求对象 |
085 |
/// </summary> |
086 |
/// <param name="uri">FTP地址</param> |
087 |
/// <param name="ftpMethod">操作命令</param> |
088 |
private FtpWebRequest OpenRequest(Uri uri, string ftpMethod) |
089 |
{ |
090 |
request = (FtpWebRequest)WebRequest.Create(uri); |
091 |
request.Method = ftpMethod; |
092 |
request.UseBinary = true; |
093 |
request.KeepAlive = false; |
094 |
request.Credentials = new NetworkCredential(this.ftpUserID, this.ftpPassword); |
095 |
return request; |
096 |
} |
097 |
/// <summary> |
098 |
/// 创建目录 |
099 |
/// </summary> |
100 |
/// <param name="remoteDirectoryName">目录名</param> |
101 |
public void CreateDirectory(string remoteDirectoryName) |
102 |
{ |
103 |
response = Open(newUri(ftpURI + remoteDirectoryName), WebRequestMethods.Ftp.MakeDirectory); |
104 |
} |
105 |
/// <summary> |
106 |
/// 更改目录或文件名 |
107 |
/// </summary> |
108 |
/// <param name="currentName">当前名称</param> |
109 |
/// <param name="newName">修改后新名称</param> |
110 |
public void ReName(string currentName, string newName) |
111 |
{ |
112 |
request = OpenRequest(newUri(ftpURI + currentName), WebRequestMethods.Ftp.Rename); |
113 |
request.RenameTo = newName; |
114 |
response = (FtpWebResponse)request.GetResponse(); |
115 |
} |
116 |
/// <summary> |
117 |
/// 切换当前目录 |
118 |
/// </summary> |
119 |
/// <param name="IsRoot">true:绝对路径 false:相对路径</param> |
120 |
public void GotoDirectory(string DirectoryName, bool IsRoot) |
121 |
{ |
122 |
if (IsRoot) |
123 |
ftpRemotePath = DirectoryName; |
124 |
else |
125 |
ftpRemotePath += "/" + DirectoryName; |
126 |
127 |
ftpURI = "ftp://" + ftpServerIP + "/" + ftpRemotePath + "/"; |
128 |
} |
129 |
/// <summary> |
130 |
/// 删除目录(包括下面所有子目录和子文件) |
131 |
/// </summary> |
132 |
/// <param name="remoteDirectoryName">要删除的带路径目录名：如web/test</param> |
133 |
/* |
134 |
* 例：删除test目录 |
135 |
FTPHelper helper = new FTPHelper("x.x.x.x", "web", "user", "password"); |
136 |
helper.RemoveDirectory("web/test"); |
137 |
*/ |
138 |
public void RemoveDirectory(string remoteDirectoryName) |
139 |
{ |
140 |
GotoDirectory(remoteDirectoryName, true); |
141 |
var listAll = ListFilesAndDirectories(); |
142 |
foreach (var m in listAll) |
143 |
{ |
144 |
if(m.IsDirectory) |
145 |
RemoveDirectory(m.Path); |
146 |
else |
147 |
DeleteFile(m.Name); |
148 |
} |
149 |
GotoDirectory(remoteDirectoryName, true); |
150 |
response = Open(new Uri(ftpURI), WebRequestMethods.Ftp.RemoveDirectory); |
151 |
} |
152 |
/// <summary> |
153 |
/// 文件上传 |
154 |
/// </summary> |
155 |
/// <param name="localFilePath">本地文件路径</param> |
156 |
public void Upload(string localFilePath) |
157 |
{ |
158 |
FileInfo fileInf = new FileInfo(localFilePath); |
159 |
request = OpenRequest(newUri(ftpURI + fileInf.Name), WebRequestMethods.Ftp.UploadFile); |
160 |
request.ContentLength = fileInf.Length; |
161 |
int buffLength = 2048; |
162 |
byte[] buff = new byte[buffLength]; |
163 |
int contentLen; |
164 |
using (var fs = fileInf.OpenRead()) |
165 |
{ |
166 |
using (var strm = request.GetRequestStream()) |
167 |
{ |
168 |
contentLen = fs.Read(buff, 0, buffLength); |
169 |
while (contentLen != 0) |
170 |
{ |
171 |
strm.Write(buff, 0, contentLen); |
172 |
contentLen = fs.Read(buff, 0, buffLength); |
173 |
} |
174 |
} |
175 |
} |
176 |
} |
177 |
/// <summary> |
178 |
/// 删除文件 |
179 |
/// </summary> |
180 |
/// <param name="remoteFileName">要删除的文件名</param> |
181 |
public void DeleteFile(string remoteFileName) |
182 |
{ |
183 |
response = Open(newUri(ftpURI + remoteFileName), WebRequestMethods.Ftp.DeleteFile); |
184 |
} |
185 |
186 |
/// <summary> |
187 |
/// 获取当前目录的文件和一级子目录信息 |
188 |
/// </summary> |
189 |
/// <returns></returns> |
190 |
public List<FileStruct> ListFilesAndDirectories() |
191 |
{ |
192 |
var fileList = new List<FileStruct>(); |
193 |
response = Open(new Uri(ftpURI), WebRequestMethods.Ftp.ListDirectoryDetails); |
194 |
using (var stream = response.GetResponseStream()) |
195 |
{ |
196 |
using (var sr = new StreamReader(stream)) |
197 |
{ |
198 |
string line = null; |
199 |
while ((line = sr.ReadLine()) != null) |
200 |
{ |
201 |
//line的格式如下： |
202 |
//08-18-13 11:05PM <DIR> aspnet_client |
203 |
//09-22-13 11:39PM 2946 Default.aspx |
204 |
DateTime dtDate = DateTime.ParseExact(line.Substring(0, 8), "MM-dd-yy", null); |
205 |
DateTime dtDateTime = DateTime.Parse(dtDate.ToString("yyyy-MM-dd") + line.Substring(8, 9)); |
206 |
string[] arrs = line.Split(' '); |
207 |
var model = new FileStruct() |
208 |
{ |
209 |
IsDirectory = line.IndexOf("<DIR>") > 0 ? true : false, |
210 |
CreateTime = dtDateTime, |
211 |
Name = arrs[arrs.Length - 1], |
212 |
Path = ftpRemotePath + "/" + arrs[arrs.Length - 1] |
213 |
}; |
214 |
fileList.Add(model); |
215 |
} |
216 |
} |
217 |
} |
218 |
return fileList; |
219 |
} |
220 |
/// <summary> |
221 |
/// 列出当前目录的所有文件 |
222 |
/// </summary> |
223 |
public List<FileStruct> ListFiles() |
224 |
{ |
225 |
var listAll = ListFilesAndDirectories(); |
226 |
var listFile = listAll.Where(m => m.IsDirectory == false).ToList(); |
227 |
return listFile; |
228 |
} |
229 |
/// <summary> |
230 |
/// 列出当前目录的所有一级子目录 |
231 |
/// </summary> |
232 |
public List<FileStruct> ListDirectories() |
233 |
{ |
234 |
var listAll = ListFilesAndDirectories(); |
235 |
var listFile = listAll.Where(m => m.IsDirectory == true).ToList(); |
236 |
return listFile; |
237 |
} |
238 |
/// <summary> |
239 |
/// 判断当前目录下指定的子目录或文件是否存在 |
240 |
/// </summary> |
241 |
/// <param name="remoteName">指定的目录或文件名</param> |
242 |
public bool IsExist(string remoteName) |
243 |
{ |
244 |
var list = ListFilesAndDirectories(); |
245 |
if (list.Count(m => m.Name == remoteName) > 0) |
246 |
return true; |
247 |
return false; |
248 |
} |
249 |
/// <summary> |
250 |
/// 判断当前目录下指定的一级子目录是否存在 |
251 |
/// </summary> |
252 |
/// <param name="RemoteDirectoryName">指定的目录名</param> |
253 |
public bool IsDirectoryExist(string remoteDirectoryName) |
254 |
{ |
255 |
var listDir = ListDirectories(); |
256 |
if (listDir.Count(m => m.Name == remoteDirectoryName) > 0) |
257 |
return true; |
258 |
return false; |
259 |
} |
260 |
/// <summary> |
261 |
/// 判断当前目录下指定的子文件是否存在 |
262 |
/// </summary> |
263 |
/// <param name="RemoteFileName">远程文件名</param> |
264 |
public bool IsFileExist(string remoteFileName) |
265 |
{ |
266 |
var listFile = ListFiles(); |
267 |
if (listFile.Count(m => m.Name == remoteFileName) > 0) |
268 |
return true; |
269 |
return false; |
270 |
} |
271 |
272 |
/// <summary> |
273 |
/// 下载 |
274 |
/// </summary> |
275 |
/// <param name="saveFilePath">下载后的保存路径</param> |
276 |
/// <param name="downloadFileName">要下载的文件名</param> |
277 |
public void Download(string saveFilePath, string downloadFileName) |
278 |
{ |
279 |
using (FileStream outputStream = new FileStream(saveFilePath + "\"+ downloadFileName, FileMode.Create)) |
280 |
{ |
281 |
response = Open(newUri(ftpURI + downloadFileName), WebRequestMethods.Ftp.DownloadFile); |
282 |
using (Stream ftpStream = response.GetResponseStream()) |
283 |
{ |
284 |
long cl = response.ContentLength; |
285 |
int bufferSize = 2048; |
286 |
int readCount; |
287 |
byte[] buffer = new byte[bufferSize]; |
288 |
readCount = ftpStream.Read(buffer, 0, bufferSize); |
289 |
while (readCount > 0) |
290 |
{ |
291 |
outputStream.Write(buffer, 0, readCount); |
292 |
readCount = ftpStream.Read(buffer, 0, bufferSize); |
293 |
} |
294 |
} |
295 |
} |
296 |
} |
297 |
298 |
|
299 |
} |
300 |
301 |
public class FileStruct |
302 |
{ |
303 |
/// <summary> |
304 |
/// 是否为目录 |
305 |
/// </summary> |
306 |
public bool IsDirectory { get; set; } |
307 |
/// <summary> |
308 |
/// 创建时间 |
309 |
/// </summary> |
310 |
public DateTime CreateTime { get; set; } |
311 |
/// <summary> |
312 |
/// 文件或目录名称 |
313 |
/// </summary> |
314 |
public string Name { get; set; } |
315 |
/// <summary> |
316 |
/// 路径 |
317 |
/// </summary> |
318 |
public string Path { get; set; } |
319 |
} |