update 打印日志

This commit is contained in:
2023-09-18 16:28:24 +08:00
parent 0372b9a6bf
commit 8c6175bedd

View File

@@ -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<String, Channel> manager = new ConcurrentHashMap<>();
public static void put(String pileSn, Channel channel) {
if (manager.containsKey(pileSn)) {
log.error("桩编号:【{}】已经是连接状态", pileSn);
}
manager.put(pileSn, channel);
}