C# 中比较好用的ftp操作类，值得学习
FTP具体操作过程的类using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.IO;
using System.Net;
using System.Runtime.InteropServices;
using System.Collections;
using System.IO.Compression;
using System.Runtime.Serialization.Formatters.Binary;
using System.Threading;
using System.Runtime.Serialization;
using Microsoft.Win32;
namespace FTP
{
class BaseClass
{
public class Win32
{
public const uint SHGFI_ICON = 0x100;
public const uint SHGFI_LARGEICON = 0x0; // 'Large icon
public const uint SHGFI_SMALLICON = 0x1; // 'Small icon
public static extern int ExtractIcon(IntPtr hInst, string lpFileName, int nIndex);
public static extern IntPtr SHGetFileInfo(string pszPath, uint dwFileAttribute, ref SHFILEINFO psfi, uint cbSizeFileInfo, uint Flags);
public static extern int DestroyIcon(IntPtr hIcon);
public static extern uint ExtractIconEx(string lpszFile, int nIconIndex, int[] phiconLarge, int[] phiconSmall, uint nIcons);
public struct SHFILEINFO
{
public IntPtr hIcon;
public IntPtr iIcon;
public uint dwAttributes;
public string szDisplayName;
public string szTypeName;
}
}
#region获取服务器图标
/// 给出文件扩展名（.*），返回相应图标
/// 若不以"."开头则返回文件夹的图标。
public Icon GetIconByFileType(string fileType,bool isLarge)
{
if(fileType == null || fileType.Equals(string.Empty)) return null;
RegistryKey regVersion = null;
string regFileType = null;
string regIconString = null;
string systemDirectory = Environment.SystemDirectory + "\\";
if(fileType == '.')
{
//读系统注册表中文件类型信息
regVersion = Registry.ClassesRoot.OpenSubKey(fileType, true);
if(regVersion != null)
{
regFileType = regVersion.GetValue("") as string;
regVersion.Close();
regVersion = Registry.ClassesRoot.OpenSubKey(regFileType + @"\DefaultIcon" , true);
if(regVersion != null)
{
regIconString = regVersion.GetValue("") as string;
regVersion.Close();
}
}
if(regIconString == null)
{
//没有读取到文件类型注册信息，指定为未知文件类型的图标
regIconString = systemDirectory +"shell32.dll,0";
}
}
else
{
//直接指定为文件夹图标
regIconString = systemDirectory +"shell32.dll,3";
}
string[] fileIcon = regIconString.Split(new char[]{','});
if(fileIcon.Length != 2)
{
//系统注册表中注册的标图不能直接提取，则返回可执行文件的通用图标
fileIcon = new string[]{systemDirectory +"shell32.dll","2"};
}
Icon resultIcon = null;
try
{
//调用API方法读取图标
int[] phiconLarge = new int;
int[] phiconSmall = new int;
uint count = Win32.ExtractIconEx(fileIcon,Int32.Parse(fileIcon),phiconLarge,phiconSmall,1);
IntPtr IconHnd = new IntPtr(isLarge?phiconLarge:phiconSmall);
resultIcon = Icon.FromHandle(IconHnd);
}
catch
{
fileIcon = new string[] { systemDirectory + "shell32.dll", "2" };
//调用API方法读取图标
int[] phiconLarge = new int;
int[] phiconSmall = new int;
uint count = Win32.ExtractIconEx(fileIcon,Int32.Parse(fileIcon),phiconLarge,phiconSmall,1);
IntPtr IconHnd = new IntPtr(isLarge?phiconLarge:phiconSmall);
resultIcon = Icon.FromHandle(IconHnd);
}
return resultIcon;
}
#endregion
#region文件夹的复制
/// <summary>
/// 文件夹的复制
/// </summary>
/// <param Ddir="string">要复制的目的路径</param>
/// <param Sdir="string">要复制的原路径</param>
public void Files_Copy(string Ddir, string Sdir)
{
DirectoryInfo dir = new DirectoryInfo(Sdir);
string SbuDir = Ddir;
try
{
if (!dir.Exists)//判断所指的文件或文件夹是否存在
{
return;
}
DirectoryInfo dirD = dir as DirectoryInfo;//如果给定参数不是文件夹则退出
string UpDir = UpAndDown_Dir(Ddir);
if (dirD == null)//判断文件夹是否为空
{
Directory.CreateDirectory(UpDir + "\\" + dirD.Name);//如果为空，创建文件夹并退出
return;
}
else
{
Directory.CreateDirectory(UpDir + "\\" + dirD.Name);
}
SbuDir = UpDir + "\\" + dirD.Name + "\\";
FileSystemInfo[] files = dirD.GetFileSystemInfos();//获取文件夹中所有文件和文件夹
//对单个FileSystemInfo进行判断,如果是文件夹则进行递归操作
foreach (FileSystemInfo FSys in files)
{
FileInfo file = FSys as FileInfo;
if (file != null)//如果是文件的话，进行文件的复制操作
{
FileInfo SFInfo = new FileInfo(file.DirectoryName + "\\" + file.Name);//获取文件所在的原始路径
SFInfo.CopyTo(SbuDir + "\\" + file.Name, true);//将文件复制到指定的路径中
}
else
{
string pp = FSys.Name;//获取当前搜索到的文件夹名称
Files_Copy(SbuDir + FSys.ToString(), Sdir + "\\" + FSys.ToString());//如果是文件，则进行递归调用
}
}
}
catch
{
MessageBox.Show("文件制复失败。");
return;
}
}
#endregion
#region返回上一级目录
/// <summary>
/// 返回上一级目录
/// </summary>
/// <param dir="string">目录</param>
/// <returns>返回String对象</returns>
public string UpAndDown_Dir(string dir)
{
string Change_dir = "";
Change_dir = Directory.GetParent(dir).FullName;
return Change_dir;
}
#endregion
public void getFTPServerICO(ImageList il,string ftpip,stringuser,stringpwd,ListView lv,string path)//获取服务器的图标
{
try
{
string[] a;
lv.Items.Clear();
il.Images.Clear();
if(path.Length==0)
a = GetFileList(ftpip, user, pwd);
else
a= GetFileList(ftpip + "/" + path.Remove(path.LastIndexOf("/")), user, pwd);
if (a != null)
{
for (int i = 0; i < a.Length; i++)
{
string[] b = a.ToString().Split(' ');
string filename = b;
string filetype="";
if (a.IndexOf("DIR") != -1)
{
filetype = filename;
}
else
{
filetype = filename.Substring(filename.LastIndexOf("."), filename.Length - filename.LastIndexOf("."));
}
try
{
il.Images.Add(GetIconByFileType(filetype, true));
}
catch (Exception)
{
il.Images.Add(Properties.Resources.file);
}
string[] info = new string;
FileInfo fi = new FileInfo(filename);
info = fi.Name;
info = GetFileSize(filename, ftpip, user, pwd, path).ToString();
if (a.IndexOf("DIR") != -1)
{
info = "";
info = "文件夹";
}
else
{
info = GetFileSize(filename, ftpip, user, pwd, path).ToString();
info = fi.Extension.ToString();
}
ListViewItem item = new ListViewItem(info, i);
lv.Items.Add(item);
}
}
}
catch{}
}
public void listFolders(ToolStripComboBox tscb)//获取本地磁盘目录
{
string[] logicdrives = System.IO.Directory.GetLogicalDrives();
for (int i = 0; i < logicdrives.Length; i++)
{
tscb.Items.Add(logicdrives);
tscb.SelectedIndex = 0;
}
}
int k = 0;
public void GOBack(ListView lv,ImageList il,string path)
{
if (AllPath.Length != 3)
{
string NewPath = AllPath.Remove(AllPath.LastIndexOf("\\")).Remove(AllPath.Remove(AllPath.LastIndexOf("\\")).LastIndexOf("\\")) + "\\";
lv.Items.Clear();
GetListViewItem(NewPath, il, lv);
AllPath = NewPath;
}
else
{
if (k == 0)
{
lv.Items.Clear();
GetListViewItem(path, il, lv);
k++;
}
}
}
public string Mpath()
{
string path=AllPath;
return path;
}
public static string AllPath = "";//---------
public void GetPath(string path, ImageList imglist, ListView lv,int ppath)//-------
{
string pp = "";
string uu = "";
if (ppath == 0)
{
if (AllPath != path)
{
lv.Items.Clear();
AllPath = path;
GetListViewItem(AllPath, imglist, lv);
}
}
else
{
uu = AllPath + path;
if (Directory.Exists(uu))
{
AllPath = AllPath + path + "\\";
pp = AllPath.Substring(0, AllPath.Length - 1);
lv.Items.Clear();
GetListViewItem(pp, imglist, lv);
}
else
{
uu = AllPath + path;
System.Diagnostics.Process.Start(uu);
}
}
}
public void GetListViewItem(string path, ImageList imglist, ListView lv)//获取指定路径下所有文件及其图标
{
lv.Items.Clear();
Win32.SHFILEINFO shfi = new Win32.SHFILEINFO();
try
{
string[] dirs = Directory.GetDirectories(path);
string[] files = Directory.GetFiles(path);
for (int i = 0; i < dirs.Length; i++)
{
string[] info = new string;
DirectoryInfo dir = new DirectoryInfo(dirs);
if (dir.Name == "RECYCLER" || dir.Name == "RECYCLED" || dir.Name == "Recycled" || dir.Name == "System Volume Information")
{ }
else
{
//获得图标
Win32.SHGetFileInfo(dirs,
(uint)0x80,
ref shfi,
(uint)System.Runtime.InteropServices.Marshal.SizeOf(shfi),
(uint)(0x100 | 0x400)); //取得Icon和TypeName
//添加图标
imglist.Images.Add(dir.Name, (Icon)Icon.FromHandle(shfi.hIcon).Clone());
info = dir.Name;
info = "";
info = "文件夹";
info = dir.LastWriteTime.ToString();
ListViewItem item = new ListViewItem(info, dir.Name);
lv.Items.Add(item);
//销毁图标
Win32.DestroyIcon(shfi.hIcon);
}
}
for (int i = 0; i < files.Length; i++)
{
string[] info = new string;
FileInfo fi = new FileInfo(files);
string Filetype = fi.Name.Substring(fi.Name.LastIndexOf(".")+1,fi.Name.Length- fi.Name.LastIndexOf(".") -1);
string newtype=Filetype.ToLower();
if (newtype == "sys" || newtype == "ini" || newtype == "bin" || newtype == "log" || newtype == "com" || newtype == "bat" || newtype == "db")
{ }
else
{
//获得图标
Win32.SHGetFileInfo(files,
(uint)0x80,
ref shfi,
(uint)System.Runtime.InteropServices.Marshal.SizeOf(shfi),
(uint)(0x100 | 0x400)); //取得Icon和TypeName
//添加图标
imglist.Images.Add(fi.Name, (Icon)Icon.FromHandle(shfi.hIcon).Clone());
info = fi.Name;
info = fi.Length.ToString();
info = fi.Extension.ToString();
info = fi.LastWriteTime.ToString();
ListViewItem item = new ListViewItem(info, fi.Name);
lv.Items.Add(item);
//销毁图标
Win32.DestroyIcon(shfi.hIcon);
}
}
}
catch
{
}
}
FtpWebRequest reqFTP;
public bool CheckFtp(string DomainName, string FtpUserName, string FtpUserPwd)//验证登录用户是否合法
{
bool ResultValue = true;
try
{
FtpWebRequest ftprequest = (FtpWebRequest)WebRequest.Create("ftp://" + DomainName);//创建FtpWebRequest对象
ftprequest.Credentials = new NetworkCredential(FtpUserName, FtpUserPwd);//设置FTP登陆信息
ftprequest.Method = WebRequestMethods.Ftp.ListDirectory;//发送一个请求命令
FtpWebResponse ftpResponse = (FtpWebResponse)ftprequest.GetResponse();//响应一个请求
ftpResponse.Close();//关闭请求
}
catch
{
ResultValue = false;
}
return ResultValue;
}
public long GetFileSize(string filename, string ftpserver,string ftpUserID, string ftpPassword,string path)
{
long filesize = 0;
try
{
FileInfo fi = new FileInfo(filename);
string uri;
if(path.Length==0)
uri = "ftp://" + ftpserver + "/" + fi.Name;
else
uri = "ftp://" + ftpserver + "/" +path+ fi.Name;
Connect(uri, ftpUserID, ftpPassword);
reqFTP.Method = WebRequestMethods.Ftp.GetFileSize;
FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
filesize = response.ContentLength;
return filesize;
}
catch
{
return 0;
}
}
//从ftp服务器上获得文件列表
public string[] GetFileList(string ftpServerIP, string ftpUserID, string ftpPassword)
{
string[] downloadFiles;
StringBuilder result = new StringBuilder();
FtpWebRequest reqFTP;
try
{
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP));
reqFTP.UseBinary = true;
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
WebResponse response = reqFTP.GetResponse();
StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.GetEncoding("GB2312"));
string 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
{
downloadFiles = null;
return downloadFiles;
}
}
public string[] GetFileListAll(string ftpServerIP, string ftpUserID, string ftpPassword,string filename,string path)//指定路径的文件列表
{
if (path == null)
path = "";
if (path.Length == 0)
{
string[] downloadFiles;
StringBuilder result = new StringBuilder();
FtpWebRequest reqFTP;
try
{
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" + filename));
reqFTP.UseBinary = true;
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.Method = WebRequestMethods.Ftp.ListDirectory;
WebResponse response = reqFTP.GetResponse();
StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.GetEncoding("GB2312"));
string 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
{
downloadFiles = null;
return downloadFiles;
}
}
else
{
string[] downloadFiles;
StringBuilder result = new StringBuilder();
FtpWebRequest reqFTP;
try
{
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" +path+ filename));
reqFTP.UseBinary = true;
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.Method = WebRequestMethods.Ftp.ListDirectory;
WebResponse response = reqFTP.GetResponse();
StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.GetEncoding("GB2312"));
string 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
{
downloadFiles = null;
return downloadFiles;
}
}
}
//去除空格
private string QCKG(string str)
{
string a = "";
CharEnumerator CEnumerator = str.GetEnumerator();
while (CEnumerator.MoveNext())
{
byte[] array = new byte;
array = System.Text.Encoding.ASCII.GetBytes(CEnumerator.Current.ToString());
int asciicode = (short)(array);
if (asciicode != 32)
{
a += CEnumerator.Current.ToString();
}
}
string sdate = System.DateTime.Now.Year.ToString() + System.DateTime.Now.Month.ToString() + System.DateTime.Now.Day.ToString() + System.DateTime.Now.Hour.ToString()
+ System.DateTime.Now.Minute.ToString() + System.DateTime.Now.Second.ToString() + System.DateTime.Now.Millisecond.ToString();
return a.Split('.') + "." + a.Split('.');
//return sdate + "." + a.Split('.');
}
public string newFileName;
//断点续传
public bool Upload(string filename, string ftpServerIP, string ftpUserID, string ftpPassword, ToolStripProgressBar pb,string path)
{
if (path == null)
path = "";
bool success = true;
FileInfo fileInf = new FileInfo(filename);
long allbye = (long)fileInf.Length;
if (fileInf.Name.IndexOf("#") == -1)
{
newFileName = QCKG(fileInf.Name);
}
else
{
newFileName = fileInf.Name.Replace("#", "＃");
newFileName = QCKG(newFileName);
}
long startfilesize = GetFileSize(newFileName, ftpServerIP, ftpUserID, ftpPassword, path);
if (startfilesize >= allbye)
{
return false;
}
//startfilesize=0;
long startbye = startfilesize;
pb.Maximum = Convert.ToInt32(allbye);
pb.Minimum = Convert.ToInt32(startfilesize);
string uri;
if (path.Length == 0)
uri = "ftp://" + ftpServerIP + "/" + newFileName;
else
uri = "ftp://" + ftpServerIP + "/" + path + newFileName;
FtpWebRequest reqFTP;
// 根据uri创建FtpWebRequest对象
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
// ftp用户名和密码
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
// 默认为true，连接不会被关闭
// 在一个命令之后被执行
reqFTP.KeepAlive = false;
// 指定执行什么命令
reqFTP.Method = WebRequestMethods.Ftp.AppendFile;
// 指定数据传输类型
reqFTP.UseBinary = true;
// 上传文件时通知服务器文件的大小
reqFTP.ContentLength = fileInf.Length;
int buffLength = 2048;// 缓冲大小设置为2kb
byte[] buff = new byte;
// 打开一个文件流 (System.IO.FileStream) 去读上传的文件
FileStream fs= fileInf.OpenRead();
try
{
// 把上传的文件写入流
Stream strm = reqFTP.GetRequestStream();
// 每次读文件流的2kb
fs.Seek(startfilesize, 0);
int contentLen = fs.Read(buff, 0, buffLength);
// 流内容没有结束
while (contentLen != 0)
{
// 把内容从file stream 写入 upload stream
strm.Write(buff, 0, contentLen);
contentLen = fs.Read(buff, 0, buffLength);
startbye += contentLen;
pb.Value = Convert.ToInt32(startbye);
}
// 关闭两个流
strm.Close();
fs.Close();
}
catch
{
success = false;
}
return success;
}
public void Connect(String path, string ftpUserID, string ftpPassword)//连接ftp
{
// 根据uri创建FtpWebRequest对象
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(path));
// 指定数据传输类型
reqFTP.UseBinary = true;
// ftp用户名和密码
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
}
//删除文件
public void DeleteFileName(string fileName, string ftpServerIP, string ftpUserID, string ftpPassword,string path)
{
try
{
string uri;
if(path.Length==0)
uri="ftp://" + ftpServerIP + "/" + fileName;
else
uri = "ftp://" + ftpServerIP + "/" + path + fileName;
// 根据uri创建FtpWebRequest对象
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
// 指定数据传输类型
reqFTP.UseBinary = true;
// ftp用户名和密码
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
// 默认为true，连接不会被关闭
// 在一个命令之后被执行
reqFTP.KeepAlive = false;
// 指定执行什么命令
reqFTP.Method = WebRequestMethods.Ftp.DeleteFile;
FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
response.Close();
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "删除错误");
}
}
//下载文件
public bool Download(string filePath, string fileName, string ftpServerIP, string ftpUserID, string ftpPassword,string path)
{
bool check = true;
FtpWebRequest reqFTP;
string uri;
if (path.Length == 0)
uri = "ftp://" + ftpServerIP + "/" + fileName;
else
uri = "ftp://" + ftpServerIP + "/" + path + fileName;
try
{
FileStream outputStream = new FileStream(filePath + "\\" + fileName, FileMode.Create);
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;
reqFTP.UseBinary = true;
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;
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
{
check = false;
}
return check;
}
//创建目录
public void MakeDir(string dirName, string ftpServerIP,string ftpUserID, string ftpPassword)
{
try
{
string uri = "ftp://" + ftpServerIP +"/"+ dirName;
Connect(uri, ftpUserID, ftpPassword);//连接
reqFTP.Method = WebRequestMethods.Ftp.MakeDirectory;
FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
response.Close();
}
catch{}
}
//删除目录
public void delDir(string dirName, string ftpServerIP, string ftpUserID, string ftpPassword)
{
try
{
string uri = "ftp://" + ftpServerIP + "/" + dirName;
Connect(uri, ftpUserID, ftpPassword);//连接
reqFTP.Method = WebRequestMethods.Ftp.RemoveDirectory;//向服务器发送删除文件夹的命令
FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
response.Close();
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
//下载文件夹
public string[] GetFTPList(string ftpServerIP, string ftpUserID, string ftpPassword, string path)//指定路径的文件列表
{
if (path == null)
path = "";
string[] downloadFiles;
StringBuilder result = new StringBuilder();
FtpWebRequest reqFTP;
try
{
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpServerIP + "/" + path.Remove(path.LastIndexOf("/"))));
reqFTP.UseBinary = true;
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
WebResponse response = reqFTP.GetResponse();
StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.GetEncoding("GB2312"));
string 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
{
downloadFiles = null;
return downloadFiles;
}
}
}
}
版权声明：本文为博主原创文章，未经博主允许不得转载。 博客列表: http://blog.iyunv.com/chr23899
页:
[1]