www.pudn.com > FtpServer.rar > Request.cs
using System;
using System.IO;
using System.Net.Sockets;
namespace FtpServer
{
///
/// Request 的摘要说明。
///
public class Request
{
public const int LOGIN_USER = 0; //USER
public const int LOGIN_PASS = 1; //PASS
public const int SYSTEM = 2; //SYST
public const int RESTART = 3; //REST
public const int RETRIEVE = 4; //RETR
public const int STORE = 5; //STOR
public const int RENAME_FROM = 6; //RNFR
public const int RENAME_TO = 7; //RNTO
public const int ABORT = 8; //ABOR
public const int DELETE = 9; //DELE
public const int XMKD = 10; //XMKD
public const int PWD = 11; //PWD
public const int LIST = 12; //LIST
public const int NOOP = 13; //NOOP
public const int REPRESENTATION_TYPE = 14; //TYPE
public const int LOGOUT = 15; //QUIT
public const int DATA_PORT = 16; //PORT
public const int PASSIVE = 17; //PASV
public const int CWD = 18; //CWD
public const int CHANGE_DIR_UP = 19; //CDUP
public const int UNKNOWN_CMD = 99; //unknow cmd
public const int PORT = 0;
public const int PASV = 1;
public const int ERROR = -1;
private string representationType;
internal int transferType;
private Client client;
//FTP客户端的请求类型
public int requestType;
public Request(Client client)
{
//
// TODO: 在此处添加构造函数逻辑
//
requestType = ERROR;
transferType = PORT;
this.client = client;
}
public int RequestType
{
get
{
return requestType;
}
set
{
requestType=value;
}
}
public int parseCmd(string[] tokens)
{
if (tokens == null || tokens.Length < 1)
{
return ERROR;
}
for (int i=0;i-1))
{
requestType = PWD;
client.sendMsg("257 当前目录\"" + getDir() + "\"");
}
else if (tokens[0].ToUpper() == "LIST" ||
tokens[0].ToUpper() == "NLST" )
{
requestType = LIST;
client.sendMsg("150 显示目录信息");
sendDirMsg();
client.sendMsg("226 显示完毕");
}
else if (tokens[0].ToUpper() == "CWD")
{
requestType = CWD;
client.FileName = tokens[1];
gotoDir(tokens);
}
else if (tokens[0].ToUpper() == "NOOP")
{
requestType = NOOP;
client.sendMsg("200 NOOP命令成功");
}
else if (tokens[0].ToUpper() == "TYPE")
{
requestType = REPRESENTATION_TYPE;
representationType = tokens[1];
client.sendMsg("200");
}
else if (tokens[0].ToUpper() == "QUIT")
{
requestType = LOGOUT;
client.isLogin = false;
client.sendMsg("221 退出登录");
}
else if (tokens[0].ToUpper() == "PORT")
{
requestType = DATA_PORT;
updatePort(tokens);
client.sendMsg("200");
}
else if (tokens[0].ToUpper() == "PASV")
{
requestType = PASSIVE;
transferType = PASV;
string ip = client.server.ip.Replace(".", ",");
ip += ",21,21";
client.sendMsg("227 进入PASV模式. " + ip);
}
else
{
requestType = UNKNOWN_CMD;
client.sendMsg("221 未知的命令");
}
return requestType;
}
private void updatePort(string[] tokens)
{
string[] data;
if (tokens.Length==2)
{
data = tokens[1].Split(new Char[]{','});
}
else if (tokens.Length==3)
{
data = tokens[2].Split(new Char[]{','});
}
else
{
return;
}
//客户端IP地址（n1.n2 .n3 .n4）和端口（n5×256+n6）
int n6 = System.Convert.ToInt32(data[5]);
int n5 = System.Convert.ToInt32(data[4]);
client.Port = n5*256+n6;
string ip = data[0] + "." +
data[1] + "." +
data[2] + "." +
data[3];
client.IpAddress = ip;
}
// 获得当前目录
private string getDir()
{
string dir = client.workingDir;
dir = dir.Remove(0, FtpServerForm.ROOT_DIR.Length);
dir = dir.Replace("\\", "/");
if (dir == "")
{
dir = "/";
}
return dir;
}
//跳转到其他目录
private void gotoDir(String[] tokens)
{
if (tokens.Length>1)
{
string dir = trimEnd(tokens[1]);
if (dir == "..")
{
//转到上一级目录
if (client.workingDir != FtpServerForm.ROOT_DIR)
{
//如果当前目录不是根目录，就转到上一级目录
try
{
DirectoryInfo directoryInfo =
Directory.GetParent(client.workingDir);
client.workingDir = directoryInfo.FullName;
client.sendMsg("257 当前目录\"" + getDir() + "\"");
}
catch (ArgumentNullException)
{
System.Console.WriteLine("路径为空");
}
catch (ArgumentException)
{
System.Console.WriteLine("当前工作路径是一个空字符串，" +
"路径中只能包含空格或者其他任何有效的字符。");
}
}
else
{
client.sendMsg("已经是根目录了，不能执行该操作");
}
}
else if (dir[0] == '/')
{
//是否从根目录开始
dir = dir.TrimStart("/".ToCharArray());
dir = FtpServerForm.ROOT_DIR + dir;
if (Directory.Exists(dir))
{
client.workingDir = dir;
client.sendMsg("257 当前目录\"" + getDir() + "\"");
}
else
{
client.sendMsg("目录不存在");
}
}
else if (dir == ".")
{
client.sendMsg("257 当前目录\"" + getDir() + "\"");
}
else
{
//进入目录
if (client.workingDir[client.workingDir.Length-1] != '\\')
{
client.workingDir += "\\";
}
dir = client.workingDir + dir;
if (Directory.Exists(dir))
{
client.workingDir = dir;
client.sendMsg("257 当前目录\"" + getDir() + "\"");
}
else
{
client.sendMsg("目录不存在");
}
}
}
else
{
client.sendMsg("257 当前目录\"" + getDir() + "\"");
}
}
// 列表当前目录文件
private void sendDirMsg()
{
try
{
string[] dirs = Directory.GetDirectories(client.workingDir);
string[] files = Directory.GetFiles(client.workingDir);
string msg="";
for(int i=0;i-1)
{
dir = org_str.Substring(0, pos);
}
else
{
dir = org_str;
}
return dir;
}
//为目录或者文件改名
private void rename(string from, string to)
{
string name = getFileName(from);
string new_name = trimEnd(to);
Console.WriteLine("重命名" + name + "到" +
client.workingDir + new_name);
FileInfo fi = new FileInfo(name);
if (fi.Exists)
{
fi.MoveTo(client.workingDir + new_name);
client.sendMsg("250 文件改名成功");
}
else if (Directory.Exists(name))
{
Directory.Move(name, client.workingDir + new_name);
client.sendMsg("250 目录改名成功");
}
else
{
client.sendMsg("550 目录或者文件不存在");
}
}
//向客户端发送文件
private void sendFile(string filename)
{
client.sendMsg("150 开始传输数据");
string name = getFileName(filename);
FileInfo fi = new FileInfo(name);
if (fi.Exists)
{
FileStream fs = fi.OpenRead();
byte[] b = new byte[fs.Length];
fs.Read(b,0,b.Length);
fs.Close();
client.sendMsgByTempSocket(b);
client.sendMsg("226 文件发送完毕");
}
else
{
client.sendMsg("550 文件不存在");
}
}
//获取发送来的文件
private void receiveFile(string filename)
{
client.sendMsg("150 开始传输数据");
string name = getFileName(filename);
FileInfo fi = new FileInfo(name);
Socket tempSocket=client.getTempSocket();
if (tempSocket.Connected)
{
byte[] buf = new byte[1];
if (!fi.Exists)
{
File.Create(name);
}
FileStream fs = File.OpenWrite(name);
while(tempSocket.Receive(buf)>0)
{
fs.Write(buf, 0 ,buf.Length);
}
fs.Close();
client.sendMsg("226 文件接收完毕");
}
else
{
client.sendMsg("550 不能上传文件");
}
}
}
}