package com.dev.lock.comm;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import com.config.AppConfig;
import com.dev.lock.data.ElectLock_Array;
import com.sql.MysqlConnPool;

public class Lock_ServerSocket_Thread extends Thread{
	private MysqlConnPool pool;
	private AppConfig config;
	private Logger logger;
	private ElectLock_Array GB_Lock_Array;
	
	public Lock_ServerSocket_Thread(MysqlConnPool pool,ElectLock_Array GB_Lock_Array,AppConfig config){
		this.pool = pool;
		this.config = config;
		this.GB_Lock_Array = GB_Lock_Array;
		this.logger = LogManager.getLogger(this);
	}
	
	@Override
	public void run() {
		logger.info(this.getName() + " - Lock_ServerSocket_Thread Started On Port " + config.getLockAcceptPort() );
		ServerSocket server = null;
		while(true) {
			try {
				logger.info(" Power_ServerSocket_Thread 开始监听" + config.getLockAcceptPort() + "端口");
				//监听9611端口
				server = new ServerSocket(config.getLockAcceptPort());
				server.setSoTimeout(600000);
				while(true) {
					Socket tmp_socket = server.accept();
					Lock_SocketClient_Thread client_Thread = new Lock_SocketClient_Thread(pool,GB_Lock_Array, config, tmp_socket);
					client_Thread.start();
				}
			} catch (Exception e) {
				logger.error(e.toString(),e);
				try {
					Thread.sleep(5000);
				} catch (InterruptedException e1) {
					logger.error(e1.toString(),e1);
				}
			} finally {
				if(null != server) {
					try {
						server.close();
					} catch (IOException e1) {
						logger.error(e1.toString(),e1);
					}
				}
			}
		}		
	}
}