// ftp 程序Ftp.java

// 此程序的功能是建立与ftp服务器的连接并实现文件传输

// 使用方法：java Ftp 服务器地址

//启动示例:java Ftp kiku.fuis.fukui-u.ac.jp

// 导入库

import java.net.*;

import java.io.*;

// Ftp类

public class Ftp {

// 准备

Socket ctrlSocket;//控制用Socket

public PrintWriter ctrlOutput;//控制输出用的流

public BufferedReader ctrlInput;// 控制输入用的流

final int CTRLPORT = 21 ;// ftp 的控制用端口

// openConnection方法

//由地址和端口号构造Socket，形成控制用的流

public void openConnection(String host)

throws IOException,UnknownHostException

{

ctrlSocket = new Socket(host, CTRLPORT);

ctrlOutput = new PrintWriter(ctrlSocket.getOutputStream());

ctrlInput

= new BufferedReader(new InputStreamReader

(ctrlSocket.getInputStream()));

}

// closeConnection方法

//关闭控制用的Socket

public void closeConnection()

throws IOException

{

ctrlSocket.close() ;

}

// showMenu方法

// 输出ftp的命令菜单

public void showMenu()

{

System.out.println(">Command?") ;

System.out.print("2 ls") ;

System.out.print(" 3 cd") ;

System.out.print(" 4 get") ;

System.out.print(" 5 put") ;

System.out.print(" 6 ascii") ;

System.out.print(" 7 binary") ;

System.out.println(" 9 quit") ;

}

// getCommand方法

// 读取用户指定的命令序号

public String getCommand()

{

String buf = "" ;

BufferedReader lineread

= new BufferedReader(new InputStreamReader(System.in)) ;

while(buf.length() != 1){// 循环接收一个字符的输入

try{

buf = lineread.readLine() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

return (buf) ;

}

// doLogin方法

// 登录到ftp服务器

public void doLogin()

{

String loginName = "" ;

String password = "" ;

BufferedReader lineread

= new BufferedReader(new InputStreamReader(System.in)) ;

try{

System.out.println("请输入用户名") ;

loginName = lineread.readLine() ;

// 利用USER命令登录

ctrlOutput.println("USER " + loginName) ;

ctrlOutput.flush() ;

// 利用PASS命令输入口令

System.out.println("请输入口令") ;

password = lineread.readLine() ;

ctrlOutput.println("PASS " + password) ;

ctrlOutput.flush() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

// doQuit方法

// 从ftp服务器注销

public void doQuit()

{

try{

ctrlOutput.println("QUIT ") ;// 发送QUIT命令

ctrlOutput.flush() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

// doCd方法

// 切换目录

public void doCd()

{

String dirName = "" ;

BufferedReader lineread

= new BufferedReader(new InputStreamReader(System.in)) ;

try{

System.out.println("请输入目录名") ;

dirName = lineread.readLine() ;

ctrlOutput.println("CWD " + dirName) ;// CWD命令

ctrlOutput.flush() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

// doLs方法

// 取得目录信息

public void doLs()

{

try{

int n ;

byte[] buff = new byte[1024] ;

// 建立数据连接

Socket dataSocket = dataConnection("LIST") ;

// 准备读取数据用的流

BufferedInputStream dataInput

= new BufferedInputStream(dataSocket.getInputStream()) ;

// 读取目录信息

while((n = dataInput.read(buff)) > 0){

System.out.write(buff,0,n) ;

}

dataSocket.close() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

// dataConnection方法

// 构造与服务器交换数据用的Socket

// 再用PORT命令将端口通知服务器

public Socket dataConnection(String ctrlcmd)

{

String cmd = "PORT " ; //PORT存放用PORT命令传递数据的变量

int i ;

Socket dataSocket = null ;// 传送数据用Socket

try{

// 得到自己的地址

byte[] address = InetAddress.getLocalHost().getAddress() ;

// 用适当的端口号构造服务器

ServerSocket serverDataSocket = new ServerSocket(0,1) ;

// 准备传送PORT命令用的数据

for(i = 0; i < 4; ++i)

cmd = cmd + (address[i] & 0xff) + "," ;

cmd = cmd + (((serverDataSocket.getLocalPort()) / 256) & 0xff)

+ ","

+ (serverDataSocket.getLocalPort() & 0xff) ;

// 利用控制用的流传送PORT命令

ctrlOutput.println(cmd) ;

ctrlOutput.flush() ;

// 向服务器发送处理对象命令(LIST,RETR,及STOR)

ctrlOutput.println(ctrlcmd) ;

ctrlOutput.flush() ;

// 接受与服务器的连接

dataSocket = serverDataSocket.accept() ;

serverDataSocket.close() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

return dataSocket ;

}

// doAscii方法

// 设置文本传输模式

public void doAscii()

{

try{

ctrlOutput.println("TYPE A") ;// A模式

ctrlOutput.flush() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

// doBinary方法

// 设置二进制传输模式

public void doBinary()

{

try{

ctrlOutput.println("TYPE I") ;// I模式

ctrlOutput.flush() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

// doGet方法

// 取得服务器上的文件

public void doGet()

{

String fileName = "" ;

BufferedReader lineread

= new BufferedReader(new InputStreamReader(System.in)) ;

try{

int n ;

byte[] buff = new byte[1024] ;

// 指定服务器上的文件名

System.out.println("??????????????") ;

fileName = lineread.readLine() ;

// 在客户端上准备接收用的文件

FileOutputStream outfile = new FileOutputStream(fileName) ;

// 构造传输文件用的数据流

Socket dataSocket = dataConnection("RETR " + fileName) ;

BufferedInputStream dataInput

= new BufferedInputStream(dataSocket.getInputStream()) ;

// 接收来自服务器的数据，写入本地文件

while((n = dataInput.read(buff)) > 0){

outfile.write(buff,0,n) ;

}

dataSocket.close() ;

outfile.close() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

// doPut方法

// 向服务器发送文件

public void doPut()

{

String fileName = "" ;

BufferedReader lineread

= new BufferedReader(new InputStreamReader(System.in)) ;

try{

int n ;

byte[] buff = new byte[1024] ;

FileInputStream sendfile = null ;

// 指定文件名

System.out.println("请输入文件名") ;

fileName = lineread.readLine() ;

// 准备读出客户端上的文件

try{

sendfile = new FileInputStream(fileName) ;

}catch(Exception e){

System.out.println("文件不存在") ;

return ;

}

// 准备发送数据的流

Socket dataSocket = dataConnection("STOR " + fileName) ;

OutputStream outstr = dataSocket.getOutputStream() ;

// 读出文件，并利用网络发送给服务器

while((n = sendfile.read(buff)) > 0){

outstr.write(buff,0,n) ;

}

dataSocket.close() ;

sendfile.close() ;

}catch(Exception e)

{

e.printStackTrace();

System.exit(1);

}

}

// execCommand方法

// 执行与各命令相应的处理

public boolean execCommand(String command)

{

boolean cont = true ;

switch(Integer.parseInt(command)){

case 2 : // 显示服务器目录信息

doLs() ;

break ;

case 3 : // 切换服务器的工作目录

doCd() ;

break ;

case 4 : // 取得服务器上的文件

doGet() ;

break ;

case 5 : // 向服务器发送文件

doPut() ;

break ;

case 6 : // 文件传输模式

doAscii() ;

break ;

case 7 : // 二进制传输模式

doBinary() ;

break ;

case 9 : // 处理结束

doQuit() ;

cont = false ;

break ;

default : //其他输入

System.out.println("请选择一个序号") ;

}

return(cont) ;

}

// main_proc方法

// 输出ftp的命令菜单，调用各种处理方法

public void main_proc()

throws IOException

{

boolean cont = true ;

try {

// 进行登录

doLogin() ;

while(cont){

// 输出菜单

showMenu() ;

// 接收并执行命令

cont = execCommand(getCommand()) ;

}

}

catch(Exception e){

System.err.print(e);

System.exit(1);

}

}

// getMsgs方法

// 启动从控制流收信的线程

public void getMsgs(){

try {

CtrlListen listener = new CtrlListen(ctrlInput) ;

Thread listenerthread = new Thread(listener) ;

listenerthread.start() ;

}catch(Exception e){

e.printStackTrace() ;

System.exit(1) ;

}

}

// main方法

// 建立TCP连接，开始处理

public static void main(String[] arg){

try {

Ftp f = null;

if(arg.length < 1){

System.out.println("usage: java Ftp ") ;

return ;

}

f = new Ftp();

f.openConnection(arg[0]); // 控制连接建立

f.getMsgs() ; // 启动接收线程

f.main_proc(); // ftp 处理

f.closeConnection() ; // 关闭连接

System.exit(0) ; // 结束程序

}catch(Exception e){

e.printStackTrace();

System.exit(1);

}

}

}

// CtrlListen 类

class CtrlListen implements Runnable{

BufferedReader ctrlInput = null ;

// 构造器 指定读取地址

public CtrlListen(BufferedReader in){

ctrlInput = in ;

}

public void run(){   while(true){    try{ // 按行读入并输出到标准输出上     System.out.println(ctrlInput.readLine()) ;    } catch (Exception e){     System.exit(1) ;    }   }  } }