From 85ca7d73f45872d708c25b33eb44ded56f9922bd Mon Sep 17 00:00:00 2001
From: whyclj <1525436766@qq.com>
Date: 星期一, 07 十二月 2020 15:02:26 +0800
Subject: [PATCH] 增加控制以及实时记录
---
Central_Monitor/src/main/main_Central_Monitor.java | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 deletions(-)
diff --git a/Central_Monitor/src/main/main_Central_Monitor.java b/Central_Monitor/src/main/main_Central_Monitor.java
index 53d43d2..140bddc 100644
--- a/Central_Monitor/src/main/main_Central_Monitor.java
+++ b/Central_Monitor/src/main/main_Central_Monitor.java
@@ -11,7 +11,9 @@
import com.config.AppConfig;
import com.data.Motor_inf;
import com.data.Comm.Central_DataParsing_Thread_SQL;
+import com.data.Comm.Central_Data_SocketServer_Thread;
import com.data.Comm.Central_Data_Task_SQL;
+import com.data.history.Central_Data_RealRecord_Thread;
import com.sql.MysqlConnPool;
public class main_Central_Monitor {
@@ -50,7 +52,7 @@
//创建config.xml文件
m_AppConfig = new AppConfig();
- logger.info("SQLserver IP：" + m_AppConfig.getMysqlServerIp() + ", port: "+MysqlServer_Port);
+ logger.info("SQLserver IP: " + m_AppConfig.getMysqlServerIp() + ", port: "+MysqlServer_Port);
checkingMySQLServerStart(); //检测数据库服务是否启动
@@ -62,6 +64,17 @@
Central_DataParsing_Thread_SQL.loadDeviceData(GB_MysqlConnPool, motors); //加载集中监控系统设备信息
+ /********************* 实时数据读取线程 ************************************************************/
+ {
+ Central_Data_SocketServer_Thread server = new Central_Data_SocketServer_Thread(GB_MysqlConnPool, motors);
+ server.start();
+ }
+
+ /********************* 历史实时数据记录线程 ************************************************************/
+ {
+ Central_Data_RealRecord_Thread record_thread = new Central_Data_RealRecord_Thread(GB_MysqlConnPool, motors);
+ record_thread.start();
+ }
while(true) {
try {
--
Gitblit v1.9.1