Netty功能怎么实现

 private static ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock(true); private static ConcurrentMap userInfos = new ConcurrentHashMap<>(); private static AtomicInteger userCount = new AtomicInteger(0);

 private static AtomicInteger uidGener = new AtomicInteger(1000);
    private boolean isAuth = false; // 是否认证    private long time = 0;  // 登录时间    private int userId;     // UID    private String nick;    // 昵称    private String addr;    // 地址    private Channel channel;// 通道

 if (msg instanceof FullHttpRequest) {            handleHttpRequest(ctx, (FullHttpRequest) msg);        } else if (msg instanceof WebSocketFrame) {            handleWebSocket(ctx, (WebSocketFrame) msg);        }

.childHandler(new ChannelInitializer() {
                    @Override                    protected void initChannel(SocketChannel ch) throws Exception {                       将group放入消息管道                        ch.pipeline().addLast(defLoopGroup,                                //请求解码器                                new HttpServerCodec(),                                //将多个消息转换成单一的消息对象                                new HttpObjectAggregator(65536),                                //支持异步发送大的码流，一般用于发送文件流                                new ChunkedWriteHandler(),                                //检测链路是否读空闲                                new IdleStateHandler(60, 0, 0),                                //处理握手和认证                                new UserAuthHandler(),                                //处理消息的发送                                new MessageHandler()                        );                    }                });

 // 定时扫描所有的Channel，关闭失效的Channel            executorService.scheduleAtFixedRate(new Runnable() {                @Override                public void run() {                    logger.info("scanNotActiveChannel --------");                    UserInfoManager.scanNotActiveChannel();                }            }, 3, 60, TimeUnit.SECONDS);
            // 定时向所有客户端发送Ping消息            executorService.scheduleAtFixedRate(new Runnable() {                @Override                public void run() {                    UserInfoManager.broadCastPing();                }            }, 3, 50, TimeUnit.SECONDS);

window.socket = new WebSocket("ws://localhost:9688/websocket")