diff --git a/jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java b/jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java index a75353ba5..bcff07c22 100644 --- a/jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java +++ b/jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java @@ -1,6 +1,7 @@ package com.jsowell.common.enums.ykc; import io.netty.channel.Channel; +import lombok.extern.slf4j.Slf4j; import java.util.HashMap; import java.util.concurrent.ConcurrentHashMap; @@ -8,6 +9,7 @@ import java.util.concurrent.ConcurrentHashMap; /** * 桩编号和channel的关联关系处理 entity */ +@Slf4j public class PileChannelEntity { /** @@ -16,6 +18,9 @@ public class PileChannelEntity { private static final ConcurrentHashMap manager = new ConcurrentHashMap<>(); public static void put(String pileSn, Channel channel) { + if (manager.containsKey(pileSn)) { + log.error("桩编号:【{}】已经是连接状态", pileSn); + } manager.put(pileSn, channel); }