Commit 12df3585 authored by 赵啸非's avatar 赵啸非

调整pom文件

parent 275e2f9c
...@@ -66,11 +66,12 @@ public class DeviceComsumersRegisterService implements IApplicationStartedServic ...@@ -66,11 +66,12 @@ public class DeviceComsumersRegisterService implements IApplicationStartedServic
if (!ObjectUtils.isEmpty(deviceUpdateComsumerIp)) { if (!ObjectUtils.isEmpty(deviceUpdateComsumerIp)) {
//判断指定了ip是否与启动节点的ip一致,如果一致则启动当前节点 //判断指定了ip是否与启动节点的ip一致,如果一致则启动当前节点
// final String localIp = NetUtil.getLocalhostStr(); // final String localIp = NetUtil.getLocalhostStr();
log.info("deviceUpdateComsumerIp :{}",deviceUpdateComsumerIp);
LinkedHashSet<String> ipSet = NetUtil.localIpv4s(); LinkedHashSet<String> ipSet = NetUtil.localIpv4s();
if(!ObjectUtils.isEmpty(ipSet)){ if(!ObjectUtils.isEmpty(ipSet)){
for (String localIp : ipSet) { for (String localIp : ipSet) {
log.info("get Ip...-->" + localIp); log.info("get Ip...-->" + localIp);
if (deviceUpdateComsumerIp.equals(localIp)) { if (deviceUpdateComsumerIp.trim().equalsIgnoreCase(localIp)) {
log.info("设备更新消费线程启动"); log.info("设备更新消费线程启动");
deviceUpdateComsumerThread.start(); deviceUpdateComsumerThread.start();
break; break;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment