From 7df8ed14d605bcc731341ff12349bc117714b69e Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期四, 17 四月 2025 16:18:24 +0800
Subject: [PATCH] 优化代码
---
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/Server.java | 443 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 443 insertions(+), 0 deletions(-)
diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/Server.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/Server.java
new file mode 100644
index 0000000..2a405c4
--- /dev/null
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/Server.java
@@ -0,0 +1,443 @@
+package com.dy.rtuMw;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import com.dy.common.util.ConfigProperties;
+import com.dy.rtuMw.server.*;
+import com.dy.rtuMw.server.msCenter.MsCenterConfigVo;
+import com.dy.rtuMw.server.msCenter.MsCenterUnit;
+import com.dy.rtuMw.server.rtuData.RtuDataUnit;
+import com.dy.rtuMw.server.rtuData.RtuDataUnitConfigVo;
+import com.dy.rtuMw.server.tasks.FromRtuComResultConstantTask;
+import com.dy.rtuMw.server.tasks.FromRtuDataConstantTask;
+import com.dy.common.mw.UnitInterface;
+import com.dy.common.mw.channel.tcp.TcpConfigVo;
+import com.dy.common.mw.channel.tcp.TcpUnit;
+import com.dy.common.mw.core.CoreUnit;
+import com.dy.common.mw.core.CoreUnitConfigVo;
+import com.dy.common.mw.protocol.ProtocolConfigVo;
+import com.dy.common.mw.protocol.ProtocolUnit;
+import com.dy.common.mw.support.SupportUnit;
+import com.dy.common.mw.support.SupportUnitConfigVo;
+import com.dy.rtuMw.server.tasks.SendMsConstantTask;
+import com.dy.rtuMw.server.tasks.RtuDownConstantTask;
+import com.dy.rtuMw.resource.ResourceUnit;
+import com.dy.rtuMw.resource.ResourceUnitConfigVo;
+import com.dy.common.springUtil.SpringContextUtil;
+import com.dy.common.util.ConfigXml4Springboot;
+import com.dy.common.util.IDLongGenerator;
+
+import com.dy.rtuMw.server.upgrade.UpgradeUnit;
+import com.dy.rtuMw.server.upgrade.UpgradeUnitConfigVo;
+import org.jdom2.Document;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.ResourceLoader;
+import org.springframework.stereotype.Component;
+
+@Component
+public class Server {
+
+ private ConfigXml4Springboot conf = null ;
+ private Document doc = null ;
+ private boolean showStartInfo = false ;
+
+ private String orgTag ;
+ private String RmiSvUrl ;
+ private String TcpSvUrl ;
+ @Value("${server.port}")
+ private String HttpSvPort ;
+ @Value("${server.servlet.context-path}")
+ private String HttpSvPath ;
+
+ @Autowired
+ protected ResourceLoader resourceLoader ;
+
+ private List<UnitInterface> units = new ArrayList<UnitInterface>() ;
+
+ /*
+ * @param args 鍙傛暟
+ public static void main(String[] args) {
+ new Server().startServer();
+ }
+ */
+
+ public void startServer(){
+ /**
+ try {
+ URL url = Server.class.getResource("/config/this.licence");
+ if(!new Lnp(null).parese(url.getPath())){
+ System.out.println("licence error!") ;
+ return ;
+ }
+ } catch (Exception e) {
+ System.out.println("licence error!") ;
+ return ;
+ }
+ */
+ if(this.doStartServer()){
+ ServerShutDownHook.OnShutDown();
+ }
+ }
+ /**
+ * 鍚姩鏈嶅姟
+ */
+ private boolean doStartServer(){
+ boolean running = false ;
+ long start = System.currentTimeMillis() ;
+ try {
+ ConfigProperties.init(this.getClass().getResourceAsStream("/config.properties"), false);
+
+ this.conf = new ConfigXml4Springboot() ;
+ this.doc = this.conf.createDom(this.resourceLoader, "config.xml") ;
+ ////////////////
+ //鏈嶅姟 閰嶇疆
+ this.showStartInfo = this.conf.getSetAttrBoolean(this.doc, "config.server", "showStartInfo", null, null) ;
+
+ this.startUnits() ;
+
+ String svName ;
+ try{
+ svName = this.conf.getSetAttrTxt(this.doc, "config.server", "name", null, false, null) ;
+ }catch(Exception e){
+ svName = "" ;
+ }
+ svName += (ServerProperties.isLowPower?"锛堜綆鍔熻�楋級": "") + "-" ;
+
+ String company ;
+ try{
+ company = this.conf.getSetAttrTxt(this.doc, "config.server", "company", null, true, null) ;
+ }catch(Exception e){
+ company = "" ;
+ }
+ System.out.println("OOOOOOOOOO OOOOOOOO OOOOOOOO") ;
+ System.out.println("@@@@@@@@@@@@@@@@#O $@@@@@@@@& @@@@@@@@#") ;
+ System.out.println("@@@@@@@@@@@@@@@@@@@# @@@@@@@@# $@@@@@@@@&") ;
+ System.out.println("@@@@@@@@@@@@@@@@@@@@@# #@@@@@@@@@@@@@@@@O") ;
+ System.out.println("@@@@@@@@@@@@@@@@@@@@@@@ &@@@@@@@@@@@@@@") ;
+ System.out.println("@@@@@@$ $@@@@@@@@@& O@@@@@@@@@@@#") ;
+ System.out.println("@@@@@@$ @@@@@@@@@ @@@@@@@@@& " + this.orgTag + svName + "RtuMw 1.0.00" ) ;
+ if(this.HttpSvPath != null && this.HttpSvPort != null){
+ System.out.println("@@@@@@$ O@@@@@@@@@ &@@@@@@@@ HttpSv [ip]:" + this.HttpSvPort + this.HttpSvPath) ;
+ }else{
+ System.out.println("@@@@@@$ O@@@@@@@@@ &@@@@@@@@") ;
+ }
+
+ if(this.TcpSvUrl != null){
+ System.out.println("@@@@@@$ O@@@@@@@@@ &@@@@@@@@ TcpSv " + this.TcpSvUrl ) ;
+ }else{
+ System.out.println("@@@@@@$ O@@@@@@@@@ &@@@@@@@@") ;
+ }
+ if(this.RmiSvUrl != null){
+ System.out.println("@@@@@@$ #@@@@@@@@@$ &@@@@@@@@ RmiSv " + this.RmiSvUrl ) ;
+ }else{
+ System.out.println("@@@@@@$ #@@@@@@@@@$ &@@@@@@@@" ) ;
+ }
+ System.out.println("@@@@@@@@@@@@@@@@@@@@@@# &@@@@@@@@ Running in standalone mode" ) ;
+ System.out.println("@@@@@@@@@@@@@@@@@@@@@& &@@@@@@@@ Startup in " + (System.currentTimeMillis() - start) + " MS" ) ;
+ System.out.println("@@@@@@@@@@@@@@@@@@@# &@@@@@@@@ " + company) ;
+ System.out.println("@@@@@@@@@@@@@@@@#O &@@@@@@@@") ;
+ running = true ;
+ }catch(Exception e){
+ e.printStackTrace();
+ running = false ;
+ }
+ return running ;
+ }
+
+ private void startUnits(){
+ try {
+ ///////////////
+ //鍩烘湰閰嶇疆
+ ServerProperties.orgTag = this.conf.getSetAttrTxt(this.doc, "config.base", "orgTag", null, false, null) ;
+ if(ServerProperties.orgTag == null || ServerProperties.orgTag.trim().equals("")){
+ throw new Exception("鏈烘瀯tag涓嶈兘涓虹┖") ;
+ }
+ this.orgTag = ServerProperties.orgTag ;
+ ServerProperties.isLowPower = conf.getSetAttrBoolean(doc, "config.base", "isLowPower", null, null) ;
+ if(ServerProperties.isLowPower == null){
+ ServerProperties.isLowPower = false ;
+ }
+
+ String onlyDealRtus = conf.getSetAttrTxt(doc, "config.base", "onlyDealRtus", null, true, null) ;
+ if(onlyDealRtus == null || onlyDealRtus.trim().equals("")){
+ ServerProperties.onlyDealRtusTest = false ;
+ }else{
+ onlyDealRtus = onlyDealRtus.replaceAll("锛�", ",") ;
+ onlyDealRtus = onlyDealRtus.replaceAll(" ", "") ;
+ ServerProperties.onlyDealRtus = onlyDealRtus.split(",") ;
+ if(ServerProperties.onlyDealRtus != null && ServerProperties.onlyDealRtus.length > 0){
+ ServerProperties.onlyDealRtusTest = true ;
+ }else{
+ ServerProperties.onlyDealRtusTest = false ;
+ }
+ }
+
+ //鍦ㄦ敮鎸佸閫氫俊鍗忚鏃讹紝鍙湁RTU涓婄嚎浜嗭紝鎵嶈兘璇嗗埆鍑鸿RTU瀹為檯鐢ㄧ殑閫氫俊鍗忚锛岃繘鑰岀敤姝ゅ崗璁В鏋愪笂琛屾暟鎹強鏋勯�犱笅琛屽懡浠ゃ��
+ //濡傛灉RTU鏈浘涓婄嚎锛堥�氫俊涓棿浠跺惎鍔ㄥ悗璇TU鏈浘涓婄嚎锛夛紝閭ｄ箞鍦ㄥ悜瀹冨彂閫佷笅琛屽懡浠ゆ椂锛屼笉鑳藉垽鏂嚭鍏堕噰鐢ㄧ殑鍗忚锛屼篃涓嶈兘鏋勯�犲懡浠わ紝灏ゅ叾鏄綆鍔熻�楁儏鍐典笅锛屼笉涓婄嚎鏄甯哥幇璞°��
+ // 褰撳彧鏈変竴涓崗璁儏鍐典笅锛屽湪RTU鏈浘涓婄嚎鏃讹紝涔熻兘鐢ㄦ鍗忚鏋勯�犲懡浠ゅ苟缂撳瓨涓嬫潵锛屽挨鍏堕�傚悎浣庡姛鑰楁儏鍐点��
+ //onlyOne=true: 閫氫俊涓棿浠跺綋鍓嶅彧鏈変竴涓崗璁�
+ ServerProperties.onlyOneProtocol = conf.getSetAttrBoolean(doc, "config.base", "onlyOneProtocol", null, null) ;
+ if(ServerProperties.onlyOneProtocol == null){
+ ServerProperties.onlyOneProtocol = false ;
+ }
+ //涓嬭鍛戒护鍏佽鍙戦�佺殑鏈�澶ф鏁癤锛屽嵆鍏佽閲嶅彂X-1
+ ServerProperties.downComandMaxResendTimes = conf.getSetAttrPlusInt(doc, "config.base", "downComandMaxResendTimes", null, 1, 5, null).byteValue() ;
+ //閽堝涓�涓猂TU锛屼笅鍙戝懡浠ょ殑鏃堕棿闂撮殧
+ ServerProperties.commandSendInterval = conf.getSetAttrPlusInt(doc, "config.base", "commandSendInterval", null, 1, 40, null) * 1000L ;
+ //閽堝涓�涓猂TU锛屼笅鍙戝揩閫熷懡浠ょ殑鏃堕棿闂撮殧
+ ServerProperties.fastCommandSendInterval = conf.getSetAttrPlusInt(doc, "config.base", "fastCommandSendInterval", null, 1, 40000, null) * 1L ;
+ //鍛戒护宸茬粡鍙戦�佽揪鏈�澶ф鏁帮紝浠嶆湭鏀跺埌鍛戒护缁撴灉锛岄渶瑕佸湪缂撳瓨缁х画绛夊緟锛屽叾绛夊緟鏈�澶ф椂闀�
+ ServerProperties.cacheWaitResultTimeout = conf.getSetAttrPlusInt(doc, "config.base", "cacheWaitResultTimeout", null, 10, 360, null) * 1000L ;
+ //涓嶅湪绾跨紦瀛樼殑鍛戒护鏈�澶х紦瀛樻椂闀�
+ ServerProperties.offLineCacheTimeout = conf.getSetAttrPlusInt(doc, "config.base", "offLineCacheTimeout", null, 15, 172800, null) * 1000L ;
+ //TCP涓婅鏁版嵁鏃跺埢缂撳瓨鏃堕暱锛屽綋杈惧埌鏃堕暱鏃讹紝TCP涓婅鏁版嵁鏃跺埢琚竻绌猴紝閲囩敤TCP涓婅鏁版嵁鏃跺埢鐩殑鏄紝闃绘涓婃暟鎹悓鏃朵笅鍙戞暟鎹紝鍥犱负RTU澶勭悊涓嶈繃鏉�
+ ServerProperties.lastUpDataTimeLive = conf.getSetAttrPlusInt(doc, "config.base", "lastUpDataTimeLive", null, 0, 5000, null) * 1L ;
+ //鏁版嵁搴撴暟鎹甶d鐢熸垚鍣ㄧ殑id鍚庣紑锛�0鏄粯璁ょ殑鍚庣紑锛屼竴鑸瑆eb绯荤粺搴旂敤锛屾暟鎹腑闂翠欢id鍚庣紑澶т簬绛変簬1
+ ServerProperties.dbDataIdSuffix = conf.getSetAttrInt(doc, "config.base", "dbDataIdSuffix", null, 0, 99, null);
+ //涓婁笅琛屾暟鎹紦瀛橀槦鍒椾腑缂撳瓨鏁版嵁涓暟鐨勬姤璀﹂噺锛岃繖涓笌鐜板疄椤圭洰鎵�鎺ユ按琛ㄦ暟鐩稿叧
+ ServerProperties.cacheUpDownDataWarnCount = conf.getSetAttrPlusInt(doc, "config.base", "cacheUpDownDataWarnCount", null, 1, null, null) ;
+ //涓婁笅琛屾暟鎹紦瀛橀槦鍒椾腑缂撳瓨鏁版嵁涓暟鐨勬渶澶у�硷紝杩欎釜涓庣幇瀹為」鐩墍鎺ユ按琛ㄦ暟鐩稿叧
+ ServerProperties.cacheUpDownDataMaxCount = conf.getSetAttrPlusInt(doc, "config.base", "cacheUpDownDataMaxCount", null, 1, null, null) ;
+ if(ServerProperties.cacheUpDownDataMaxCount <= ServerProperties.cacheUpDownDataWarnCount){
+ throw new Exception("cacheUpDownDataMaxCount蹇呴』澶т簬cacheUpDownDataWarnCount") ;
+ }
+ //娌℃湁涓婅鏁版嵁鐨勫垎閽熸暟锛岃揪鍒拌繖涓垎閽熸暟锛岃涓篟TU鏂綉浜嗭紝鍙栧�艰寖鍥存槸2-100
+ ServerProperties.disconnectedByNoUpDataMinutes = 0L + conf.getSetAttrPlusInt(doc, "config.base", "disconnectedByNoUpDataMinutes", null, 1, 100, null) ;
+ if(ServerProperties.disconnectedByNoUpDataMinutes < 1 || ServerProperties.disconnectedByNoUpDataMinutes > 100){
+ throw new Exception("disconnectedByNoUpDataMinutes鍙栧�煎繀椤绘槸1~100") ;
+ }
+ ServerProperties.disconnectedByNoUpDataMinutes = ServerProperties.disconnectedByNoUpDataMinutes * 60 * 1000 ;
+
+ //宸ヤ綔鎶ュお棰戠箒锛孨娆′笂鎶ュ鐞�1娆★紝鍙栧�艰寖鍥存槸1-100
+ ServerProperties.workReportDealOneByTimes = conf.getSetAttrPlusInt(doc, "config.base", "workReportDealOneByTimes", null, 1, 100, null) ;
+
+ //瑙﹀彂鍙戦�侀拤閽夋姤璀︽秷鎭殑鍙栨按鍙ｆ棩婕忔崯閲忕殑鏈�灏忓�硷紙鍖呮嫭浣嗛櫎0.0澶栵級
+ ServerProperties.intakeAlarmLossMinValue = conf.getSetAttrPlusDouble(doc, "config.base", "intakeAlarmLossMinValue", null, 0.0, 1000000.0, null) ;
+
+ //鏈夋姤璀﹀彂鐢熸椂锛屽悜閽夐拤鍙戦�佹秷鎭殑闂撮殧鏃堕暱锛堝垎閽燂級
+ ServerProperties.sendDingDingAlarmMsInterval = conf.getSetAttrPlusInt(doc, "config.base", "sendDingDingAlarmMsInterval", null, 1, 600, null) ;
+
+ //璁剧疆ID鐢熸垚鍣ㄧ殑鍚庣紑
+ IDLongGenerator.setSuffix(ServerProperties.dbDataIdSuffix.intValue());
+
+
+ ////////////////
+ //鍗忚妯″潡
+ ProtocolConfigVo protoVo = new ProtocolConfigVo();
+ protoVo.centerAddr = conf.getSetAttrPlusInt(doc, "config.protocol", "centerAddr", null, 1, 4, null) ;
+ protoVo.synchroRtuClock = conf.getSetAttrBoolean(doc, "config.protocol", "synchroRtuClock", null, null) ;
+ //褰揜TU涓庢湇鍔″櫒鏃堕挓鐩稿樊涓�瀹氱閽熷悗锛岃繘琛屾牎鏃�
+ protoVo.synchroRtuClockTimepieces = 1000 * conf.getSetAttrPlusInt(doc, "config.protocol", "synchroRtuClockTimepieces", null, null, null, null) ;
+ protoVo.showStartInfo = showStartInfo ;
+ AdapterImp_ProtocolUnit protoAdap = new AdapterImp_ProtocolUnit();
+ protoAdap.setConfig(protoVo);
+ ProtocolUnit protoUnit = ProtocolUnit.getInstance();
+ protoUnit.setAdapter(protoAdap);
+ protoUnit.start(obj -> {
+ });
+ units.add(protoUnit) ;
+
+ ////////////////////////////////////////////////////////
+ //鏀寔妯″潡锛� springHibernate鍜� 绾跨▼姹�
+ SupportUnitConfigVo supVo = new SupportUnitConfigVo() ;
+ //鐭伐浣滄椂闀跨嚎绋嬫睜锛岀嚎绋嬭礋璐ｇ敤鏃惰緝鐭殑宸ヤ綔浠诲姟
+ supVo.short_maxThread = conf.getSetAttrPlusInt(doc, "config.support", "short_maxThread", null, -1, 1000, null) ;//姹犱腑鏈�澶х嚎绋嬫暟涓烘墍鏈塁PU鏍告暟+1
+ if(supVo.short_maxThread < 0){
+ supVo.short_maxThread = -1 ;
+ }
+ supVo.short_minThread = conf.getSetAttrPlusInt(doc, "config.support", "short_minThread", null, -1, 100, null) ;//姹犱腑鏈�灏忕嚎绋嬫暟
+ if(supVo.short_minThread < 0){
+ supVo.short_minThread = -1 ;
+ }
+ supVo.short_freeTimeout = conf.getSetAttrPlusInt(doc, "config.support", "short_freeTimeout", null, 1, 90, null) * 1000 ;//绾跨▼鏁扮┖闂叉椂闀匡紝鑻ユ睜涓嚎绋嬫暟閲忓ぇ浜巑inThread锛屼笖鏈夌殑绾跨▼绌洪棽鏃堕暱瓒呰繃freeTimeout锛屽垯娓呴櫎璇ョ嚎绋嬶紝涓轰簡涓嶆竻闄わ紝鎶妋inThread涓巑axThread璁剧疆鐩哥瓑
+ supVo.short_busyTimeout = conf.getSetAttrPlusInt(doc, "config.support", "short_busyTimeout", null, 1, 10, null) * 1000 ;//绾跨▼涓嶉棿鏂伐浣滄椂闀匡紙鍗曚綅涓虹)瓒呮椂闄愶紝璁や负绾跨▼宸茬粡浜嗗穿婧冿紝灏嗗己鍒舵竻闄わ紝鐭伐浣滄椂闀胯缃负5绉�
+ if(supVo.short_maxThread == 0 || supVo.short_minThread == 0){
+ supVo.enableShortThreadPool = false ;
+ }else{
+ supVo.enableShortThreadPool = true ;
+ }
+
+ //闀垮伐浣滄椂闀跨嚎绋嬫睜锛岀嚎绋嬭礋璐ｇ敤鏃惰緝闀跨殑宸ヤ綔浠诲姟
+ supVo.long_maxThread = conf.getSetAttrInt(doc, "config.support", "long_maxThread", null, -1, 1000, null) ;//姹犱腑鏈�澶х嚎绋嬫暟,鑻ヤ负-1锛屼笉鍙楅檺鍒�
+ if(supVo.long_maxThread < 0){
+ supVo.long_maxThread = -1 ;
+ }
+ supVo.long_minThread = conf.getSetAttrPlusInt(doc, "config.support", "long_minThread", null, -1, 100, null) ;//姹犱腑鏈�灏忕嚎绋嬫暟
+ if(supVo.long_minThread < 0){
+ supVo.long_minThread = -1 ;
+ }
+ supVo.long_freeTimeout = conf.getSetAttrPlusInt(doc, "config.support", "long_freeTimeout", null, 1, 90, null) * 1000 ;//绾跨▼鏁扮┖闂叉椂闀匡紝鑻ユ睜涓嚎绋嬫暟閲忓ぇ浜巑inThread锛屼笖鏈夌殑绾跨▼绌洪棽鏃堕暱瓒呰繃freeTimeout锛屽垯娓呴櫎璇ョ嚎绋�
+ supVo.long_busyTimeout = conf.getSetAttrInt(doc, "config.support", "long_busyTimeout", null, -1, 10, null) ;//绾跨▼涓嶉棿鏂伐浣滄椂闀匡紙鍗曚綅涓虹)瓒呮椂闄愶紝鑻ヤ负-1锛屼笉鍙楅檺鍒�
+ if(supVo.long_busyTimeout < 0){
+ supVo.long_busyTimeout = -1 ;
+ }
+ if(supVo.long_maxThread == 0 || supVo.long_minThread == 0){
+ supVo.enableLongThreadPool = false ;
+ }else{
+ supVo.enableLongThreadPool = true ;
+ }
+
+ supVo.showStartInfo = showStartInfo ;
+
+ AdapterImp_SupportUnit supAdap = new AdapterImp_SupportUnit() ;
+ supAdap.setConfig(supVo);
+ SupportUnit supUnit = SupportUnit.getInstance() ;
+ supUnit.setAdapter(supAdap);
+ supUnit.start(obj -> {
+ });
+ units.add(supUnit) ;
+
+
+ /////////////////////////
+ //璧勬簮妯″潡
+ ResourceUnitConfigVo resVo = new ResourceUnitConfigVo() ;
+ //RTU鏃ュ織鏂囦欢瀛樺偍鐩綍(鐩稿鐩綍)
+ resVo.rtuLogDir = conf.getSetAttrTxt(doc, "config.resource", "rtuLogDir", null, false, null) ;
+ //RTU鏃ュ織鏂囦欢鏈�澶у瓧鑺傛暟(KB)
+ resVo.rtuLogFileMaxSize = conf.getSetAttrPlusInt(doc, "config.resource", "rtuLogFileMaxSize", null, 10, 2000000, null) ;
+ //RTU鏃ュ織鏂囦欢鏈�澶ф枃浠舵暟
+ resVo.rtuLogFileMaxCount = conf.getSetAttrPlusInt(doc, "config.resource", "rtuLogFileMaxCount", null, 1, 10, null) ;
+
+ //Rtu鐘舵�佺洃瑙嗛棿闅�(鍒嗛挓)
+ resVo.monitorInterval = conf.getSetAttrPlusInt(doc, "config.resource", "monitorInterval", null, 1, 5, null) ;
+ //Rtu鐘舵�佸瓨鏁版嵁搴撻棿闅�(鍒嗛挓)
+ resVo.saveDbInterval = conf.getSetAttrPlusInt(doc, "config.resource", "saveDbInterval", null, 5, 20, null) ;
+ //Rtu鏃犳暟鎹笂浼犺揪鍒版鍊硷紝鍒欒涓轰笉鍦ㄧ嚎浜�(鍒嗛挓)
+ //娉ㄦ剰锛歯oUpDataLimitTime鍦ㄥ厓绱燾onfig.protocol涓�
+ //resVo.noUpDataLimitTime = conf.getSetAttrPlusInt(doc, "config.protocol", "noUpDataLimitTime", null, 30, 60, null) ;
+ AdapterImp_ResourceUnit resAdap = new AdapterImp_ResourceUnit() ;
+ resAdap.setConfig(resVo);
+ ResourceUnit resUnit = ResourceUnit.getInstance() ;
+ resUnit.setAdapter(resAdap);
+ //褰撳墠鏀寔spring + hibernate
+ resUnit.setSpringContext(SpringContextUtil.getApplicationContext());
+
+ resUnit.start(obj -> {
+ });
+ units.add(resUnit) ;
+
+
+ /////////////////
+ //RMI妯″潡 鏆傛椂涓嶅簲鐢�
+ /*
+ RmiConfigVo rmiVo = new RmiConfigVo();
+ rmiVo.enable = conf.getSetAttrBoolean(doc, "config.rmi", "enable", null, null) ;
+ if(rmiVo.enable){
+ rmiVo.port = conf.getSetAttrPlusInt(doc, "config.rmi", "port", null, 100, 65535, null);
+ rmiVo.context = conf.getSetAttrTxt(doc, "config.rmi", "context", null, false, null);
+ rmiVo.showStartInfo = showStartInfo ;
+ AdapterImp_RmiUnit rmiAdap = new AdapterImp_RmiUnit();
+ rmiAdap.setConfig(rmiVo);
+ RmiUnit rmiUnit = RmiUnit.getInstance();
+ rmiUnit.setAdapter(rmiAdap);
+ rmiUnit.start(obj -> {
+ });
+ RmiSvUrl = "[ip]:" + rmiVo.port + "/" + rmiVo.context ;
+ units.add(rmiUnit) ;
+ }
+ */
+
+
+ /////////////////
+ //娑堟伅涓績妯″潡
+ MsCenterConfigVo mscVo = new MsCenterConfigVo();
+ mscVo.enable = conf.getSetAttrBoolean(doc, "config.msCenter", "enable", null, null) ;
+ mscVo.notifyMsInterval = conf.getSetAttrPlusInt(doc, "config.msCenter", "notifyInterval", null, 1, 600, null) * 1000L ;
+ mscVo.showStartInfo = showStartInfo ;
+ AdapterImp_MsCenterUnit mscAdapt = new AdapterImp_MsCenterUnit();
+ mscAdapt.setConfig(mscVo);
+ MsCenterUnit mscUnit = MsCenterUnit.getInstance();
+ mscUnit.setAdapter(mscAdapt);
+ mscUnit.start(obj -> {
+ });
+ units.add(mscUnit) ;
+
+
+ /////////////////
+ //RTU杩滅▼鍗囩骇妯″潡
+ UpgradeUnitConfigVo ugVo = new UpgradeUnitConfigVo();
+ ugVo.enable = conf.getSetAttrBoolean(doc, "config.upgrade", "enable", null, null) ;
+ ugVo.openNoUpgrade = conf.getSetAttrBoolean(doc, "config.upgrade", "openNoUpgrade", null, null) ;
+ ugVo.lastOpenMaxGoOn = conf.getSetAttrPlusInt(doc, "config.upgrade", "lastOpenMaxGoOn", null, 5, 360000, null);
+ ugVo.lastOpenMaxGoOn = ugVo.lastOpenMaxGoOn * 1000 ;//鍙樻垚姣
+ ugVo.noOneRtuUpgradeMaxDuration = conf.getSetAttrPlusInt(doc, "config.upgrade", "noOneRtuUpgradeMaxDuration", null, 5, 360000, null);
+ ugVo.noOneRtuUpgradeMaxDuration = ugVo.noOneRtuUpgradeMaxDuration * 1000 ;//鍙樻垚姣
+ ugVo.runningAndIdleDuration = conf.getSetAttrPlusInt(doc, "config.upgrade", "runningAndIdleDuration", null, 5, 360000, null);
+ ugVo.runningAndIdleDuration = ugVo.runningAndIdleDuration * 1000 ;//鍙樻垚姣
+ ugVo.failTryTimes = conf.getSetAttrPlusInt(doc, "config.upgrade", "failTryTimes", null, 0, 100, null);
+ ugVo.ugMaxRtuAtOnce = conf.getSetAttrPlusInt(doc, "config.upgrade", "ugMaxRtuAtOnce", null, 0, 1000000, null);
+ ugVo.rtuOffLineWaitDuration = conf.getSetAttrPlusInt(doc, "config.upgrade", "rtuOffLineWaitDuration", null, 1, 3600000, null);
+ ugVo.rtuOffLineWaitDuration = ugVo.rtuOffLineWaitDuration * 1000;//鍙樻垚姣
+ ugVo.notifyStateInterval = conf.getSetAttrPlusInt(doc, "config.upgrade", "notifyStateInterval", null, 1, 300, null);
+ ugVo.notifyStateInterval = ugVo.notifyStateInterval * 1000;//鍙樻垚姣
+ ugVo.notifyTimesAfterOver = conf.getSetAttrPlusInt(doc, "config.upgrade", "notifyTimesAfterOver", null, 0, null, null);
+ ugVo.showStartInfo = showStartInfo ;
+ AdapterImp_UpgradeUnit ugAdap = new AdapterImp_UpgradeUnit();
+ ugAdap.setConfig(ugVo);
+ UpgradeUnit ugUnit = UpgradeUnit.getInstance();
+ ugUnit.setAdapter(ugAdap);
+ ugUnit.start(obj -> {
+ });
+ units.add(ugUnit) ;
+
+ /////////////////
+ //RTU涓婅鏁版嵁澶勭悊妯″潡锛堜换鍔℃爲锛�
+ RtuDataUnitConfigVo rducVo = new RtuDataUnitConfigVo();
+ rducVo.resourceLoader = this.resourceLoader ;
+ AdapterImp_RtuDataUnit rducAdap = new AdapterImp_RtuDataUnit();
+ rducAdap.setConfig(rducVo);
+ RtuDataUnit rducUnit = RtuDataUnit.getInstance();
+ rducUnit.setAdapter(rducAdap);
+ rducUnit.start(obj -> {
+ });
+ units.add(rducUnit) ;
+
+
+
+ // ///////////////
+ // 鏍稿績
+ CoreUnitConfigVo coreConfVo = new CoreUnitConfigVo();
+ coreConfVo.coreInterval = conf.getSetAttrPlusInt(doc, "config.core", "coreInterval", null, 1, 200, null).longValue() ;
+ coreConfVo.queueWarnSize = ServerProperties.cacheUpDownDataWarnCount ;
+ coreConfVo.queueMaxSize = ServerProperties.cacheUpDownDataMaxCount ;
+ coreConfVo.showStartInfo = showStartInfo ;
+ AdapterImp_CoreUnit coreAdap = new AdapterImp_CoreUnit();
+ coreAdap.setConfig(coreConfVo);
+ CoreUnit coreUnit = CoreUnit.getInstance();
+ coreUnit.setAdapter(coreAdap);
+ CoreUnit.addConstantTask(new RtuDownConstantTask());
+ CoreUnit.addConstantTask(new FromRtuDataConstantTask());
+ CoreUnit.addConstantTask(new FromRtuComResultConstantTask());
+ CoreUnit.addConstantTask(new SendMsConstantTask());
+ coreUnit.start(obj -> {
+ });
+ units.add(coreUnit) ;
+
+
+ // ///////////////
+ // TCP 妯″潡
+ TcpConfigVo tcpVo = new TcpConfigVo();
+ tcpVo.enable = conf.getSetAttrBoolean(doc, "config.tcp", "enable", null, null) ;
+ if(tcpVo.enable){
+ tcpVo.port = conf.getSetAttrPlusInt(doc, "config.tcp", "port", null, 100, 65535, null);
+ tcpVo.processors = conf.getSetAttrPlusInt(doc, "config.tcp", "processors", null, 1, 100, null);
+ tcpVo.idle = conf.getSetAttrPlusInt(doc, "config.tcp", "idle", null, 1, 20, null);// 10鍒嗛挓
+ tcpVo.showStartInfo = showStartInfo ;
+ AdapterImp_TcpUnit tcpAdap = new AdapterImp_TcpUnit();
+ tcpAdap.setConfig(tcpVo);
+ TcpUnit tcpUnit = TcpUnit.getInstance();
+ tcpUnit.setAdapter(tcpAdap);
+ tcpUnit.start(obj -> {
+ });
+ TcpSvUrl = "[ip]:" + tcpVo.port ;
+ units.add(tcpUnit) ;
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+
+}
--
Gitblit v1.8.0