From 8c6175beddad08cbfad866a0d136d459cd1b1920 Mon Sep 17 00:00:00 2001 From: "autumn.g@foxmail.com" Date: Mon, 18 Sep 2023 16:28:24 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=89=93=E5=8D=B0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/jsowell/common/enums/ykc/PileChannelEntity.java | 5 +++++ 1 file changed, 5 insertions(+) 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); }