diff options
| author | fangshunjian <[email protected]> | 2018-11-21 13:48:39 +0800 |
|---|---|---|
| committer | fangshunjian <[email protected]> | 2018-11-21 13:48:39 +0800 |
| commit | 1a5f97d11df2afeec6daacc7d37994b21d7be724 (patch) | |
| tree | 90e399e96127bc61384b8f1bf74886f46153356b | |
| parent | be4890a1085e7eb3d56d17171250f5c8be0bb16a (diff) | |
1、nc启动时根据配置文件随机sleep n秒，防止批量执行nc启动导致dc无法处理
| -rw-r--r-- | src/com/nis/nmsclient/NmsClient.java | 8 | ||||
| -rw-r--r-- | src/com/nis/nmsclient/common/Contants.java | 12 |
2 files changed, 19 insertions, 1 deletions
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){ |