一、引用DLL
using System.IO;using System.Net;
二、創(chuàng)建FTP連接
/// <summary> /// 連接FTP服務器/// </summary> /// <param name="FtpServerIP">FTP連接地址</param> /// <param name="FtpRemotePath">指定FTP連接成功后的當前目錄, 如果不指定默認根目錄</param> /// <param name="FtpUserID">用戶名</param> /// <param name="FtpPassword">密碼</param> public FTPHelper(string FtpServerIP, string FtpRemotePath, string FtpUserID, string FtpPassword){ System.Net.ServicePointManager.DefaultConnectionLimit = 200;
FtpServerIP = FtpServerIP.Replace("ftp://", "");
string[] arr = FtpServerIP.Split('/'); if (arr.Length > 1) { FtpServerIP = arr[0]; for (int i = 1; i < arr.Length; i++) { FtpRemotePath += "/" + arr[i]; } if (FtpRemotePath.Substring(FtpRemotePath.Length - 1) == "/") { FtpRemotePath = FtpRemotePath.Substring(0, FtpRemotePath.Length - 1); } }
ftpServerIP = FtpServerIP; ftpRemotePath = FtpRemotePath; ftpUserID = FtpUserID; ftpPassword = FtpPassword; if (string.IsNullOrEmpty(ftpRemotePath)) { ftpURI = "ftp://" + ftpServerIP + "/"; } else { ftpURI = "ftp://" + ftpServerIP + ftpRemotePath + "/"; } FtpCheckDirectoryExist(ftpRemotePath + "/");}
三、上傳、下載
/// <summary> /// 上傳 /// </summary> public void Upload(string filename){ FileInfo fileInf = new FileInfo(filename); FtpWebRequest reqFTP; reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + fileInf.Name)); reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword); reqFTP.Method = WebRequestMethods.Ftp.UploadFile; reqFTP.UsePassive = false; reqFTP.KeepAlive = true; reqFTP.UseBinary = true; reqFTP.ContentLength = fileInf.Length; int buffLength = 2048; byte[] buff = new byte[buffLength]; int contentLen; FileStream fs = fileInf.OpenRead(); try { Stream strm = reqFTP.GetRequestStream(); contentLen = fs.Read(buff, 0, buffLength); while (contentLen != 0) { strm.Write(buff, 0, contentLen); contentLen = fs.Read(buff, 0, buffLength); } strm.Close(); fs.Close(); } catch (Exception ex) { throw new Exception(ex.Message); }}
/// <summary> /// 下載 /// </summary> public void Download(string filePath, string fileName){ try { FileInfo fileInf = new FileInfo(fileName);
FtpWebRequest reqFTP; reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + fileInf.Name)); reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.Method = WebRequestMethods.Ftp.DownloadFile; reqFTP.UseBinary = true; 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);
FileStream outputStream = new FileStream(filePath + "\\" + fileName, FileMode.Create); while (readCount > 0) { outputStream.Write(buffer, 0, readCount); readCount = ftpStream.Read(buffer, 0, bufferSize); } ftpStream.Close(); outputStream.Close(); response.Close(); } catch (Exception ex) { throw new Exception(ex.Message); }}
四、創(chuàng)建目錄
/// <summary>/// 判斷文件的目錄是否存,不存則創(chuàng)建 /// </summary>/// <param name="destFilePath"></param>public void FtpCheckDirectoryExist(string destFilePath){ try { string fullDir = FtpParseDirectory(destFilePath); string[] dirs = fullDir.Split('/'); string curDir = "/"; for (int i = 0; i < dirs.Length; i++) { string dir = dirs[i]; //如果是以/開始的路徑,第一個為空 if (dir != null && dir.Length > 0) { try { curDir += dir + "/"; Uri uri = new Uri("ftp://" + ftpServerIP + curDir);
if (!DirectoryIsExist(uri, ftpUserID, ftpPassword)) { FtpMakeDir(curDir); } } catch (Exception e) { throw new Exception(e.Message); } } } } catch (Exception ex) { throw new Exception("FtpCheckDirectoryExist異常" + ex.Message); }
}
/// <summary>/// 截圖字符/// </summary>/// <param name="destFilePath"></param>/// <returns></returns>public string FtpParseDirectory(string destFilePath){ return destFilePath.Substring(0, destFilePath.LastIndexOf("/"));}
/// <summary>/// 創(chuàng)建目錄/// </summary>/// <param name="localFile"></param>/// <returns></returns> public Boolean FtpMakeDir(string localFile){ FtpWebRequest req = (FtpWebRequest)WebRequest.Create("ftp://" + ftpServerIP + localFile); req.Credentials = new NetworkCredential(ftpUserID, ftpPassword); req.Method = WebRequestMethods.Ftp.MakeDirectory; try { FtpWebResponse response = req.GetResponse() as FtpWebResponse; response.Close(); } catch (Exception) { req.Abort(); return false; } req.Abort(); return true;}
//文件是否存在public bool DirectoryIsExist(Uri pFtpServerIP, string pFtpUserID, string pFtpPW){ string[] value = GetFileList(pFtpServerIP, pFtpUserID, pFtpPW); if (value == null) { return false; } else { return true; }}
//獲取文件集public string[] GetFileList(Uri pFtpServerIP, string pFtpUserID, string pFtpPW){ StringBuilder result = new StringBuilder(); try { FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(pFtpServerIP); reqFTP.UseBinary = true; reqFTP.Credentials = new NetworkCredential(pFtpUserID, pFtpPW); reqFTP.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
WebResponse response = reqFTP.GetResponse(); StreamReader reader = new StreamReader(response.GetResponseStream()); string line = reader.ReadLine(); while (line != null) { result.Append(line); result.Append("\n"); line = reader.ReadLine(); } reader.Close(); response.Close(); return result.ToString().Split('\n'); } catch(Exception e) { return null; }}
五、刪除文件
/// 刪除文件 /// </summary> public void Delete(string fileName){ try { FtpWebRequest reqFTP; reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + fileName)); reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword); reqFTP.Method = WebRequestMethods.Ftp.DeleteFile; reqFTP.KeepAlive = 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(ex.Message); }}
該文章在 2024/12/26 9:18:10 編輯過
400 186 1886
