java中怎么实现ftp服务器

学习了计算机网络之后，利用java写了一个ftp服务器。

一、实现的ftp命令

实现了基本的user,pass,list,port,quit,retr,cwd,stor等命令

二、以上命令所对应的功能

对应的功能是：下载，上传，获取服务器目录，切换目录等

三、用于测试的ftp客户端：windows自带的ftp客户端

四、实现的思想

1、使用ServerSocket进行监听，每个控制连接的请求到来之后，开启一个线程进行处理（这里使用的java bio,效率较差，对于控制连接最好使用NIO处理，之后会再写个

nio的实现）

2、 对于命令使用工厂方法模式进行设计，当需要添加新的命令的时候，只需要添加一个新的命令类，实现相应接口，修改工厂产生逻辑，而不用修改其他的程序代码。可

扩展性较好，同时符合开闭原则。

五、实现过程中碰到的问题

1、对于tcp与socket的关系理解错误，以为所有的数据的输入都是要经过serverSocket().accept（）方法。其实，ServerSocket.accept（）所对应的是tcp里面的三次握手建

立连接的阶段，之后的tcp的连接由客户端和服务器端的一对socket来维护，是属于establish阶段，在这个阶段，通信是全双工的，任何一方都能够发送数据。

socket.close（）对应的阶段是断开连接（四次挥手）的阶段。

2、刚开始对于ftp协议不是很理解，不知道他的工作方式是怎样的，后来在看了tcp协议卷里面的ftp的内容之后，才知道ftp命令和应答码是关键。eg:刚开始测试时，在

输入用户名之后，不会提示输入密码的。原因：没有返回对应的应答码：331. 另外要注意的是：返回的数据要以换行回车作为结束--\r\n.

六、代码列表

简单说明：

ftpServer:是服务器的主程序，入口，同时负责监听本地的21号端口。

ControllerThread.java：用于处理控制连接的线程（每一个控制连接请求对应一个线程）ps:实在很浪费（流量小，连接多）。

Share：一些全局性数据的维护。

Command:是命令接口，定义了一个所有命令都要实现的方法。

CommandFactory:命令工厂，通过传人的参数，决定生成的命令对象。

UserCommand,PortCommand等：是具体ftp命令的实现

多次需要把文件上传到单独的服务器，而程序是在单独的服务器上部署的，在进行文件操作的时候就需要跨服务器进行操作包括：文件上传、文件下载、文件删除等。跨服务器文件操作一般是需要FTP协议和SFTP协议两种，现在就通过Java实现FTP协议的文件上传。要实现FTP操作文件需要引入jar包： commons-net-1.4.1.jar

参考资料来源：百度贴吧

FTP(File Transfer Protocol 文件传输协议)是Internet 上用来传送文件的协议。在Internet上通过FTP 服务器可以进行文件的上传(Upload)或下载(Download)。FTP是实时联机服务，在使用它之前必须是具有该服务的一个用户(用户名和口令)，工作时客户端必须先登录到作为服务器一方的计算机上，用户登录后可以进行文件搜索和文件传送等有关操作，如改变当前工作目录、列文件目录、设置传输参数及传送文件等。使用FTP可以传送所有类型的文件，如文本文件、二进制可执行文件、图象文件、声音文件和数据压缩文件等。

FTP 命令

FTP 的主要操作都是基于各种命令基础之上的。常用的命令有：

设置传输模式，它包括ASCⅡ(文本) 和BINARY 二进制模式

目录操作，改变或显示远程计算机的当前目录(cd、dir/ls 命令)

连接操作，open命令用于建立同远程计算机的连接；close命令用于关闭连接

发送操作，put命令用于传送文件到远程计算机；mput 命令用于传送多个文件到远程计算机

获取操作，get命令用于接收一个文件；mget命令用于接收多个文件。

?

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635

import java.net.Socketimport org.apache.log4j.Logger/** * 角色——服务器A * @author Leon * */public class ServerA{ public static void main(String[] args){final String F_DIR = "c:/test"//根路径final int PORT = 22//监听端口号Logger.getRootLogger() Logger logger = Logger.getLogger("com") try{ ServerSocket s = new ServerSocket(PORT) logger.info("Connecting to server A...") logger.info("Connected Successful! Local Port:"+s.getLocalPort()+". Default Directory:'"+F_DIR+"'.") while( true ){//接受客户端请求Socket client = s.accept() //创建服务线程new ClientThread(client, F_DIR).start() }} catch(Exception e) { logger.error(e.getMessage()) for(StackTraceElement ste : e.getStackTrace()){logger.error(ste.toString()) }} }}import java.io.BufferedReaderimport java.io.Fileimport java.io.FileNotFoundExceptionimport java.io.IOExceptionimport java.io.InputStreamimport java.io.InputStreamReaderimport java.io.OutputStreamimport java.io.PrintWriterimport java.io.RandomAccessFileimport java.net.ConnectExceptionimport java.net.InetAddressimport java.net.ServerSocketimport java.net.Socketimport java.net.UnknownHostExceptionimport java.nio.charset.Charsetimport java.util.Randomimport org.apache.log4j.Logger/** * 客户端子线程类 * @author Leon * */public class ClientThread extends Thread { private Socket socketClient//客户端socket private Logger logger//日志对象 private String dir//绝对路径 private String pdir = "/"//相对路径 private final static Random generator = new Random()//随机数 public ClientThread(Socket client, String F_DIR){this.socketClient = client this.dir = F_DIR } @Override public void run() {Logger.getRootLogger() logger = Logger.getLogger("com") InputStream is = null OutputStream os = null try { is = socketClient.getInputStream() os = socketClient.getOutputStream() } catch (IOException e) { logger.error(e.getMessage()) for(StackTraceElement ste : e.getStackTrace()){logger.error(ste.toString()) }}BufferedReader br = new BufferedReader(new InputStreamReader(is,Charset.forName("UTF-8"))) PrintWriter pw = new PrintWriter(os) String clientIp = socketClient.getInetAddress().toString().substring(1)//记录客户端IPString username = "not logged in"//用户名String password = ""//口令String command = ""//命令boolean loginStuts = false//登录状态final String LOGIN_WARNING = "530 Please log in with USER and PASS first." String str = ""//命令内容字符串int port_high = 0 int port_low = 0 String retr_ip = ""//接收文件的IP地址Socket tempsocket = null //打印欢迎信息pw.println("220-FTP Server A version 1.0 written by Leon Guo") pw.flush() logger.info("("+username+") ("+clientIp+")>Connected, sending welcome message...") logger.info("("+username+") ("+clientIp+")>220-FTP Server A version 1.0 written by Leon Guo") boolean b = true while ( b ){ try {//获取用户输入的命令command = br.readLine() if(null == command) break } catch (IOException e) {pw.println("331 Failed to get command") pw.flush() logger.info("("+username+") ("+clientIp+")>331 Failed to get command") logger.error(e.getMessage()) for(StackTraceElement ste : e.getStackTrace()){ logger.error(ste.toString()) }b = false } /* * 访问控制命令 */ // USER命令 if(command.toUpperCase().startsWith("USER")){logger.info("(not logged in) ("+clientIp+")>"+command) username = command.substring(4).trim()if("".equals(username)){ pw.println("501 Syntax error") pw.flush() logger.info("(not logged in) ("+clientIp+")>501 Syntax error") username = "not logged in" }else{ pw.println("331 Password required for " + username) pw.flush() logger.info("(not logged in) ("+clientIp+")>331 Password required for " + username) }loginStuts = false } //end USER // PASS命令 else if(command.toUpperCase().startsWith("PASS")){logger.info("(not logged in) ("+clientIp+")>"+command) password = command.substring(4).trim()if(username.equals("root") &&password.equals("root")){ pw.println("230 Logged on") pw.flush() logger.info("("+username+") ("+clientIp+")>230 Logged on")// logger.info("客户端 "+clientIp+" 通过 "+username+"用户登录") loginStuts = true }else{ pw.println("530 Login or password incorrect!") pw.flush() logger.info("(not logged in) ("+clientIp+")>530 Login or password incorrect!") username = "not logged in" } } //end PASS // PWD命令 else if(command.toUpperCase().startsWith("PWD")){logger.info("("+username+") ("+clientIp+")>"+command) if(loginStuts){// logger.info("用户"+clientIp+"："+username+"执行PWD命令") pw.println("257 /""+pdir+"/" is current directory") pw.flush() logger.info("("+username+") ("+clientIp+")>257 /""+pdir+"/" is current directory") }else{ pw.println(LOGIN_WARNING) pw.flush() logger.info("("+username+") ("+clientIp+")>"+LOGIN_WARNING) } } //end PWD // CWD命令 else if(command.toUpperCase().startsWith("CWD")){logger.info("("+username+") ("+clientIp+")>"+command) if(loginStuts){ str = command.substring(3).trim() if("".equals(str)){pw.println("250 Broken client detected, missing argument to CWD. /""+pdir+"/" is current directory.") pw.flush() logger.info("("+username+") ("+clientIp+")>250 Broken client detected, missing argument to CWD. /""+pdir+"/" is current directory.") } else{//判断目录是否存在String tmpDir = dir + "/" + str File file = new File(tmpDir) if(file.exists()){//目录存在 dir = dir + "/" + str if("/".equals(pdir)){pdir = pdir + str } else{pdir = pdir + "/" + str }// logger.info("用户"+clientIp+"："+username+"执行CWD命令") pw.println("250 CWD successful. /""+pdir+"/" is current directory") pw.flush() logger.info("("+username+") ("+clientIp+")>250 CWD successful. /""+pdir+"/" is current directory") }else{//目录不存在 pw.println("550 CWD failed. /""+pdir+"/": directory not found.") pw.flush() logger.info("("+username+") ("+clientIp+")>550 CWD failed. /""+pdir+"/": directory not found.")

---