|
@ -220,8 +220,8 @@ public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerC |
|
|
if (log.isWarnEnabled()) { |
|
|
if (log.isWarnEnabled()) { |
|
|
log.warn("{} 所有内容都为空, all_null:{} ,暂定{}s", tag, all_null, 5000 + random); |
|
|
log.warn("{} 所有内容都为空, all_null:{} ,暂定{}s", tag, all_null, 5000 + random); |
|
|
} |
|
|
} |
|
|
|
|
|
ThreadUtl.sleep((long) ((new Random()).nextInt(3) + 1) * 1000); |
|
|
ThreadUtl.sleep((long) (5000 + random)); |
|
|
break start; |
|
|
} else if (this.all_null < 6) { |
|
|
} else if (this.all_null < 6) { |
|
|
if (log.isWarnEnabled()) { |
|
|
if (log.isWarnEnabled()) { |
|
|
log.warn(tag + "重新创建server"); |
|
|
log.warn(tag + "重新创建server"); |
|
@ -233,15 +233,15 @@ public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerC |
|
|
if (log.isWarnEnabled()) { |
|
|
if (log.isWarnEnabled()) { |
|
|
// log.warn("{} 所有内容都为空, all_null:{} ,暂定{}ms", tag, all_null, '\uea60' + random);
|
|
|
// log.warn("{} 所有内容都为空, all_null:{} ,暂定{}ms", tag, all_null, '\uea60' + random);
|
|
|
} |
|
|
} |
|
|
|
|
|
ThreadUtl.sleep((long) ((new Random()).nextInt(3) + 1) * 1000); |
|
|
|
|
|
break start; |
|
|
|
|
|
|
|
|
ThreadUtl.sleep((long) ('\uea60' + random)); |
|
|
|
|
|
} else { |
|
|
} else { |
|
|
if (log.isWarnEnabled()) { |
|
|
if (log.isWarnEnabled()) { |
|
|
// log.warn("{} 所有内容都为空, all_null:{} ,暂定{}ms", tag, all_null, 120000 + random);
|
|
|
// log.warn("{} 所有内容都为空, all_null:{} ,暂定{}ms", tag, all_null, 120000 + random);
|
|
|
} |
|
|
} |
|
|
|
|
|
// ThreadUtl.sleep((long) ((new Random()).nextInt(3) + 1) * 1000);
|
|
|
ThreadUtl.sleep((long) (120000 + random)); |
|
|
// break start;
|
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
++this.all_null; |
|
|
++this.all_null; |
|
|
} else { |
|
|
} else { |
|
|