multiserverthread.java

来自「JAVA 2应用开发指南源码」· Java 代码 · 共 47 行

//MultiServerThread.java
import java.net.*;
import java.io.*;

class MultiServerThread extends Thread 
{
    private Socket socket = null;

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

    public void run() 
	{

        try 
		{
            DataInputStream in = new DataInputStream(
                   new BufferedInputStream(socket.getInputStream()));
            PrintStream out = new PrintStream(
                   new BufferedOutputStream(socket.getOutputStream(), 1024), false);
            String inputLine, outputLine;
	        GreetingsProtocol greetings = new GreetingsProtocol();
            outputLine = greetings.processInput(null);
            out.println(outputLine);
            out.flush();
            while ((inputLine = in.readLine()) != null) 
			{
                outputLine = greetings.processInput(inputLine);
                out.println(outputLine);
                out.flush();
                if (outputLine.equals("Bye"))
                    break;
            }
            out.close();
            in.close();
            socket.close();
        } 
catch (IOException e) 
{
            e.printStackTrace();
        }
    }
}