https://netftp.codeplex.com/SourceControl/latest
http://ftplib.codeplex.com/
https://www.codeproject.com/articles/18537/c-ftp-client-library
https://www.codeproject.com/Articles/31624/An-FTP-secure-client-library-for-C
using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;using System.IO;using System.Net;using System.Runtime;namespace ftpdemo{ /// /// /// public partial class Form2 : Form { string ftpServerIP; string ftpUserID; string ftpPassword; /// /// /// public Form2() { InitializeComponent(); } /// /// /// /// /// private void Form2_Load(object sender, EventArgs e) { ftpServerIP = "88.88.88.88";// ftpUserID = "dusystem.com";//dusystem.com ftpPassword = "geovindu"; txtServerIP.Text = ftpServerIP; txtUsername.Text = ftpUserID; txtPassword.Text = ftpPassword; this.Text += ftpServerIP; btnFTPSave.Enabled = false; } /// /// Method to upload the specified file to the specified FTP Server /// 隻能是根目錄下，要解決這個問題 /// 上传，必须存在文件夹下。 /// 最好是不要用中文名称文件夹或文件 /// /// file full name to be uploaded private void Upload(string filename) { FileInfo fileInf = new FileInfo(filename); string uri = "ftp://" + ftpServerIP + "/" + fileInf.Name; FtpWebRequest reqFTP; // Create FtpWebRequest object from the Uri provided reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" + fileInf.Name)); // Provide the WebPermission Credintials reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword); // By default KeepAlive is true, where the control connection is not closed // after a command is executed. reqFTP.KeepAlive = false; // Specify the command to be executed. reqFTP.Method = WebRequestMethods.Ftp.UploadFile; // Specify the data transfer type. reqFTP.UseBinary = true; // Notify the server about the size of the uploaded file reqFTP.ContentLength = fileInf.Length; // The buffer size is set to 2kb int buffLength = 2048; byte[] buff = new byte[buffLength]; int contentLen; // Opens a file stream (System.IO.FileStream) to read the file to be uploaded FileStream fs = fileInf.OpenRead(); try { // Stream to which the file to be upload is written Stream strm = reqFTP.GetRequestStream(); // Read from the file stream 2kb at a time contentLen = fs.Read(buff, 0, buffLength); // Till Stream content ends while (contentLen != 0) { // Write Content from the file stream to the FTP Upload Stream strm.Write(buff, 0, contentLen); contentLen = fs.Read(buff, 0, buffLength); } // Close the file stream and the Request Stream strm.Close(); fs.Close(); } catch (Exception ex) { MessageBox.Show(ex.Message, "Upload Error"); } } /// /// 删除 /// /// public void DeleteFTP(string fileName) { try { string uri = "ftp://" + ftpServerIP + "/" + fileName; FtpWebRequest reqFTP; reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" + fileName)); reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword); reqFTP.KeepAlive = false; reqFTP.Method = WebRequestMethods.Ftp.DeleteFile; string result = String.Empty; FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); long size = response.ContentLength; Stream datastream = response.GetResponseStream(); StreamReader sr = new StreamReader(datastream); result = sr.ReadToEnd(); sr.Close(); datastream.Close(); response.Close(); } catch (Exception ex) { MessageBox.Show(ex.Message, "FTP 2.0 Delete"); } } /// /// 要得到文件名，文件夾，文件地址，文件大小，文件建立時間 /// 获取文件和文件夹列表 /// /// /// 获取文件列表 /// /// /// 下载 /// /// /// private void Download(string filePath, string fileName) { FtpWebRequest reqFTP; try { //filePath = < >, //fileName = < > FileStream outputStream = new FileStream(filePath + "\\" + fileName, FileMode.Create); reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" + fileName)); reqFTP.Method = WebRequestMethods.Ftp.DownloadFile; reqFTP.UseBinary = true; reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword); FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); Stream ftpStream = response.GetResponseStream(); long cl = response.ContentLength; int bufferSize = 2048; int readCount; byte[] buffer = new byte[bufferSize]; readCount = ftpStream.Read(buffer, 0, bufferSize); while (readCount > 0) { outputStream.Write(buffer, 0, readCount); readCount = ftpStream.Read(buffer, 0, bufferSize); } ftpStream.Close(); outputStream.Close(); response.Close(); } catch (Exception ex) { MessageBox.Show(ex.Message); } } /// /// 上传 /// /// /// private void btnUpload_Click(object sender, EventArgs e) { OpenFileDialog opFilDlg = new OpenFileDialog(); if (opFilDlg.ShowDialog() == DialogResult.OK) { Upload(opFilDlg.FileName); } } /// /// 下载 /// /// /// private void btnDownload_Click(object sender, EventArgs e) { FolderBrowserDialog fldDlg = new FolderBrowserDialog(); if (txtUpload.Text.Trim().Length > 0) { if (fldDlg.ShowDialog() == DialogResult.OK) { Download(fldDlg.SelectedPath, txtUpload.Text.Trim()); } } else { MessageBox.Show("Please enter the File name to download"); } } /// /// 删除文件 /// /// /// private void btndelete_Click(object sender, EventArgs e) { OpenFileDialog fldDlg = new OpenFileDialog(); if (txtUpload.Text.Trim().Length > 0) { DeleteFTP(txtUpload.Text.Trim()); } else { MessageBox.Show("Please enter the File name to delete"); } } /// /// /// /// /// /// 计算文件大小 /// /// /// 改名 /// /// /// private void Rename(string currentFilename, string newFilename) { FtpWebRequest reqFTP; try { reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" + currentFilename)); reqFTP.Method = WebRequestMethods.Ftp.Rename; reqFTP.RenameTo = newFilename; reqFTP.UseBinary = true; reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword); FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); Stream ftpStream = response.GetResponseStream(); ftpStream.Close(); response.Close(); } catch (Exception ex) { MessageBox.Show(ex.Message); } } /// /// /// /// private void MakeDir(string dirName) { FtpWebRequest reqFTP; try { // dirName = name of the directory to create. reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" + dirName)); reqFTP.Method = WebRequestMethods.Ftp.MakeDirectory; reqFTP.UseBinary = true; reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword); FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); Stream ftpStream = response.GetResponseStream(); ftpStream.Close(); response.Close(); } catch (Exception ex) { MessageBox.Show(ex.Message); } } /// /// 文件大小 /// /// /// private void btnFileSize_Click(object sender, EventArgs e) { long size = GetFileSize(txtUpload.Text.Trim()); string s = setSize(size); //MessageBox.Show(size.ToString() + " bytes"); MessageBox.Show(s); } /// /// 改名 /// /// /// private void button1_Click(object sender, EventArgs e) { Rename(txtCurrentFilename.Text.Trim(), txtNewFilename.Text.Trim()); } /// /// /// /// /// private void btnewDir_Click(object sender, EventArgs e) { MakeDir(txtNewDir.Text.Trim()); } /// /// 显示文件列表 /// /// /// private void btnLstFiles_Click(object sender, EventArgs e) { string[] filenames = GetFileList(); lstFiles.Items.Clear(); foreach (string filename in filenames) { lstFiles.Items.Add(filename); } } /// /// 显示文件和文件夹列表 /// /// /// private void btnFileDetailList_Click(object sender, EventArgs e) { string[] filenames = GetFilesDetailList(); lstFiles.Items.Clear(); foreach (string filename in filenames) { lstFiles.Items.Add(filename); } } /// /// /// /// /// private void btnFTPSave_Click(object sender, EventArgs e) { ftpServerIP = txtServerIP.Text.Trim(); ftpUserID = txtUsername.Text.Trim(); ftpPassword = txtPassword.Text.Trim(); btnFTPSave.Enabled = false; } private void txtServerIP_TextChanged(object sender, EventArgs e) { btnFTPSave.Enabled = true; } private void txtUsername_TextChanged(object sender, EventArgs e) { btnFTPSave.Enabled = true; } private void txtPassword_TextChanged(object sender, EventArgs e) { btnFTPSave.Enabled = true; } }}
using System;using System.Collections.Generic;using System.Linq;using System.Net;using System.IO;using System.Text;using System.Net.Sockets;namespace ftpdemo{ /// /// /// public class FTPClient { #region 构造函数 /// /// 缺省构造函数 /// public FTPClient() { strRemoteHost = ""; strRemotePath = ""; strRemoteUser = ""; strRemotePass = ""; strRemotePort = 21; bConnected = false; } /// /// 构造函数 /// /// FTP服务器IP地址 /// 当前服务器目录 /// 登录用户账号 /// 登录用户密码 /// FTP服务器端口 public FTPClient(string remoteHost, string remotePath, string remoteUser, string remotePass, int remotePort) { strRemoteHost = remoteHost; strRemotePath = remotePath; strRemoteUser = remoteUser; strRemotePass = remotePass; strRemotePort = remotePort; Connect(); } #endregion #region 登陆字段、属性 /// /// FTP服务器IP地址 /// private string strRemoteHost; public string RemoteHost { get { return strRemoteHost; } set { strRemoteHost = value; } } /// /// FTP服务器端口 /// private int strRemotePort; public int RemotePort { get { return strRemotePort; } set { strRemotePort = value; } } /// /// 当前服务器目录 /// private string strRemotePath; public string RemotePath { get { return strRemotePath; } set { strRemotePath = value; } } /// /// 登录用户账号 /// private string strRemoteUser; public string RemoteUser { set { strRemoteUser = value; } } /// /// 用户登录密码 /// private string strRemotePass; public string RemotePass { set { strRemotePass = value; } } /// /// 是否登录 /// private Boolean bConnected; public bool Connected { get { return bConnected; } } #endregion #region 链接 /// /// 建立连接 /// public void Connect() { socketControl = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPEndPoint ep = new IPEndPoint(IPAddress.Parse(RemoteHost), strRemotePort); // 链接 try { socketControl.Connect(ep); } catch (Exception) { throw new IOException("Couldn't connect to remote server"); } // 获取应答码 ReadReply(); if (iReplyCode != 220) { DisConnect(); throw new IOException(strReply.Substring(4)); } // 登陆 SendCommand("USER " + strRemoteUser); if (!(iReplyCode == 331 || iReplyCode == 230)) { CloseSocketConnect();//关闭连接 throw new IOException(strReply.Substring(4)); } if (iReplyCode != 230) { SendCommand("PASS " + strRemotePass); if (!(iReplyCode == 230 || iReplyCode == 202)) { CloseSocketConnect();//关闭连接 throw new IOException(strReply.Substring(4)); } } bConnected = true; // 切换到初始目录 if (!string.IsNullOrEmpty(strRemotePath)) { ChDir(strRemotePath); } } /// /// 关闭连接 /// public void DisConnect() { if (socketControl != null) { SendCommand("QUIT"); } CloseSocketConnect(); } #endregion #region 传输模式 /// /// 传输模式:二进制类型、ASCII类型 /// public enum TransferType { Binary, ASCII }; /// /// 设置传输模式 /// /// 传输模式 public void SetTransferType(TransferType ttType) { if (ttType == TransferType.Binary) { SendCommand("TYPE I");//binary类型传输 } else { SendCommand("TYPE A");//ASCII类型传输 } if (iReplyCode != 200) { throw new IOException(strReply.Substring(4)); } else { trType = ttType; } } /// /// 获得传输模式 /// /// 传输模式 public TransferType GetTransferType() { return trType; } #endregion #region 文件操作 /// /// 获得文件列表 /// /// 文件名的匹配字符串 /// /// 获取文件大小 /// /// 文件名 /// 文件大小 public long GetFileSize(string strFileName) { if (!bConnected) { Connect(); } SendCommand("SIZE " + Path.GetFileName(strFileName)); long lSize = 0; if (iReplyCode == 213) { lSize = Int64.Parse(strReply.Substring(4)); } else { throw new IOException(strReply.Substring(4)); } return lSize; } /// /// 删除 /// /// 待删除文件名 public void Delete(string strFileName) { if (!bConnected) { Connect(); } SendCommand("DELE " + strFileName); if (iReplyCode != 250) { throw new IOException(strReply.Substring(4)); } } /// /// 重命名(如果新文件名与已有文件重名,将覆盖已有文件) /// /// 旧文件名 /// 新文件名 public void Rename(string strOldFileName, string strNewFileName) { if (!bConnected) { Connect(); } SendCommand("RNFR " + strOldFileName); if (iReplyCode != 350) { throw new IOException(strReply.Substring(4)); } // 如果新文件名与原有文件重名,将覆盖原有文件 SendCommand("RNTO " + strNewFileName); if (iReplyCode != 250) { throw new IOException(strReply.Substring(4)); } } #endregion #region 上传和下载 /// /// 下载一批文件 /// /// 文件名的匹配字符串 /// 本地目录(不得以\结束) public void Get(string strFileNameMask, string strFolder) { if (!bConnected) { Connect(); } string[] strFiles = Dir(strFileNameMask); foreach (string strFile in strFiles) { if (!strFile.Equals(""))//一般来说strFiles的最后一个元素可能是空字符串 { if (strFile.LastIndexOf(".") > -1) { Get(strFile.Replace("\r", ""), strFolder, strFile.Replace("\r", "")); } } } } /// /// 下载目录 /// /// 要下载的文件名 /// 本地目录(不得以\结束) /// 保存在本地时的文件名 public void Get(string strRemoteFileName, string strFolder, string strLocalFileName) { if (strLocalFileName.StartsWith("-r")) { string[] infos = strLocalFileName.Split(' '); strRemoteFileName = strLocalFileName = infos[infos.Length - 1]; if (!bConnected) { Connect(); } SetTransferType(TransferType.Binary); if (strLocalFileName.Equals("")) { strLocalFileName = strRemoteFileName; } if (!File.Exists(strLocalFileName)) { Stream st = File.Create(strLocalFileName); st.Close(); } FileStream output = new FileStream(strFolder + "\\" + strLocalFileName, FileMode.Create); Socket socketData = CreateDataSocket(); SendCommand("RETR " + strRemoteFileName); if (!(iReplyCode == 150 || iReplyCode == 125 || iReplyCode == 226 || iReplyCode == 250)) { throw new IOException(strReply.Substring(4)); } while (true) { int iBytes = socketData.Receive(buffer, buffer.Length, 0); output.Write(buffer, 0, iBytes); if (iBytes <= 0) { break; } } output.Close(); if (socketData.Connected) { socketData.Close(); } if (!(iReplyCode == 226 || iReplyCode == 250)) { ReadReply(); if (!(iReplyCode == 226 || iReplyCode == 250)) { throw new IOException(strReply.Substring(4)); } } } } /// /// 下载一个文件 /// /// 要下载的文件名 /// 本地目录(不得以\结束) /// 保存在本地时的文件名 public void GetFile(string strRemoteFileName, string strFolder, string strLocalFileName) { if (!bConnected) { Connect(); } SetTransferType(TransferType.Binary); if (strLocalFileName.Equals("")) { strLocalFileName = strRemoteFileName; } if (!File.Exists(strLocalFileName)) { Stream st = File.Create(strLocalFileName); st.Close(); } FileStream output = new FileStream(strFolder + "\\" + strLocalFileName, FileMode.Create); Socket socketData = CreateDataSocket(); SendCommand("RETR " + strRemoteFileName); if (!(iReplyCode == 150 || iReplyCode == 125 || iReplyCode == 226 || iReplyCode == 250)) { throw new IOException(strReply.Substring(4)); } while (true) { int iBytes = socketData.Receive(buffer, buffer.Length, 0); output.Write(buffer, 0, iBytes); if (iBytes <= 0) { break; } } output.Close(); if (socketData.Connected) { socketData.Close(); } if (!(iReplyCode == 226 || iReplyCode == 250)) { ReadReply(); if (!(iReplyCode == 226 || iReplyCode == 250)) { throw new IOException(strReply.Substring(4)); } } } /// /// 下载一个文件 /// /// 要下载的文件名 /// 本地目录(不得以\结束) /// 保存在本地时的文件名 public void GetBrokenFile(string strRemoteFileName, string strFolder, string strLocalFileName, long size) { if (!bConnected) { Connect(); } SetTransferType(TransferType.Binary); FileStream output = new FileStream(strFolder + "\\" + strLocalFileName, FileMode.Append); Socket socketData = CreateDataSocket(); SendCommand("REST " + size.ToString()); SendCommand("RETR " + strRemoteFileName); if (!(iReplyCode == 150 || iReplyCode == 125 || iReplyCode == 226 || iReplyCode == 250)) { throw new IOException(strReply.Substring(4)); } //int byteYu = (int)size % 512; //int byteChu = (int)size / 512; //byte[] tempBuffer = new byte[byteYu]; //for (int i = 0; i < byteChu; i++) //{ // socketData.Receive(buffer, buffer.Length, 0); //} //socketData.Receive(tempBuffer, tempBuffer.Length, 0); //socketData.Receive(buffer, byteYu, 0); while (true) { int iBytes = socketData.Receive(buffer, buffer.Length, 0); //totalBytes += iBytes; output.Write(buffer, 0, iBytes); if (iBytes <= 0) { break; } } output.Close(); if (socketData.Connected) { socketData.Close(); } if (!(iReplyCode == 226 || iReplyCode == 250)) { ReadReply(); if (!(iReplyCode == 226 || iReplyCode == 250)) { throw new IOException(strReply.Substring(4)); } } } /// /// 上传一批文件 /// /// 本地目录(不得以\结束) /// 文件名匹配字符(可以包含*和?) public void Put(string strFolder, string strFileNameMask) { string[] strFiles = Directory.GetFiles(strFolder, strFileNameMask); foreach (string strFile in strFiles) { //strFile是完整的文件名(包含路径) Put(strFile); } } /// /// 上传一个文件 /// /// 本地文件名 public void Put(string strFileName) { bool isok = false; try { if (!bConnected) { Connect(); } Socket socketData = CreateDataSocket(); SendCommand("STOR " + Path.GetFileName(strFileName)); if (!(iReplyCode == 125 || iReplyCode == 150)) { throw new IOException(strReply.Substring(4)); } FileStream input = new FileStream(strFileName, FileMode.Open); int iBytes = 0; while ((iBytes = input.Read(buffer, 0, buffer.Length)) > 0) { socketData.Send(buffer, iBytes, 0); } input.Close(); if (socketData.Connected) { socketData.Close(); } if (!(iReplyCode == 226 || iReplyCode == 250)) { ReadReply(); if (!(iReplyCode == 226 || iReplyCode == 250)) { throw new IOException(strReply.Substring(4)); } } isok = true; } catch (Exception ex) { ex.Message.ToString(); } } /// /// /// /// public bool Putload(string strFileName) { bool isok = false; try { if (!bConnected) { Connect(); } Socket socketData = CreateDataSocket(); SendCommand("STOR " + Path.GetFileName(strFileName)); if (!(iReplyCode == 125 || iReplyCode == 150)) { throw new IOException(strReply.Substring(4)); } FileStream input = new FileStream(strFileName, FileMode.Open); int iBytes = 0; while ((iBytes = input.Read(buffer, 0, buffer.Length)) > 0) { socketData.Send(buffer, iBytes, 0); } input.Close(); if (socketData.Connected) { socketData.Close(); } if (!(iReplyCode == 226 || iReplyCode == 250)) { ReadReply(); if (!(iReplyCode == 226 || iReplyCode == 250)) { throw new IOException(strReply.Substring(4)); } } isok = true; } catch (Exception ex) { ex.Message.ToString(); } return isok; } #endregion #region 目录操作 /// /// 创建目录 /// /// 目录名 public void MkDir(string strDirName) { if (!bConnected) { Connect(); } SendCommand("MKD " + strDirName); if (iReplyCode != 257) { throw new IOException(strReply.Substring(4)); } } /// /// 删除目录 /// /// 目录名 public void RmDir(string strDirName) { if (!bConnected) { Connect(); } SendCommand("RMD " + strDirName); if (iReplyCode != 250) { throw new IOException(strReply.Substring(4)); } } /// /// 改变目录 /// /// 新的工作目录名 public void ChDir(string strDirName) { if (strDirName.Equals(".") || strDirName.Equals("")) { return; } if (!bConnected) { Connect(); } SendCommand("CWD " + strDirName); if (iReplyCode != 250) { throw new IOException(strReply.Substring(4)); } this.strRemotePath = strDirName; } #endregion #region 内部变量 /// /// 服务器返回的应答信息(包含应答码) /// private string strMsg; /// /// 服务器返回的应答信息(包含应答码) /// private string strReply; /// /// 服务器返回的应答码 /// private int iReplyCode; /// /// 进行控制连接的socket /// private Socket socketControl; /// /// 传输模式 /// private TransferType trType; /// /// 接收和发送数据的缓冲区 /// private static int BLOCK_SIZE = 512; Byte[] buffer = new Byte[BLOCK_SIZE]; /// /// 编码方式(为防止出现中文乱码采用 GB2312编码方式) /// Encoding GB2312 = Encoding.GetEncoding("gb2312"); #endregion #region 内部函数 /// /// 将一行应答字符串记录在strReply和strMsg /// 应答码记录在iReplyCode /// private void ReadReply() { strMsg = ""; strReply = ReadLine(); iReplyCode = Int32.Parse(strReply.Substring(0, 3)); } /// /// 建立进行数据连接的socket /// /// 数据连接socket private Socket CreateDataSocket() { SendCommand("PASV"); if (iReplyCode != 227) { throw new IOException(strReply.Substring(4)); } int index1 = strReply.IndexOf('('); int index2 = strReply.IndexOf(')'); string ipData = strReply.Substring(index1 + 1, index2 - index1 - 1); int[] parts = new int[6]; int len = ipData.Length; int partCount = 0; string buf = ""; for (int i = 0; i < len && partCount <= 6; i++) { char ch = Char.Parse(ipData.Substring(i, 1)); if (Char.IsDigit(ch)) buf += ch; else if (ch != ',') { throw new IOException("Malformed PASV strReply: " + strReply); } if (ch == ',' || i + 1 == len) { try { parts[partCount++] = Int32.Parse(buf); buf = ""; } catch (Exception) { throw new IOException("Malformed PASV strReply: " + strReply); } } } string ipAddress = parts[0] + "." + parts[1] + "." + parts[2] + "." + parts[3]; int port = (parts[4] << 8) + parts[5]; Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPEndPoint ep = new IPEndPoint(IPAddress.Parse(ipAddress), port); try { s.Connect(ep); } catch (Exception) { throw new IOException("Can't connect to remote server"); } return s; } /// /// 关闭socket连接(用于登录以前) /// private void CloseSocketConnect() { if (socketControl != null) { socketControl.Close(); socketControl = null; } bConnected = false; } /// /// 读取Socket返回的所有字符串 /// /// 包含应答码的字符串行 private string ReadLine() { while (true) { int iBytes = socketControl.Receive(buffer, buffer.Length, 0); strMsg += GB2312.GetString(buffer, 0, iBytes); if (iBytes < buffer.Length) { break; } } char[] seperator = { '\n' }; string[] mess = strMsg.Split(seperator); if (strMsg.Length > 2) { strMsg = mess[mess.Length - 2]; //seperator[0]是10,换行符是由13和0组成的,分隔后10后面虽没有字符串, //但也会分配为空字符串给后面(也是最后一个)字符串数组, //所以最后一个mess是没用的空字符串 //但为什么不直接取mess[0],因为只有最后一行字符串应答码与信息之间有空格 } else { strMsg = mess[0]; } if (!strMsg.Substring(3, 1).Equals(" "))//返回字符串正确的是以应答码(如220开头,后面接一空格,再接问候字符串) { return ReadLine(); } return strMsg; } /// /// 发送命令并获取应答码和最后一行应答字符串 /// /// 命令 private void SendCommand(String strCommand) { Byte[] cmdBytes = GB2312.GetBytes((strCommand + "\r\n").ToCharArray()); socketControl.Send(cmdBytes, cmdBytes.Length, 0); ReadReply(); } #endregion }} 测试：
////// 下载文件 /// /// /// private void button1_Click(object sender, EventArgs e) { FTPClient client = new FTPClient(ftpServer, "/", user, pwd, int.Parse(port)); client.Connect(); GetFolder("*", remotingFolder, client, CreateFolder()); client.DisConnect(); ClearFolder(); MessageBox.Show("下载完毕"); System.Threading.Thread.Sleep(3000); } ////// 在本地目录下创建一个以日期为名称的目录，我做这个ftp的主要目的是为了每天都备份 /// ///创建的目录名 private string CreateFolder() { string folder = localFolder + "\\" + DateTime.Now.ToShortDateString(); if (!Directory.Exists(folder)) Directory.CreateDirectory(folder); return folder; } ////// 在下载结束后清空程序目录的多余文件 /// private void ClearFolder() { string folder = Environment.CurrentDirectory; string[] dictorys = Directory.GetFiles(folder); foreach (string dictory in dictorys) { FileInfo info = new FileInfo(dictory); if (info.Length == 0) File.Delete(dictory); } } ////// 递归获取ftp文件夹的内容 /// /// 文件标记 /// 远程路径 /// /// private void GetFolder(string fileMark, string path, FTPClient client, string folder) { string[] dirs = client.Dir(path); //获取目录下的内容 client.ChDir(path); //改变目录 foreach (string dir in dirs) { string[] infos = dir.Split(' '); string info = infos[infos.Length - 1].Replace("\r", ""); if (dir.StartsWith("d") && !string.IsNullOrEmpty(dir)) //为目录 { if (!info.EndsWith(".") && !info.EndsWith("..")) //筛选出真实的目录 { Directory.CreateDirectory(folder + "\\" + info); GetFolder(fileMark, path + "/" + info, client, folder + "\\" + info); client.ChDir(path); } } else if (dir.StartsWith("-r")) //为文件 { string file = folder + "\\" + info; if (File.Exists(file)) { long remotingSize = client.GetFileSize(info); FileInfo fileInfo = new FileInfo(file); long localSize = fileInfo.Length; if (remotingSize != localSize) //短点续传 { client.GetBrokenFile(info, folder, info, localSize); } } else { client.GetFile(info, folder, info); //下载文件 MessageBox.Show("文件" + folder + info + "已经下载"); } } } } ////// 上传文件 /// /// /// private void button2_Click(object sender, EventArgs e) { try { OpenFileDialog op = new OpenFileDialog(); op.InitialDirectory = Application.StartupPath; op.RestoreDirectory = true; op.Filter = "压缩文件(*.zip)|*.zip|压缩文件(*.rar)|*.rar|所有文件(*.*)|*.*"; if (op.ShowDialog() == DialogResult.OK) { string aa = op.FileName; //上传在根目录下 //FTPClient client = new FTPClient(ftpServer, "/", user, pwd, int.Parse(port)); //client.Connect(); //client.Put(@"C:\nltk_data\tokenizers\punkt.zip"); //System.Threading.Thread.Sleep(3000); //上传在根目录下 FTPClient client = new FTPClient(ftpServer, "/", user, pwd, int.Parse(port)); client.Connect(); bool isok = client.Putload(aa); System.Threading.Thread.Sleep(3000); //FileUpDownload.FtpServerIP = ftpServer; //FileUpDownload.FtpUserID = user; //FileUpDownload.FtpPassword = pwd; //全路径 // bool isok = FileUpDownload.FtpUploadFile(aa); //上传成功 //在根目录下 // //bool isok = Upload(aa); //在根目录下 if (isok) { MessageBox.Show("OK!"); } } } catch (Exception ex) { MessageBox.Show("erro"); } } ////// Method to upload the specified file to the specified FTP Server /// /// file full name to be uploaded private bool Upload(string filename) { bool isok = false; FileInfo fileInf = new FileInfo(filename); string uri = "ftp://" + ftpServer + "/" + fileInf.Name; //+ localFolder + FtpWebRequest reqFTP; // Create FtpWebRequest object from the Uri provided reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServer + "/" + fileInf.Name));//+ localFolder + "/" // Provide the WebPermission Credintials reqFTP.Credentials = new NetworkCredential(user, pwd); // By default KeepAlive is true, where the control connection is not closed // after a command is executed. reqFTP.KeepAlive = false; // Specify the command to be executed. reqFTP.Method = WebRequestMethods.Ftp.UploadFile; // Specify the data transfer type. reqFTP.UseBinary = true; // Notify the server about the size of the uploaded file reqFTP.ContentLength = fileInf.Length; // The buffer size is set to 2kb int buffLength = 2048; byte[] buff = new byte[buffLength]; int contentLen; // Opens a file stream (System.IO.FileStream) to read the file to be uploaded FileStream fs = fileInf.OpenRead(); try { // Stream to which the file to be upload is written Stream strm = reqFTP.GetRequestStream(); // Read from the file stream 2kb at a time contentLen = fs.Read(buff, 0, buffLength); // Till Stream content ends while (contentLen != 0) { // Write Content from the file stream to the FTP Upload Stream strm.Write(buff, 0, contentLen); contentLen = fs.Read(buff, 0, buffLength); } // Close the file stream and the Request Stream isok = true; strm.Close(); fs.Close(); } catch (Exception ex) { MessageBox.Show(ex.Message, "Upload Error"); } return isok; }
////// ftp帮助类 /// public class FtpHelper { private string ftpHostIP { get; set; } private string username { get; set; } private string password { get; set; } private string ftpURI { get { return string.Format("ftp://{0}/", ftpHostIP); } } ////// 初始化ftp参数 /// /// ftp主机IP /// ftp账户 /// ftp密码 public FtpHelper(string ftpHostIP, string username, string password) { this.ftpHostIP = ftpHostIP; this.username = username; this.password = password; } ////// 异常方法委托,通过Lamda委托统一处理异常，方便改写 /// /// 当前执行的方法 /// ///private bool MethodInvoke(string method, Action action) { if (action != null) { try { action(); //Logger.Write2File($@"FtpHelper.{method}:执行成功"); //FluentConsole.Magenta.Line($@"FtpHelper({ftpHostIP},{username},{password}).{method}:执行成功"); return true; } catch (Exception ex) { //FluentConsole.Red.Line($@"FtpHelper({ftpHostIP},{username},{password}).{method}:执行失败:\n {ex}"); // Logger.Write2File(FtpHelper({ftpHostIP},{username},{password}).{method}:执行失败 \r\n{ex}"); return false; } } else { return false; } } /// /// 异常方法委托,通过Lamda委托统一处理异常，方便改写 /// /// ////// /// /// private T MethodInvoke (string method, Func func) { if (func != null) { try { //FluentConsole.Magenta.Line($@"FtpHelper({ftpHostIP},{username},{password}).{method}:执行成功"); //Logger.Write2File($@"FtpHelper({ftpHostIP},{username},{password}).{method}:执行成功"); return func(); } catch (Exception ex) { //FluentConsole.Red.Line($@"FtpHelper({ftpHostIP},{username},{password}).{method}:执行失败:").Line(ex); // Logger.Write2File($@"FtpHelper({ftpHostIP},{username},{password}).{method}:执行失败 \r\n{ex}"); return default(T); } } else { return default(T); } } /// /// https://stackoverflow.com/questions/17451620/reusing-ftpwebrequest /// /// ///private FtpWebRequest GetRequest(string URI) { //根据服务器信息FtpWebRequest创建类的对象 FtpWebRequest result = (FtpWebRequest)WebRequest.Create(URI); //result.Credentials = new NetworkCredential(username, password); result.Method = WebRequestMethods.Ftp.GetFileSize; NetworkCredential nc = new NetworkCredential(username, password); result.Credentials = nc; //result.UseBinary = true; //result.UsePassive = true; //result.KeepAlive = true; result.KeepAlive = false; result.UsePassive = false; result.UseBinary = true; return result; } /// 上传文件 /// 需要上传的文件路径 /// 目标路径 public bool UploadFile(string filePath, string dirName = "") { FileInfo fileInfo = new FileInfo(filePath); if (dirName != "") { //if(DirectoryExist(dirName) MakeDir(dirName);//检查文件目录，不存在就自动创建 } string uri =ftpURI+dirName;// Path.Combine(ftpURI, dirName, fileInfo.Name); return MethodInvoke(@"uploadFile({filePath},{dirName})", () => { FtpWebRequest ftp = GetRequest(uri); ftp.Method = WebRequestMethods.Ftp.UploadFile; ftp.ContentLength = fileInfo.Length; int buffLength = 2048; byte[] buff = new byte[buffLength]; int contentLen; using (FileStream fs = fileInfo.OpenRead()) { using (Stream strm = ftp.GetRequestStream()) { contentLen = fs.Read(buff, 0, buffLength); while (contentLen != 0) { strm.Write(buff, 0, contentLen); contentLen = fs.Read(buff, 0, buffLength); } strm.Close(); } fs.Close(); } }); } ////// 从一个目录将其内容复制到另一目录 /// /// 源目录 /// 目标目录 public void UploadAllFile(string localDir, string DirName = "") { string localDirName = string.Empty; int targIndex = localDir.LastIndexOf("\\"); if (targIndex > -1 && targIndex != (localDir.IndexOf(":\\") + 1)) localDirName = localDir.Substring(0, targIndex); localDirName = localDir.Substring(targIndex + 1); string newDir = Path.Combine(DirName, localDirName); MethodInvoke(@"UploadAllFile({localDir},{DirName})", () => { MakeDir(newDir); DirectoryInfo directoryInfo = new DirectoryInfo(localDir); FileInfo[] files = directoryInfo.GetFiles(); //复制所有文件 foreach (FileInfo file in files) { UploadFile(file.FullName, newDir); } //最后复制目录 DirectoryInfo[] directoryInfoArray = directoryInfo.GetDirectories(); foreach (DirectoryInfo dir in directoryInfoArray) { UploadAllFile(Path.Combine(localDir, dir.Name), newDir); } }); } ////// 删除单个文件 /// /// public bool DelFile(string filePath) { string uri = Path.Combine(ftpURI, filePath); return MethodInvoke(@"DelFile({filePath})", () => { FtpWebRequest ftp = GetRequest(uri); ftp.Method = WebRequestMethods.Ftp.DeleteFile; FtpWebResponse response = (FtpWebResponse)ftp.GetResponse(); response.Close(); }); } ////// 删除最末及空目录 /// /// private bool DelDir(string dirName) { string uri = Path.Combine(ftpURI, dirName); return MethodInvoke(@"DelDir({dirName})", () => { FtpWebRequest ftp = GetRequest(uri); ftp.Method = WebRequestMethods.Ftp.RemoveDirectory; FtpWebResponse response = (FtpWebResponse)ftp.GetResponse(); response.Close(); }); } ///删除目录或者其目录下所有的文件 /// 目录名称 /// 是否删除目录下所有的文件 public bool DelAll(string dirName) { var list = GetAllFtpFile(new List(),dirName); if (list == null) return DelDir(dirName); if (list.Count==0) return DelDir(dirName);//删除当前目录 var newlist = list.OrderByDescending(x => x.level); foreach (var item in newlist) { //FluentConsole.Yellow.Line(@"level:{item.level},isDir:{item.isDir},path:{item.path}"); } string uri = Path.Combine(ftpURI, dirName); return MethodInvoke(@"DelAll({dirName})", () => { foreach (var item in newlist) { if (item.isDir)//判断是目录调用目录的删除方法 DelDir(item.path); else DelFile(item.path); } DelDir(dirName);//删除当前目录 return true; }); } /// /// 下载单个文件 /// /// 从ftp要下载的文件路径 /// 下载至本地路径 /// 文件名 public bool DownloadFile(string ftpFilePath, string saveDir) { string filename = ftpFilePath.Substring(ftpFilePath.LastIndexOf("\\") + 1); string tmpname = Guid.NewGuid().ToString(); string uri = ftpURI+ftpFilePath;//Path.Combine(ftpURI, ftpFilePath);// return MethodInvoke(@"DownloadFile({ftpFilePath},{saveDir},{filename})", () => { if (!Directory.Exists(saveDir)) Directory.CreateDirectory(saveDir); FtpWebRequest ftp = GetRequest(uri); ftp.Method = WebRequestMethods.Ftp.DownloadFile; using (FtpWebResponse response = (FtpWebResponse)ftp.GetResponse()) { using (Stream responseStream = response.GetResponseStream()) { using (FileStream fs = new FileStream(Path.Combine(saveDir, filename), FileMode.CreateNew)) //Path.Combine(saveDir, filename) { byte[] buffer = new byte[2048]; int read = 0; do { read = responseStream.Read(buffer, 0, buffer.Length); fs.Write(buffer, 0, read); } while (!(read == 0)); responseStream.Close(); fs.Flush(); fs.Close(); } responseStream.Close(); } response.Close(); } }); } ////// 从FTP下载整个文件夹 /// /// FTP文件夹路径 /// 保存的本地文件夹路径 public void DownloadAllFile(string dirName, string saveDir) { MethodInvoke(@"DownloadAllFile({dirName},{saveDir})", () => { Listfiles = GetFtpFile(dirName); if (!Directory.Exists(saveDir)) { Directory.CreateDirectory(saveDir); } foreach (var f in files) { if (f.isDir) //文件夹，递归查询 { DownloadAllFile(Path.Combine(dirName,f.name), Path.Combine(saveDir ,f.name)); } else //文件，直接下载 { DownloadFile(Path.Combine(dirName,f.name), saveDir); } } }); } /// /// 获取当前目录下的目录及文件 /// /// param name="ftpfileList"> /// ///public List GetFtpFile(string dirName,int ilevel = 0) { var ftpfileList = new List (); string uri = Path.Combine(ftpURI, dirName); return MethodInvoke(@"GetFtpFile({dirName})", () => { var a = new List
>(); FtpWebRequest ftp = GetRequest(uri); ftp.Method = WebRequestMethods.Ftp.ListDirectoryDetails; Stream stream = ftp.GetResponse().GetResponseStream(); using (StreamReader sr = new StreamReader(stream)) { string line = sr.ReadLine(); while (!string.IsNullOrEmpty(line)) { ftpfileList.Add(new ActFile { isDir = line.IndexOf(" ") > -1, name = line.Substring(39).Trim(), path = Path.Combine(dirName, line.Substring(39).Trim()), level= ilevel }); line = sr.ReadLine(); } sr.Close(); } return ftpfileList; }); } /// /// 获取FTP目录下的所有目录及文件包括其子目录和子文件 /// /// param name="result"> /// ///public List GetAllFtpFile(List result,string dirName, int level = 0) { var ftpfileList = new List (); string uri = Path.Combine(ftpURI, dirName); return MethodInvoke(@"GetAllFtpFile({dirName})", () => { ftpfileList = GetFtpFile(dirName, level); result.AddRange(ftpfileList); var newlist = ftpfileList.Where(x => x.isDir).ToList(); foreach (var item in newlist) { GetAllFtpFile(result,item.path, level+1); } return result; }); } /// /// 检查目录是否存在 /// /// /// ///public bool CheckDir(string dirName, string currentDir) // = "" { string uri = ftpURI+currentDir; //Path.Combine(ftpURI, currentDir); if (!string.IsNullOrEmpty(currentDir)) { return MethodInvoke(@"CheckDir({dirName}{currentDir})", () => { FtpWebRequest ftp = GetRequest(uri); ftp.UseBinary = true; ftp.Method = WebRequestMethods.Ftp.ListDirectoryDetails; //获取FTP目录下所有的文件和文件夹的名字 // WebRequestMethods.Ftp.ListDirectory; Stream stream = ftp.GetResponse().GetResponseStream(); using (StreamReader sr = new StreamReader(stream)) { string line = sr.ReadLine(); while (!string.IsNullOrEmpty(line)) { if (line.IndexOf(" ") > -1) { if (line.Substring(39).Trim() == dirName) return true; } line = sr.ReadLine(); } sr.Close(); } stream.Close(); return false; }); } else { return false; } } /// /// 在ftp服务器上创建指定目录,父目录不存在则创建 /// /// 创建的目录名称 public bool MakeDir(string dirName) { var dirs = dirName.Split('\\').ToList();//针对多级目录分割 string currentDir = string.Empty; return MethodInvoke(@"MakeDir({dirName})", () => { foreach (var dir in dirs) { //涂聚文 Geovin Du //if (string.IsNullOrEmpty(dir)) //{ // continue; //} if (!string.IsNullOrEmpty(dir)) { //存在问题，判断是文件夹，再判断是否存在此文件夹，不存在也创建 if (!dir.Contains(".")) //如果是文件不考虑 { currentDir = currentDir + "/" + dir;//Path.Combine(currentDir, dir); string uri = ftpURI + currentDir;// Path.Combine(ftpURI, currentDir); if (!DirectoryExist(uri))//检查目录不存在则创建CheckDir(dir, currentDir) //要考虑不是文件，是文件夹。 { FtpWebRequest ftp = GetRequest(uri); ftp.Method = WebRequestMethods.Ftp.MakeDirectory; //无权限 FtpWebResponse response = (FtpWebResponse)ftp.GetResponse(); response.Close(); } } } } }); } /// /// 文件夹是否存在 /// /// ///public bool DirectoryExist(string uri) { FtpWebRequest reqFTP = GetRequest(uri); // FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri)); //reqFTP.Credentials = new NetworkCredential("", ""); reqFTP.Method = WebRequestMethods.Ftp.ListDirectory; //PrintWorkingDirectory ListDirectoryDetails reqFTP.UseBinary = true; try { FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8); string line = reader.ReadLine(); reader.Close(); response.Close(); if (line != null) { return true; } else { return false; } } catch (Exception ex) { string e = ex.Message; return false; } } /// /// Normalizes the URI. /// /// The URI. ///A normalized URI private Uri NormalizeUri(Uri uri) { if (uri == null) throw new ArgumentNullException("uri"); if (uri.Scheme != Uri.UriSchemeFtp) throw new ArgumentException("The URI isn't a valid FTP URI", "uri"); string path = uri.AbsoluteUri; //Cut the "ftp://" off path = path.Substring(6); path = path.Replace("//", "/").Replace(@"\\", "/").Replace(@"\", "/"); return new Uri("ftp://" + path); } ///文件重命名 /// 当前名称 /// 重命名名称 /// 所在的目录 public bool Rename(string currentFilename, string newFilename, string dirName = "") { string uri = Path.Combine(ftpURI, dirName, currentFilename); return MethodInvoke(@"Rename({currentFilename},{newFilename},{dirName})", () => { FtpWebRequest ftp = GetRequest(uri); ftp.Method = WebRequestMethods.Ftp.Rename; ftp.RenameTo = newFilename; FtpWebResponse response = (FtpWebResponse)ftp.GetResponse(); response.Close(); }); } } ////// /// public class ActFile { public int level { get; set; } public bool isDir { get; set; } public string name { get; set; } public string path { get; set; } }
测试：
////// /// /// /// private void button1_Click(object sender, EventArgs e) { var ftp = new FtpHelper(ftpServer, user, pwd);//初始化ftp，创建ftp对象 //ftp.DelAll("test");//删除ftptest目录及其目录下的所有文件 // ftp.UploadAllFile("F:\\涂聚文维修方案000.pdf");//上传单个文件到指定目录 //ftp.UploadAllFile("F:\\test");//将本地test目录的所有文件上传 // bool ok= ftp.DownloadFile(@"\htdocs\涂聚文维修方案.pdf", "F:\\");//下载单个目录 // ftp.DownloadAllFile("test", "F:\\test1");//批量下载整个目录 //ftp.MakeDir("aaa\\bbb\\ccc\\ddd");//创建多级目录 bool ok = ftp.UploadFile("F:\\涂聚文维修方案000.pdf", @"\htdocs\geovindu\涂聚文维修方案000.pdf"); //上传成功 if (ok) { MessageBox.Show("ok"); } else { MessageBox.Show("no"); } }
https://github.com/hgupta9/FluentFTP
https://fluentftp.codeplex.com/
测试示例：
using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Windows.Forms;using System.Configuration;using FluentFTP;using System.Threading;using System.Net;namespace FluentFtpDemo{ /// /// 涂聚文测试示例 /// Geovin Du /// public partial class Form1 : Form { string remotingFolder = System.Configuration.ConfigurationManager.AppSettings["remotingFolder"]; //远程ftp文件目录 string localFolder = System.Configuration.ConfigurationManager.AppSettings["localFolder"]; //要下载到的本地目录 string ftpServer = System.Configuration.ConfigurationManager.AppSettings["ftpServer"]; //ftp服务器 string user = System.Configuration.ConfigurationManager.AppSettings["user"]; //用户名 string pwd = System.Configuration.ConfigurationManager.AppSettings["pwd"]; //密码 string port = System.Configuration.ConfigurationManager.AppSettings["port"]; //端口 string remotingFolderOther = System.Configuration.ConfigurationManager.AppSettings["remotingFolderOther"]; static ManualResetEvent m_reset = new ManualResetEvent(false); /// /// /// public Form1() { InitializeComponent(); } /// /// /// /// /// private void Form1_Load(object sender, EventArgs e) { } /// /// 判断文件夹是否存在 /// public void BeginDirectoryExists() { // The using statement here is OK _only_ because m_reset.WaitOne() // causes the code to block until the async process finishes, otherwise // the connection object would be disposed early. In practice, you // typically would not wrap the following code with a using statement. using (FtpClient conn = new FtpClient()) { m_reset.Reset(); conn.Host = ftpServer; conn.Credentials = new NetworkCredential(user, pwd); conn.BeginDirectoryExists("/htdocs/admin", new AsyncCallback(DirectoryExistsCallback), conn); m_reset.WaitOne(); conn.Disconnect(); } } /// /// /// /// void DirectoryExistsCallback(IAsyncResult ar) { FtpClient conn = ar.AsyncState as FtpClient; try { if (conn == null) throw new InvalidOperationException("The FtpControlConnection object is null!"); MessageBox.Show("Directory Exiss: " + conn.EndDirectoryExists(ar)); } catch (Exception ex) { MessageBox.Show(ex.ToString()); } finally { m_reset.Set(); } } /// /// 文件是否存在 /// /// /// private void button1_Click(object sender, EventArgs e) { BeginFileExists(); } /// /// 判断文件是否存在 /// public void BeginFileExists() { // The using statement here is OK _only_ because m_reset.WaitOne() // causes the code to block until the async process finishes, otherwise // the connection object would be disposed early. In practice, you // typically would not wrap the following code with a using statement. using (FtpClient conn = new FtpClient()) { m_reset.Reset(); conn.Encoding = Encoding.UTF8; //设置编码 conn.Host = ftpServer; conn.Credentials = new NetworkCredential(user, pwd); conn.Connect(); string file = (@"\htdocs\法律法规依据目录.pdf"); //中文文件名出问题 conn.BeginFileExists(file, new AsyncCallback(BeginFileExistsCallback), conn);//涂聚文维修方案.pdf m_reset.WaitOne(); conn.Disconnect(); } } /// /// /// /// void BeginFileExistsCallback(IAsyncResult ar) { FtpClient conn = ar.AsyncState as FtpClient; try { if (conn == null) throw new InvalidOperationException("The FtpControlConnection object is null!"); MessageBox.Show("File exists: " + conn.EndFileExists(ar)); } catch (Exception ex) { MessageBox.Show(ex.ToString()); } finally { m_reset.Set(); } } /// /// GB2312转换成UTF8 /// /// /// /// UTF8转换成GB2312 /// /// /// /// 文件夹是否存在 /// /// /// private void button2_Click(object sender, EventArgs e) { BeginDirectoryExists(); } /// /// 创建文件夹 /// /// /// private void button3_Click(object sender, EventArgs e) { BeginCreateDirectory(); } /// /// 创建文件夹 /// public void BeginCreateDirectory() { // The using statement here is OK _only_ because m_reset.WaitOne() // causes the code to block until the async process finishes, otherwise // the connection object would be disposed early. In practice, you // typically would not wrap the following code with a using statement. using (FtpClient conn = new FtpClient()) { m_reset.Reset(); conn.Host = ftpServer; conn.Encoding = Encoding.UTF8; conn.Credentials = new NetworkCredential(user, pwd); // conn.DeleteDirectory("/test"); conn.BeginCreateDirectory("/htdocs/geovindu/created", true,new AsyncCallback(CreateDirectoryCallback), conn); m_reset.WaitOne(); conn.Disconnect(); } } /// /// /// /// void CreateDirectoryCallback(IAsyncResult ar) { FtpClient conn = ar.AsyncState as FtpClient; try { if (conn == null) throw new InvalidOperationException("The FtpControlConnection object is null!"); conn.EndCreateDirectory(ar); MessageBox.Show("创建成功！"); } catch (Exception ex) { MessageBox.Show(ex.ToString()); } finally { m_reset.Set(); } } /// /// 删除文件夹 /// /// /// private void button4_Click(object sender, EventArgs e) { BeginDeleteDirectory(); } /// /// /// public void BeginDeleteDirectory() { // The using statement here is OK _only_ because m_reset.WaitOne() // causes the code to block until the async process finishes, otherwise // the connection object would be disposed early. In practice, you // typically would not wrap the following code with a using statement. using (FtpClient conn = new FtpClient()) { m_reset.Reset(); conn.Host = ftpServer; conn.Encoding = Encoding.UTF8; conn.Credentials = new NetworkCredential(user, pwd); //conn.CreateDirectory("/some/test/directory"); conn.BeginDeleteDirectory("/htdocs/geovindu", new AsyncCallback(DeleteDirectoryCallback), conn); m_reset.WaitOne(); conn.Disconnect(); } } /// /// /// /// void DeleteDirectoryCallback(IAsyncResult ar) { FtpClient conn = ar.AsyncState as FtpClient; try { if (conn == null) throw new InvalidOperationException("The FtpControlConnection object is null!"); conn.EndDeleteDirectory(ar); MessageBox.Show("删除成功"); } catch (Exception ex) { MessageBox.Show(ex.ToString()); } finally { m_reset.Set(); } } }}