echomultiserverthread.java

《Java TCP/IP应用开发详解》的部分源程序,开发环境为ECLIPSE3.1

package section15;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class EchoMultiServerThread extends Thread {
    private Socket incoming=null;
	public EchoMultiServerThread(Socket socket) {
		super("EchoMultiServerThread");
		this.incoming=socket;
		// TODO Auto-generated constructor stub
	}

    public void run(){
    	
    	try{
    	PrintWriter out=null;
    	BufferedReader in=null;
    	
    	out=new PrintWriter(incoming.getOutputStream(),true);
    	in=new BufferedReader(new InputStreamReader(incoming.getInputStream()));
    	out.println("Hello!...");
    	out.println("Enter BYE to exit");
    	out.flush();
    	boolean isExit=false;
    	while(!isExit)
    	{
    	  String str=in.readLine();
    	  if(str==null)isExit=true;
    	  if(str.trim().equalsIgnoreCase("BYE"))
    		  isExit=true;
    	  out.println("Echo: "+str);
    	}
    	
    out.close();
   	in.close();
	incoming.close();
    	}catch(IOException e){
    		e.printStackTrace();
    	}
    	
    	
    }
}