echomultiserverthread.java

java应用开发详解

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

public class EchoMultiServerThread extends Thread {
    private Socket socket = null;
    

    public EchoMultiServerThread(Socket socket) {
	super("EchoMultiServerThread");
	this.socket = socket;
    }

    public void run() {

	try {
	    PrintWriter out = null;
	    BufferedReader in = null;


            out = new PrintWriter(socket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out.println("Hello! . . . ");
            out.println("Enter BYE to exit");
            out.flush();
            while(true)
            {
            	String str = in.readLine();
            	if(str == null)
            	{
            		break; //client closed connection
            	}
            	else
            	{
            		out.println("Echo: "+str);
            		out.flush();
            		if(str.trim().equalsIgnoreCase("BYE"))
            		  break;
            	}
            }
            
            out.close();
	    in.close();
	
	    socket.close(); 


	} catch (IOException e) {
	    e.printStackTrace();
	}
    }
}