以下代码使用C#完成!完成。
using System;
using System.Net.Sockets;
/// <summary>
/// Ftp 的摘要说明。
/// </summary>
public class Ftp
{
public Ftp()
{
//
// TODO: 在此处添加构造函数逻辑
//
}
string _ser;
public string Server
{
set{ _ser=value;}
get{return _ser;}
}
string _port;
public string Port
{
set{_port=value;}
get{return _port;}
}
string _user;
public string User
{
set{ _user=value;}
get{return _user;}
}
string _pws;
public string Password
{
set{ _pws=value;}
get{return _pws;}
}
bool _IsLog;
public bool IsLogined
{
set{ _IsLog=value;}
get{return _IsLog;}
}
int _MsgID;
public int MsgID
{
set{ _MsgID=value;}
get{return _MsgID;}
}
System.Windows.Forms.Label _infx=new System.Windows.Forms.Label() ;
public System.Windows.Forms.Label InfsShow
{
set{_infx=value;}
get{return _infx;}
}
System.Windows.Forms.ListBox _infs=new System.Windows.Forms.ListBox();
public System.Windows.Forms.ListBox InfsList
{
set{_infs=value;}
get{return _infs;}
}
System.Windows.Forms.ProgressBar _pb=new System.Windows.Forms.ProgressBar() ;
public System.Windows.Forms.ProgressBar Progress
{
set{_pb=value;}
get{return _pb;}
}
public string NowInf;
System.Net.Sockets.TcpClient tcFtp;
NetworkStream Stm;
public bool Login()
{
try
{
SetInf("正在连接服务器...");
tcFtp=new TcpClient(_ser, System.Convert.ToInt32(_port));//连接服务器
Stm= tcFtp.GetStream();//获取网络流
byte[] data=new byte[255];
int bytes;
SetInf("等待服务器就绪!");
bytes=Stm.Read(data,0,data.Length);
string msg=System.Text.Encoding.ASCII.GetString(data,0,bytes);//读取登录成功的消息
if (msg.Substring(0,3)=="220")
{
SetInf(msg);
if (DoCmd("USER " + _user+" ","331"))
{
if (DoCmd("PASS " + _pws,"230"))
{
SetInf("服务器就绪!");
this.IsLogined=true;
return true;
}
SetInf("密码错误!",230);
return false;
}
SetInf("用户名错误",331);
return false;
}
else
{
SetInf("服务器没有正确响应!",220);
return false;
}
}
catch (System.Exception ex)
{
NowInf=ex.Message ;
_infx.Text=NowInf;
return false;
}
}
/// <summary>
///
/// </summary>
/// <param name="cmd"></param>
/// <param name="wait">匹配前面的字符就可以了</param>
/// <returns></returns>
private bool DoCmd(string cmd,string wait)
{
string msg=DoCommand(cmd);
SetInf(msg);
if (msg.IndexOf("/r/n")>=0)
{
string xx=msg.Substring(msg.IndexOf("/r/n")) ;
msg=(xx=="/r/n"?msg:xx);
msg=msg.Replace("/r/n","");
}
msg+="/r/n";
return (msg.Substring(0,wait.Length).ToLower()==wait.ToLower() );//如果msg的前部分是wait,则返回成功.
}
private bool RetOk(string s1,string s2)
{
string msg=s1;
if (msg.IndexOf("/r/n")>=0)
{
string xx=msg.Substring(msg.IndexOf("/r/n")) ;
msg=(xx=="/r/n"?msg:xx);
msg=msg.Replace("/r/n","");
}
s1=msg+"/r/n";
return (s1.Substring(0,s2.Length).ToLower()==s2.ToLower() );//如果msg的前部分是wait,则返回成功.
}
private string DoCommand(string cmd)
{
string msg=cmd;//+System.Text.Encoding.ASCII.GetString(vbnull);
byte[] data=System.Text.Encoding.ASCII.GetBytes(msg+"/r/n");
Stm.Write(data,0,data.Length);
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
data=new byte[255];
int bytes;
while(Stm.DataAvailable==false)
{
System.Windows.Forms.Application.DoEvents() ;
NowInf="正在等待服务器响应!";
}
bytes=Stm.Read(data,0,data.Length);
msg=System.Text.Encoding.ASCII.GetString(data,0,bytes);
return msg;
}
private void SetInf(string msg)
{
if( msg.IndexOf("/r/n")>=0)
{
msg=msg.Substring(0,msg.LastIndexOf("/r/n")-"/r/n".Length );
msg+=" "+ System.DateTime.Now.TimeOfDay.ToString();
}
NowInf=msg;
_infx.Text=NowInf;
_infs.Items.AddRange(msg.Split("/r/n".ToCharArray()));
System.Windows.Forms.Application.DoEvents();
_infs.SelectedIndex=_infs.Items.Count-1;
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
}
private void SetInf(string msg,int msgid)
{
SetInf(msg);
_MsgID=msgid;
}
private string GetMsg()
{
string msg;
byte[] data=new byte[1024];
int bytes;
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
while(Stm.DataAvailable==false)//如果没有信息可读,等待服务器响应.
{
System.Windows.Forms.Application.DoEvents() ;
}
bytes=Stm.Read(data,0,data.Length);//读取数据
msg=System.Text.Encoding.ASCII.GetString(data,0,bytes);//转换为字符
int rn= msg.IndexOf("/r/n",0);//查找换行符号
if (rn>0)
{
string mg=msg.Substring(rn);//这里是为了防止传输来多行数据,我试图加大缓冲,也是这样.
if( mg.Length>2)//在这里处理如同226这样消息.
{ //前面一次返回接受了一部分,第二次接受到了前面的一部分,在这里用来分开他们
mg=mg.Substring(2);
msg=mg;
}
}
SetInf(msg);
return msg;
}
/// <summary>
/// 注销登录
/// </summary>
/// <returns>成功时返回真</returns>
public bool Logout()
{
this.IsLogined=false;
bool ok=DoCmd("QUIT","221");
SetInf("已断开服务器!",221);
return ok;
}
public bool SetCurDir(string Path)
{
if (DoCmd("CWD "+Path,"250")==false)//"" is current directory.
{
SetInf("确认当前目录失败!",257);
return false;
}
if (DoCmd("PWD "+Path,"257")==false)//"" is current directory.
{
SetInf("确认当前目录失败!",257);
return false;
}
return true;
}
public string GetCurDir()
{
string msg=DoCommand("PWD");
string[] st=msg.Split((char)34);
return st[1];
}
public bool Delete(string FileName)
{
return DoCmd("DELE "+FileName,"250");
}
/// <summary>
/// 上传文件
/// </summary>
/// <param name="FileName">要上传的本地文件</param>
/// <param name="SvrPath">服务器目标路径.</param>
/// <returns>传输成功返回真.</returns>
public bool UploadFile(string FileName)
{
_pb.Value=5;
if (this.IsLogined==false)
{
SetInf("没有连接到服务器或没有登录!");
return false;
}
if (DoCmd("TYPE I","200")==false)//Type set to I.
{
SetInf("执行Type i失败!",200);
return false;
}
_pb.Value=10;
string[] pt=FileName.Split("//".ToCharArray());
string filename=pt[pt.Length-1] ;//SvrPath+"/"+pt[pt.Length-1] ;
string tmp1=DoCommand("SIZE "+ filename);
SetInf(tmp1);
if (RetOk(tmp1,"550")!=true)//50 /bbs/Dv_ForumNews/广告.txt: No such file.
{
if (RetOk(tmp1,"501")!=true)
{
SetInf("文件已存在!",550);
return false;
}
else
{
SetInf("文件名为空,请指定文件名!",501);
return false;
}
}
_pb.Value=15;
if (DoCmd("MODE S" ,"200")==false)//Type set to I.
{
SetInf("模式设置失败!");
//return false;
}
/////获取传输文件的ip和段口
string tmp2 =DoCommand("PASV");
SetInf(tmp2);
if (RetOk(tmp2,"227")==false)//Type set to I.
{
SetInf("服务器没有返回227,无法知道端口,也无法开始传输文件!",227);
return false;
}
string[] ips=GetIP( tmp2);
///////////////////
TcpClient tcm;
try
{
_pb.Value=20;
SetInf("正在连接文件传输服务器!");
tcm=new TcpClient(ips[0],System.Convert.ToInt32(ips[1]));//连接传输服务器.
}
catch (System.Exception ex1)
{
SetInf("连接文件传输服务器时出错:IP地址:"+ips[0]+"端口:" + ips[1]+" 相关信息:" + ex1.Message );
return false;
}
if (DoCmd("STOR "+ filename,"150")==false)//发送传输文件的指令.返回应该是150,否则出错
{
SetInf("开始传输文件的指令服务器响应的不是150,不知道服务器是不是准备接受文件!",150);
return false;
}
//读取文件///////////////////////
SetInf("正在读取文件,准备传输...");
System.IO.FileStream fs;
byte[] fbins;
try
{
_pb.Value=25;
fs=new System.IO.FileStream(FileName,System.IO.FileMode.Open,System.IO.FileAccess.Read);
fbins=new byte[fs.Length] ;
fs.Read(fbins,0,System.Convert.ToInt32(fs.Length));
}
catch( System.Exception ex2)
{
SetInf("文件读取失败,失败原因:"+ex2.Message);
return false;
}
_pb.Value=35;
/////////////////////////////////////////////////////
NetworkStream tmx=tcm.GetStream();//获得流
SetInf("正在向网络数据流中写入数据...");
_pb.Value=45;
tmx.Write(fbins,0,fbins.Length);//写入信息
tmx=null;
tcm.Close();
_pb.Value=55;
if (RetOk(GetMsg(),"226")==false)//一般226信息为两次 ,本次是说明磁盘目前可用大小已经使用大小
{
}
string tmp3;
_pb.Value=65;
tmp3=DoCommand("SIZE "+ filename);//获取大小.
SetInf(tmp3);
_pb.Value=75;
if (RetOk(tmp3,"213"))//返回大小
{
SetInf("正在核对文件大小");
int ln=System.Convert.ToInt32(tmp3.Substring(4));//得到远程文件的大小
_pb.Value=89;
if( ln==fbins.Length)//如果大小相同.说明完整传输.
{
SetInf("文件传输成功!",0);
return true;
}
SetInf("文件传输后文件大小不一致!",213);
return false;
}
_pb.Value=100;
SetInf("文件传输成功,但确认文件大小时服务器响应的不是213!因此无法保证数据传输是否正确!",213);
return false;
}
/// <summary>
/// 从消息里提取用于传输文件的服务器地址和端口
/// </summary>
/// <param name="Inf">消息</param>
/// <returns>数组,0为ip地址,1为端口.</returns>
private string[] GetIP(string Inf)
{
string[] rt=new string[2];
if (Inf.IndexOf("(")>0 )
{
string ips=Inf.Substring( Inf.IndexOf("(")+1);
ips=ips.Substring(0,ips.IndexOf(")"));
string[] ip=ips.Split(",".ToCharArray());
rt[0]=ip[0]+"."+ip[1]+"."+ip[2]+"."+ip[3];//前面4组byte是ip地址.
int x1=System.Convert.ToInt16(ip[4]);//ip地址
int x2=System.Convert.ToInt16(ip[5]);//端口
int rtx=x1*256+x2;//计算端口.消息里后两组byte是端口,前者乘256加上后者就是服务器给你的端口.
rt[1]=rtx.ToString();
}
return rt;
}
public bool DownloadFile(string SvrFileName,string SaveToFileName)
{
string FileName=SvrFileName;
if (this.IsLogined==false)
{
SetInf("没有连接到服务器或没有登录!");
return false;
}
_pb.Value=5;
DoCmd("NOOP","200");
if (DoCmd("TYPE I","200")==false)//Type set to I.
{
SetInf("执行Type i失败!",200);
return false;
}
_pb.Value=10;
DoCmd("NOOP","200");
_pb.Value=25;
if (DoCmd("MODE S" ,"200")==false)//Type set to I.
{
SetInf("模式设置失败!",200);
//return false;
}
/////获取传输文件的ip和段口
DoCmd("NOOP","200");
_pb.Value=34;
string tmp2 =DoCommand("PASV");
SetInf(tmp2);
_pb.Value=40;;
if (RetOk(tmp2,"227")==false)//Type set to I.
{
SetInf("服务器没有返回227,无法知道端口,也无法开始传输文件!",227);
return false;
}
string[] ips=GetIP( tmp2);
TcpClient tcm;
try
{
_pb.Value=50;
SetInf("正在连接文件传输服务器!");
tcm=new TcpClient(ips[0],System.Convert.ToInt32(ips[1]));//连接传输服务器.
}
catch (System.Exception ex1)
{
SetInf("连接文件传输服务器时出错:IP地址:"+ips[0]+"端口:" + ips[1]+" 相关信息:" + ex1.Message );
return false;
}
_pb.Value=55;
DoCmd("NOOP","200");
string inf=DoCommand("RETR "+ FileName);
if (inf.IndexOf("150")==-1)
{
SetInf(inf);
return false;
}
_pb.Value=60;
SetInf("正在准备接收文件...");
System.IO.FileStream fs;
try
{
fs=new System.IO.FileStream(SaveToFileName,System.IO.FileMode.OpenOrCreate ,System.IO.FileAccess.ReadWrite );
}
catch( System.Exception ex2)
{
SetInf("文件创建或打开失败,失败原因:"+ex2.Message);
return false;
}
/////////////////////////////////////////////////////
///
NetworkStream tmx=tcm.GetStream();//获得流
_pb.Value=70;
SetInf("正在接收文件...");
int i=0;
int c=0;
do
{
byte[] dats=new byte[10240];
i=tmx.Read(dats,0,dats.Length);
c+=i;
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
fs.Write(dats,0,i);
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
System.Windows.Forms.Application.DoEvents();
this.InfsShow.Text=c+"字节已复制.";
}
while (i>0 );
c=0;
this.InfsShow.Text="正在保存文件!";
fs.Close();
tmx=null;
tcm.Close();
DoCmd("NOOP","200");
this.InfsShow.Text="";
return true;
}
}
相关文章
- 07-11使用嵌套字用FTP协议进行文件上传下载!