multiserverthreadtest.java

JAVA编程百例书中各章节的所有例子的源代码,包括套接字编程

package ch07.section07;

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

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

  public MultiServerThreadTest(Socket socket) {
    super("MultiServerThreadTest");
    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;
      ServerProtocolTest kkp = new ServerProtocolTest();
      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();
    }
  }
}