FTP上传类FTP上传类

现在的位置: 首页 > 综合 > 正文

RSS

FTP上传类FTP上传类

2013年08月15日 ⁄ 综合 ⁄ 共 16447字 ⁄ 字号小中大 ⁄ 评论关闭

[c-sharp]
view plain copy print ?

using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.IO;
using System.Globalization;
using System.Text.RegularExpressions;
namespace WebBaseLib
{
/// <summary>
/// FTP处理操作类
/// 功能：
/// 下载文件
/// 上传文件
/// 上传文件的进度信息
/// 下载文件的进度信息
/// 删除文件
/// 列出文件
/// 列出目录
/// 进入子目录
/// 退出当前目录返回上一层目录
/// 判断远程文件是否存在
/// 判断远程文件是否存在
/// 删除远程文件
/// 建立目录
/// 删除目录
/// 文件（目录）改名
/// </summary>
/// <remarks>
/// 创建人：南疯
/// 创建时间：2007年4月28日
/// </remarks>
#region 文件信息结构
public struct FileStruct
{
public string Flags;
public string Owner;
public string Group;
public bool IsDirectory;
public DateTime CreateTime;
public string Name;
}
public enum FileListStyle
{
UnixStyle,
WindowsStyle,
Unknown
}
#endregion
public class NewFtp
{
#region 属性信息
/// <summary>
/// FTP请求对象
/// </summary>
FtpWebRequest Request = null;
/// <summary>
/// FTP响应对象
/// </summary>
FtpWebResponse Response = null;
/// <summary>
/// FTP服务器地址
/// </summary>
private Uri _Uri;
/// <summary>
/// FTP服务器地址
/// </summary>
public Uri Uri
{
get
{
if( _DirectoryPath ==
"/" )
{
return _Uri;
}
else
{
string strUri = _Uri.ToString();
if( strUri.EndsWith(
"/" ) )
{
strUri = strUri.Substring( 0, strUri.Length - 1 );
}
return new Uri( strUri +
this.DirectoryPath );
}
}
set
{
if( value.Scheme != Uri.UriSchemeFtp )
{
throw
new Exception( "Ftp 地址格式错误!" );
}
_Uri = new Uri( value.GetLeftPart( UriPartial.Authority ) );
_DirectoryPath = value.AbsolutePath;
if( !_DirectoryPath.EndsWith(
"/" ) )
{
_DirectoryPath +=
"/";
}
}
}
/// <summary>
/// 当前工作目录
/// </summary>
private string _DirectoryPath;
/// <summary>
/// 当前工作目录
/// </summary>
public string DirectoryPath
{
get
{
return _DirectoryPath;
}
set
{
_DirectoryPath = value;
}
}
/// <summary>
/// FTP登录用户
/// </summary>
private string _UserName;
/// <summary>
/// FTP登录用户
/// </summary>
public string UserName
{
get
{
return _UserName;
}
set
{
_UserName = value;
}
}
/// <summary>
/// 错误信息
/// </summary>
private string _ErrorMsg;
/// <summary>
/// 错误信息
/// </summary>
public string ErrorMsg
{
get
{
return _ErrorMsg;
}
set
{
_ErrorMsg = value;
}
}
/// <summary>
/// FTP登录密码
/// </summary>
private string _Password;
/// <summary>
/// FTP登录密码
/// </summary>
public string Password
{
get
{
return _Password;
}
set
{
_Password = value;
}
}
/// <summary>
/// 连接FTP服务器的代理服务
/// </summary>
private WebProxy _Proxy =
null;
/// <summary>
/// 连接FTP服务器的代理服务
/// </summary>
public WebProxy Proxy
{
get
{
return _Proxy;
}
set
{
_Proxy = value;
}
}
/// <summary>
/// 是否需要删除临时文件
/// </summary>
private bool _isDeleteTempFile =
false;
/// <summary>
/// 异步上传所临时生成的文件
/// </summary>
private string _UploadTempFile =
"";
#endregion
#region 事件
public delegate
void De_DownloadProgressChanged(
object sender, DownloadProgressChangedEventArgs e );
public delegate
void De_DownloadDataCompleted( object sender, System.ComponentModel.AsyncCompletedEventArgs e );
public delegate
void De_UploadProgressChanged( object sender, UploadProgressChangedEventArgs e );
public delegate
void De_UploadFileCompleted( object sender, UploadFileCompletedEventArgs e );
/// <summary>
/// 异步下载进度发生改变触发的事件
/// </summary>
public event De_DownloadProgressChanged DownloadProgressChanged;
/// <summary>
/// 异步下载文件完成之后触发的事件
/// </summary>
public event De_DownloadDataCompleted DownloadDataCompleted;
/// <summary>
/// 异步上传进度发生改变触发的事件
/// </summary>
public event De_UploadProgressChanged UploadProgressChanged;
/// <summary>
/// 异步上传文件完成之后触发的事件
/// </summary>
public event De_UploadFileCompleted UploadFileCompleted;
#endregion
#region 构造析构函数
/// <summary>
/// 构造函数
/// </summary>
/// <param name="FtpUri">FTP地址</param>
/// <param name="strUserName">登录用户名</param>
/// <param name="strPassword">登录密码</param>
public NewFtp( Uri FtpUri,
string strUserName, string strPassword )
{
this._Uri =
new Uri( FtpUri.GetLeftPart( UriPartial.Authority ) );
_DirectoryPath = FtpUri.AbsolutePath;
if( !_DirectoryPath.EndsWith(
"/" ) )
{
_DirectoryPath += "/";
}
this._UserName = strUserName;
this._Password = strPassword;
this._Proxy =
null;
}
/// <summary>
/// 构造函数
/// </summary>
/// <param name="FtpUri">FTP地址</param>
/// <param name="strUserName">登录用户名</param>
/// <param name="strPassword">登录密码</param>
/// <param name="objProxy">连接代理</param>
public NewFtp( Uri FtpUri,
string strUserName, string strPassword, WebProxy objProxy )
{
this._Uri = new Uri( FtpUri.GetLeftPart( UriPartial.Authority ) );
_DirectoryPath = FtpUri.AbsolutePath;
if( !_DirectoryPath.EndsWith(
"/" ) )
{
_DirectoryPath += "/";
}
this._UserName = strUserName;
this._Password = strPassword;
this._Proxy = objProxy;
}
/// <summary>
/// 构造函数
/// </summary>
public NewFtp()
{
this._UserName =
"anonymous"; //匿名用户
this._Password =
"@anonymous";
this._Uri =
null;
this._Proxy = null;
}
/// <summary>
/// 析构函数
/// </summary>
~NewFtp()
{
if( Response != null )
{
Response.Close();
Response = null;
}
if( Request !=
null )
{
Request.Abort();
Request = null;
}
}
#endregion
#region 建立连接
/// <summary>
/// 建立FTP链接,返回响应对象
/// </summary>
/// <param name="uri">FTP地址</param>
/// <param name="FtpMathod">操作命令</param>
private FtpWebResponse Open( Uri uri,
string FtpMathod )
{
try
{
Request = ( FtpWebRequest ) WebRequest.Create( uri );
Request.Method = FtpMathod;
Request.UseBinary = true;
Request.Credentials =
new NetworkCredential( this.UserName,
this.Password );
if( this.Proxy !=
null )
{
Request.Proxy = this.Proxy;
}
return ( FtpWebResponse ) Request.GetResponse();
}
catch( Exception ep )
{
ErrorMsg = ep.ToString();
throw ep;
}
}
/// <summary>
/// 建立FTP链接,返回请求对象
/// </summary>
/// <param name="uri">FTP地址</param>
/// <param name="FtpMathod">操作命令</param>
private FtpWebRequest OpenRequest( Uri uri,
string FtpMathod )
{
try
{
Request = ( FtpWebRequest ) WebRequest.Create( uri );
Request.Method = FtpMathod;
Request.UseBinary = true;
Request.Credentials = new NetworkCredential(
this.UserName, this.Password );
if(
this.Proxy != null )
{
Request.Proxy = this.Proxy;
}
return Request;
}
catch( Exception ep )
{
ErrorMsg = ep.ToString();
throw ep;
}
}
#endregion
#region 下载文件
/// <summary>
/// 从FTP服务器下载文件，使用与远程文件同名的文件名来保存文件
/// </summary>
/// <param name="RemoteFileName">远程文件名</param>
/// <param name="LocalPath">本地路径</param>
public bool DownloadFile(
string RemoteFileName, string LocalPath )
{
return DownloadFile( RemoteFileName, LocalPath, RemoteFileName );
}
/// <summary>
/// 从FTP服务器下载文件，指定本地路径和本地文件名
/// </summary>
/// <param name="RemoteFileName">远程文件名</param>
/// <param name="LocalPath">本地路径</param>
/// <param name="LocalFilePath">保存文件的本地路径,后面带有""</param>
/// <param name="LocalFileName">保存本地的文件名</param>
public bool DownloadFile(
string RemoteFileName, string LocalPath,
string LocalFileName )
{
byte[] bt =
null;
try
{
if( !IsValidFileChars( RemoteFileName ) || !IsValidFileChars( LocalFileName ) || !IsValidPathChars( LocalPath ) )
{
throw new Exception(
"非法文件名或目录名!" );
}
if( !Directory.Exists( LocalPath ) )
{
throw new Exception(
"本地文件路径不存在!" );
}
string LocalFullPath = Path.Combine( LocalPath, LocalFileName );
if( File.Exists( LocalFullPath ) )
{
throw new Exception(
"当前路径下已经存在同名文件！" );
}
bt = DownloadFile( RemoteFileName );
if( bt !=
null )
{
FileStream stream =
new FileStream( LocalFullPath, FileMode.Create );
stream.Write( bt, 0, bt.Length );
stream.Flush();
stream.Close();
return
true;
}
else
{
return
false;
}
}
catch( Exception ep )
{
ErrorMsg = ep.ToString();
throw ep;
}
}
/// <summary>
/// 从FTP服务器下载文件，返回文件二进制数据
/// </summary>
/// <param name="RemoteFileName">远程文件名</param>
public byte[] DownloadFile(
string RemoteFileName )
{
try
{
if( !IsValidFileChars( RemoteFileName ) )
{
throw
new Exception( "非法文件名或目录名!" );
}
Response = Open( new Uri(
this.Uri.ToString() + RemoteFileName ), WebRequestMethods.Ftp.DownloadFile );
Stream Reader = Response.GetResponseStream();
MemoryStream mem = new MemoryStream( 1024 * 500 );
byte[] buffer =
new byte[ 1024 ];
int bytesRead = 0;
int TotalByteRead = 0;
while( true )
{
bytesRead = Reader.Read( buffer, 0, buffer.Length );
TotalByteRead += bytesRead;
if( bytesRead == 0 )
break;
mem.Write( buffer, 0, bytesRead );
}
if( mem.Length > 0 )
{
return mem.ToArray();
}
else
{
return null;
}
}
catch( Exception ep )
{
ErrorMsg = ep.ToString();
throw ep;
}
}
#endregion
#region 异步下载文件
/// <summary>
/// 从FTP服务器异步下载文件，指定本地路径和本地文件名
/// </summary>
/// <param name="RemoteFileName">远程文件名</param>
/// <param name="LocalPath">保存文件的本地路径,后面带有""</param>
/// <param name="LocalFileName">保存本地的文件名</param>
public void DownloadFileAsync(
string RemoteFileName, string LocalPath,
string LocalFileName )
{
byte[] bt =
null;
try
{
if( !IsValidFileChars( RemoteFileName ) || !IsValidFileChars( LocalFileName ) || !IsValidPathChars( LocalPath ) )
{
throw new Exception(
"非法文件名或目录名!" );
}
if( !Directory.Exists( LocalPath ) )
{
throw new Exception(
"本地文件路径不存在!" );
}
string LocalFullPath = Path.Combine( LocalPath, LocalFileName );
if( File.Exists( LocalFullPath ) )
{
throw new Exception(
"当前路径下已经存在同名文件！" );
}
DownloadFileAsync( RemoteFileName, LocalFullPath );
}
catch( Exception ep )
{
ErrorMsg = ep.ToString();
throw ep;
}
}
/// <summary>
/// 从FTP服务器异步下载文件，指定本地完整路径文件名
/// </summary>
/// <param name="RemoteFileName">远程文件名</param>
/// <param name="LocalFullPath">本地完整路径文件名</param>
public void DownloadFileAsync(
string RemoteFileName, string LocalFullPath )
{
try
{
if( !IsValidFileChars( RemoteFileName ) )
{
throw
new Exception( "非法文件名或目录名!" );
}
if( File.Exists( LocalFullPath ) )
{
throw
new Exception( "当前路径下已经存在同名文件！" );
}
MyWebClient client =
new MyWebClient();
client.DownloadProgressChanged +=
new DownloadProgressChangedEventHandler( client_DownloadProgressChanged );
client.DownloadFileCompleted += new System.ComponentModel.AsyncCompletedEventHandler( client_DownloadFileCompleted );
client.Credentials =
new NetworkCredential( this.UserName,
this.Password );
if( this.Proxy !=
null )
{
client.Proxy = this.Proxy;
}
client.DownloadFileAsync( new Uri(
this.Uri.ToString() + RemoteFileName ), LocalFullPath );
}
catch( Exception ep )
{
ErrorMsg = ep.ToString();
throw ep;
}
}
/// <summary>
/// 异步下载文件完成之后触发的事件
/// </summary>
/// <param name="sender">下载对象</param>
/// <param name="e">数据信息对象</param>
void client_DownloadFileCompleted(
object sender, System.ComponentModel.AsyncCompletedEventArgs e )
{
if( DownloadDataCompleted !=
null )
{
DownloadDataCompleted( sender, e );
}
}
/// <summary>
/// 异步下载进度发生改变触发的事件
/// </summary>
/// <param name="sender">下载对象</param>
/// <param name="e">进度信息对象</param>
void client_DownloadProgressChanged(
object sender, DownloadProgressChangedEventArgs e )
{
if( DownloadProgressChanged !=
null )
{
DownloadProgressChanged( sender, e );
}
}
#endregion
#region 上传文件
/// <summary>
/// 上传文件到FTP服务器
/// </summary>
/// <param name="LocalFullPath">本地带有完整路径的文件名</param>
public bool UploadFile(
string LocalFullPath )
{
return UploadFile( LocalFullPath, Path.GetFileName( LocalFullPath ),
false );
}
/// <summary>
/// 上传文件到FTP服务器
/// </summary>
/// <param name="LocalFullPath">本地带有完整路径的文件</param>
/// <param name="OverWriteRemoteFile">是否覆盖远程服务器上面同名的文件</param>
public bool UploadFile(
string LocalFullPath, bool OverWriteRemoteFile )
{
return UploadFile( LocalFullPath, Path.GetFileName( LocalFullPath ), OverWriteRemoteFile );
}
/// <summary>
/// 上传文件到FTP服务器
/// </summary>
/// <param name="LocalFullPath">本地带有完整路径的文件</param>
/// <param name="RemoteFileName">要在FTP服务器上面保存文件名</param>
public bool UploadFile(
string LocalFullPath, string RemoteFileName )
{
return UploadFile( LocalFullPath, RemoteFileName,
false );
}
/// <summary>
/// 上传文件到FTP服务器
/// </summary>
/// <param name="LocalFullPath">本地带有完整路径的文件名</param>
/// <param name="RemoteFileName">要在FTP服务器上面保存文件名</param>
/// <param name="OverWriteRemoteFile">是否覆盖远程服务器上面同名的文件</param>
public bool UploadFile(
string LocalFullPath, string RemoteFileName,
bool

【上篇】git 因为sshkey连接不上需要passwd,add ssh 报错
【下篇】IE提示：无法下载，请求的站点不可用

作者: puller

该日志由 puller 于11年前发表在综合分类下，最后更新于 2013年08月15日.
转载请注明: FTP上传类FTP上传类 | 学步园 +复制链接

抱歉!评论已关闭.

返回首页

（其他合作也可洽谈）

必威体育

必威电竞

学步园

FTP上传类FTP上传类

作者: puller

书签

最新文章New

本站推荐

返回首页