serverthread.java~27~

《深入浅出设计模式》的完整源代码

package socket;
import java.util.*;
import java.io.*;
import java.net.*;

public class serverThread extends Thread {
  private SocketInterface server_socket;
  String str;
  protected void serverThread () {
    // 3. The client deals
  }

  public void run () {
    server_socket = new SocketProxy ("127.0.0.1", 8189, true);
    while (true) {
      try {
        Thread.sleep (5000);
      }
      catch (Exception e) {
        System.out.println (e);
      }

      try {
        str = server_socket.readLine ();
      }
      catch (Exception e) {
        str = "";
      }
      if (str.length () > 2) {
        System.out.println ("Receive - " + str); // java ProxyDemo first
        if (str.equals ("quit"))
          str = "";
      }
    } // Receive - 234 567
  }
}