C# FTP客户端源码下载

【实例简介】

【实例截图】

【核心代码】

using System;

using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.IO;
using System.Net;

namespace FTP客户端
{
    public partial class FormFTP : Form
    {
        public FormFTP()
        {
            InitializeComponent();
        }

        private void label4_Click(object sender, EventArgs e)
        {

        }

        private void buttonUpLoad_Click(object sender, EventArgs e)
        {
            OpenFileDialog openDlg = new OpenFileDialog();
            if (openDlg.ShowDialog() != DialogResult.OK) return;
 
                    string fileName = openDlg.FileName;
                    this.lblFileName.Text = fileName;
            Thread thread = new Thread(new ThreadStart(delegate()
        {
            this.UploadFileByFtpWebRequest(fileName, this.txtFTPServerIP.Text, this.txtPath.Text, this.txtUserName.Text, this.txtPassword.Text);
        }));
         thread.Start();
        }
         private bool UploadFileByFtpWebRequest(string fileName, string ftpServerIP, string path, string userName, string password)
         {
             bool result = true;
            string url = string.Format("ftp://{0}/{1}/{2}", ftpServerIP, path, fileName.Substring(fileName.LastIndexOf(@"\") 1));
 
            FtpWebRequest request = (FtpWebRequest)WebRequest.Create(url);
            request.Credentials = new NetworkCredential(userName, password);
            request.Method = WebRequestMethods.Ftp.UploadFile;

            Stream stream = request.GetRequestStream();
            FileStream fileStream = new FileStream(fileName, FileMode.Open);
 
            int packageSize = 1024 * 1024;
            int packageCount = (int)(fileStream.Length / packageSize);
            int rest = (int)(fileStream.Length % packageSize);
            this.BeginInvoke(new DoSomething(delegate()
            {
            this.pbarProcessUpload.Maximum = packageCount;
            if (rest != 0) this.pbarProcessUpload.Maximum = 1;
            }));
 
            for (int index = 0; index < packageCount; index )
            {
                byte[] buffer = new byte[packageSize];
                fileStream.Read(buffer, 0, buffer.Length);

                stream.Write(buffer, 0, buffer.Length);
 
                this.BeginInvoke(new DoSomething(delegate()
                    {
                        this.pbarProcessUpload.Value = index;
                    }));
            }
 
            if (rest != 0)
            {
                byte[] buffer = new byte[rest];
                fileStream.Read(buffer, 0, buffer.Length);
                stream.Write(buffer, 0, buffer.Length);
                this.BeginInvoke(new DoSomething(delegate()
                    {
                        this.pbarProcessUpload.Value =1;
                    }));
            }
 
            stream.Close();
            fileStream.Close();
 
            this.BeginInvoke(new DoSomething(delegate()
                {
                    this.pbarProcessUpload.Value = 0;
                }));

            return result;
            }
            private delegate void DoSomething();

            private void buttonFreshList_Click(object sender, EventArgs e)
            {
                this.lstFiles.Items.Clear();
 
                Thread thread = new Thread(new ParameterizedThreadStart(delegate(object parms)
                {
                    object[] values = (object[])parms;
                    string userName = (string)values[0];
                    string password = (string)values[1];
 
                    string[] files = this.GetFileList(string.Format("ftp://{0}/{1}", this.txtFTPServerIP.Text, this.txtPath.Text),userName, password);
 
                    foreach (string file in files)
                    {
                        this.lstFiles.Items.Add(file);
                    }
                }));
 
                thread.Start(new object[] { this.txtUserName.Text, this.txtPassword.Text });
            }
        private string[] GetFileList(string url,string userName,string password)
        {
            //获得FTP文件上的文件列表
            FtpWebRequest request = (FtpWebRequest)WebRequest.Create(url);
            request.Method = WebRequestMethods.Ftp.ListDirectory;
            request.Credentials = new NetworkCredential(userName, password);

            FtpWebResponse response = (FtpWebResponse)request.GetResponse();
            Stream stream = response.GetResponseStream();

            StreamReader reader = new StreamReader(stream);
            List<string> files = new List<string>();
 
            while (!reader.EndOfStream)
            {
                string file = reader.ReadLine();
                files.Add(file);
            }
 
            reader.Close();
            stream.Close();
 
            return files.ToArray();
        }

        private void buttonDownload_Click(object sender, EventArgs e)
        {
            //SaveFileDialog saveDlg = new SaveFileDialog();
            //saveDlg.FileName = this.lstFiles.Text;
 
            //if (saveDlg.ShowDialog() != DialogResult.OK) return;
 
            //string fileName = saveDlg.FileName;
 
            Thread thread = new Thread(new ThreadStart(delegate()
            {
//                this.DownloadFileByFtpWebRequest(this.lstFiles.Text, this.txtFTPServerIP.Text, this.txtPath.Text, this.txtUserName.Text, this.txtPassword.Text,fileName);
                this.DownloadFileByFtpWebRequest("", "211.149.246.103", "", "baocms", "xhu20151111", "d://听课记录表.doc");

            }));
            thread.Start();
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="fileName"></param>
        /// <param name="ftpServerIP"></param>
        /// <param name="path"></param>
        /// <param name="userName"></param>
        /// <param name="password"></param>
        /// <param name="fileNameSaveAs"></param>
        /// <returns></returns>
        private bool DownloadFileByFtpWebRequest(string fileName, string ftpServerIP, string path, string userName, string password,string fileNameSaveAs)
        {
            string url = string.Format("ftp://{0}/{1}/{2}", ftpServerIP, path, fileName);
 
            FtpWebRequest requsetOfLength = (FtpWebRequest)WebRequest.Create(url);
            requsetOfLength.Credentials = new NetworkCredential(userName, password);
            //requsetOfLength.Method = WebRequestMethods.Ftp.GetFileSize;
            requsetOfLength.Method = WebRequestMethods.Ftp.ListDirectory;
            //long fileSize = requsetOfLength.GetResponse().ContentLength;
            WebResponse Tmp = requsetOfLength.GetResponse();
            long fileSize = 0;

            FtpWebRequest request = (FtpWebRequest)WebRequest.Create(url);
            request.Credentials = new NetworkCredential(userName, password);
 
            request.KeepAlive = false;
            request.Method = WebRequestMethods.Ftp.DownloadFile;
 
            FtpWebResponse response = (FtpWebResponse)request.GetResponse();
            Stream stream = response.GetResponseStream();
 
            FileStream fileStream = new FileStream(fileNameSaveAs,FileMode.Create);
 
            int packageSize = 1024 * 1024;
            int packageCount = (int)(fileSize / packageSize);
            int rest = (int)(fileSize % packageSize);
 
            this.BeginInvoke(new DoSomething(delegate()
            {
                this.pbarProcessDownload.Maximum = packageCount;
                if (rest != 0) this.pbarProcessDownload.Maximum = 1;
            }));
 
            for (int index = 0; index < packageCount; index )
            {
                byte[] buffer = new byte[packageSize];
                stream.Read(buffer, 0, buffer.Length);
 
                fileStream.Write(buffer, 0, buffer.Length);
 
                this.BeginInvoke(new DoSomething(delegate()
                {
                    this.pbarProcessDownload.Value = index;
                }
                ));
            }
 
            if (rest != 0)
            {
                byte[] buffer = new byte[rest];
                int count = stream.Read(buffer, 0, buffer.Length);
 
                fileStream.Write(buffer, 0, buffer.Length);
 
                this.BeginInvoke(new DoSomething(delegate()
                {
                    this.pbarProcessDownload.Value = 1;
                }));
            }
 
            stream.Close();
            fileStream.Close();
 
            this.BeginInvoke(new DoSomething(delegate()
            {
                this.pbarProcessDownload.Value = 0;
            }));
 
            return true;
        }

        private void button1_Click(object sender, EventArgs e)
        {
            FTPHelper Tmp = new FTPHelper("baocms","xhu20151111");

            List<FileStruct> Tmpfiles = Tmp.ListFilesAndDirectories("ftp://211.149.246.103");
            MessageBox.Show(Tmpfiles.Count.ToString());
        }
    }
}