一个网上下载的ftp类（修改了其中几个bug）
2006-11-26 13:14
411 查看
/**//*
FTPFactory.cs
Better view with tab space=4
Written by Jaimon Mathew (jaimonmathew@rediffmail.com)
Rolander,Dan (Dan.Rolander@marriott.com) has modified the
download
method to cope with file name with path information. He also
provided
the XML comments so that the library provides Intellisense
descriptions.
use the following line to compile
csc /target:library /out:FTPLib.dll /r:System.DLL FTPFactory.cs
*/
using System;
using System.Net;
using System.IO;
using System.Text;
using System.Net.Sockets;
namespace FtpLib
...{
public class FTPFactory
...{
private string remoteHost, remotePath, remoteUser, remotePass, mes;
private int remotePort, bytes;
private Socket clientSocket;
private int retValue;
private Boolean debug;
private Boolean logined;
private string reply;
private static int BLOCK_SIZE = 512;
Byte[] buffer = new Byte[BLOCK_SIZE];
//
Encoding _ASCII = Encoding.ASCII;
public Encoding ASCII
...{
get ...{ return _ASCII; }
set ...{ _ASCII = value; }
}
public class FileInfo
...{
private bool _isForder = true;
private string _time ;
private string _fileName = "";
private long _size = 0;
public long Size
...{
get ...{ return _size; }
set ...{ _size = value; }
}
public bool IsForder
...{
get ...{ return _isForder; }
set ...{ _isForder = value; }
}
public string Time
...{
get ...{ return _time; }
set ...{ _time = value; }
}
public string FileName
...{
get ...{ return _fileName; }
set ...{ _fileName = value; }
}
}
public FTPFactory()
...{
remoteHost = "localhost";
remotePath = ".";
remoteUser = "anonymous";
remotePass = "jaimon@school2000.co.uk";
remotePort = 21;
debug = false;
logined = false;
}
/**////
/// Set the name of the FTP server to connect to.
///
/// Server name
public void setRemoteHost(string remoteHost)
...{
this.remoteHost = remoteHost;
}
/**////
/// Return the name of the current FTP server.
///
/// Server name
public string getRemoteHost()
...{
return remoteHost;
}
/**////
/// Set the port number to use for FTP.
///
/// Port number
public void setRemotePort(int remotePort)
...{
this.remotePort = remotePort;
}
/**////
/// Return the current port number.
///
/// Current port number
public int getRemotePort()
...{
return remotePort;
}
/**////
/// Set the remote directory path.
///
/// The remote directory path
public void setRemotePath(string remotePath)
...{
this.remotePath = remotePath;
}
/**////
/// Return the current remote directory path.
///
/// The current remote directory path.
public string getRemotePath()
...{
return remotePath;
}
/**////
/// Set the user name to use for logging into the remote server.
///
/// Username
public void setRemoteUser(string remoteUser)
...{
this.remoteUser = remoteUser;
}
/**////
/// Set the password to user for logging into the remote server.
///
/// Password
public void setRemotePass(string remotePass)
...{
this.remotePass = remotePass;
}
/**////
/// Return a string array containing the remote directory's file list.
///
///
///
public string[] getFileList(string mask)//添加
...{
if (!logined)
...{
login();
}
Socket cSocket = createDataSocket();
sendCommand("NLST " + mask);
if (!(retValue == 150 || retValue == 125))
...{
throw new IOException(reply.Substring(4));
}
mes = "";
while (true)
...{
buffer = new byte[buffer.Length];//添加
int bytes = cSocket.Receive(buffer, buffer.Length, 0);
mes += _ASCII.GetString(buffer, 0, bytes);
if (bytes < buffer.Length)
...{
break;
}
}
char[] seperator = ...{ ' ' };
string[] mess = mes.Split(seperator);
cSocket.Close();
readReply();
if (retValue != 226)
...{
throw new IOException(reply.Substring(4));
}
return mess;
}
/**//// <summary>
/// Return a string array containing the remote directory's fileForder list.
/// </summary>
/// <param name="mask"></param>
/// <returns></returns>
public FileInfo[] GetFileList(string mask)
...{
if (!logined )
...{
login();
}
Socket socket = createDataSocket();
sendCommand("list " + mask);
if (!(retValue == 150 || retValue == 125))
...{
throw new IOException(reply.Substring(4));
}
mes = "";
while (true)
...{
buffer = new byte[buffer.Length];//添加
int length = socket.Receive(buffer, buffer.Length, SocketFlags.None);
mes += _ASCII.GetString(buffer);
if (length < buffer.Length)
break;
}
string[] mess = mes.Split(' ');
FileInfo[] file = new FileInfo[mess.GetLength(0) - 1];
for (int i = 0; i < mess.GetLength(0) - 1; i++)
...{
file[i] = new FileInfo();
if (mess[i][0] == 'd')
file[i].IsForder = true;
else file[i].IsForder = false;
int index = mess[i].IndexOf("group");
mess[i] = mess[i].Remove(0, index + 5);
mess[i] = mess[i].TrimStart(' ');
index = mess[i].IndexOf(' ');
string str = mess[i].Substring(0, index);
file[i].Size = long.Parse(str);
mess[i] = mess[i].Remove(0, index);
mess[i] = mess[i].TrimStart(' ');
index = mess[i].IndexOf(' ');
str = mess[i].Substring(0, index);
str += " ";
mess[i] = mess[i].Remove(0, index);
mess[i] = mess[i].TrimStart(' ');
index = mess[i].IndexOf(' ');
str += mess[i].Substring(0, index);
str += " ";
mess[i] = mess[i].Remove(0, index);
mess[i] = mess[i].TrimStart(' ');
index = mess[i].IndexOf(' ');
str += mess[i].Substring(0, index);
file[i].Time = str;
mess[i] = mess[i].Remove(0, index);
mess[i] = mess[i].TrimStart(' ');
mess[i] = mess[i].TrimEnd(' ');
file[i].FileName = mess[i];
}
socket.Close();
readReply();
if (retValue != 226)
...{
throw new IOException(reply.Substring(4));
}
return file;
}
/**////
/// Return the size of a file.
///
///
///
public long getFileSize(string fileName)
...{
if (!logined)
...{
login();
}
sendCommand("SIZE " + fileName);
long size = 0;
if (retValue == 213)
...{
size = Int64.Parse(reply.Substring(4));
}
else
...{
throw new IOException(reply.Substring(4));
}
return size;
}
/**////
/// Login to the remote server.
///
public void login()
...{
clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPEndPoint ep = new IPEndPoint(Dns.GetHostEntry(remoteHost).AddressList[0], remotePort);
try
...{
clientSocket.Connect(ep);
}
catch (Exception)
...{
throw new IOException("Couldn't connect to remote server");
}
readReply();
if (retValue != 220)
...{
close();
throw new IOException(reply.Substring(4));
}
if (debug)
Console.WriteLine("USER " + remoteUser);
sendCommand("USER " + remoteUser);
if (!(retValue == 331 || retValue == 230))
...{
cleanup();
throw new IOException(reply.Substring(4));
}
if (retValue != 230)
...{
if (debug)
Console.WriteLine("PASS xxx");
sendCommand("PASS " + remotePass);
if (!(retValue == 230 || retValue == 202))
...{
cleanup();
throw new IOException(reply.Substring(4));
}
}
logined = true;
Console.WriteLine("Connected to " + remoteHost);
chdir(remotePath);
}
/**////
/// If the value of mode is true, set binary mode for downloads.
/// Else, set Ascii mode.
///
///
public void setBinaryMode(Boolean mode)
...{
if (mode)
...{
sendCommand("TYPE I");
}
else
...{
sendCommand("TYPE A");
}
if (retValue != 200)
...{
throw new IOException(reply.Substring(4));
}
}
/**////
/// Download a file to the Assembly's local directory,
/// keeping the same file name.
///
///
public void download(string remFileName)
...{
download(remFileName, "", false);
}
/**////
/// Download a remote file to the Assembly's local directory,
/// keeping the same file name, and set the resume flag.
///
///
///
public void download(string remFileName, Boolean resume)
...{
download(remFileName, "", resume);
}
/**////
/// Download a remote file to a local file name which can include
/// a path. The local file name will be created or overwritten,
/// but the path must exist.
///
///
///
public void download(string remFileName, string locFileName)
...{
download(remFileName, locFileName, false);
}
/**////
/// Download a remote file to a local file name which can include
/// a path, and set the resume flag. The local file name will be
/// created or overwritten, but the path must exist.
///
///
///
///
public void download(string remFileName, string locFileName, Boolean resume)
...{
if (!logined)
...{
login();
}
setBinaryMode(true);
Console.WriteLine("Downloading file " + remFileName + " from " + remoteHost + "/" + remotePath);
if (locFileName.Equals(""))
...{
locFileName = remFileName;
}
if (!File.Exists(locFileName))
...{
Stream st = File.Create(locFileName);
st.Close();
}
FileStream output = new FileStream(locFileName, FileMode.Open);
Socket cSocket = createDataSocket();
long offset = 0;
if (resume)
...{
offset = output.Length;
if (offset > 0)
...{
sendCommand("REST " + offset);
if (retValue != 350)
...{
//throw new IOException(reply.Substring(4));
//Some servers may not support resuming.
offset = 0;
}
}
if (offset > 0)
...{
if (debug)
...{
Console.WriteLine("seeking to " + offset);
}
long npos = output.Seek(offset, SeekOrigin.Begin);
Console.WriteLine("new pos=" + npos);
}
}
sendCommand("RETR " + remFileName);
if (!(retValue == 150 || retValue == 125))
...{
throw new IOException(reply.Substring(4));
}
while (true)
...{
buffer = new byte[buffer.Length];//添加
bytes = cSocket.Receive(buffer, buffer.Length, 0);
output.Write(buffer, 0, bytes);
if (bytes <= 0)
...{
break;
}
}
output.Close();
if (cSocket.Connected)
...{
cSocket.Close();
}
Console.WriteLine("");
readReply();
if (!(retValue == 226 || retValue == 250))
...{
throw new IOException(reply.Substring(4));
}
}
/**////
/// Upload a file.
///
///
public void upload(string fileName)
...{
upload(fileName, false);
}
/**////
/// Upload a file and set the resume flag.
///
///
///
public void upload(string fileName, Boolean resume)
...{
if (!logined)
...{
login();
}
Socket cSocket = createDataSocket();
long offset = 0;
if (resume)
...{
try
...{
setBinaryMode(true);
offset = getFileSize(fileName);
}
catch (Exception)
...{
offset = 0;
}
}
if (offset > 0)
...{
sendCommand("REST " + offset);
if (retValue != 350)
...{
//throw new IOException(reply.Substring(4));
//Remote server may not support resuming.
offset = 0;
}
}
sendCommand("STOR " + Path.GetFileName(fileName));
if (!(retValue == 125 || retValue == 150))
...{
throw new IOException(reply.Substring(4));
}
// open input stream to read source file
FileStream input = new FileStream(fileName, FileMode.Open);
if (offset != 0)
...{
if (debug)
...{
Console.WriteLine("seeking to " + offset);
}
input.Seek(offset, SeekOrigin.Begin);
}
Console.WriteLine("Uploading file " + fileName + " to " + remotePath);
while ((bytes = input.Read(buffer, 0, buffer.Length)) > 0)
...{
cSocket.Send(buffer, bytes, 0);
}
input.Close();
Console.WriteLine("");
if (cSocket.Connected)
...{
cSocket.Close();
}
readReply();
if (!(retValue == 226 || retValue == 250))
...{
throw new IOException(reply.Substring(4));
}
}
/**////
/// Delete a file from the remote FTP server.
///
///
public void deleteRemoteFile(string fileName)
...{
if (!logined)
...{
login();
}
sendCommand("DELE " + fileName);
if (retValue != 250)
...{
throw new IOException(reply.Substring(4));
}
}
/**////
/// Rename a file on the remote FTP server.
///
///
///
public void renameRemoteFile(string oldFileName, string newFileName)
...{
if (!logined)
...{
login();
}
sendCommand("RNFR " + oldFileName);
if (retValue != 350)
...{
throw new IOException(reply.Substring(4));
}
// known problem
// rnto will not take care of existing file.
// i.e. It will overwrite if newFileName exist
sendCommand("RNTO " + newFileName);
if (retValue != 250)
...{
throw new IOException(reply.Substring(4));
}
}
/**////
/// Create a directory on the remote FTP server.
///
///
public void mkdir(string dirName)
...{
if (!logined)
...{
login();
}
sendCommand("MKD " + dirName);
if (retValue != 250)
...{
throw new IOException(reply.Substring(4));
}
}
/**////
/// Delete a directory on the remote FTP server.
///
///
public void rmdir(string dirName)
...{
if (!logined)
...{
login();
}
sendCommand("RMD " + dirName);
if (retValue != 250)
...{
throw new IOException(reply.Substring(4));
}
}
/**////
/// Change the current working directory on the remote FTP server.
///
///
public void chdir(string dirName)
...{
if (dirName.Equals("."))
...{
return;
}
if (!logined)
...{
login();
}
sendCommand("CWD " + dirName);
if (retValue != 250)
...{
throw new IOException(reply.Substring(4));
}
this.remotePath = dirName;
Console.WriteLine("Current directory is " + remotePath);
}
/**////
/// Close the FTP connection.
///
public void close()
...{
if (clientSocket != null)
...{
sendCommand("QUIT");
}
cleanup();
Console.WriteLine("Closing...");
}
/**////
/// Set debug mode.
///
///
public void setDebug(Boolean debug)
...{
this.debug = debug;
}
private void readReply()
...{
mes = "";
reply = readLine();
retValue = Int32.Parse(reply.Substring(0, 3));
}
private void cleanup()
...{
if (clientSocket != null)
...{
clientSocket.Close();
clientSocket = null;
}
logined = false;
}
private string readLine()
...{
while (true)
...{
buffer = new byte[buffer.Length];//添加
bytes = clientSocket.Receive(buffer, buffer.Length, SocketFlags.None);
mes += _ASCII.GetString(buffer, 0, bytes);
if (bytes < buffer.Length)
...{
break;
}
}
char[] seperator = ...{ ' ' };
string[] mess = mes.Split(seperator);
if (mes.Length > 2)
...{
mes = mess[mess.Length - 2];
}
else
...{
mes = mess[0];
}
if (!mes.Substring(3, 1).Equals(" "))
...{
return readLine();
}
if (debug)
...{
for (int k = 0; k < mess.Length - 1; k++)
...{
Console.WriteLine(mess[k]);
}
}
return mes;
}
private void sendCommand(String command)
...{
Byte[] cmdBytes = ASCII.GetBytes((command + " ").ToCharArray());
clientSocket.Send(cmdBytes, cmdBytes.Length, 0);
readReply();
}
private Socket createDataSocket()
...{
sendCommand("PASV");
if (retValue != 227)
...{
throw new IOException(reply.Substring(4));
}
int index1 = reply.IndexOf('(');
int index2 = reply.IndexOf(')');
string ipData = reply.Substring(index1 + 1, index2 - index1 - 1);
int[] parts = new int[6];
int len = ipData.Length;
int partCount = 0;
string buf = "";
for (int i = 0; i < len && partCount <= 6; i++)
...{
char ch = Char.Parse(ipData.Substring(i, 1));
if (Char.IsDigit(ch))
buf += ch;
else if (ch != ',')
...{
throw new IOException("Malformed PASV reply: " + reply);
}
if (ch == ',' || i + 1 == len)
...{
try
...{
parts[partCount++] = Int32.Parse(buf);
buf = "";
}
catch (Exception)
...{
throw new IOException("Malformed PASV reply: " + reply);
}
}
}
string ipAddress = parts[0] + "." + parts[1] + "." +
parts[2] + "." + parts[3];
int port = (parts[4] << 8) + parts[5];
Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPEndPoint ep = new IPEndPoint(Dns.GetHostEntry(ipAddress).AddressList[0], port);
try
...{
s.Connect(ep);
}
catch (Exception)
...{
throw new IOException("Can't connect to remote server");
}
return s;
}
}
}
//Following is the listing of a test program which uses this
//library
/**//*
File : Test.cs
Better view with tab space=4
use the following line to compile
csc.exe /t:exe /r:System.DLL /r:FTPLib.dll /out:"Test.exe"
"Test.cs"
*/
using System;
using System.Text;
//using FtpLib;
namespace FtpLib
...{
public class Test
...{
public static void Main()
...{
try
...{
FTPFactory ftp = new FTPFactory();
ftp.setRemoteHost("192.168.0.10");
ftp.setRemoteUser("xzl");
ftp.setRemotePass("123");
ftp.login();
ftp.ASCII = Encoding.GetEncoding("gb2312");
Console.WriteLine("当前目录下内容...");
FTPFactory.FileInfo []fileList = ftp.GetFileList("");
foreach (FTPFactory.FileInfo f in fileList)
...{
Console.Write(f.FileName + " ");
if (f.IsForder)
Console.Write("文件夹 ");
else
Console.Write("文件 ");
}
Console.WriteLine("请输入查找目录...");
string forder = Console.ReadLine();
ftp.chdir(forder);
fileList = null;
fileList = ftp.GetFileList("");
foreach (FTPFactory.FileInfo f in fileList)
...{
Console.Write(f.FileName + " ");
if (f.IsForder)
Console.Write("文件夹 ");
else
Console.Write("文件 ");
}
Console.WriteLine("请输入要下载文件的文件名...");
string fileName = Console.ReadLine();
Console.WriteLine("请输入文件保存路径...");
string filePath = Console.ReadLine();
ftp.download(fileName, filePath);
Console.WriteLine("请输入要上传文件的文件名...");
fileName = Console.ReadLine();
ftp.upload(fileName);
}
catch (Exception e)
...{
Console.WriteLine("Caught Error :" + e.Message);
}
Console.Read();
}
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- NewCrossArticle 模块（修改了其中一个bug)
- 金额转大写的函数 （网上找到的几个有Bug 只好自己写了一个）
- 修改一个java Swing 进销存系统 BUG 不能进货和退货。
- 哪些年遇到过的Andriod问题(13)Mars的下载文件代码不知道是什么问题，在网上去新COPY了一个就可以下载了。
- 求s=a+aa+aaa+aaaa+aa...a的值，其中a是一个数字。例如2+22+222+2222+22222(此时共有5个数相加)，几个数相加有键盘控制。
- 一个ftp下载的shell脚本
- 辨别真假虚实：目前网上盛传的Windows 7“SP1”下载和通过修改注册表“更新”是真的吗？
- C++ - 给出一个函数来连接两个字符串A和B，其中字符串A的后几个字节和字符串B的前几个字节重叠
- 修改了gnokii的一个BUG
- 下载一个指定文件，下载成功后修改权限，自动重试60次，带详细日志记录。
- Ogre Lod的一个bug及其修改
- sqlserver/oracle当插入表数据时同时修改其中一个字段的触发器
- python练习-从网上下载一个文件并打印出来
- 使用FTP软件上传下载PHP文件时换行丢失BUG（全部变为一行）
- 从网上看到的一个电子书资源FTP（英）
- linux下下载ftp上的一个文件
- 写了一个小程序:定时从网上下载图片来设置桌面
- 近日学习Cache，搜集到的一个Demo下载[不断修改、讨论]
- 一个简单的FTP客户端 实现上传下载
- QT QFtp使用实例 从FTP下载一个文件