netty ByteToMessageDecoder 分析

    ByteToMessageDecoder
        1.socket 移除時觸發,最後次讀數據處理
        
            @Override
        public final void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
            ByteBuf buf = internalBuffer();
             if (buf.isReadable()) {
                ByteBuf bytes = buf.readBytes(buf.readableBytes());
                buf.release();
                ctx.fireChannelRead(bytes);
            }
            cumulation = null;
            ctx.fireChannelReadComplete();
            handlerRemoved0(ctx);
        }
        
        2.讀取數據 ByteBuf release,discardSomeReadBytes 方法後面研究
        
         public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            RecyclableArrayList out = RecyclableArrayList.newInstance();//建立包裝過的數組
            try {
                if (msg instanceof ByteBuf) {
                    ByteBuf data = (ByteBuf) msg;
                    if (cumulation == null) { //是否繼續讀取數據
                        cumulation = data;
                        try {
                            callDecode(ctx, cumulation, out);
                        } finally {
                            if (cumulation != null && !cumulation.isReadable()) {
                                cumulation.release();
                                cumulation = null;
                            }
                        }
                    } else {//繼續讀取處理
                        try {
                            //若是剩餘空間不夠開建立新空間
                            if (cumulation.writerIndex() > cumulation.maxCapacity() - data.readableBytes()) {
                                ByteBuf oldCumulation = cumulation;
                                cumulation = ctx.alloc().buffer(oldCumulation.readableBytes() + data.readableBytes());
                                cumulation.writeBytes(oldCumulation);
                                oldCumulation.release();
                            }
                            cumulation.writeBytes(data);
                            callDecode(ctx, cumulation, out);
                        } finally {
                            if (cumulation != null) {
                                if (!cumulation.isReadable()) {
                                    cumulation.release();
                                    cumulation = null;
                                } else {
                                    cumulation.discardSomeReadBytes();
                                }
                            }
                            data.release();
                        }
                    }
                } else {
                    out.add(msg);
                }
            } catch (DecoderException e) {
                throw e;
            } catch (Throwable t) {
                throw new DecoderException(t);
            } finally {
                int size = out.size();
                if (size == 0) {
                    decodeWasNull = true;
                } else {
                    for (int i = 0; i < size; i ++) {
                        ctx.fireChannelRead(out.get(i));
                    }
                }
                out.recycle();
            }
        }
        
        //其實只要管核心代碼 decode 調用業務處理
         protected void callDecode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) {
            try {
                //循環讀取數據
                while (in.isReadable()) {
                    int outSize = out.size();
                    int oldInputLength = in.readableBytes();
                    decode(ctx, in, out);//業務擴展處理

                    // Check if this handler was removed before continuing the loop.
                    // If it was removed, it is not safe to continue to operate on the buffer.
                    //
                    // See https://github.com/netty/netty/issues/1664
                    //若是 handler 刪除以前，那麼不讀取數據了
                    if (ctx.isRemoved()) {
                        break;
                    }
                    //下面寫得很不清晰。。。。。
                    
                    if (outSize == out.size()) {
                        if (oldInputLength == in.readableBytes()) {
                            break;
                        } else {
                            continue;
                        }
                    }

                    if (oldInputLength == in.readableBytes()) {
                        throw new DecoderException(
                                StringUtil.simpleClassName(getClass()) +
                                ".decode() did not read anything but decoded a message.");
                    }

                    if (isSingleDecode()) {
                        break;
                    }
                }
            } catch (DecoderException e) {
                throw e;
            } catch (Throwable cause) {
                throw new DecoderException(cause);
            }
        }