参考了网上一些代码，作了一些调整优化。
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 |
} |