multiserverthreadtest.java

来自「Java 2实用编程百例,一些比较实用的J2SE小程序,可以通过这些程序熟悉JA」· Java 代码 · 共 41 行

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();
    }
  }
}