标签：web 获取 collect 时间 network return ftp model group
C# FTPHelper实现FTP服务器文件读写操作，支持SSL协议（FTP服务器为：Serv-U10.0）。
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Security;
using System.Security.Cryptography.X509Certificates;
using System.Text;
namespace FTPTest
{
public class FTPHelper
{
#region 变量
///
/// FTP请求对象
///
FtpWebRequest request = null;
///
/// FTP响应对象
///
FtpWebResponse response = null;
///
/// FTP服务器长地址
///
public string FtpURI { get; private set; }
///
/// FTP服务器IP
///
public string ServerIP { get; private set; }
///
/// FTP端口
///
public int ServerPort { get; private set; }
///
/// FTP用户
///
public string Username { get; private set; }
///
/// FTP密码
///
public string Password { get; private set; }
///
/// 是否启用SSL
///
public bool EnableSsl { get; private set; }
#endregion
#region 构造
///
/// 初始化
///
/// IP
/// 端口
/// 用户名
/// 密码
public FTPHelper(string ftpServerIP, int ftpServerPort, string ftpUsername, string ftpPassword, bool ftpEnableSsl = false)
{
ServerIP = ftpServerIP;
ServerPort = ftpServerPort;
Username = ftpUsername;
Password = ftpPassword;
EnableSsl = ftpEnableSsl;
FtpURI = string.Format("ftp://{0}:{1}/", ftpServerIP, ftpServerPort);
}
~FTPHelper()
{
if (response != null)
{
response.Close();
response = null;
}
if (request != null)
{
request.Abort();
request = null;
}
}
#endregion
#region 方法
///
/// 建立FTP链接,返回响应对象
///
/// FTP地址
/// 操作命令
private FtpWebResponse Open(Uri uri, string ftpMethod)
{
try
{
request = (FtpWebRequest)FtpWebRequest.Create(uri);
request.Method = ftpMethod;
request.UseBinary = true;
request.KeepAlive = false;
request.UsePassive = true;//被动模式
request.EnableSsl = EnableSsl;
request.Credentials = new NetworkCredential(Username, Password);
request.Timeout = 30000;
//首次连接FTP Server时，会有一个证书分配过程。
//根据验证过程，远程证书无效。
ServicePoint sp = request.ServicePoint;
ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(ValidateServerCertificate);
return (FtpWebResponse)request.GetResponse();
}
catch (Exception ex)
{
return null;
}
}
///
/// 建立FTP链接,返回请求对象
///
/// FTP地址
/// 操作命令
private FtpWebRequest OpenRequest(Uri uri, string ftpMethod)
{
try
{
request = (FtpWebRequest)WebRequest.Create(uri);
request.Method = ftpMethod;
request.UseBinary = true;
request.KeepAlive = false;
request.UsePassive = true;//被动模式
request.EnableSsl = EnableSsl;
request.Credentials = new NetworkCredential(Username, Password);
request.Timeout = 30000;
ServicePoint sp = request.ServicePoint;
ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(ValidateServerCertificate);
return request;
}
catch (Exception ex)
{
return null;
}
}
///
/// 证书验证回调
///
private bool ValidateServerCertificate(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
{
return true;
}
///
/// 下载文件
///
/// 远程文件
/// 本地文件
public bool Get(string remoteFileName, string localFileName)
{
response = Open(new Uri(FtpURI + remoteFileName), WebRequestMethods.Ftp.DownloadFile);
if (response == null) return false;
try
{
using (FileStream outputStream = new FileStream(localFileName, FileMode.Create))
{
using (Stream ftpStream = response.GetResponseStream())
{
long length = 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);
}
}
}
return true;
}
catch
{
return false;
}
}
///
/// 文件上传
///
/// 本地文件
/// 远程文件
public bool Put(string localFileName, string remoteFileName)
{
FileInfo fi = new FileInfo(localFileName);
if (fi.Exists == false) return false;
request = OpenRequest(new Uri(FtpURI + remoteFileName), WebRequestMethods.Ftp.UploadFile);
if (request == null) return false;
request.ContentLength = fi.Length;
int buffLength = 2048;
byte[] buff = new byte[buffLength];
int contentLen;
try
{
using (var fs = fi.OpenRead())
{
using (var strm = request.GetRequestStream())
{
contentLen = fs.Read(buff, 0, buffLength);
while (contentLen != 0)
{
strm.Write(buff, 0, contentLen);
contentLen = fs.Read(buff, 0, buffLength);
}
}
}
return true;
}
catch
{
return false;
}
}
///
/// 删除文件
///
public bool DeleteFile(string fileName)
{
response = Open(new Uri(FtpURI + fileName), WebRequestMethods.Ftp.DeleteFile);
return response == null ? false : true;
}
///
/// 创建目录
///
public bool CreateDirectory(string dirName)
{
response = Open(new Uri(FtpURI + dirName), WebRequestMethods.Ftp.MakeDirectory);
return response == null ? false : true;
}
///
/// 删除目录(包括下面所有子目录和子文件)
///
public bool DeleteDirectory(string dirName)
{
var listAll = GetDirectoryAndFiles(dirName);
if (listAll == null) return false;
foreach (var m in listAll)
{
if (m.IsDirectory)
DeleteDirectory(m.Path);
else
DeleteFile(m.Path);
}
response = Open(new Uri(FtpURI + dirName), WebRequestMethods.Ftp.RemoveDirectory);
return response == null ? false : true;
}
///
/// 获取目录的文件和一级子目录信息
///
public List GetDirectoryAndFiles(string dirName)
{
var fileList = new List();
response = Open(new Uri(FtpURI + dirName), WebRequestMethods.Ftp.ListDirectoryDetails);
if (response == null) return fileList;
try
{
using (var stream = response.GetResponseStream())
{
using (var sr = new StreamReader(stream, Encoding.Default))
{
string line = null;
while ((line = sr.ReadLine()) != null)
{
//line的格式如下：serv-u(文件夹为第1位为d)
//drw-rw-rw- 1 user group 0 Jun 10 2019 BStatus
//-rw-rw-rw- 1 user group 625 Dec 7 2018 FTP文档.txt
string[] arr = line.Split(‘ ‘);
if (arr.Length 12) continue;//remotePath不为空时，第1行返回值为：total 10715
var model = new FileStruct()
{
IsDirectory = line.Substring(0, 3) == "drw" ? true : false,
Name = arr[arr.Length - 1],
Path = dirName + "/" + arr[arr.Length - 1]
};
if (model.Name != "." && model.Name != "..")//排除.和..
{
fileList.Add(model);
}
}
}
}
return fileList;
}
catch
{
return fileList;
}
}
///
/// 获取目录的文件
///
public List GetFiles(string dirName)
{
var fileList = new List();
response = Open(new Uri(FtpURI + dirName), WebRequestMethods.Ftp.ListDirectory);
if (response == null) return fileList;
try
{
using (var stream = response.GetResponseStream())
{
using (var sr = new StreamReader(stream, Encoding.Default))
{
string line = null;
while ((line = sr.ReadLine()) != null)
{
var model = new FileStruct()
{
Name = line,
Path = dirName + "/" + line
};
fileList.Add(model);
}
}
}
return fileList;
}
catch
{
return fileList;
}
}
///
/// 获得远程文件大小
///
public long GetFileSize(string fileName)
{
response = Open(new Uri(FtpURI + fileName), WebRequestMethods.Ftp.GetFileSize);
return response == null ? -1 : response.ContentLength;
}
///
/// 文件是否存在
///
public bool FileExist(string fileName)
{
long length = GetFileSize(fileName);
return length == -1 ? false : true;
}
///
/// 目录是否存在
///
public bool DirectoryExist(string dirName)
{
var list = GetDirectoryAndFiles(Path.GetDirectoryName(dirName));
return list.Count(m => m.IsDirectory == true && m.Name == dirName) > 0 ? true : false;
}
///
/// 更改目录或文件名
///
/// 老名称
/// 新名称
public bool ReName(string oldName, string newName)
{
request = OpenRequest(new Uri(FtpURI + oldName), WebRequestMethods.Ftp.Rename);
request.RenameTo = newName;
try
{
response = (FtpWebResponse)request.GetResponse();
return response == null ? false : true;
}
catch
{
return false;
}
}
#endregion
}
///
/// FTP文件类
///
public class FileStruct
{
///
/// 是否为目录
///
public bool IsDirectory { get; set; }
///
/// 创建时间(FTP上无法获得时间)
///
//public DateTime CreateTime { get; set; }
///
/// 文件或目录名称
///
public string Name { get; set; }
///
/// 路径
///
public string Path { get; set; }
}
}
SSL测试调用代码
var ftp = new FTPHelper("192.168.0.36", 21, "test", "1", true);
var list = ftp.GetFiles("");
任何地方如有纰漏，欢迎诸位道友指教。
【C#】工具类-FTP操作封装类FTPHelper
标签：web 获取 collect 时间 network return ftp model group
原文地址：https://www.cnblogs.com/zhangwc/p/12170769.html