FTPhelper类

FTP连接地址
///

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

用户名
///

密码
public FtpHelper(string ServerIP, string RemotePath, string UserID, string Password)
{
ftpServerIP = ServerIP;
ftpRemotePath = RemotePath;
ftpUserID = UserID;
ftpPassword = Password;
ftpURI = "ftp://" + ftpServerIP + ftpRemotePath + "/";
}

///

文件名
public void UploadFile(string FileName)
{
FileInfo fileInfo = new FileInfo(FileName);
string uri = ftpURI + fileInfo.Name;
FtpWebRequest reqFTP;

reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.KeepAlive = false;
reqFTP.Method = WebRequestMethods.Ftp.UploadFile;
reqFTP.UseBinary = true;
reqFTP.UsePassive = false;
reqFTP.COntentLength= fileInfo.Length;
int BufferSize = 2048;
byte[] buff = new byte[BufferSize];
int ContentLength;
FileStream fs = fileInfo.OpenRead();
try
{
Stream strm = reqFTP.GetRequestStream();
COntentLength= fs.Read(buff, 0, BufferSize);
while (ContentLength != 0)
{
strm.Write(buff, 0, ContentLength);
COntentLength= fs.Read(buff, 0, BufferSize);
}

strm.Close();
fs.Close();
}
catch (Exception ex)
{
throw new Exception("Ftphelper Upload Error --> " + ex.Message);
}
}

///

文件路径
///

文件名
public void DownloadFile(string FileName, string LocalSavePath)
{
FtpWebRequest reqFTP;
try
{
FileStream outputStream = new FileStream(LocalSavePath, FileMode.Create);
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpUserID + ":" + ftpPassword + "@" + ftpServerIP + "/" + FileName));
reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;
reqFTP.UseBinary = true;
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.UsePassive = false;
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 ex;
MessageBox.Show("ex: " + ex);
}
}

///

文件夹名
public void RemoveDirectory(string folderName)
{
try
{
string uri = ftpURI + folderName;
FtpWebRequest reqFTP;
reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));

reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.KeepAlive = false;
reqFTP.Method = WebRequestMethods.Ftp.RemoveDirectory;
reqFTP.UsePassive = 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("FtpHelper Delete Error --> " + ex.Message + " 文件名:" + folderName);
}
}

///