edit.txt

TCP/IP用java语言实现

// 椺java Wrnet kiku.fuis.fukui-u.ac.jp 80

//儔僀僽儔儕偺棙梡
import java.io.*;
import java.net.* ;

// Wrnet僋儔僗
public class Wrnet {
	// 僾儘僌儔儉偺杮懱main
	public static void main(String[] args){
		byte[] buff = new byte[1024];//攝楍偺掕媊
		Socket wrsocket = null ;// 僒乕僶愙懕梡僜働僢僩
		InputStream instr = null;// 僨乕僞撉傒庢傝梡僆僽僕僃僋僩
		OutputStream outstr = null;// 僨乕僞弌椡梡僆僽僕僃僋僩
		boolean cont = true ;
		// 巜掕偺億乕僩偵懳偟偰,僜働僢僩傪嶌惉偟傑偡
		// 擖弌椡偺僗僩儕乕儉傪嶌傝,僨乕僞撉傒弌偟傪弨旛偟傑偡
		try{
			wrsocket
				= new Socket(args[0],Integer.parseInt(args[1])) ;
			instr = wrsocket.getInputStream() ;
			outstr = wrsocket.getOutputStream() ;
		}
		catch(Exception e){
			System.err.println("僱僢僩儚乕僋僄儔乕偱偡") ;
			System.exit(1) ;
		}
		//
		while (cont) {
			try {
				// System.in偐傜偺撉傒崬傒
				int n = System.in.read(buff);
				// System.out傊偺彂偒弌偟
				// System.out.write(buff, 0, n) ;
				// 峴摢僺儕僆僪偺専弌
				if(buff[0] == '.') cont = false ;
				else outstr.write(buff,0,n) ;
			}
			// 埲壓偼椺奜張棟偱偡
			catch(Exception e){
				// 椺奜帪偼僾儘僌儔儉傪廔椆偟傑偡
				System.exit(1);
			}
		}
		// 僨乕僞偺廔椆傑偱,埲壓偺儖乕僾傪孞傝曉偟傑偡
		cont = true ;
		while (cont) {
			try {
				// 撉傒崬傒
				int n = instr.read(buff);
				// System.out傊偺彂偒弌偟
				System.out.write(buff, 0, n) ;
			}
			// 埲壓偼椺奜張棟偱偡
			catch(Exception e){
				// 撉傒弌偟廔椆帪偵儖乕僾傕廔椆偟傑偡
				cont = false ;
			}
		}
		// 僐僱僋僔儑儞傪暵偠傑偡
		try{
			instr.close() ;
		}
		catch(Exception e){
			// 僱僢僩儚乕僋僋儘乕僘幐攕偱偡
			System.err.println("僱僢僩儚乕僋偺僄儔乕偱偡") ;
			System.exit(1) ;
		}
	}
}
 Volume in drive F has no label.
 Volume Serial Number is 60C5-9AEA

 Directory of F:\TCP_IP~1\ch3

2007-04-08  12:57    <DIR>          .
2007-04-08  12:57    <DIR>          ..
2006-05-21  12:58             1,301 0.gif
2006-05-22  16:50               591 1.gif
2006-05-22  18:21               666 CtrlListen.class
2006-05-22  16:49                 0 dd
2006-05-22  18:21             6,819 Ftp.class
2006-05-22  18:21            10,837 Ftp.java
2002-08-07  07:56             4,699 Ftp1.java
2002-08-07  08:04             7,219 Ftp2.java
2006-05-19  22:13             5,393 Ftp3.class
2002-08-07  08:16             9,244 Ftp3.java
2002-08-07  07:44             1,506 Getdatad.java
2002-08-07  07:26             2,745 T1.java
2002-08-07  07:32             3,828 T2.java
2002-08-07  07:41             4,723 Telnet.java
2002-08-07  07:19             1,133 Threadtest.java
              15 File(s)         60,704 bytes
               2 Dir(s)  25,302,482,944 bytes free

import java.net.*;
import java.io.*;

public class Ftp {
	//准备socket
	Socket ctrlSocket;				//控制用socket
	public PrintWriter ctrlOutput;	//控制输出的流
	public BufferedReader ctrlInput;//控制输入的流

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

	//openConnection方法
	//由地址和端口 构造Socket 形成控制用的流
	public void openConnection(String host)throws IOException,UnknownHostException
	{
		ctrlSocket = new Socket(host, CTRLPORT);//21
		ctrlOutput = new PrintWriter(ctrlSocket.getOutputStream());
		ctrlInput  = new BufferedReader(new InputStreamReader
							(ctrlSocket.getInputStream()));
	}

	public void closeConnection()
		throws IOException
	{
		ctrlSocket.close() ;
	}
	
	//showMenu 立法
	//输出 FTP 的命令菜单
	public void showMenu()
	{
		System.out.println("~~~~~~~~~~~~~~>  命令格式  <~~~~~~~~~~~~~~~") ;
		System.out.print("1 dir ;") ;
		System.out.print(" 2 cd ;") ;
		System.out.print(" 3 pwd ;") ;
		System.out.print(" 4 cdup ;") ;
		System.out.print(" 5 mkd ;") ;
		System.out.print(" 6 get ;") ;
		System.out.println(" 7 put .") ;
		System.out.println(" 8 asc .") ;
		System.out.println(" 9 bin .") ;
		System.out.println(" 10 abor .") ;
		System.out.println(" 11 dele .") ;
		System.out.println(" 12 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() ;
			ctrlOutput.println("USER " + loginName) ;
			ctrlOutput.flush() ;			//刷新流
			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);
		}
	}
	
	//doCdup
	//上一层目录
	public void doCdup()
	{
		try{
			ctrlOutput.println("CDUP ") ;// CDUP命令
			ctrlOutput.flush() ;
		}catch(Exception e)
		{
			e.printStackTrace();
			System.exit(1);
		}
	}

	//显示当前目录
	public void doPwd()
	{
		try{
			ctrlOutput.println("PWD ") ;// PWD命令
			ctrlOutput.flush() ;
		}catch(Exception e)
		{
			e.printStackTrace();
			System.exit(1);
		}
	}
	
	//强行关闭当前的传送数据的Socket
	public void doAbor()
	{
		try{
			ctrlOutput.println("ABOR ") ;// ABOR命令
			ctrlOutput.flush() ;
		}catch(Exception e)
		{
			e.printStackTrace();
			System.exit(1);
		}
	}
	
	//删除服务器上的指定文件
	public void doDele()
	{
		String dirName = "" ;
		BufferedReader lineread	= new BufferedReader(new InputStreamReader(System.in)) ;

		try{
			System.out.println("请输入要删的文件名或目录名：") ;
			dirName = lineread.readLine() ;
			ctrlOutput.println("DELE " + dirName) ;// CWD命令
			ctrlOutput.flush() ;
		}catch(Exception e)
		{
			e.printStackTrace();
			System.exit(1);
		}
	}
	
	////建立目录
	public void doMkd()
	{
		String dirName = "" ;
		BufferedReader lineread	= new BufferedReader(new InputStreamReader(System.in)) ;

		try{
			System.out.println("请起个目录名：") ;
			dirName = lineread.readLine() ;
			ctrlOutput.println("MKD " + 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命令的数据 所用的变量
		int i ;
		Socket dataSocket = null ;
		try{
			// 取得自己用的地址
			byte[] address = InetAddress.getLocalHost().getAddress() ;
			// 用适当的端口号构造服务器 Socket
			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);
		}
	}