科技行者

行者学院 转型私董会 科技行者专题报道 网红大战科技行者

知识库

知识库 安全导航

至顶网软件频道用Java实现FTP服务器解决方案

用Java实现FTP服务器解决方案

  • 扫一扫
    分享文章到微信

  • 扫一扫
    关注官方公众号
    至顶头条

用Java实现FTP服务器解决方案

作者: jiaolisd 来源:赛迪网技术社区 2007年11月19日

关键字: 服务器 ftp java

  • 评论
  • 分享微博
  • 分享邮件
 FTP 命令 mj? )XLz  
2I{H'1Q  
  FTP 的主要操作都是基于各种命令基础之上的。常用的命令有: Tp8?$AZ  
|YxR@$v;;  
  · 设置传输模式,它包括ASCⅡ(文本) 和BINARY 二进制模式; .L npA)m  
!xH~?aT  
  · 目录操作,改变或显示远程计算机的当前目录(cd、dir/ls 命令); xO,/ ^zs2  
B7*N>eXDB  
  · 连接操作,open命令用于建立同远程计算机的连接;close命令用于关闭连接; 0D+&3 a2ZK  
gJvIU W  
  · 发送操作,put命令用于传送文件到远程计算机;mput 命令用于传送多个文件到远程计算机; uc s5m7!  
8>SU .)#  
  · 获取操作,get命令用于接收一个文件;mget命令用于接收多个文件。 hWY&,QN  
+ 3uJe  
  编程思路 hc) @yOl  
NP7 ;XW >B  
  根据FTP 的工作原理,在主函数中建立一个服务器套接字端口,等待客户端请求,一旦客户端请求被接受,服务器程序就建立一个服务器分线程,处理客户端的命令。如果客户端需要和服务器端进行文件的传输,则建立一个新的套接字连接来完成文件的操作。 x.yMH:P  
KK^WtLl2}c  
  编程技巧说明 0JR`(>m\s  
bn2JCBA$  
  1.主函数设计 wghQK/qV*  
1MVhKPa8T  
  在主函数中,完成服务器端口的侦听和服务线程的创建。我们利用一个静态字符串变量initDir 来保存服务器线程运行时所在的工作目录。服务器的初始工作目录是由程序运行时用户输入的,缺省为C盘的根目录。 h-&R_J!3  
'mO,V(< n/  
  具体的代码如下: 8J{I1+&k  
EwvZ ,fK#a  
  public class ftpServer extends Thread{ xK=1^WW-8c  
  private Socket socketClient; #o0EyS~  
  private int counter; ZcmsVl9&  
  private static String initDir; &,\)mgv   
  public static void main(String[] args){ ^fGnmcJ_  
  if(args.length != 0) { 98o)@%Ge~  
   initDir = args[0]; |~B!{  
  }else{ initDir = "c:";} *wk *x>T  
  int i = 1;  *):hG  
  try{ ?i2' {bTP  
   System.out.println("ftp server started!"); B?{G8P=IUr  
   //监听21号端口 _SB/LM%i  
   ServerSocket s = new ServerSocket(21); `%(C-50  
   for(;;){ o\dyDw  
    //接受客户端请求 11 5HpA\,  
    Socket incoming = s.accept(); I&i~cTVh  
    //创建服务线程 }B)}>7E  
    new ftpServer(incoming,i).start(); pA .MxW3  
    i++; J$r:C=ym7T  
   } ;u'@w!Gc  
  }catch(Exception e){} >>ujr<n(  
  } dWrRR@^VN<  
?c|@* xRL  
  2. 线程类的设计 p@sWT  
XAWM{n X  
  线程类的主要设计都是在run()方法中实现。用run()方法得到客户端的套接字信息,根据套接字得到输入流和输出流,向客户端发送欢迎信息。 5Q 'GX&  
pj= YDn/-  
  3. FTP 命令的处理 Fg$.BSFj6  
*UP`#Es)j  
  (1) 访问控制命令 V 1\<o  
Onu3LkYn  
  · user name(user) 和 password (pass) 命令处理代码如下: 38B e|5 ?  
U PZ(y]@  
  if(str.startsWith("USER")){ 3')S$n</  
  user = str.substring(4); q;*|o}:s  
  user = user.trim(); 9F^X|/ V^  
  out.println("331 Password"); ![oV0|gI  
  } ]7I{Xwy  
  if(str.startsWith("PASS")) yLQi6p 0  
  out.println("230 User "+user+" logged in."); _XWkm1Th>  
jAa/=Gt7  
  User 命令和 Password 命令分别用来提交客户端用户输入的用户名和口令。 'Fl gW1(2  
EqN/  
  · CWD (CHANGE WORKING DIRECTORY) 命令处理代码如下: SeZuBCpyQ)  
iY6f*fv  
  if(str.startsWith("CWD")){ a96N%kK  
  String str1 = str.substring(3); 8b{I,3 e)  
  dir = dir+"/"+str1.trim(); "PbpP"  
  out.println("250 CWD command succesful"); 8dIGv35Y  
  } .HPzxQ t$  
M*CDSA[1  
  该命令改变工作目录到用户指定的目录。 WEp{=`Q  
qAn1q9  
  · CDUP (CHANGE TO PARENT DIRECTORY) 命令处理代码如下: pC3\rA0  
v$!DiW1^  
  if(str.startsWith("CDUP")){ 8J vYkl|"  
  int n = dir.lastIndexOf("/"); q> -8:)*  
  dir = dir.substring(0,n); #]Fh&>A  
  out.println("250 CWD command succesful"); 0B>:$$q#j  
  } BtMr{G5{  
hO[`T<#y  
  该命令改变当前目录为上一层目录。 Q|fK]Eq5  
WSML9?Yn  
  · QUIT命令处理代码如下: >uY:Q L  
L#yxHi|Hg  
  if(str.startsWith("QUIT")) { OoX[=/n;$  
  out.println("GOOD BYE"); WC'p#e8E  
  done = true; SfoSf(qivP  
  } ! -QMoI&  
?s+w Dm  
  该命令退出及关闭与服务器的连接,输出GOOD BYE。 DOU  KU}  
l+4 }cHer^  
  (2) 传输参数命令 Lx8 =3Di+  
QJ(gp \O4  
  · Port命令处理代码如下: qWx !?G  
Y_ DU  
  if(str.startsWith("PORT")) { (piK'$jA  
  out.println("200 PORT command successful"); (t~HUZ&2  
  int i = str.length() - 1; ?{@X<BIH  
  int j = str.lastIndexOf(","); MB 8SSD  
  int k = str.lastIndexOf(",",j-1); ;tKeg_oGgO  
  String str1,str2; ~f~+fLL  
  str1=""; f1R] \R|  
  str2=""; k*")m{_  
  for(int l=k+1;lstr1 = str2 + str.charAt(l); ZHY)p &!`  
  } q Z4#G>  
  for(int l=j+1;l<=i;l++){ Z|hsX  
  str2 = str2 + str.charAt(l); )tW`iJ-bn,  
  } EC/CGy%  
  tempPort = Integer.parseInt(str1) * 16 *16 +Integer.parseInt(str2); (vK^  
  } Lgx/#>&DZ$  
<|IY 6={  
  使用该命令时,客户端必须发送客户端用于接收数据的32位IP 地址和16位 的TCP 端口号。这些信息以8位为一组,使用十进制传输,中间用逗号隔开。 )Nfg7n]:t  
*e Opn:  
  · TYPE命令处理代码如下: Qo*`u0v1  
pd0j}iZ!  
  if(str.startsWith("TYPE")){ qOh{e z  
  out.println("200 type set"); F- &ssQ  
  } qD%+6V#S.  
+\r%iuT`  
  TYPE 命令用来完成类型设置。 <|$i6]11  
tVE/ A2^vd  
  (3) FTP 服务命令 Z0 Z1"  
*a/`OBTVz  
  · RETR (RETEIEVE) 和 STORE (STORE)命令处理的代码 PbCZ\S  
1#fV\,H  
  if(str.startsWith("RETR")){ h$wj5,-o  
  out.println("150 Binary data connection"); li6)Z& i\M  
  str = str.substring(4); SGmwGNB  
  str = str.trim(); ts tVHvZA  
  RandomAccessFile outFile = new lEX NLF)H  
  RandomAccessFile(dir+"/"+str,"r"); t]U@c// 0U  
  Socket tempSocket = new Socket(host,tempPort); qZOrr%r/  
  OutputStream outSocket = tempSocket.getOutputStream(); FU`-mQ"R  
  byte byteBuffer[]= new byte[1024]; <:<"{;-j  
  int amount; Ak[?BD"@=  
  try{ L~tS  
  while((amount = outFile.read(byteBuffer)) != -1){ %JX#Ge;  
   outSocket.write(byteBuffer, 0, amount); Yw0nog  
  } v>@6tw  
  outSocket.close(); md0,`lSyMq  
  out.println("226 transfer complete"); FB)oGkOS{  
  outFile.close(); 1c|R-X4@  
  tempSocket.close(); )l2Z:I  
  } eS+0[T+$b  
  catch(IOException e){} kX0mp(md  
  } )lj~96 5  
  if(str.startsWith("STOR")){ {==7g`Jc  
  out.println("150 Binary data connection"); 180u`< I5  
  str = str.substring(4); ])nP#-C@  
  str = str.trim(); Qg_k0!`#E  
  RandomAccessFile inFile = new 2CMjSQ]`z=  
  RandomAccessFile(dir+"/"+str,"rw"); "3#"G`D*  
  Socket tempSocket = new Socket(host,tempPort); bv>1PdGZLQ  
  InputStream inSocket = tempSocket.getInputStream(); 0>xOs2hj  
  byte byteBuffer[] = new byte[1024]; Z jTl g\  
  int amount; {@rK#'#J!  
  try{ 5Y~t_QXF  
  while((amount =inSocket.read(byteBuffer) )!= -1){ n+49l o  
  inFile.write(byteBuffer, 0, amount); 86BM_kqY  
  } e/YW"YF_  
  inSocket.close(); ` +Umr H  
  out.println("226 transfer complete"); TZSY:#6;  
  inFile.close(); m9.PQBpXQ  
  tempSocket.close(); CMmc-4  
  } :#Kz5.E|a  
  catch(IOException e){} ,a\GR(czg  
  } ^UEYI  
C. [Xn#  
  文件传输命令包括从服务器中获得文件RETR和向服务器中发送文件STOR,这两个命令的处理非常类似。处理RETR命令时,首先得到用户要获得的文件的名称,根据名称创建一个文件输入流,然后和客户端建立临时套接字连接,并得到一个输出流。随后,将文件输入流中的数据读出并借助于套接字输出流发送到客户端,传输完毕以后,关闭流和临时套接字。 'iZ[g[~v@P  
'H$wIYqNL  
  STOR 命令的处理也是同样的过程,只是方向正好相反。 >jL>Sa2  
L=i9g  
  · DELE (DELETE)命令处理代码如下: ] q\0c>  
~9Y>5'Y|>n  
  if(str.startsWith("DELE")){ _!UQb!4  
  str = str.substring(4); >G*J3_ r^O  
  str = str.trim(); XL=;/KA}  
  File file = new File(dir,str); RUHD~^a6O  
  boolean del = file.delete(); St<y.]N@Y  
  out.println("250 delete command successful"); 'tL{31OY1  
  } 9?q2(*]6d?  
-A.-uV<,  
  DELE 命令用于删除服务器上的指定文件。 _xTi<p$x  
T?pKe  
  · LIST命令处理代码如下: 68z<LGq0  
<AbZ9E3  
  if(str.startsWith("LIST")) { #vct%'P\e  
  try{ .JtB(Op<  
  out.println("150 ASCII data"); ]/oEhVw  
  Socket tempSocket = new Socket(host,tempPort); &*rI[@=/+  
  PrintWriter out2= new PrintWriter(tempSocket.getOutputStream(),true); W7AHsd   
  File file = new File(dir); Oss6D,,m  
  String[] dirStructure = new String; U)N]e8s  
  dirStructure= file.list(); |U*>~EQ<X  
  String strType=""; 8 OGAmu6o  
  for(int i=0;iif( dirStructure.indexOf(".") == -1) { strType = "d ";} |,^bIWLa'  
   else fDz|Wjvpi  
   {strType = "- ";} M ~xXUeQbj  
   out2.println(strType+dirStructure); 4 (]V)#b  
  } _tjY S  
  tempSocket.close(); 7-mXeI<M-)  
  out.println("226 transfer complete"); nG/-LKgE  
  } %-r0#." N  
  catch(IOException e){} #qFj*0v:  
=nr_YjxlC~  
  LIST 命令用于向客户端返回服务器中工作目录下的目录结构,包括文件和目录的列表。处理这个命令时,先创建一个临时的套接字向客户端发送目录信息。这个套接字的目的端口号缺省为1,然后为当前工作目录创建File 对象,利用该对象的list()方法得到一个包含该目录下所有文件和子目录名称的字符串数组,然后根据名称中是否含有文件名中特有的“.”来区别目录和文件。最后,将得到的名称数组通过临时套接字发送到客户端。
查看本文来源
    • 评论
    • 分享微博
    • 分享邮件
    邮件订阅

    如果您非常迫切的想了解IT领域最新产品与技术信息,那么订阅至顶网技术邮件将是您的最佳途径之一。

    重磅专题
    往期文章
    最新文章