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 755f70cac..a75353ba5 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 @@ -3,13 +3,17 @@ package com.jsowell.common.enums.ykc; import io.netty.channel.Channel; import java.util.HashMap; +import java.util.concurrent.ConcurrentHashMap; /** * 桩编号和channel的关联关系处理 entity */ public class PileChannelEntity { - private static HashMap manager = new HashMap<>(); + /** + * 管理一个全局map,保存连接进服务端的通道数量 + */ + private static final ConcurrentHashMap manager = new ConcurrentHashMap<>(); public static void put(String pileSn, Channel channel) { manager.put(pileSn, channel);