【C#公共幫助類】FTPClientHelper幫助類，實現文件上傳，目錄操做，下載等動做
本文檔使用Socket通訊方式來實現ftp文件的上傳下載等命令的執行html
歡迎傳播分享，必須保持原做者的信息，但禁止將該文檔直接用於商業盈利。git
本人自從幾年前走上編程之路，一直致力於收集和總結出好用的框架和通用類庫，不論是微軟本身的仍是第三方的只要實際項目中好用且能夠解決實際問題那都會收集好，編寫好文章和別人一塊兒分享，這樣本身學到了，別人也能學到知識，當今社會很須要知識的搬運工。編程
Email：707055073@qq.com
c#
本文章地址：http://www.cnblogs.com/wohexiaocai/p/5475506.html數組
1.基本介紹
因爲最近的項目是客戶端的程序，須要將客戶端的圖片文件【切圖】-【打包】-【ftp上傳】，如今就差最後一步了，慢慢的把這些小功能實現了，合併到一塊兒就是一個大功能了，因此一個業務須要拆分的很小很小才能夠看清楚，這個項目實際須要用到哪些知識點，下面介紹一下ftp上傳的命令安全
ftp命令的參考連接：http://jingyan.baidu.com/article/b2c186c8ee1116c46ef6ffc8.html，這是我參考的百度，不全的地方還請你們留言告訴我一下。服務器
- ftp適合小文件上傳
- 對帶寬要求要求較高
- 服務器安全性也要考慮到
- 命令須要熟悉，否則比較難
2.實際項目
- 文件上傳
- 文件下載
- 刪除文件
- 建立文件夾
- 文件夾重命名
- 刪除文件夾
- 改變目錄
- 獲取文件夾中文件列表
- 等等
2.1 圖片上傳和下載
寫了幾個方法，通常用的最多的就是Put，具體的能夠下載複製源碼下來進行實戰一下。
2.2 目錄建立和刪除
這個方法今天恰好用上了，折騰了一會，才搞定的。框架
3.調用代碼參考
因爲這個幫助類不是靜態的，因此須要實例化socket
string userName = "xxx"; string password = "xxx"; var ftp = new FTPClientHelper("xxx", ".", userName, password, 1021);
下面仍是調用經常使用的方法，就能夠了，由於帳號、密碼、服務器的IP地址都被我用「xxx」代替了，因此你們本身改下，還有ftp默認端口號是：21，若是有變更仍是須要本身改下的。ide
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 }
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 }
慢慢積累，你的這些代碼都是你的財富，能夠幫你提升工做效率，勤勤懇懇的幹好每件事情，點滴積累，開心編程。
相關文章
- 1. 【C#公共幫助類】 WebHelper幫助類
- 2. 【C#公共幫助類】 Log4net 幫助類
- 3. ASP.NET文件操做幫助類
- 4. Redis 操做幫助類
- 5. 【C#公共幫助類】WinRarHelper幫助類，實現文件或文件夾壓縮和解壓，實戰乾貨
- 6. [轉]C#操做Memcached幫助類
- 7. C#文件幫助類FoderHelper
- 8. 【C#公共幫助類】JsonHelper 操做幫助類， 之後不再用滿地找Json了，拿來直接用
- 9. 【C#公共幫助類】JsonHelper 操做幫助類， 之後不再用滿地找Json了，拿來直接用...
- 10. FTP基本操做類大全，外加c#基礎公共幫助類
- 更多相關文章...
- • ASP.NET Web Pages - 幫助器 - ASP.NET 教程
- • ASP.NET Web Pages - WebGrid 幫助器 - ASP.NET 教程
- • Docker容器實戰(七) - 容器眼光下的文件系統
- • Kotlin學習（二）基本類型
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. 【C#公共幫助類】 WebHelper幫助類
- 2. 【C#公共幫助類】 Log4net 幫助類
- 3. ASP.NET文件操做幫助類
- 4. Redis 操做幫助類
- 5. 【C#公共幫助類】WinRarHelper幫助類，實現文件或文件夾壓縮和解壓，實戰乾貨
- 6. [轉]C#操做Memcached幫助類
- 7. C#文件幫助類FoderHelper
- 8. 【C#公共幫助類】JsonHelper 操做幫助類， 之後不再用滿地找Json了，拿來直接用
- 9. 【C#公共幫助類】JsonHelper 操做幫助類， 之後不再用滿地找Json了，拿來直接用...
- 10. FTP基本操做類大全，外加c#基礎公共幫助類