Ftp 上传下载 *** 作C# 类

概述Ftp 上传下载 *** 作C# 类

下面是内存溢出 jb51.cc 通过网络收集整理的代码片段。

内存溢出小编现在分享给大家，也给大家做个参考。

using System;using System.Collections.Generic;using System.Text;using System.Net;using System.Net.sockets;using System.IO;namespace AppUtility{    /// <summary>    /// FTP ClIEnt    /// </summary>    public class FTPClIEnt    {        #region 构造函数        /// <summary>        /// 缺省构造函数        /// </summary>        public FTPClIEnt()        {            strRemoteHost  = "";            strRemotePath  = "";            strRemoteUser  = "";            strRemotePass  = "";            strRemotePort  = 21;            bConnected     = false;        }        /// <summary>        /// 构造函数        /// </summary>        /// <param name="remoteHost"></param>        /// <param name="remotePath"></param>        /// <param name="remoteUser"></param>        /// <param name="remotePass"></param>        /// <param name="remotePort"></param>        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 登陆        /// <summary>        /// FTP服务器IP地址        /// </summary>        private string strRemoteHost;        public string RemoteHost        {            get            {                return strRemoteHost;            }            set            {                strRemoteHost = value;            }        }        /// <summary>        /// FTP服务器端口        /// </summary>        private int strRemotePort;        public int RemotePort        {            get            {            return strRemotePort;            }            set            {                strRemotePort = value;            }        }        /// <summary>        /// 当前服务器目录        /// </summary>        private string strRemotePath;        public string RemotePath        {            get            {                return strRemotePath;            }            set            {                strRemotePath = value;            }        }        /// <summary>        /// 登录用户账号        /// </summary>        private string strRemoteUser;        public string RemoteUser        {            set            {                strRemoteUser = value;            }        }        /// <summary>        /// 用户登录密码        /// </summary>        private string strRemotePass;        public string RemotePass        {            set            {                strRemotePass = value;            }        }        /// <summary>        /// 是否登录        /// </summary>        private Boolean bConnected;        public bool Connected        {            get            {                return bConnected;            }        }        #endregion        #region 链接        /// <summary>        /// 建立连接         /// </summary>        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;            // 切换到目录            ChDir(strRemotePath);        }        /// <summary>        /// 关闭连接        /// </summary>        public voID disConnect()        {            if( socketControl != null )            {                SendCommand("QUIT");            }            CloseSocketConnect();        }        #endregion        #region 传输模式        /// <summary>        /// 传输模式:二进制类型、ASCII类型        /// </summary>        public enum TransferType {Binary,ASCII};        /// <summary>        /// 设置传输模式        /// </summary>        /// <param name="ttType">传输模式</param>        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;            }        }        /// <summary>        /// 获得传输模式        /// </summary>        /// <returns>传输模式</returns>        public TransferType GetTransferType()        {            return trType;        }        #endregion        #region 文件 *** 作        /// <summary>        /// 获得文件列表        /// </summary>        /// <param name="strMask">文件名的匹配字符串</param>        /// <returns></returns>        public string[] Dir(string strMask)        {            // 建立链接            if(!bConnected)            {                Connect();            }            //建立进行数据连接的socket            Socket socketData = CreateDataSocket();            //传送命令            SendCommand("NLST " + strMask);            //分析应答代码            if(!(iReplyCode == 150 || iReplyCode == 125 || iReplyCode == 226))            {                throw new IOException(strReply.Substring(4));            }            //获得结果            strMsg = "";            while(true)            {                int iBytes = socketData.Receive(buffer,buffer.Length,0);                strMsg += ASCII.GetString(buffer,iBytes);                if(iBytes < buffer.Length)                {                    break;                }            }            char[] seperator = {' '};            string[] strsfileList = strMsg.Split(seperator);            socketData.Close();//数据socket关闭时也会有返回码            if(iReplyCode != 226)            {                ReadReply();                if(iReplyCode != 226)                {                    throw new IOException(strReply.Substring(4));                }            }            return strsfileList;        }        /// <summary>        /// 获取文件大小        /// </summary>        /// <param name="strfilename">文件名</param>        /// <returns>文件大小</returns>        private 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;        }        /// <summary>        /// 删除        /// </summary>        /// <param name="strfilename">待删除文件名</param>        public voID Delete(string strfilename)        {            if(!bConnected)            {                Connect();            }            SendCommand("DELE "+strfilename);            if(iReplyCode != 250)            {                throw new IOException(strReply.Substring(4));            }        }        /// <summary>        /// 重命名(如果新文件名与已有文件重名,将覆盖已有文件)        /// </summary>        /// <param name="stroldfilename">旧文件名</param>        /// <param name="strNewfilename">新文件名</param>        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 上传和下载        /// <summary>        /// 下载一批文件        /// </summary>        /// <param name="strfilenameMask">文件名的匹配字符串</param>        /// <param name="strFolder">本地目录(不得以结束)</param>        public voID Get(string strfilenameMask,string strFolder)        {            if(!bConnected)            {                Connect();            }            string[] strfiles = Dir(strfilenameMask);            foreach(string strfile in strfiles)            {                if(!strfile.Equals(""))//一般来说strfiles的最后一个元素可能是空字符串                {                    Get(strfile,strFolder,strfile);                }            }        }        /// <summary>        /// 下载一个文件        /// </summary>        /// <param name="strRemotefilename">要下载的文件名</param>        /// <param name="strFolder">本地目录(不得以结束)</param>        /// <param name="strLocalfilename">保存在本地时的文件名</param>        public voID Get(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,0);                output.Write(buffer,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));                }            }        }        /// <summary>        /// 上传一批文件        /// </summary>        /// <param name="strFolder">本地目录(不得以结束)</param>        /// <param name="strfilenameMask">文件名匹配字符(可以包含*和?)</param>        public voID Put(string strFolder,string strfilenameMask)        {            string[] strfiles = Directory.Getfiles(strFolder,strfilenameMask);            foreach(string strfile in strfiles)            {                //strfile是完整的文件名(包含路径)                Put(strfile);            }        }        /// <summary>        /// 上传一个文件        /// </summary>        /// <param name="strfilename">本地文件名</param>        public voID Put(string strfilename)        {            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,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));                }            }        }        #endregion        #region 目录 *** 作        /// <summary>        /// 创建目录        /// </summary>        /// <param name="strDirname">目录名</param>        public voID MkDir(string strDirname)        {            if(!bConnected)            {                Connect();            }            SendCommand("MKD "+strDirname);            if(iReplyCode != 257)            {                throw new IOException(strReply.Substring(4));            }        }        /// <summary>        /// 删除目录        /// </summary>        /// <param name="strDirname">目录名</param>        public voID RmDir(string strDirname)        {            if(!bConnected)            {                Connect();            }            SendCommand("RMD "+strDirname);            if(iReplyCode != 250)            {                throw new IOException(strReply.Substring(4));            }        }        /// <summary>        /// 改变目录        /// </summary>        /// <param name="strDirname">新的工作目录名</param>        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 内部变量        /// <summary>        /// 服务器返回的应答信息(包含应答码)        /// </summary>        private string strMsg;        /// <summary>        /// 服务器返回的应答信息(包含应答码)        /// </summary>        private string strReply;        /// <summary>        /// 服务器返回的应答码        /// </summary>        private int iReplyCode;        /// <summary>        /// 进行控制连接的socket        /// </summary>        private Socket socketControl;        /// <summary>        /// 传输模式        /// </summary>        private TransferType trType;        /// <summary>        /// 接收和发送数据的缓冲区        /// </summary>        private static int BLOCK_SIZE = 512;        Byte[] buffer = new Byte[BLOCK_SIZE];        /// <summary>        /// 编码方式        /// </summary>        EnCoding ASCII = EnCoding.ASCII;        #endregion        #region 内部函数        /// <summary>        /// 将一行应答字符串记录在strReply和strMsg        /// 应答码记录在iReplyCode        /// </summary>        private voID ReadReply()        {            strMsg = "";            strReply = Readline();            iReplyCode = Int32.Parse(strReply.Substring(0,3));        }        /// <summary>        /// 建立进行数据连接的socket        /// </summary>        /// <returns>数据连接socket</returns>        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,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;        }        /// <summary>        /// 关闭socket连接(用于登录以前)        /// </summary>        private voID CloseSocketConnect()        {            if(socketControl!=null)            {                socketControl.Close();                socketControl = null;            }            bConnected = false;        }        /// <summary>        /// 读取Socket返回的所有字符串        /// </summary>        /// <returns>包含应答码的字符串行</returns>        private string Readline()        {            while(true)            {                int iBytes = socketControl.Receive(buffer,iBytes);                if(iBytes < buffer.Length)                {                    break;                }            }            char[] seperator = {' '};            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;        }        /// <summary>        /// 发送命令并获取应答码和最后一行应答字符串        /// </summary>        /// <param name="strCommand">命令</param>        private voID SendCommand(String strCommand)        {            Byte[] cmdBytes =             EnCoding.ASCII.GetBytes((strCommand+" ").tochararray());            socketControl.Send(cmdBytes,cmdBytes.Length,0);            ReadReply();        }        #endregion    }}

以上是内存溢出(jb51.cc)为你收集整理的全部代码内容，希望文章能够帮你解决所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。

总结

以上是内存溢出为你收集整理的Ftp 上传下载 *** 作C# 类全部内容，希望文章能够帮你解决Ftp 上传下载 *** 作C# 类所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。