C# FTP操作类
发布时间:2020-12-15 17:54:02 所属栏目:百科 来源:网络整理
导读:今天PHP站长网 52php.cn把收集自互联网的代码分享给大家,仅供参考。 using System;using System.Collections.Generic;using System.Text;using System.Net;using System.IO;namespace Utility{ public class FtpUpDown {
以下代码由PHP站长网 52php.cn收集自互联网 现在PHP站长网小编把它分享给大家,仅供参考 using System; using System.Collections.Generic; using System.Text; using System.Net; using System.IO; namespace Utility { public 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) { Log.WriteError("Get FileList Error:" + 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,buffLength); // 流内容没有结束 while (contentLen != 0) { // 把内容从file stream 写入upload stream strm.Write(buff,contentLen); contentLen = fs.Read(buff,buffLength); } // 关闭两个流 strm.Close(); fs.Close(); } catch (Exception ex) { Log.WriteError( "Upload Error:" + ex.Message); } } 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,bufferSize); FileStream outputStream = new FileStream(newFileName,FileMode.Create); while (readCount > 0) { outputStream.Write(buffer,readCount); readCount = ftpStream.Read(buffer,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) { Log.WriteError("删除错误:" + 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) { Log.WriteError("创建目录错误:" + 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) { Log.WriteError("删除目录错误:" + 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) { Log.WriteError("获得文件大小错误:" + 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(); response.Close(); } catch (Exception ex) { Log.WriteError("文件改名错误:" + ex.Message); } } //读取文件 public Stream ReadFile(string fileName) { try { string url = "ftp://" + ftpServerIP + "/" + fileName; Connect(url);//连接 reqFTP.Credentials = new NetworkCredential(ftpUserID,ftpPassword); FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse(); Stream ftpStream = response.GetResponseStream(); return ftpStream; } catch (Exception ex) { Log.WriteError("读取文件错误:" + ex.Message); return null; } } //获得文件明晰 public string[] GetFilesDetailList() { return GetFileList("ftp://" + ftpServerIP + "/",WebRequestMethods.Ftp.ListDirectoryDetails); } //获得文件明晰 public string[] GetFilesDetailList(string path) { return GetFileList("ftp://" + ftpServerIP + "/" + path,WebRequestMethods.Ftp.ListDirectoryDetails); } // 文件存在检查 public bool fileCheckExist(string fileName) { bool success = false; FtpWebResponse response = null; StreamReader reader = null; try { string url = "ftp://" + ftpServerIP + "/" + fileName; Connect(url);//连接 reqFTP.Credentials = new NetworkCredential(ftpUserID,ftpPassword); response = (FtpWebResponse)reqFTP.GetResponse(); reader = new StreamReader(response.GetResponseStream()); string line = reader.ReadLine(); if (line != null) { success = true; } } catch (Exception) { success = false; } finally { if (reader != null) { reader.Close(); } if (response != null) { response.Close(); } } return success; } } } 以上内容由PHP站长网【52php.cn】收集整理供大家参考研究 如果以上内容对您有帮助,欢迎收藏、点赞、推荐、分享。 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |