【C#公共幫助類】FTPClientHelper幫助類，實現文件上傳，目錄操作，下載等動作，
關於本文檔的說明
本文檔使用Socket通信方式來實現ftp文件的上傳下載等命令的執行
歡迎傳播分享，必須保持原作者的信息，但禁止將該文檔直接用於商業盈利。
本人自從幾年前走上編程之路，一直致力於收集和總結出好用的框架和通用類庫，不管是微軟自己的還是第三方的只要實際項目中好用且可以解決實際問題那都會收集好，編寫好文章和別人一起分享，這樣自己學到了，別人也能學到知識，當今社會很需要知識的搬運工。
Email：[email protected]
本文章地址：http://www.cnblogs.com/wohexiaocai/p/5475506.html
1.基本介紹
由於最近的項目是客戶端的程序，需要將客戶端的圖片文件【切圖】-【打包】-【ftp上傳】，現在就差最後一步了，慢慢的把這些小功能實現了，合並到一起就是一個大功能了，所以一個業務需要拆分的很小很小才可以看清楚，這個項目實際需要用到哪些知識點，下面介紹一下ftp上傳的命令
ftp命令的參考鏈接：http://jingyan.baidu.com/article/b2c186c8ee1116c46ef6ffc8.html，這是我參考的百度，不全的地方還請大家留言告訴我一下。
2.實際項目
2.1 圖片上傳和下載
寫了幾個方法，一般用的最多的就是Put，具體的可以下載復制源碼下來進行實戰一下。
2.2 目錄創建和刪除
這個方法今天剛好用上了，折騰了一會，才搞定的。
3.調用代碼參考
由於這個幫助類不是靜態的，所以需要實例化
string userName = "xxx";
string password = "xxx";
var ftp = new FTPClientHelper("xxx", ".", userName, password, 1021);
下面還是調用常用的方法，就可以了，因為賬號、密碼、服務器的IP地址都被我用“xxx”代替了，所以大家自己改下，還有ftp默認端口號是：1021，如果有變動還是需要自己改下的。
4.FTPClientHelper下載
![]()
1 //-------------------------------------------------------------------------------------
2 // All Rights Reserved , Copyright (C) 2015 , ZTO , Ltd .
3 //-------------------------------------------------------------------------------------
4
5 using System;
6 using System.IO;
7 using System.Net;
8 using System.Net.Sockets;
9 using System.Text;
10 using System.Threading;
11
12 namespace ZTO.PicTest.Utilities
13 {
14 /// <summary>
15 /// FTP操作幫助類
16 ///
17 /// 修改紀錄
18 ///
19 /// 2016-4-4 版本：1.0 YangHengLian 創建主鍵，注意命名空間的排序，測試非常好。
20 ///
21 /// 版本：1.0
22 ///
23 /// <author>
24 /// <name>YangHengLian</name>
25 /// <date>2016-4-4</date>
26 /// </author>
27 /// </summary>
28 public class FTPClientHelper
29 {
30 public static object Obj = new object();
31
32 #region 構造函數
33 /// <summary>
34 /// 缺省構造函數
35 /// </summary>
36 public FTPClientHelper()
37 {
38 RemoteHost = "";
39 _strRemotePath = "";
40 _strRemoteUser = "";
41 _strRemotePass = "";
42 _strRemotePort = 21;
43 _bConnected = false;
44 }
45
46 /// <summary>
47 /// 構造函數
48 /// </summary>
49 public FTPClientHelper(string remoteHost, string remotePath, string remoteUser, string remotePass, int remotePort)
50 {
51 // Ip地址
52 RemoteHost = remoteHost;
53 // 這個很重要，表示連接路徑，如果是.表示根目錄
54 _strRemotePath = remotePath;
55 // 登錄賬號
56 _strRemoteUser = remoteUser;
57 // 登錄密碼
58 _strRemotePass = remotePass;
59 // ftp端口號
60 _strRemotePort = remotePort;
61
62 Connect();
63 }
64 #endregion
65
66 #region 字段
67 private int _strRemotePort;
68 private Boolean _bConnected;
69 private string _strRemotePass;
70 private string _strRemoteUser;
71 private string _strRemotePath;
72
73 /// <summary>
74 /// 服務器返回的應答信息(包含應答碼)
75 /// </summary>
76 private string _strMsg;
77 /// <summary>
78 /// 服務器返回的應答信息(包含應答碼)
79 /// </summary>
80 private string _strReply;
81 /// <summary>
82 /// 服務器返回的應答碼
83 /// </summary>
84 private int _iReplyCode;
85 /// <summary>
86 /// 進行控制連接的socket
87 /// </summary>
88 private Socket _socketControl;
89 /// <summary>
90 /// 傳輸模式
91 /// </summary>
92 private TransferType _trType;
93
94 /// <summary>
95 /// 接收和發送數據的緩沖區
96 /// </summary>
97 private const int BlockSize = 512;
98
99 /// <summary>
100 /// 編碼方式
101 /// </summary>
102 readonly Encoding _ascii = Encoding.ASCII;
103 /// <summary>
104 /// 字節數組
105 /// </summary>
106 readonly Byte[] _buffer = new Byte[BlockSize];
107 #endregion
108
109 #region 屬性
110
111 /// <summary>
112 /// FTP服務器IP地址
113 /// </summary>
114 public string RemoteHost { get; set; }
115
116 /// <summary>
117 /// FTP服務器端口
118 /// </summary>
119 public int RemotePort
120 {
121 get
122 {
123 return _strRemotePort;
124 }
125 set
126 {
127 _strRemotePort = value;
128 }
129 }
130
131 /// <summary>
132 /// 當前服務器目錄
133 /// </summary>
134 public string RemotePath
135 {
136 get
137 {
138 return _strRemotePath;
139 }
140 set
141 {
142 _strRemotePath = value;
143 }
144 }
145
146 /// <summary>
147 /// 登錄用戶賬號
148 /// </summary>
149 public string RemoteUser
150 {
151 set
152 {
153 _strRemoteUser = value;
154 }
155 }
156
157 /// <summary>
158 /// 用戶登錄密碼
159 /// </summary>
160 public string RemotePass
161 {
162 set
163 {
164 _strRemotePass = value;
165 }
166 }
167
168 /// <summary>
169 /// 是否登錄
170 /// </summary>
171 public bool Connected
172 {
173 get
174 {
175 return _bConnected;
176 }
177 }
178 #endregion
179
180 #region 鏈接
181 /// <summary>
182 /// 建立連接
183 /// </summary>
184 public void Connect()
185 {
186 lock (Obj)
187 {
188 _socketControl = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
189 var ep = new IPEndPoint(IPAddress.Parse(RemoteHost), _strRemotePort);
190 try
191 {
192 _socketControl.Connect(ep);
193 }
194 catch (Exception)
195 {
196 throw new IOException("不能連接ftp服務器");
197 }
198 }
199 ReadReply();
200 if (_iReplyCode != 220)
201 {
202 DisConnect();
203 throw new IOException(_strReply.Substring(4));
204 }
205 SendCommand("USER " + _strRemoteUser);
206 if (!(_iReplyCode == 331 || _iReplyCode == 230))
207 {
208 CloseSocketConnect();
209 throw new IOException(_strReply.Substring(4));
210 }
211 if (_iReplyCode != 230)
212 {
213 SendCommand("PASS " + _strRemotePass);
214 if (!(_iReplyCode == 230 || _iReplyCode == 202))
215 {
216 CloseSocketConnect();
217 throw new IOException(_strReply.Substring(4));
218 }
219 }
220 _bConnected = true;
221 ChDir(_strRemotePath);
222 }
223
224 /// <summary>
225 /// 關閉連接
226 /// </summary>
227 public void DisConnect()
228 {
229 if (_socketControl != null)
230 {
231 SendCommand("QUIT");
232 }
233 CloseSocketConnect();
234 }
235 #endregion
236
237 #region 傳輸模式
238 /// <summary>
239 /// 傳輸模式:二進制類型、ASCII類型
240 /// </summary>
241 public enum TransferType { Binary, ASCII };
242
243 /// <summary>
244 /// 設置傳輸模式
245 /// </summary>
246 /// <param name="ttType">傳輸模式</param>
247 public void SetTransferType(TransferType ttType)
248 {
249 SendCommand(ttType == TransferType.Binary ? "TYPE I" : "TYPE A");
250 if (_iReplyCode != 200)
251 {
252 throw new IOException(_strReply.Substring(4));
253 }
254 _trType = ttType;
255 }
256
257 /// <summary>
258 /// 獲得傳輸模式
259 /// </summary>
260 /// <returns>傳輸模式</returns>
261 public TransferType GetTransferType()
262 {
263 return _trType;
264 }
265 #endregion
266
267 #region 文件操作
268 /// <summary>
269 /// 獲得文件列表
270 /// </summary>
271 /// <param name="strMask">文件名的匹配字符串</param>
272 public string[] Dir(string strMask)
273 {
274 if (!_bConnected)
275 {
276 Connect();
277 }
278 Socket socketData = CreateDataSocket();
279 SendCommand("NLST " + strMask);
280 if (!(_iReplyCode == 150 || _iReplyCode == 125 || _iReplyCode == 226))
281 {
282 throw new IOException(_strReply.Substring(4));
283 }
284 _strMsg = "";
285 Thread.Sleep(2000);
286 while (true)
287 {
288 int iBytes = socketData.Receive(_buffer, _buffer.Length, 0);
289 _strMsg += _ascii.GetString(_buffer, 0, iBytes);
290 if (iBytes < _buffer.Length)
291 {
292 break;
293 }
294 }
295 char[] seperator = { '\n' };
296 string[] strsFileList = _strMsg.Split(seperator);
297 socketData.Close(); //數據socket關閉時也會有返回碼
298 if (_iReplyCode != 226)
299 {
300 ReadReply();
301 if (_iReplyCode != 226)
302 {
303
304 throw new IOException(_strReply.Substring(4));
305 }
306 }
307 return strsFileList;
308 }
309
310 public void NewPutByGuid(string strFileName, string strGuid)
311 {
312 if (!_bConnected)
313 {
314 Connect();
315 }
316 string str = strFileName.Substring(0, strFileName.LastIndexOf("\\", StringComparison.Ordinal));
317 string strTypeName = strFileName.Substring(strFileName.LastIndexOf(".", StringComparison.Ordinal));
318 strGuid = str + "\\" + strGuid;
319 Socket socketData = CreateDataSocket();
320 SendCommand("STOR " + Path.GetFileName(strGuid));
321 if (!(_iReplyCode == 125 || _iReplyCode == 150))
322 {
323 throw new IOException(_strReply.Substring(4));
324 }
325 var input = new FileStream(strGuid, FileMode.Open);
326 input.Flush();
327 int iBytes;
328 while ((iBytes = input.Read(_buffer, 0, _buffer.Length)) > 0)
329 {
330 socketData.Send(_buffer, iBytes, 0);
331 }
332 input.Close();
333 if (socketData.Connected)
334 {
335 socketData.Close();
336 }
337 if (!(_iReplyCode == 226 || _iReplyCode == 250))
338 {
339 ReadReply();
340 if (!(_iReplyCode == 226 || _iReplyCode == 250))
341 {
342 throw new IOException(_strReply.Substring(4));
343 }
344 }
345 }
346
347 /// <summary>
348 /// 獲取文件大小
349 /// </summary>
350 /// <param name="strFileName">文件名</param>
351 /// <returns>文件大小</returns>
352 public long GetFileSize(string strFileName)
353 {
354 if (!_bConnected)
355 {
356 Connect();
357 }
358 SendCommand("SIZE " + Path.GetFileName(strFileName));
359 long lSize;
360 if (_iReplyCode == 213)
361 {
362 lSize = Int64.Parse(_strReply.Substring(4));
363 }
364 else
365 {
366 throw new IOException(_strReply.Substring(4));
367 }
368 return lSize;
369 }
370
371 /// <summary>
372 /// 獲取文件信息
373 /// </summary>
374 /// <param name="strFileName">文件名</param>
375 /// <returns>文件大小</returns>
376 public string GetFileInfo(string strFileName)
377 {
378 if (!_bConnected)
379 {
380 Connect();
381 }
382 Socket socketData = CreateDataSocket();
383 SendCommand("LIST " + strFileName);
384 if (!(_iReplyCode == 150 || _iReplyCode == 125
385 || _iReplyCode == 226 || _iReplyCode == 250))
386 {
387 throw new IOException(_strReply.Substring(4));
388 }
389 byte[] b = new byte[512];
390 MemoryStream ms = new MemoryStream();
391
392 while (true)
393 {
394 int iBytes = socketData.Receive(b, b.Length, 0);
395 ms.Write(b, 0, iBytes);
396 if (iBytes <= 0)
397 {
398
399 break;
400 }
401 }
402 byte[] bt = ms.GetBuffer();
403 string strResult = Encoding.ASCII.GetString(bt);
404 ms.Close();
405 return strResult;
406 }
407
408 /// <summary>
409 /// 刪除
410 /// </summary>
411 /// <param name="strFileName">待刪除文件名</param>
412 public void Delete(string strFileName)
413 {
414 if (!_bConnected)
415 {
416 Connect();
417 }
418 SendCommand("DELE " + strFileName);
419 if (_iReplyCode != 250)
420 {
421 throw new IOException(_strReply.Substring(4));
422 }
423 }
424
425 /// <summary>
426 /// 重命名(如果新文件名與已有文件重名,將覆蓋已有文件)
427 /// </summary>
428 /// <param name="strOldFileName">舊文件名</param>
429 /// <param name="strNewFileName">新文件名</param>
430 public void Rename(string strOldFileName, string strNewFileName)
431 {
432 if (!_bConnected)
433 {
434 Connect();
435 }
436 SendCommand("RNFR " + strOldFileName);
437 if (_iReplyCode != 350)
438 {
439 throw new IOException(_strReply.Substring(4));
440 }
441 // 如果新文件名與原有文件重名,將覆蓋原有文件
442 SendCommand("RNTO " + strNewFileName);
443 if (_iReplyCode != 250)
444 {
445 throw new IOException(_strReply.Substring(4));
446 }
447 }
448 #endregion
449
450 #region 上傳和下載
451 /// <summary>
452 /// 下載一批文件
453 /// </summary>
454 /// <param name="strFileNameMask">文件名的匹配字符串</param>
455 /// <param name="strFolder">本地目錄(不得以\結束)</param>
456 public void Get(string strFileNameMask, string strFolder)
457 {
458 if (!_bConnected)
459 {
460 Connect();
461 }
462 string[] strFiles = Dir(strFileNameMask);
463 foreach (string strFile in strFiles)
464 {
465 if (!strFile.Equals(""))//一般來說strFiles的最後一個元素可能是空字符串
466 {
467 Get(strFile, strFolder, strFile);
468 }
469 }
470 }
471
472 /// <summary>
473 /// 下載一個文件
474 /// </summary>
475 /// <param name="strRemoteFileName">要下載的文件名</param>
476 /// <param name="strFolder">本地目錄(不得以\結束)</param>
477 /// <param name="strLocalFileName">保存在本地時的文件名</param>
478 public void Get(string strRemoteFileName, string strFolder, string strLocalFileName)
479 {
480 Socket socketData = CreateDataSocket();
481 try
482 {
483 if (!_bConnected)
484 {
485 Connect();
486 }
487 SetTransferType(TransferType.Binary);
488 if (strLocalFileName.Equals(""))
489 {
490 strLocalFileName = strRemoteFileName;
491 }
492 SendCommand("RETR " + strRemoteFileName);
493 if (!(_iReplyCode == 150 || _iReplyCode == 125 || _iReplyCode == 226 || _iReplyCode == 250))
494 {
495 throw new IOException(_strReply.Substring(4));
496 }
497 var output = new FileStream(strFolder + "\\" + strLocalFileName, FileMode.Create);
498 while (true)
499 {
500 int iBytes = socketData.Receive(_buffer, _buffer.Length, 0);
501 output.Write(_buffer, 0, iBytes);
502 if (iBytes <= 0)
503 {
504 break;
505 }
506 }
507 output.Close();
508 if (socketData.Connected)
509 {
510 socketData.Close();
511 }
512 if (!(_iReplyCode == 226 || _iReplyCode == 250))
513 {
514 ReadReply();
515 if (!(_iReplyCode == 226 || _iReplyCode == 250))
516 {
517 throw new IOException(_strReply.Substring(4));
518 }
519 }
520 }
521 catch
522 {
523 socketData.Close();
524 _socketControl.Close();
525 _bConnected = false;
526 _socketControl = null;
527 }
528 }
529
530 /// <summary>
531 /// 下載一個文件
532 /// </summary>
533 /// <param name="strRemoteFileName">要下載的文件名</param>
534 /// <param name="strFolder">本地目錄(不得以\結束)</param>
535 /// <param name="strLocalFileName">保存在本地時的文件名</param>
536 public void GetNoBinary(string strRemoteFileName, string strFolder, string strLocalFileName)
537 {
538 if (!_bConnected)
539 {
540 Connect();
541 }
542
543 if (strLocalFileName.Equals(""))
544 {
545 strLocalFileName = strRemoteFileName;
546 }
547 Socket socketData = CreateDataSocket();
548 SendCommand("RETR " + strRemoteFileName);
549 if (!(_iReplyCode == 150 || _iReplyCode == 125 || _iReplyCode == 226 || _iReplyCode == 250))
550 {
551 throw new IOException(_strReply.Substring(4));
552 }
553 var output = new FileStream(strFolder + "\\" + strLocalFileName, FileMode.Create);
554 while (true)
555 {
556 int iBytes = socketData.Receive(_buffer, _buffer.Length, 0);
557 output.Write(_buffer, 0, iBytes);
558 if (iBytes <= 0)
559 {
560 break;
561 }
562 }
563 output.Close();
564 if (socketData.Connected)
565 {
566 socketData.Close();
567 }
568 if (!(_iReplyCode == 226 || _iReplyCode == 250))
569 {
570 ReadReply();
571 if (!(_iReplyCode == 226 || _iReplyCode == 250))
572 {
573 throw new IOException(_strReply.Substring(4));
574 }
575 }
576 }
577
578 /// <summary>
579 /// 上傳一批文件
580 /// </summary>
581 /// <param name="strFolder">本地目錄(不得以\結束)</param>
582 /// <param name="strFileNameMask">文件名匹配字符(可以包含*和?)</param>
583 public void Put(string strFolder, string strFileNameMask)
584 {
585 string[] strFiles = Directory.GetFiles(strFolder, strFileNameMask);
586 foreach (string strFile in strFiles)
587 {
588 Put(strFile);
589 }
590 }
591
592 /// <summary>
593 /// 上傳一個文件
594 /// </summary>
595 /// <param name="strFileName">本地文件名</param>
596 public void Put(string strFileName)
597 {
598 if (!_bConnected)
599 {
600 Connect();
601 }
602 Socket socketData = CreateDataSocket();
603 if (Path.GetExtension(strFileName) == "")
604 SendCommand("STOR " + Path.GetFileNameWithoutExtension(strFileName));
605 else
606 SendCommand("STOR " + Path.GetFileName(strFileName));
607
608 if (!(_iReplyCode == 125 || _iReplyCode == 150))
609 {
610 throw new IOException(_strReply.Substring(4));
611 }
612
613 var input = new FileStream(strFileName, FileMode.Open);
614 int iBytes;
615 while ((iBytes = input.Read(_buffer, 0, _buffer.Length)) > 0)
616 {
617 socketData.Send(_buffer, iBytes, 0);
618 }
619 input.Close();
620 if (socketData.Connected)
621 {
622 socketData.Close();
623 }
624 if (!(_iReplyCode == 226 || _iReplyCode == 250))
625 {
626 ReadReply();
627 if (!(_iReplyCode == 226 || _iReplyCode == 250))
628 {
629 throw new IOException(_strReply.Substring(4));
630 }
631 }
632 }
633
634 /// <summary>
635 /// 上傳一個文件
636 /// </summary>
637 /// <param name="strFileName">本地文件名</param>
638 ///
639 /// <param name="strGuid"> </param>
640 public void PutByGuid(string strFileName, string strGuid)
641 {
642 if (!_bConnected)
643 {
644 Connect();
645 }
646 string str = strFileName.Substring(0, strFileName.LastIndexOf("\\", StringComparison.Ordinal));
647 string strTypeName = strFileName.Substring(strFileName.LastIndexOf(".", System.StringComparison.Ordinal));
648 strGuid = str + "\\" + strGuid;
649 File.Copy(strFileName, strGuid);
650 File.SetAttributes(strGuid, FileAttributes.Normal);
651 Socket socketData = CreateDataSocket();
652 SendCommand("STOR " + Path.GetFileName(strGuid));
653 if (!(_iReplyCode == 125 || _iReplyCode == 150))
654 {
655 throw new IOException(_strReply.Substring(4));
656 }
657 var input = new FileStream(strGuid, FileMode.Open, System.IO.FileAccess.Read, System.IO.FileShare.Read);
658 int iBytes = 0;
659 while ((iBytes = input.Read(_buffer, 0, _buffer.Length)) > 0)
660 {
661 socketData.Send(_buffer, iBytes, 0);
662 }
663 input.Close();
664 File.Delete(strGuid);
665 if (socketData.Connected)
666 {
667 socketData.Close();
668 }
669 if (!(_iReplyCode == 226 || _iReplyCode == 250))
670 {
671 ReadReply();
672 if (!(_iReplyCode == 226 || _iReplyCode == 250))
673 {
674 throw new IOException(_strReply.Substring(4));
675 }
676 }
677 }
678 #endregion
679
680 #region 目錄操作
681 /// <summary>
682 /// 創建目錄
683 /// </summary>
684 /// <param name="strDirName">目錄名</param>
685 public void MkDir(string strDirName)
686 {
687 if (!_bConnected)
688 {
689 Connect();
690 }
691 SendCommand("MKD " + strDirName);
692 if (_iReplyCode != 257)
693 {
694 throw new IOException(_strReply.Substring(4));
695 }
696 }
697
698 /// <summary>
699 /// 刪除目錄
700 /// </summary>
701 /// <param name="strDirName">目錄名</param>
702 public void RmDir(string strDirName)
703 {
704 if (!_bConnected)
705 {
706 Connect();
707 }
708 SendCommand("RMD " + strDirName);
709 if (_iReplyCode != 250)
710 {
711 throw new IOException(_strReply.Substring(4));
712 }
713 }
714
715 /// <summary>
716 /// 改變目錄
717 /// </summary>
718 /// <param name="strDirName">新的工作目錄名</param>
719 public void ChDir(string strDirName)
720 {
721 if (strDirName.Equals(".") || strDirName.Equals(""))
722 {
723 return;
724 }
725 if (!_bConnected)
726 {
727 Connect();
728 }
729 SendCommand("CWD " + strDirName);
730 if (_iReplyCode != 250)
731 {
732 throw new IOException(_strReply.Substring(4));
733 }
734 this._strRemotePath = strDirName;
735 }
736 #endregion
737
738 #region 內部函數
739 /// <summary>
740 /// 將一行應答字符串記錄在strReply和strMsg,應答碼記錄在iReplyCode
741 /// </summary>
742 private void ReadReply()
743 {
744 _strMsg = "";
745 _strReply = ReadLine();
746 _iReplyCode = Int32.Parse(_strReply.Substring(0, 3));
747 }
748
749 /// <summary>
750 /// 建立進行數據連接的socket
751 /// </summary>
752 /// <returns>數據連接socket</returns>
753 private Socket CreateDataSocket()
754 {
755 SendCommand("PASV");
756 if (_iReplyCode != 227)
757 {
758 throw new IOException(_strReply.Substring(4));
759 }
760 int index1 = _strReply.IndexOf('(');
761 int index2 = _strReply.IndexOf(')');
762 string ipData = _strReply.Substring(index1 + 1, index2 - index1 - 1);
763 int[] parts = new int[6];
764 int len = ipData.Length;
765 int partCount = 0;
766 string buf = "";
767 for (int i = 0; i < len && partCount <= 6; i++)
768 {
769 char ch = Char.Parse(ipData.Substring(i, 1));
770 if (Char.IsDigit(ch))
771 buf += ch;
772 else if (ch != ',')
773 {
774 throw new IOException("Malformed PASV strReply: " + _strReply);
775 }
776 if (ch == ',' || i + 1 == len)
777 {
778 try
779 {
780 parts[partCount++] = Int32.Parse(buf);
781 buf = "";
782 }
783 catch (Exception)
784 {
785 throw new IOException("Malformed PASV strReply: " + _strReply);
786 }
787 }
788 }
789 string ipAddress = parts[0] + "." + parts[1] + "." + parts[2] + "." + parts[3];
790 int port = (parts[4] << 8) + parts[5];
791 var s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
792 var ep = new IPEndPoint(IPAddress.Parse(ipAddress), port);
793 try
794 {
795 s.Connect(ep);
796 }
797 catch (Exception)
798 {
799 throw new IOException("無法連接ftp服務器");
800 }
801 return s;
802 }
803
804 /// <summary>
805 /// 關閉socket連接(用於登錄以前)
806 /// </summary>
807 private void CloseSocketConnect()
808 {
809 lock (Obj)
810 {
811 if (_socketControl != null)
812 {
813 _socketControl.Close();
814 _socketControl = null;
815 }
816 _bConnected = false;
817 }
818 }
819
820 /// <summary>
821 /// 讀取Socket返回的所有字符串
822 /// </summary>
823 /// <returns>包含應答碼的字符串行</returns>
824 private string ReadLine()
825 {
826 lock (Obj)
827 {
828 while (true)
829 {
830 int iBytes = _socketControl.Receive(_buffer, _buffer.Length, 0);
831 _strMsg += _ascii.GetString(_buffer, 0, iBytes);
832 if (iBytes < _buffer.Length)
833 {
834 break;
835 }
836 }
837 }
838 char[] seperator = { '\n' };
839 string[] mess = _strMsg.Split(seperator);
840 if (_strMsg.Length > 2)
841 {
842 _strMsg = mess[mess.Length - 2];
843 }
844 else
845 {
846 _strMsg = mess[0];
847 }
848 if (!_strMsg.Substring(3, 1).Equals(" ")) //返回字符串正確的是以應答碼(如220開頭,後面接一空格,再接問候字符串)
849 {
850 return ReadLine();
851 }
852 return _strMsg;
853 }
854
855 /// <summary>
856 /// 發送命令並獲取應答碼和最後一行應答字符串
857 /// </summary>
858 /// <param name="strCommand">命令</param>
859 public void SendCommand(String strCommand)
860 {
861 lock (Obj)
862 {
863 Byte[] cmdBytes = Encoding.ASCII.GetBytes((strCommand + "\r\n").ToCharArray());
864 _socketControl.Send(cmdBytes, cmdBytes.Length, 0);
865 Thread.Sleep(100);
866 ReadReply();
867 }
868 }
869 #endregion
870 }
871 }
FTPClientHelper
5.FTP常用的命令
![]()
1 #region 程序集 System.dll, v4.0.0.0
2 // C:\Program Files (x86)\Reference Assemblies\Microsoft\Framework\.NETFramework\v4.0\System.dll
3 #endregion
4
5 using System;
6
7 namespace System.Net
8 {
9 // 摘要:
10 // System.Net.WebRequestMethods.Ftp、System.Net.WebRequestMethods.File 和 System.Net.WebRequestMethods.Http
11 // 類的容器類。無法繼承此類
12 public static class WebRequestMethods
13 {
14
15 // 摘要:
16 // 表示可用於 FILE 請求的文件協議方法的類型。無法繼承此類。
17 public static class File
18 {
19 // 摘要:
20 // 表示用來從指定的位置檢索文件的 FILE GET 協議方法。
21 public const string DownloadFile = "GET";
22 //
23 // 摘要:
24 // 表示用來將文件復制到指定位置的 FILE PUT 協議方法。
25 public const string UploadFile = "PUT";
26 }
27
28 // 摘要:
29 // 表示可與 FTP 請求一起使用的 FTP 協議方法的類型。無法繼承此類。
30 public static class Ftp
31 {
32 // 摘要:
33 // 表示要用於將文件追加到 FTP 服務器上的現有文件的 FTP APPE 協議方法。
34 public const string AppendFile = "APPE";
35 //
36 // 摘要:
37 // 表示要用於刪除 FTP 服務器上的文件的 FTP DELE 協議方法。
38 public const string DeleteFile = "DELE";
39 //
40 // 摘要:
41 // 表示要用於從 FTP 服務器下載文件的 FTP RETR 協議方法。
42 public const string DownloadFile = "RETR";
43 //
44 // 摘要:
45 // 表示要用於從 FTP 服務器上的文件檢索日期時間戳的 FTP MDTM 協議方法。
46 public const string GetDateTimestamp = "MDTM";
47 //
48 // 摘要:
49 // 表示要用於檢索 FTP 服務器上的文件大小的 FTP SIZE 協議方法。
50 public const string GetFileSize = "SIZE";
51 //
52 // 摘要:
53 // 表示獲取 FTP 服務器上的文件的簡短列表的 FTP NLIST 協議方法。
54 public const string ListDirectory = "NLST";
55 //
56 // 摘要:
57 // 表示獲取 FTP 服務器上的文件的詳細列表的 FTP LIST 協議方法。
58 public const string ListDirectoryDetails = "LIST";
59 //
60 // 摘要:
61 // 表示在 FTP 服務器上創建目錄的 FTP MKD 協議方法。
62 public const string MakeDirectory = "MKD";
63 //
64 // 摘要:
65 // 表示打印當前工作目錄的名稱的 FTP PWD 協議方法。
66 public const string PrintWorkingDirectory = "PWD";
67 //
68 // 摘要:
69 // 表示移除目錄的 FTP RMD 協議方法。
70 public const string RemoveDirectory = "RMD";
71 //
72 // 摘要:
73 // 表示重命名目錄的 FTP RENAME 協議方法。
74 public const string Rename = "RENAME";
75 //
76 // 摘要:
77 // 表示將文件上載到 FTP 服務器的 FTP STOR 協議方法。
78 public const string UploadFile = "STOR";
79 //
80 // 摘要:
81 // 表示將具有唯一名稱的文件上載到 FTP 服務器的 FTP STOU 協議方法。
82 public const string UploadFileWithUniqueName = "STOU";
83 }
84
85 // 摘要:
86 // 表示可與 HTTP 請求一起使用的 HTTP 協議方法的類型。
87 public static class Http
88 {
89 // 摘要:
90 // 表示與代理一起使用的 HTTP CONNECT 協議方法，該代理可以動態切換到隧道，如 SSL 隧道的情況。
91 public const string Connect = "CONNECT";
92 //
93 // 摘要:
94 // 表示一個 HTTP GET 協議方法。
95 public const string Get = "GET";
96 //
97 // 摘要:
98 // 表示一個 HTTP HEAD 協議方法。除了服務器在響應中只返回消息頭不返回消息體以外，HEAD 方法和 GET 是一樣的。
99 public const string Head = "HEAD";
100 //
101 // 摘要:
102 // 表示一個 HTTP MKCOL 請求，該請求在請求 URI（統一資源標識符）指定的位置新建集合，如頁的集合。
103 public const string MkCol = "MKCOL";
104 //
105 // 摘要:
106 // 表示一個 HTTP POST 協議方法，該方法用於將新實體作為補充發送到某個 URI。
107 public const string Post = "POST";
108 //
109 // 摘要:
110 // 表示一個 HTTP PUT 協議方法，該方法用於替換 URI 標識的實體。
111 public const string Put = "PUT";
112 }
113 }
114 }
WebRequestMethods
慢慢積累，你的這些代碼都是你的財富，可以幫你提高工作效率，勤勤懇懇的干好每件事情，點滴積累，開心編程。
