package com.briup.impl.net;

import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Collection;
import java.util.Properties;

import com.briup.Config;
import com.briup.Log;
import com.briup.NetServer;
import com.briup.exception.NetServerException;
import com.jk.test.NetTread_yingjj;

public class NetServerImpl implements NetServer {
	private int port;
	private int backlog;
	private Config config;
	private int count;
	public NetServerImpl(Properties pro){
		port =Integer.parseInt(pro.getProperty("port"));
		backlog = Integer.parseInt(pro.getProperty("backlog"));
	}

	public void setConfig(Config config) throws NetServerException {
	//當傳進一個cofig對象是將其作為一個實例變量保存下來
		this.config = config;
	}

	public void start() throws NetServerException {
		ServerSocket ss =null;
		Socket s =null;
		Log log = null;
		ObjectInputStream ois = null;
		try {
				log = config.getLog();
				ss = new ServerSocket(port,backlog);
			 log.writeInfo("Gather server is listening on port: " + port); //日志監聽已起動
			 while(true){
				 
				 s=ss.accept();
				 ois=new ObjectInputStream(s.getInputStream());
				 new NetServerThread(s,config);
				 ois.close();
				 s.close();
				 log.writeInfo("Gather server is listening on thread");
			 }
			/*
			while(true){
				 s=ss.accept();
				 
				 NetServerThread2 thread1 = new  NetServerThread2(s,config);
				 Thread thread = new Thread(thread1);
			 } */
				
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			throw new NetServerException(e);
		}
	}
}