Administrator
2021-05-13 80ef12799a70a916846aa9cf50562c919e6e9357
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
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();
                }
            }
        }        
    }    
}