From 1a5f97d11df2afeec6daacc7d37994b21d7be724 Mon Sep 17 00:00:00 2001 From: fangshunjian Date: Wed, 21 Nov 2018 13:48:39 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81nc=E5=90=AF=E5=8A=A8=E6=97=B6?= =?UTF-8?q?=E6=A0=B9=E6=8D=AE=E9=85=8D=E7=BD=AE=E6=96=87=E4=BB=B6=E9=9A=8F?= =?UTF-8?q?=E6=9C=BAsleep=20n=E7=A7=92=EF=BC=8C=E9=98=B2=E6=AD=A2=E6=89=B9?= =?UTF-8?q?=E9=87=8F=E6=89=A7=E8=A1=8Cnc=E5=90=AF=E5=8A=A8=E5=AF=BC?= =?UTF-8?q?=E8=87=B4dc=E6=97=A0=E6=B3=95=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/com/nis/nmsclient/NmsClient.java | 8 ++++++++ src/com/nis/nmsclient/common/Contants.java | 12 +++++++++++- 2 files changed, 19 insertions(+), 1 deletion(-) diff --git a/src/com/nis/nmsclient/NmsClient.java b/src/com/nis/nmsclient/NmsClient.java index 101a4c6..c153bf7 100644 --- a/src/com/nis/nmsclient/NmsClient.java +++ b/src/com/nis/nmsclient/NmsClient.java @@ -112,6 +112,14 @@ public class NmsClient{ AlarmUtil.sendNMSErrorMsg(ErrorCode.DeamonNotExist, Utils.getLocalIp(), "i18n_client.NmsClient.ncDeamonStartException_n81i," + e.getMessage()); } + try { + int sleep = (int)(1+Math.random()*Contants.STARTUP_SLEEP_SECOND); + logger.debug(String.format("startup sleep %ss", sleep)); + Thread.sleep(sleep*1000); + } catch (Exception e) { + logger.error("",e); + } + /** * 相关业务操作入口 */ diff --git a/src/com/nis/nmsclient/common/Contants.java b/src/com/nis/nmsclient/common/Contants.java index 3f43a06..a62eb2d 100644 --- a/src/com/nis/nmsclient/common/Contants.java +++ b/src/com/nis/nmsclient/common/Contants.java @@ -135,6 +135,11 @@ public class Contants { public static final int DATA_SEND_THREAD_PORT; //主动数据上报间隔 INTERVAL,单位 10 S public static final int DATA_SEND_THREAD_INTERVAL; + /** + * 启动时最大 暂停时间,为了缓解一次启动多个nc ,dc无法处理的情况 + * 默认:10s + */ + public static final int STARTUP_SLEEP_SECOND; static{ SYSTEM_PATH = SysConfig.getSystemDir(); @@ -244,7 +249,11 @@ public class Contants { DATA_SEND_THREAD_PORT = SysConfig.getIntegerVal("data.send.thread.port", "9527"); //主动数据上报间隔 INTERVAL,单位 10 S DATA_SEND_THREAD_INTERVAL = SysConfig.getIntegerVal("data.send.thread.interval", "10"); - + /* + * 启动时最大 暂停时间,为了缓解一次启动多个nc ,dc无法处理的情况 + * 单位:s + */ + STARTUP_SLEEP_SECOND = SysConfig.getIntegerVal("startup.sleep.second", "10"); // 初始化创建文件夹 if(!new File(localDetecConfPath).exists()){ @@ -271,6 +280,7 @@ public class Contants { if(!new File(localTempDataIncomingPath).exists()){ new File(localTempDataIncomingPath).mkdirs(); } + } private static String formatPath(String path){