科技行者

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

知识库

知识库 安全导航

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

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

  • 扫一扫
    分享文章到微信

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

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

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

关键字: ftp java

  • 评论
  • 分享微博
  • 分享邮件
 FTP 命令 ^"{7Hi  
SZ>)"cR D  
  FTP 的主要操作都是基于各种命令基础之上的。常用的命令有: IUeY0\(  
; nBbHey  
  · 设置传输模式,它包括ASCⅡ(文本) 和BINARY 二进制模式; al]$|z d  
o[xETR2ib  
  · 目录操作,改变或显示远程计算机的当前目录(cd、dir/ls 命令); 7Y,I&N.3  
m Ne)VFj/  
  · 连接操作,open命令用于建立同远程计算机的连接;close命令用于关闭连接; u" i.kEk  
C{r]Mcu^R  
  · 发送操作,put命令用于传送文件到远程计算机;mput 命令用于传送多个文件到远程计算机; YG""9Gmy  
|uV?rxi  
  · 获取操作,get命令用于接收一个文件;mget命令用于接收多个文件。 XovC=B   
lK qA  
  编程思路 %mt{ey7  
G}`H1;]>`  
  根据FTP 的工作原理,在主函数中建立一个服务器套接字端口,等待客户端请求,一旦客户端请求被接受,服务器程序就建立一个服务器分线程,处理客户端的命令。如果客户端需要和服务器端进行文件的传输,则建立一个新的套接字连接来完成文件的操作。 ~Pq+HO75  
Gu3@]X` F  
  编程技巧说明 (bV>)fj  
zweidP"  
  1.主函数设计 5 feG$kOvp  
u)"U eJN+  
  在主函数中,完成服务器端口的侦听和服务线程的创建。我们利用一个静态字符串变量initDir 来保存服务器线程运行时所在的工作目录。服务器的初始工作目录是由程序运行时用户输入的,缺省为C盘的根目录。 W P)w\:Y  
IY9 9)5  
  具体的代码如下: 8m:O!4i9d&  
F~:J2hF@a  
  public class ftpServer extends Thread{ *rk)j3i<~)  
  private Socket socketClient; W>IW^3RW&  
  private int counter; @($>%Z;.  
  private static String initDir; y-+n0BOpU  
  public static void main(String[] args){ 8Sr;Il  
  if(args.length != 0) { #q%{8]D  
   initDir = args[0]; dS GT vM'4  
  }else{ initDir = "c:";} -1 5 <B  
  int i = 1; .< ?rr  
  try{ '(^+^AV=#  
   System.out.println("ftp server started!"); l^Bv]n5Y  
   //监听21号端口 fFrU+QnrM  
   ServerSocket s = new ServerSocket(21); Mjk*xgv%y  
   for(;;){ AIs'X$}\:  
    //接受客户端请求 q#UA9bB  
    Socket incoming = s.accept(); $`lnd1A=z  
    //创建服务线程 bjP18U9  
    new ftpServer(incoming,i).start(); S`, B{KV  
    i++; k3't]_N d  
   } 0\ZVK'X  
  }catch(Exception e){} f]f 8(  
  } `dr 4DCO  
Q;UpyUao-  
  2. 线程类的设计 g:q `l=G  
^h3)x7 V  
  线程类的主要设计都是在run()方法中实现。用run()方法得到客户端的套接字信息,根据套接字得到输入流和输出流,向客户端发送欢迎信息。 wwFavsJ  
V| U  
  3. FTP 命令的处理 6XVDUQ"b'  
NQ"sB&sh)  
  (1) 访问控制命令 }p|S`:Tt  
}laf;fL  
  · user name(user) 和 password (pass) 命令处理代码如下: G ~TY]L  
TC.>8  
  if(str.startsWith("USER")){ u1Q@+:(a  
  user = str.substring(4); ;A5WG)%_N  
  user = user.trim(); VBNS  
  out.println("331 Password"); py ]2v6  
  } hqb V:=%  
  if(str.startsWith("PASS")) #U</hU  
  out.println("230 User "+user+" logged in."); Mfvu'T4Q4  
/'=iW^S  
  User 命令和 Password 命令分别用来提交客户端用户输入的用户名和口令。 wWi84SH'   
kkSE{8ik  
  · CWD (CHANGE WORKING DIRECTORY) 命令处理代码如下: us8OG  
0 7m WKzo  
  if(str.startsWith("CWD")){ hwtUi7{  
  String str1 = str.substring(3); I9;~E)Cf  
  dir = dir+"/"+str1.trim(); nO<O2XBt  
  out.println("250 CWD command succesful"); /z/YsnoP  
  } [.m0J>mk  
|x^Bu+0H  
  该命令改变工作目录到用户指定的目录。 xqPC1KCM  
__ >d@G.S  
  · CDUP (CHANGE TO PARENT DIRECTORY) 命令处理代码如下: K =J9u'Ad  
E'xW-Lq  
  if(str.startsWith("CDUP")){ O\,x`i  
  int n = dir.lastIndexOf("/"); hw9UY280  
  dir = dir.substring(0,n); x,k)a~RNk  
  out.println("250 CWD command succesful"); }SO*Ba<7  
  } A-svLbx iq  
eDioH($z>  
  该命令改变当前目录为上一层目录。 Z:K{kdxfD  
Z_wWTJ zW  
  · QUIT命令处理代码如下: )?(rC<Ne"k  
%AjtBfRr  
  if(str.startsWith("QUIT")) {  zUxr3  
  out.println("GOOD BYE"); Ys74 nrS  
  done = true; N+) 8Em  
  } 6MZYh;W  
ML "Lc<Qb}  
  该命令退出及关闭与服务器的连接,输出GOOD BYE。 zu%G[\94  
'u>/rJLff  
  (2) 传输参数命令 ?P>}K<J  
zS3$N>bIW  
  · Port命令处理代码如下: YFZDX  
xF.v5N  
  if(str.startsWith("PORT")) { `yJ;Fx  
  out.println("200 PORT command successful"); N>nuS SUz$  
  int i = str.length() - 1; (6vsn^y  
  int j = str.lastIndexOf(","); 2jW3 ?$  
  int k = str.lastIndexOf(",",j-1); ETo9]5  
  String str1,str2; ?sIn1!6i  
  str1=""; nb&/?XYIo  
  str2=""; 48}[5_]  
  for(int l=k+1;lstr1 = str2 + str.charAt(l); &LT`-_ F  
  } !^09D  
  for(int l=j+1;l<=i;l++){ DIl0X8/J  
  str2 = str2 + str.charAt(l); D`V ;?V2  
  } ty@[d\#  
  tempPort = Integer.parseInt(str1) * 16 *16 +Integer.parseInt(str2); }eabu%^L  
  }  nRj{C(X  
ITIS2T  
  使用该命令时,客户端必须发送客户端用于接收数据的32位IP 地址和16位 的TCP 端口号。这些信息以8位为一组,使用十进制传输,中间用逗号隔开。 KHR~O9o4  
66:E<-^  
  · TYPE命令处理代码如下: aH^pu z  
K $`:mJ6  
  if(str.startsWith("TYPE")){ E$ck}4Z  
  out.println("200 type set"); g-]c`h<  
  } K@TBAh'  
l!e3\[)C  
  TYPE 命令用来完成类型设置。 uNFx).,  
BsTZV5jV\?  
  (3) FTP 服务命令 t>!l+h3  
WP B3Cu  
  · RETR (RETEIEVE) 和 STORE (STORE)命令处理的代码 ^L&+8T2  
}!ef>x=X\q  
  if(str.startsWith("RETR")){ O[f0k ?  
  out.println("150 Binary data connection"); bpc'>'w)  
  str = str.substring(4); qsU^!)Ncz  
  str = str.trim(); )ekSkn xT  
  RandomAccessFile outFile = new <_?hhq  
  RandomAccessFile(dir+"/"+str,"r"); zou/kkR;  
  Socket tempSocket = new Socket(host,tempPort); sBnx"8I_  
  OutputStream outSocket = tempSocket.getOutputStream(); !QCDN:<K+  
  byte byteBuffer[]= new byte[1024]; +9n|+}_KV  
  int amount; LY$-p!X  
  try{ - |\a.]f  
  while((amount = outFile.read(byteBuffer)) != -1){ 7ps U V  
   outSocket.write(byteBuffer, 0, amount); 0}g@BiSty  
  } gk;W|0~  
  outSocket.close(); ,.Mj0)ke  
  out.println("226 transfer complete"); cLM9]6u5Lj  
  outFile.close(); B:P'8KY  
  tempSocket.close(); )PXglh  
  } {^Y\v" b$P  
  catch(IOException e){} ^C-u"_B  
  } XgcXW1(eY  
  if(str.startsWith("STOR")){ c9&VMX`R~  
  out.println("150 Binary data connection"); OQu.Eej  
  str = str.substring(4); ^{D`(xHR  
  str = str.trim(); DSjtq$P0.  
  RandomAccessFile inFile = new @hP/RT  
  RandomAccessFile(dir+"/"+str,"rw"); k9d"c`>  
  Socket tempSocket = new Socket(host,tempPort); -qfM?Zt4;  
  InputStream inSocket = tempSocket.getInputStream(); paf?VTq>!  
  byte byteBuffer[] = new byte[1024]; d.Jm&e'v  
  int amount; 4Zp-/-GdBX  
  try{ `F_@C .N  
  while((amount =inSocket.read(byteBuffer) )!= -1){ .1mHROeW  
  inFile.write(byteBuffer, 0, amount); hLJ"y*6  
  }  nzQY.N6S  
  inSocket.close(); VJR0JU"9  
  out.println("226 transfer complete"); a>r#u;Y1t7  
  inFile.close(); >#BL"wi b[  
  tempSocket.close(); vG7i [%w(  
  } 6OPx@F`4cJ  
  catch(IOException e){} 76kxe-B>  
  } $qDXupeQO  
_~@4o-(gu  
  文件传输命令包括从服务器中获得文件RETR和向服务器中发送文件STOR,这两个命令的处理非常类似。处理RETR命令时,首先得到用户要获得的文件的名称,根据名称创建一个文件输入流,然后和客户端建立临时套接字连接,并得到一个输出流。随后,将文件输入流中的数据读出并借助于套接字输出流发送到客户端,传输完毕以后,关闭流和临时套接字。 =}H6'~ L  
JFg."l  
  STOR 命令的处理也是同样的过程,只是方向正好相反。  DaL^ d  
8@AcCzvK  
  · DELE (DELETE)命令处理代码如下: <SGYIA{  
fjCx&b\'y  
  if(str.startsWith("DELE")){ 1@cu5:I  
  str = str.substring(4); $YGA7^~  
  str = str.trim(); '!*MktOx  
  File file = new File(dir,str); !fzy %%%:  
  boolean del = file.delete(); &13 7"b@  
  out.println("250 delete command successful"); 02h#+`LX  
  } ^B#V8:2e  
||5eM3&  
  DELE 命令用于删除服务器上的指定文件。 $#O<a(4$v  
|m\YNA (b  
  · LIST命令处理代码如下: B59O:W~  
I g_;DY  
  if(str.startsWith("LIST")) { QkcRhf[AB  
  try{ ;rEH& 0W  
  out.println("150 ASCII data"); 2q%{ \McQ  
  Socket tempSocket = new Socket(host,tempPort); vdiF'{a  
  PrintWriter out2= new PrintWriter(tempSocket.getOutputStream(),true); va*}wMH;9  
  File file = new File(dir); 33*=gwW!F  
  String[] dirStructure = new String; $`?9 dF  
  dirStructure= file.list(); f^X@"(`  
  String strType=""; gZi7 \+/  
  for(int i=0;iif( dirStructure.indexOf(".") == -1) { strType = "d ";} N^wTpc9F  
   else 6@SaK~d  
   {strType = "- ";} Rbjx70T@  
   out2.println(strType+dirStructure); ]SBDixKM  
  } \*9mB2  
  tempSocket.close(); {A2;lV<>~  
  out.println("226 transfer complete"); Qm7jgmR!=  
  } 8Y>8YiK'  
  catch(IOException e){} 2IVRT"M2}I  
f }HOW)R  
  LIST 命令用于向客户端返回服务器中工作目录下的目录结构,包括文件和目录的列表。处理这个命令时,先创建一个临时的套接字向客户端发送目录信息。这个套接字的目的端口号缺省为1,然后为当前工作目录创建File 对象,利用该对象的list()方法得到一个包含该目录下所有文件和子目录名称的字符串数组,然后根据名称中是否含有文件名中特有的“.”来区别目录和文件。最后,将得到的名称数组通过临时套接字发送到客户端。
查看本文来源
    • 评论
    • 分享微博
    • 分享邮件
    邮件订阅

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

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