gfwleak/nms-nmsweb
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.修复上报的问题

Browse Source 
2.修复chrome下节点配置页面的显示问题
This commit is contained in:
chenjinsong
2018-11-01 16:20:23 +08:00
parent 56b3ef4101
commit 48d187962e
6 changed files with 26 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/com/nms/servlet/auto/run/AutoRunForSocketServerServlet.java
View File

@@ -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);
}
}

4
src/com/nms/thread/NmsPortThread.java
View File

@@ -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;
}

5
src/com/nms/thread/NmsRuleThread.java
View File

@@ -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 {

3
src/com/nms/thread/NmsStatusThread.java
View File

@@ -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<Map> results = new ArrayList<Map>();
String setId = null;