modify

Helius

2021-03-05 9e6054ca0612a05ec2b698b8a63db7605c600725

 src/main/java/com/xcong/excoin/netty/handler/WebSocketServerHandler.java

@@ -1,7 +1,7 @@
package com.xcong.excoin.netty.handler;


import com.xcong.excoin.netty.common.ChannelManager;
import com.xcong.excoin.netty.common.ServerChannelManager;
import com.xcong.excoin.netty.common.Contans;
import com.xcong.excoin.netty.common.NettyTools;
import com.xcong.excoin.netty.dispatch.MsgDispatch;
@@ -50,13 +50,13 @@
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        log.info("[websocket客户端连入服务器]-->{}", ctx.channel().id());
        ChannelManager.addWebSocketChannel(ctx.channel());
        ServerChannelManager.addWebSocketChannel(ctx.channel());
    }

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        log.info("[离开websocket服务器]-->{}", ctx.channel().id());
        ChannelManager.removeWebSocketChannel(ctx.channel());
        ServerChannelManager.removeWebSocketChannel(ctx.channel());
    }

    @Override