add netty

Helius

2021-02-28 d8d653b40cc6565c72cccd28de831474e5d5c512

 src/main/java/com/xcong/excoin/netty/common/ChannelManager.java

@@ -22,6 +22,8 @@

    private static final ChannelGroup WEBSOCKET_GROUP = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    private static final ChannelGroup TCP_GROUP = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    private static final ConcurrentMap<String, ChannelGroup> DEPTH_MAP = new ConcurrentHashMap<>();

    private static final ConcurrentMap<String, ChannelGroup> TRADE_MAP = new ConcurrentHashMap<>();
@@ -31,11 +33,24 @@
    // 当前连接到服务器的通道(tcp和websocket)
    private static final ConcurrentMap<String, ChannelId> CHANNEL_MAP = new ConcurrentHashMap<>();


    public static void addTcpChannel(Channel channel) {
        TCP_GROUP.add(channel);
    }

    public static void removeTcpChannel(Channel channel) {
        TCP_GROUP.remove(channel);
    }

    public static void addWebSocketChannel(Channel channel) {
        WEBSOCKET_GROUP.add(channel);
        CHANNEL_MAP.put(channel.id().asShortText(), channel.id());
    }

    public static ChannelGroup getTcpGroup() {
        return TCP_GROUP;
    }

    public static void removeWebSocketChannel(Channel channel) {
        WEBSOCKET_GROUP.remove(channel);
        CHANNEL_MAP.remove(channel.id().asShortText());