import java.net.*;
import java.io.*;
import java.util.*;
public class Server4{
  private ServerSocket server;
  Vector sManager=new Vector();
  Random rnd=new Random();
  public Server4(){}
  void startServer(){
    try{
      server=new ServerSocket(7777);
      System.out.println("輯滾家南撈 積己登菌嚼聰促.");
      while(true){
        Socket socket=server.accept();
        System.out.println("努扼撈攫飄客 楷搬登菌嚼聰促.");
        new KBBCom_Thread(socket).start();
        sManager.add(socket);
        System.out.println("泅犁 努扼撈攫飄 薦: "+sManager.size());
      }
    }catch(Exception e){
      System.out.println(e); 
    }
  }
  public static void main(String[] args){
    Server4 server=new Server4();
    server.startServer();
  }
  class KBBCom_Thread extends Thread{
    Socket socket;
    private DataInputStream reader;
    private DataOutputStream writer;
    KBBCom_Thread(Socket socket){
      this.socket=socket;
    }
    public void run(){
      try{
        reader=new DataInputStream(socket.getInputStream());
        writer=new DataOutputStream(socket.getOutputStream());
        String msg;
        while((msg=reader.readUTF())!=null){
          if(msg.equals("OK")){
            writer.writeInt(rnd.nextInt(3));
            writer.flush();
          }
        }
      }catch(Exception se){
      }finally{  
        try{
          sManager.remove(socket);
          if(reader!=null) reader.close();
          if(writer!=null) writer.close();
          if(socket!=null) socket.close();
          reader=null; writer=null; socket=null;

          System.out.println("努扼撈攫飄啊 唱艾嚼聰促.");
          System.out.println("泅犁 努扼撈攫飄 薦: "+sManager.size());
        }catch(Exception e){}
      }
    }
  }
}