C# winfrom 模拟ftp文件管理实现代码

using system;
using system.collections.generic;
using system.text;
using system.net;
using system.io;
using system.windows.forms;

 
namespace convertdata
{
    class ftpupdown
    {

        string ftpserverip;
        string ftpuserid;
        string ftppassword;
        ftpwebrequest reqftp;

        private void connect(string path)//连接ftp
        {
            // 根据uri创建ftpwebrequest对象
            reqftp = (ftpwebrequest)ftpwebrequest.create(new uri(path));
            // 指定数据传输类型
            reqftp.usebinary = true;
            // ftp用户名和密码
            reqftp.credentials = new networkcredential(ftpuserid, ftppassword);
        }

        public ftpupdown(string ftpserverip, string ftpuserid, string ftppassword)
        {
            this.ftpserverip = ftpserverip;
            this.ftpuserid = ftpuserid;
            this.ftppassword = ftppassword;
        }

        //都调用这个
        private string[] getfilelist(string path, string wrmethods)//上面的代码示例了如何从ftp服务器上获得文件列表
        {
            string[] downloadfiles;
            stringbuilder result = new stringbuilder();
            try
            {
                connect(path);
                reqftp.method = wrmethods;
                webresponse response = reqftp.getresponse();
                streamreader reader = new streamreader(response.getresponsestream(), system.text.encoding.default);//中文文件名
                string line = reader.readline();
                while (line != null)
                {
                    result.append(line);
                    result.append("\n");
                    line = reader.readline();
                }
                // to remove the trailing '\n'
                result.remove(result.tostring().lastindexof('\n'), 1);
                reader.close();
                response.close();
                return result.tostring().split('\n');
            }
            catch (exception ex)
            {
                system.windows.forms.messagebox.show(ex.message);
                downloadfiles = null;
                return downloadfiles;
            }
        }

        public string[] getfilelist(string path)//上面的代码示例了如何从ftp服务器上获得文件列表
        {
            return getfilelist("ftp://" + ftpserverip + "/" + path, webrequestmethods.ftp.listdirectory);

        }

 

        public string[] getfilelist()//上面的代码示例了如何从ftp服务器上获得文件列表
        {
            return getfilelist("ftp://" + ftpserverip + "/", webrequestmethods.ftp.listdirectory);
        }

        public void upload(string filename) //上面的代码实现了从ftp服务器上载文件的功能
        {
            fileinfo fileinf = new fileinfo(filename);
            string uri = "ftp://" + ftpserverip + "/" + fileinf.name;
            connect(uri);//连接      
            // 默认为true，连接不会被关闭
            // 在一个命令之后被执行
            reqftp.keepalive = false;
            // 指定执行什么命令
            reqftp.method = webrequestmethods.ftp.uploadfile;
            // 上传文件时通知服务器文件的大小
            reqftp.contentlength = fileinf.length;
            // 缓冲大小设置为kb 
            int bufflength = 2048;

            byte[] buff = new byte[bufflength];
            int contentlen;
            // 打开一个文件流(system.io.filestream) 去读上传的文件
            filestream fs = fileinf.openread();
            try
            {
                // 把上传的文件写入流
                stream strm = reqftp.getrequeststream();
                // 每次读文件流的kb 
                contentlen = fs.read(buff, 0, bufflength);
                // 流内容没有结束
                while (contentlen != 0)
                {
                    // 把内容从file stream 写入upload stream 
                    strm.write(buff, 0, contentlen);
                    contentlen = fs.read(buff, 0, bufflength);
                }
                // 关闭两个流
                strm.close();
                fs.close();
            }
            catch (exception ex)
            {
                messagebox.show(ex.message, "upload error");
            }
        }
        public bool download(string filepath, string filename, out string errorinfo)////上面的代码实现了从ftp服务器下载文件的功能
        {
            try
            {
                string onlyfilename = path.getfilename(filename);
                string newfilename = filepath + "\\" + onlyfilename;
                if (file.exists(newfilename))
                {
                    errorinfo = string.format("本地文件{0}已存在,无法下载", newfilename);
                    return false;
                }
                string url = "ftp://" + ftpserverip + "/" + filename;
                connect(url);//连接  
                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);
                filestream outputstream = new filestream(newfilename, filemode.create);

                while (readcount > 0)
                {
                    outputstream.write(buffer, 0, readcount);

                    readcount = ftpstream.read(buffer, 0, buffersize);
                }
                ftpstream.close();
                outputstream.close();
                response.close();
                errorinfo = "";
                return true;
            }
            catch (exception ex)
            {
                errorinfo = string.format("因{0},无法下载", ex.message);
                return false;
            }
        }

        //删除文件

         public void deletefilename(string filename)
         {
             try
             {
                 fileinfo fileinf = new fileinfo(filename);
                 string uri = "ftp://" + ftpserverip + "/" + fileinf.name;
                 connect(uri);//连接        
                 // 默认为true，连接不会被关闭

                 // 在一个命令之后被执行

                 reqftp.keepalive = false;

                 // 指定执行什么命令

                 reqftp.method = webrequestmethods.ftp.deletefile;
                 ftpwebresponse response = (ftpwebresponse)reqftp.getresponse();
                 response.close();
             }
             catch (exception ex)
             {
                 messagebox.show(ex.message, "删除错误");
             }
         }

        //创建目录

        public void makedir(string dirname)
        {
            try
            {
                string uri = "ftp://" + ftpserverip + "/" + dirname;
                connect(uri);//连接       
                reqftp.method = webrequestmethods.ftp.makedirectory;
                ftpwebresponse response = (ftpwebresponse)reqftp.getresponse();
                response.close();
            }
            catch (exception ex)
            {
                messagebox.show(ex.message);
            }
        }
        //删除目录
        public void deldir(string dirname)
        {
            try
            {

                string uri = "ftp://" + ftpserverip + "/" + dirname;
                connect(uri);//连接       
                reqftp.method = webrequestmethods.ftp.removedirectory;
                ftpwebresponse response = (ftpwebresponse)reqftp.getresponse();
                response.close();
            }
            catch (exception ex)
            {
                messagebox.show(ex.message);
            }
        }

        //获得文件大小

        public long getfilesize(string filename)
        {
            long filesize = 0;
            try
            {
                fileinfo fileinf = new fileinfo(filename);
                string uri = "ftp://" + ftpserverip + "/" + fileinf.name;
                connect(uri);//连接       
                reqftp.method = webrequestmethods.ftp.getfilesize;
                ftpwebresponse response = (ftpwebresponse)reqftp.getresponse();
                filesize = response.contentlength;
                response.close();
            }
            catch (exception ex)
            {
                messagebox.show(ex.message);
            }
            return filesize;
        }

        //文件改名
        public void rename(string currentfilename, string newfilename)
        {
            try
            {
                fileinfo fileinf = new fileinfo(currentfilename);
                string uri = "ftp://" + ftpserverip + "/" + fileinf.name;
                connect(uri);//连接
                reqftp.method = webrequestmethods.ftp.rename;
                reqftp.renameto = newfilename;
                ftpwebresponse response = (ftpwebresponse)reqftp.getresponse();
                //stream ftpstream = response.getresponsestream();

                //ftpstream.close();
                response.close();
            }
            catch (exception ex)
            {
                messagebox.show(ex.message);
            }
        }

        //获得文件明晰
        public string[] getfilesdetaillist()
        {
            return getfilelist("ftp://" + ftpserverip + "/", webrequestmethods.ftp.listdirectorydetails);
        }
        //获得文件明晰
        public string[] getfilesdetaillist(string path)
        {
            return getfilelist("ftp://" + ftpserverip + "/" + path, webrequestmethods.ftp.listdirectorydetails);
        }

    }
}

上面为类，举例证明如何代用

private void button1_click(object sender, eventargs e)//文件上传
        {
            ftpupdown ftpupdown = new ftpupdown("192.168.2.130:21", "wl","123456");
            ftpupdown.upload("e:\\other.rar");  
        }
 private void button3_click(object sender, eventargs e)//修改
        {
            ftpupdown ftpupdown = new ftpupdown("192.168.2.130:21", "wl", "123456");
            ftpupdown.rename("张三", "李四");
        }
 private void button4_click(object sender, eventargs e)//删除
        {
            ftpupdown ftpupdown = new ftpupdown("192.168.2.130:21", "wl", "123456");
            ftpupdown.deldir("张三");
        }
 private void button2_click(object sender, eventargs e)//添加
        {
            ftpupdown ftpupdown = new ftpupdown("192.168.2.130:21", "wl", "123456");
            ftpupdown.makedir(this.txt_name.text);
        }

 
//获得ftp文件的文件明晰，还为处理，能够获得所有的文件名称
 ftpupdown ftpupdown = new ftpupdown("192.168.2.130", "wl", "123456");
            string[] str = ftpupdown.getfilesdetaillist();
            int i = 1;
            foreach (string item in str)
            {
                string[] name = item.split(' ');
                txt_name.text += name[name.length - 1] + ";";
                i++;
            }
            label1.text = i.tostring();