package com.dev.fbs9600;
|
|
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.battdata_rt.BattData_RT_Array;
|
import com.sql.MysqlConnPool;
|
|
public class FBS9600_ServerSocket_Thread extends Thread{
|
private MysqlConnPool pool;
|
private BattData_RT_Array m_Data;
|
private Logger logger;
|
|
public FBS9600_ServerSocket_Thread(MysqlConnPool pool,BattData_RT_Array m_Data){
|
this.pool = pool;
|
this.m_Data = m_Data;
|
logger = LogManager.getLogger(this);
|
}
|
|
@Override
|
public void run() {
|
logger.info(this.getName() + " - FBS9600_ServerSocket_Thread Started On Port 9611");
|
ServerSocket server = null;
|
while(true) {
|
try {
|
logger.info(" FBS9600_ServerSocket_Thread 开始监听9611端口");
|
//监听9611端口
|
server = new ServerSocket(9611);
|
while(true) {
|
Socket tmp_socket = server.accept();
|
FBS9600_SocketClient2 client = new FBS9600_SocketClient2(tmp_socket,m_Data, pool);
|
client.start();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
try {
|
server.close();
|
} catch (IOException e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
}
|
}
|