package train.server;

import java.net.*;
import java.sql.*;
import train.mvc.*;
/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: 沈陽化工學院計算機</p>
 *
 * @author 彭勝勇 胡林
 * @version 1.0
 */
public class Server {
    ServerSocket serverSocket;
    IoStrategy poolManager;

    public Server(IoStrategy poolManager) {
        this.poolManager = poolManager;
        try {
            serverSocket = new ServerSocket(10000);
        } catch (Exception ex) {
            ex.printStackTrace();
        }

        System.out.println("Server is ready......");
        acceptConnection();

    }

    public static void main(String[] args){
        IoStrategy poolManager=null;
        Model model = new ModelDBImpl();
        BrokerServer broker = new BrokerServer(model);
        poolManager = new ThreadPoolManager(broker);
        Server server1 = new Server(poolManager);
    }

    private void acceptConnection(){
    while(true){
      try{
        Socket socket=serverSocket.accept();
        poolManager.ioService(socket);
      }
      catch(Exception e){
        System.out.println("Excetpion in acceptConnection:"+e.getMessage() );
      }
    }
   }
}