kkmultiserverthread.java

java实现的遗传算法

package org.jgap.distr.sockets;

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