package com.dev.btse.data;
|
|
import java.io.IOException;
|
import java.net.ServerSocket;
|
import java.net.Socket;
|
import java.net.SocketTimeoutException;
|
import java.util.Date;
|
|
import com.battmonitor.base.Com;
|
import com.battmonitor.sql.MysqlConnPool;
|
|
|
public class TmpSensor_ServerSocketThread extends Thread{
|
private ServerSocket m_ServerSocket;
|
private MysqlConnPool pool;
|
|
|
public TmpSensor_ServerSocketThread(MysqlConnPool pool) {
|
this.pool = pool;
|
}
|
|
@Override
|
public void run() {
|
System.out.println("TmpSensor_ServerSocketThread start at "+Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
|
TmpSensor_SQL.createRealDataBase(pool);
|
TmpSensor_SQL.createSensor_infTable(pool);
|
TmpSensor_SQL.createSensor_mapinfoTable(pool);
|
TmpSensor_SQL.createSensor_StateTable(pool);
|
|
while(true) {
|
try {
|
this.m_ServerSocket = new ServerSocket(9010);
|
while(true) {
|
this.m_ServerSocket.setSoTimeout(600000); //600seconds
|
|
Socket tmp_socket = this.m_ServerSocket.accept();
|
TmpSensor_SocketThread thread = new TmpSensor_SocketThread(tmp_socket,pool);
|
thread.start();
|
}
|
} catch (SocketTimeoutException e1) {
|
//System.err.println(e1.getMessage());
|
} catch (IOException e) {
|
System.err.println(e.getMessage());
|
} finally {
|
try {
|
Thread.sleep(1000);
|
if(null != this.m_ServerSocket) {
|
this.m_ServerSocket.close();
|
}
|
} catch (IOException | InterruptedException e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
}
|
}
|
