serverthread.java~36~

来自「《深入浅出设计模式》的完整源代码」· JAVA~36~ 代码 · 共 35 行

package socket;
//定义服务器的线程
import java.util.*;
import java.io.*;
import java.net.*;

public class serverThread extends Thread {
  private SocketInterface server_socket;
  String str;

  public void run () {
    server_socket = new SocketProxy ("127.0.0.1", 8189, true);
    System.out.println("thread begin");
    while (true) {
      try {
        Thread.sleep (3000);
      }
      catch (Exception e) {
        System.out.println (e);
      }
      str = server_socket.readLine ();
      if (str.length () > 0) {
       if (str.equals ("quit"))//收到quit就结束循环
        break;
        str="(server echo)"+str;
        server_socket.writeLine(str);
        if (str.equals ("quit"))
          str = "";
      }
    }
    server_socket.dispose();
    System.out.println("thread end");
  }
}