美文网首页
第一篇文章

第一篇文章

作者: Solchen | 来源:发表于2017-12-14 09:24 被阅读0次

    1、连接FTP服务器

    ///

    /// 连接FTP服务器

    ///

    /// FTP连接地址

    /// 指定FTP连接成功后的当前目录, 如果不指定即默认为根目录

    /// 用户名

    /// 密码

    public FTPHelper(string FtpServerIP, string FtpRemotePath, string FtpUserID, string FtpPassword)

    {

    ftpServerIP = FtpServerIP;

    ftpRemotePath = FtpRemotePath;

    ftpUserID = FtpUserID;

    ftpPassword = FtpPassword;

    ftpURI = "ftp://" + ftpServerIP + "/" + ftpRemotePath + "/";

    }

    2、上传

    ///

    /// 上传

    ///

    public void Upload(string filename)

    {

    FileInfo fileInf = new FileInfo(filename);

    FtpWebRequest reqFTP;

    reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + fileInf.Name));

    reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);

    reqFTP.Method = WebRequestMethods.Ftp.UploadFile;

    reqFTP.KeepAlive = false;

    reqFTP.UseBinary = true;

    reqFTP.ContentLength = fileInf.Length;

    int buffLength = 2048;

    byte[] buff = new byte[buffLength];

    int contentLen;

    FileStream fs = fileInf.OpenRead();

    try

    {

    Stream strm = reqFTP.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();

    }

    catch (Exception ex)

    {

    throw new Exception(ex.Message);

    }

    }

    3、下载

    ///

    /// 下载

    ///

    public void Download(string filePath, string fileName)

    {

    try

    {

    FileStream outputStream = new FileStream(filePath + "\\" + fileName, FileMode.Create);

    FtpWebRequest reqFTP;

    reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + fileName));

    reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);

    reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;

    reqFTP.UseBinary = true;

    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)

    {

    throw new Exception(ex.Message);

    }

    }

    4、删除文件

    ///

    /// 删除文件

    ///

    public void Delete(string fileName)

    {

    try

    {

    FtpWebRequest reqFTP;

    reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + fileName));

    reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);

    reqFTP.Method = WebRequestMethods.Ftp.DeleteFile;

    reqFTP.KeepAlive = false;

    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)

    {

    throw new Exception(ex.Message);

    }

    }

    5、获取当前目录下明细(包含文件和文件夹)

    ///

    /// 获取当前目录下明细(包含文件和文件夹)

    ///

    public string[] GetFilesDetailList()

    {

    try

    {

    StringBuilder result = new StringBuilder();

    FtpWebRequest ftp;

    ftp = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI));

    ftp.Credentials = new NetworkCredential(ftpUserID, ftpPassword);

    ftp.Method = WebRequestMethods.Ftp.ListDirectoryDetails;

    WebResponse response = ftp.GetResponse();

    StreamReader reader = new StreamReader(response.GetResponseStream());

    string line = reader.ReadLine();

    line = reader.ReadLine();

    line = reader.ReadLine();

    while (line != null)

    {

    result.Append(line);

    result.Append("\n");

    line = reader.ReadLine();

    }

    result.Remove(result.ToString().LastIndexOf("\n"), 1);

    reader.Close();

    response.Close();

    return result.ToString().Split('\n');

    }

    catch (Exception ex)

    {

    throw new Exception(ex.Message);

    }

    }

    6、 获取FTP文件列表(包括文件夹)

    ///

    /// 获取FTP文件列表(包括文件夹)

    ///

    private string[] GetAllList(string url)

    {

    List list = new List();

    FtpWebRequest req = (FtpWebRequest)WebRequest.Create(new Uri(url));

    req.Credentials = new NetworkCredential(ftpPassword, ftpPassword);

    req.Method = WebRequestMethods.Ftp.ListDirectory;

    req.UseBinary = true;

    req.UsePassive = true;

    try

    {

    using (FtpWebResponse res = (FtpWebResponse)req.GetResponse())

    {

    using (StreamReader sr = new StreamReader(res.GetResponseStream()))

    {

    string s;

    while ((s = sr.ReadLine()) != null)

    {

    list.Add(s);

    }

    }

    }

    }

    catch (Exception ex)

    {

    throw (ex);

    }

    return list.ToArray();

    }

    7、获取当前目录下文件列表(不包括文件夹)

    ///

    /// 获取当前目录下文件列表(不包括文件夹)

    ///

    public string[] GetFileList(string url)

    {

    StringBuilder result = new StringBuilder();

    FtpWebRequest reqFTP;

    try

    {

    reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(url));

    reqFTP.UseBinary = true;

    reqFTP.Credentials = new NetworkCredential(ftpPassword, ftpPassword);

    reqFTP.Method = WebRequestMethods.Ftp.ListDirectoryDetails;

    WebResponse response = reqFTP.GetResponse();

    StreamReader reader = new StreamReader(response.GetResponseStream());

    string line = reader.ReadLine();

    while (line != null)

    {

    if (line.IndexOf("") == -1)

    {

    result.Append(Regex.Match(line, @"[\S]+ [\S]+", RegexOptions.IgnoreCase).Value.Split(' ')[1]);

    result.Append("\n");

    }

    line = reader.ReadLine();

    }

    result.Remove(result.ToString().LastIndexOf('\n'), 1);

    reader.Close();

    response.Close();

    }

    catch (Exception ex)

    {

    throw (ex);

    }

    return result.ToString().Split('\n');

    }

    8、判断当前目录下指定的文件是否存在

    ///

    /// 判断当前目录下指定的文件是否存在

    ///

    /// 远程文件名

    public bool FileExist(string RemoteFileName)

    {

    string[] fileList = GetFileList("*.*");

    foreach (string str in fileList)

    {

    if (str.Trim() == RemoteFileName.Trim())

    {

    return true;

    }

    }

    return false;

    }

    9、创建文件夹

    ///

    /// 创建文件夹

    ///

    public void MakeDir(string dirName)

    {

    FtpWebRequest reqFTP;

    try

    {

    reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + 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)

    { }

    }

    10、获取指定文件大小

    ///

    /// 获取指定文件大小

    ///

    public long GetFileSize(string filename)

    {

    FtpWebRequest reqFTP;

    long fileSize = 0;

    try

    {

    reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + filename));

    reqFTP.Method = WebRequestMethods.Ftp.GetFileSize;

    reqFTP.UseBinary = true;

    reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);

    FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();

    Stream ftpStream = response.GetResponseStream();

    fileSize = response.ContentLength;

    ftpStream.Close();

    response.Close();

    }

    catch (Exception ex)

    { }

    return fileSize;

    }

    11、更改文件名

    ///

    /// 更改文件名

    ///

    public void ReName(string currentFilename, string newFilename)

    {

    FtpWebRequest reqFTP;

    try

    {

    reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + 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)

    { }

    }

    12、移动文件

    ///

    /// 移动文件

    ///

    public void MovieFile(string currentFilename, string newDirectory)

    {

    ReName(currentFilename, newDirectory);

    }

    13、切换当前目录

    ///

    /// 切换当前目录

    ///

    /// true:绝对路径 false:相对路径

    public void GotoDirectory(string DirectoryName, bool IsRoot)

    {

    if (IsRoot)

    {

    ftpRemotePath = DirectoryName;

    }

    else

    {

    ftpRemotePath += DirectoryName + "/";

    }

    ftpURI = "ftp://" + ftpServerIP + "/" + ftpRemotePath + "/";

    }

    附上github地址,https://github.com/Jimmey-Jiang/Common.Utility.git求star喜欢点赞

    20171011.png

    作者:安与生_

    链接:http://www.jianshu.com/p/c396a2b59a7b

    來源:简书

    著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

    相关文章

      网友评论

          本文标题:第一篇文章

          本文链接:https://www.haomeiwen.com/subject/wiehwxtx.html