From 48d187962e65e48ab99d3484cd385c10deed1641 Mon Sep 17 00:00:00 2001 From: chenjinsong Date: Thu, 1 Nov 2018 16:20:23 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E5=A4=8D=E4=B8=8A=E6=8A=A5=E7=9A=84?= =?UTF-8?q?=E9=97=AE=E9=A2=98=202.=E4=BF=AE=E5=A4=8Dchrome=E4=B8=8B?= =?UTF-8?q?=E8=8A=82=E7=82=B9=E9=85=8D=E7=BD=AE=E9=A1=B5=E9=9D=A2=E7=9A=84?= =?UTF-8?q?=E6=98=BE=E7=A4=BA=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../nodeGroupManage/nodegroupInfoList.jsp | 4 ++-- .../run/AutoRunForSocketServerServlet.java | 18 +++++++++++------- src/com/nms/thread/NmsPortThread.java | 4 +++- src/com/nms/thread/NmsRuleThread.java | 5 +++-- src/com/nms/thread/NmsStatusThread.java | 3 +++ src/conf/myconfig.properties | 6 ++++-- 6 files changed, 26 insertions(+), 14 deletions(-) diff --git a/WebRoot/page/systemManage/nodeGroupManage/nodegroupInfoList.jsp b/WebRoot/page/systemManage/nodeGroupManage/nodegroupInfoList.jsp index 8739a7c..51c381e 100644 --- a/WebRoot/page/systemManage/nodeGroupManage/nodegroupInfoList.jsp +++ b/WebRoot/page/systemManage/nodeGroupManage/nodegroupInfoList.jsp @@ -989,8 +989,8 @@ - diff --git a/src/com/nms/servlet/auto/run/AutoRunForSocketServerServlet.java b/src/com/nms/servlet/auto/run/AutoRunForSocketServerServlet.java index b728267..9fbc999 100644 --- a/src/com/nms/servlet/auto/run/AutoRunForSocketServerServlet.java +++ b/src/com/nms/servlet/auto/run/AutoRunForSocketServerServlet.java @@ -114,19 +114,23 @@ public class AutoRunForSocketServerServlet extends HttpServlet implements Servle boolean open = StringUtil.isBlank(openStr) ? false : ("1".equals(openStr) ? true : false); if (open) { //nms上报 - String intervalStr = BaseAction.rb.getString("nms.report.interval"); + String sintervalStr = BaseAction.rb.getString("nms.report.status.interval"); + String rintervalStr = BaseAction.rb.getString("nms.report.rule.interval"); + String pintervalStr = BaseAction.rb.getString("nms.report.port.interval"); //nms上报间隔 - long interval = StringUtil.isBlank(intervalStr) ? 300000 : Long.parseLong(intervalStr)*1000; + long statusInterval = StringUtil.isBlank(sintervalStr) ? 300000 : Long.parseLong(sintervalStr)*1000; + long ruleInterval = StringUtil.isBlank(rintervalStr) ? 900000 : Long.parseLong(rintervalStr)*1000; + long portInterval = StringUtil.isBlank(pintervalStr) ? 300000 : Long.parseLong(pintervalStr)*1000; //nms初次上报延时 long now = new Date().getTime(); long initInterval = 0l; - if(now%interval > 0) { - initInterval = interval-(now%interval); + if(now%statusInterval > 0) { + initInterval = statusInterval-(now%statusInterval); } - ThreadPoolCommon.scheduled.scheduleAtFixedRate(new NmsStatusThread(), initInterval, interval, TimeUnit.MILLISECONDS); - ThreadPoolCommon.scheduled.scheduleAtFixedRate(new NmsRuleThread(), initInterval, interval, TimeUnit.MILLISECONDS); - ThreadPoolCommon.scheduled.scheduleAtFixedRate(new NmsPortThread(), initInterval, interval, TimeUnit.MILLISECONDS); + ThreadPoolCommon.scheduled.scheduleAtFixedRate(new NmsStatusThread(), initInterval, statusInterval, TimeUnit.MILLISECONDS); + ThreadPoolCommon.scheduled.scheduleAtFixedRate(new NmsRuleThread(), initInterval, ruleInterval, TimeUnit.MILLISECONDS); + ThreadPoolCommon.scheduled.scheduleAtFixedRate(new NmsPortThread(), initInterval, portInterval, TimeUnit.MILLISECONDS); } } diff --git a/src/com/nms/thread/NmsPortThread.java b/src/com/nms/thread/NmsPortThread.java index 0379df3..6c6c041 100644 --- a/src/com/nms/thread/NmsPortThread.java +++ b/src/com/nms/thread/NmsPortThread.java @@ -21,11 +21,13 @@ public class NmsPortThread implements Runnable { @Override public void run() { + Thread currentThread = Thread.currentThread(); + currentThread.setName("Port Report Thread"); Date now = new Date(); Long nowLong = now.getTime(); Integer interval = null; try { - interval = Integer.parseInt(BaseAction.rb.getString("nms.report.interval")); + interval = Integer.parseInt(BaseAction.rb.getString("nms.report.port.interval")); } catch (Exception e) { interval = 300; } diff --git a/src/com/nms/thread/NmsRuleThread.java b/src/com/nms/thread/NmsRuleThread.java index 5dd505a..9158a25 100644 --- a/src/com/nms/thread/NmsRuleThread.java +++ b/src/com/nms/thread/NmsRuleThread.java @@ -22,11 +22,13 @@ public class NmsRuleThread implements Runnable { @Override public void run() { + Thread currentThread = Thread.currentThread(); + currentThread.setName("Rule Report Thread"); Date now = new Date(); Long nowLong = now.getTime(); Integer interval = null; try { - interval = Integer.parseInt(BaseAction.rb.getString("nms.report.interval")); + interval = Integer.parseInt(BaseAction.rb.getString("nms.report.rule.interval")); } catch (Exception e) { interval = 300; } @@ -67,7 +69,6 @@ public class NmsRuleThread implements Runnable { HttpClientUtil httpUtil = new HttpClientUtil(); JSONObject fromObject = JSONObject.fromObject(data); - logger.info(BaseAction.rb.getString("nms.rule.url")); httpUtil.post(BaseAction.rb.getString("nms.rule.url"), fromObject.toString()); logger.info("rule上报完毕"); } else { diff --git a/src/com/nms/thread/NmsStatusThread.java b/src/com/nms/thread/NmsStatusThread.java index 89e7e53..6450b73 100644 --- a/src/com/nms/thread/NmsStatusThread.java +++ b/src/com/nms/thread/NmsStatusThread.java @@ -23,6 +23,9 @@ public class NmsStatusThread implements Runnable { @Override public void run() { + Thread currentThread = Thread.currentThread(); + currentThread.setName("Status Report Thread"); + String now = DateUtil.format.format(new Date()); List results = new ArrayList(); String setId = null; diff --git a/src/conf/myconfig.properties b/src/conf/myconfig.properties index e960f0f..a0d1eb9 100644 --- a/src/conf/myconfig.properties +++ b/src/conf/myconfig.properties @@ -94,10 +94,12 @@ dept.mk.id=280 #1:open 0:close nms.report.open=0 #unit:s -nms.report.interval=20 +nms.report.status.interval=300 +nms.report.port.interval=300 +nms.report.rule.interval=900 nms.status.setId=7 nms.status.url=http\://192.168.11.64\:8080/galaxy-service/service/nms/v1/saveServerStatus -nms.port.url=http\://192.168.11.64\:8080/galaxy-service/service/nms/v1/rafficNetflowPortInfo +nms.port.url=http\://192.168.11.64\:8080/galaxy-service/service/nms/v1/trafficNetflowPortInfo nms.rule.url=http\://192.168.11.64\:8080/galaxy-service/service/nms/v1/saveNmsDiRule default.nodeGroupId=100000