FTP客户端类（C#）
最近在搞FTP，挺头大的，后来索性在网上找了个FTP的类，直接调用函数即可。由于网上的版本较多，我用的这个测试了下，比较好用。现共享给大家。1 using System;
2 using System.Net;
3 using System.IO;
4 using System.Text;
5 using System.Net.Sockets;
6
7 namespace WindowsFormsApplication1
8 {
9 public class FTPClient
10 {
11 #region 构造函数
12 ///
13 /// 缺省构造函数
14 ///
15 public FTPClient()
16 {
17 strRemoteHost = "";
18 strRemotePath = "";
19 strRemoteUser = "";
20 strRemotePass = "";
21 strRemotePort = 21;
22 bConnected = false;
23 }
24
25 ///
26 /// 构造函数
27 ///
28 ///
29 ///
30 ///
31 ///
32 ///
33 public FTPClient(string remoteHost, string remotePath, string remoteUser, string remotePass, int remotePort)
34 {
35 strRemoteHost = remoteHost;
36 strRemotePath = remotePath;
37 strRemoteUser = remoteUser;
38 strRemotePass = remotePass;
39 strRemotePort = remotePort;
40 Connect();
41 }
42 #endregion
43
44 #region 登陆
45 ///
46 /// FTP服务器IP地址
47 ///
48 private string strRemoteHost;
49 public string RemoteHost
50 {
51 get
52 {
53 return strRemoteHost;
54 }
55 set
56 {
57 strRemoteHost = value;
58 }
59 }
60 ///
61 /// FTP服务器端口
62 ///
63 private int strRemotePort;
64 public int RemotePort
65 {
66 get
67 {
68 return strRemotePort;
69 }
70 set
71 {
72 strRemotePort = value;
73 }
74 }
75 ///
76 /// 当前服务器目录
77 ///
78 private string strRemotePath;
79 public string RemotePath
80 {
81 get
82 {
83 return strRemotePath;
84 }
85 set
86 {
87 strRemotePath = value;
88 }
89 }
90 ///
91 /// 登录用户账号
92 ///
93 private string strRemoteUser;
94 public string RemoteUser
95 {
96 set
97 {
98 strRemoteUser = value;
99 }
100 }
101 ///
102 /// 用户登录密码
103 ///
104 private string strRemotePass;
105 public string RemotePass
106 {
107 set
108 {
109 strRemotePass = value;
110 }
111 }
112
113 ///
114 /// 是否登录
115 ///
116 private Boolean bConnected;
117 public bool Connected
118 {
119 get
120 {
121 return bConnected;
122 }
123 }
124 #endregion
125
126 #region 链接
127 ///
128 /// 建立连接
129 ///
130 public void Connect()
131 {
132 socketControl = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
133 IPEndPoint ep = new IPEndPoint(IPAddress.Parse(RemoteHost), strRemotePort);
134 // 链接
135 try
136 {
137 socketControl.Connect(ep);
138 }
139 catch (Exception)
140 {
141 throw new IOException("Couldn't connect to remote server");
142 }
143
144 // 获取应答码
145 ReadReply();
146 if (iReplyCode != 220)
147 {
148 DisConnect();
149 throw new IOException(strReply.Substring(4));
150 }
151
152 // 登陆
153 SendCommand("USER " + strRemoteUser);
154 if (!(iReplyCode == 331 || iReplyCode == 230))
155 {
156 CloseSocketConnect();//关闭连接
157 throw new IOException(strReply.Substring(4));
158 }
159 if (iReplyCode != 230)
160 {
161 SendCommand("PASS " + strRemotePass);
162 if (!(iReplyCode == 230 || iReplyCode == 202))
163 {
164 CloseSocketConnect();//关闭连接
165 throw new IOException(strReply.Substring(4));
166 }
167 }
168 bConnected = true;
169
170 // 切换到目录
171 ChDir(strRemotePath);
172 }
173
174
175 ///
176 /// 关闭连接
177 ///
178 public void DisConnect()
179 {
180 if (socketControl != null)
181 {
182 SendCommand("QUIT");
183 }
184 CloseSocketConnect();
185 }
186
187 #endregion
188
189 #region 传输模式
190
191 ///
192 /// 传输模式:二进制类型、ASCII类型
193 ///
194 public enum TransferType { Binary, ASCII };
195
196 ///
197 /// 设置传输模式
198 ///
199 /// 传输模式
200 public void SetTransferType(TransferType ttType)
201 {
202 if (ttType == TransferType.Binary)
203 {
204 SendCommand("TYPE I");//binary类型传输
205 }
206 else
207 {
208 SendCommand("TYPE A");//ASCII类型传输
209 }
210 if (iReplyCode != 200)
211 {
212 throw new IOException(strReply.Substring(4));
213 }
214 else
215 {
216 trType = ttType;
217 }
218 }
219
220
221 ///
222 /// 获得传输模式
223 ///
224 /// 传输模式
225 public TransferType GetTransferType()
226 {
227 return trType;
228 }
229
230 #endregion
231
232 #region 文件操作
233 ///
234 /// 获得文件列表
235 ///
236 /// 文件名的匹配字符串
237 ///
238 public string[] Dir(string strMask)
239 {
240 // 建立链接
241 if (!bConnected)
242 {
243 Connect();
244 }
245
246 //建立进行数据连接的socket
247 Socket socketData = CreateDataSocket();
248
249 //传送命令
250 SendCommand("NLST " + strMask);
251
252 //分析应答代码
253 if (!(iReplyCode == 150 || iReplyCode == 125 || iReplyCode == 226))
254 {
255 throw new IOException(strReply.Substring(4));
256 }
257
258 //获得结果
259 strMsg = "";
260 while (true)
261 {
262 int iBytes = socketData.Receive(buffer, buffer.Length, 0);
263 strMsg += Encoding.Default.GetString(buffer, 0, iBytes);
264 if (iBytes < buffer.Length)
265 {
266 break;
267 }
268 }
269 char[] seperator = "\r\n".ToCharArray();
270 string[] strsFileList = strMsg.Split(seperator, StringSplitOptions.RemoveEmptyEntries);
271 socketData.Close();//数据socket关闭时也会有返回码
272 if (iReplyCode != 226)
273 {
274 ReadReply();
275 if (iReplyCode != 226)
276 {
277 throw new IOException(strReply.Substring(4));
278 }
279 }
280 return strsFileList;
281 }
282
283
284 ///
285 /// 获取文件大小
286 ///
287 /// 文件名
288 /// 文件大小
289 private long GetFileSize(string strFileName)
290 {
291 if (!bConnected)
292 {
293 Connect();
294 }
295 SendCommand("SIZE " + Path.GetFileName(strFileName));
296 long lSize = 0;
297 if (iReplyCode == 213)
298 {
299 lSize = Int64.Parse(strReply.Substring(4));
300 }
301 else
302 {
303 throw new IOException(strReply.Substring(4));
304 }
305 return lSize;
306 }
307
308 ///
309 /// 获得文件详细信息列表
310 ///
311 /// 文件名的匹配字符串
312 ///
313 public string[] List(string strMask)
314 {
315 // 建立链接
316 if (!bConnected)
317 {
318 Connect();
319 }
320
321 //建立进行数据连接的socket
322 Socket socketData = CreateDataSocket();
323
324 //传送命令
325 SendCommand("LIST " + strMask);
326
327 //分析应答代码
328 if (!(iReplyCode == 150 || iReplyCode == 125 || iReplyCode == 226))
329 {
330 throw new IOException(strReply.Substring(4));
331 }
332
333 //获得结果
334 strMsg = "";
335 while (true)
336 {
337 int iBytes = socketData.Receive(buffer, buffer.Length, 0);
338 strMsg += Encoding.Default.GetString(buffer, 0, iBytes);
339 if (iBytes < buffer.Length)
340 {
341 break;
342 }
343 }
344 char[] seperator = "\r\n".ToCharArray();
345 string[] strsFileList = strMsg.Split(seperator, StringSplitOptions.RemoveEmptyEntries);
346 socketData.Close();//数据socket关闭时也会有返回码
347 if (iReplyCode != 226)
348 {
349 ReadReply();
350 if (iReplyCode != 226)
351 {
352 throw new IOException(strReply.Substring(4));
353 }
354 }
355 return strsFileList;
356 }
357
358
359 ///
360 /// 删除
361 ///
362 /// 待删除文件名
363 public void Delete(string strFileName)
364 {
365 if (!bConnected)
366 {
367 Connect();
368 }
369 SendCommand("DELE " + strFileName);
370 if (iReplyCode != 250)
371 {
372 throw new IOException(strReply.Substring(4));
373 }
374 }
375
376
377 ///
378 /// 重命名(如果新文件名与已有文件重名,将覆盖已有文件)
379 ///
380 /// 旧文件名
381 /// 新文件名
382 public void Rename(string strOldFileName, string strNewFileName)
383 {
384 if (!bConnected)
385 {
386 Connect();
387 }
388 SendCommand("RNFR " + strOldFileName);
389 if (iReplyCode != 350)
390 {
391 throw new IOException(strReply.Substring(4));
392 }
393 //如果新文件名与原有文件重名,将覆盖原有文件
394 SendCommand("RNTO " + strNewFileName);
395 if (iReplyCode != 250)
396 {
397 throw new IOException(strReply.Substring(4));
398 }
399 }
400 #endregion
401
402 #region 上传和下载
403 ///
404 /// 下载一批文件
405 ///
406 /// 文件名的匹配字符串
407 /// 本地目录(不得以\结束)
408 public void Get(string strFileNameMask, string strFolder)
409 {
410 if (!bConnected)
411 {
412 Connect();
413 }
414 string[] strFiles = Dir(strFileNameMask);
415 foreach (string strFile in strFiles)
416 {
417 if (!strFile.Equals(""))//一般来说strFiles的最后一个元素可能是空字符串
418 {
419 Get(strFile, strFolder, strFile);
420 }
421 }
422 }
423
424
425 ///
426 /// 下载一个文件
427 ///
428 /// 要下载的文件名
429 /// 本地目录(不得以\结束)
430 /// 保存在本地时的文件名
431 public void Get(string strRemoteFileName, string strFolder, string strLocalFileName)
432 {
433 if (!bConnected)
434 {
435 Connect();
436 }
437 SetTransferType(TransferType.Binary);
438 if (strLocalFileName.Equals(""))
439 {
440 strLocalFileName = strRemoteFileName;
441 }
442 if (!File.Exists(strLocalFileName))
443 {
444 Stream st = File.Create(strLocalFileName);
445 st.Close();
446 }
447 FileStream output = new
448 FileStream(strFolder + "\\" + strLocalFileName, FileMode.Create);
449 Socket socketData = CreateDataSocket();
450 SendCommand("RETR " + strRemoteFileName);
451 if (!(iReplyCode == 150 || iReplyCode == 125
452 || iReplyCode == 226 || iReplyCode == 250))
453 {
454 throw new IOException(strReply.Substring(4));
455 }
456 while (true)
457 {
458 int iBytes = socketData.Receive(buffer, buffer.Length, 0);
459 output.Write(buffer, 0, iBytes);
460 if (iBytes0)
517 {
518 socketData.Send(buffer, iBytes, 0);
519 }
520 input.Close();
521 if (socketData.Connected)
522 {
523 socketData.Close();
524 }
525 if (!(iReplyCode == 226 || iReplyCode == 250))
526 {
527 ReadReply();
528 if (!(iReplyCode == 226 || iReplyCode == 250))
529 {
530 throw new IOException(strReply.Substring(4));
531 }
532 }
533 }
534
535 #endregion
536
537 #region 目录操作
538 ///
539 /// 创建目录
540 ///
541 /// 目录名
542 public void MkDir(string strDirName)
543 {
544 if (!bConnected)
545 {
546 Connect();
547 }
548 SendCommand("MKD " + strDirName);
549 if (iReplyCode != 257)
550 {
551 throw new IOException(strReply.Substring(4));
552 }
553 }
554
555
556 ///
557 /// 删除目录
558 ///
559 /// 目录名
560 public void RmDir(string strDirName)
561 {
562 if (!bConnected)
563 {
564 Connect();
565 }
566 SendCommand("RMD " + strDirName);
567 if (iReplyCode != 250)
568 {
569 throw new IOException(strReply.Substring(4));
570 }
571 }
572
573
574 ///
575 /// 改变目录
576 ///
577 /// 新的工作目录名
578 public void ChDir(string strDirName)
579 {
580 if (strDirName.Equals(".") || strDirName.Equals(""))
581 {
582 return;
583 }
584 if (!bConnected)
585 {
586 Connect();
587 }
588 SendCommand("CWD " + strDirName);
589 if (iReplyCode != 250)
590 {
591 throw new IOException(strReply.Substring(4));
592 }
593 strRemotePath = strDirName;
594 }
595
596 #endregion
597
598 #region 内部变量
599 ///
600 /// 服务器返回的应答信息(包含应答码)
601 ///
602 private string strMsg;
603 ///
604 /// 服务器返回的应答信息(包含应答码)
605 ///
606 private string strReply;
607 ///
608 /// 服务器返回的应答码
609 ///
610 private int iReplyCode;
611 ///
612 /// 进行控制连接的socket
613 ///
614 private Socket socketControl;
615 ///
616 /// 传输模式
617 ///
618 private TransferType trType;
619 ///
620 /// 接收和发送数据的缓冲区
621 ///
622 private static int BLOCK_SIZE = 512;
623 Byte[] buffer = new Byte;
624 ///
625 /// 编码方式
626 ///
627 Encoding ASCII = Encoding.ASCII;
628 #endregion
629
630 #region 内部函数
631 ///
632 /// 将一行应答字符串记录在strReply和strMsg
633 /// 应答码记录在iReplyCode
634 ///
635 private void ReadReply()
636 {
637 strMsg = "";
638 strReply = ReadLine();
639 iReplyCode = Int32.Parse(strReply.Substring(0, 3));
640 }
641
642 ///
643 /// 建立进行数据连接的socket
644 ///
645 /// 数据连接socket
646 private Socket CreateDataSocket()
647 {
648 SendCommand("PASV");
649 if (iReplyCode != 227)
650 {
651 throw new IOException(strReply.Substring(4));
652 }
653 int index1 = strReply.IndexOf('(');
654 int index2 = strReply.IndexOf(')');
655 string ipData =
656 strReply.Substring(index1 + 1, index2 - index1 - 1);
657 int[] parts = new int;
658 int len = ipData.Length;
659 int partCount = 0;
660 string buf = "";
661 for (int i = 0; i < len && partCount
页:
[1]