kkmultiserverthread.java

精通Java核心技术的随书源代码

// ==================== Program Discription =====================
// 程序名称：示例12-5: KKMultiServerThread.java
// 程序目的：创建server端线程类。
//=============================================================
import java.net.*;
import java.io.*;

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

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

    public void run() 
    {
       try {
	       	PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
	       	BufferedReader in = new BufferedReader( new InputStreamReader(
				            socket.getInputStream()));
       	String inputLine, outputLine;
	       	KnockKnockProtocol kkp = new KnockKnockProtocol();
	       	outputLine = kkp.processInput(null);
	       	out.println(outputLine);

	       	while ((inputLine = in.readLine()) != null)  
       	{
		     	outputLine = kkp.processInput(inputLine);
		     	out.println(outputLine);
         		if (outputLine.equals("Bye"))
		        		break;
	       	}
	    		out.close();
	    		in.close();
	    		socket.close();
       } catch (IOException e) {
	    		 e.printStackTrace();
       }
    }
}