java类io.netty.handler.codec.http.HttpContentDecompressor的实例源码

@Override
protected void initChannel(final SocketChannel sc) throws Exception {
     ChannelPipeline p = sc.pipeline();          
     p.addLast(new HttpContentCompressor());
     p.addLast(new HttpClientCodec());
     p.addLast(new HttpContentDecompressor());      
     p.addLast(new HttpObjectAggregator(1048576));
}

/**
 * Modifies the pipeline to handle HTTP requests
 * @param ctx The calling channel handler context
 * @param maxRequestSize The maximum request size in bytes
 */
private void switchToHttp(final ChannelHandlerContext ctx, final int maxRequestSize) {
    ChannelPipeline p = ctx.pipeline();         
    p.addLast("httpHandler", new HttpServerCodec());  // TODO: config ?
    p.addLast("decompressor", new HttpContentDecompressor());
    p.addLast("aggregator", new HttpObjectAggregator(maxRequestSize)); 
    p.addLast("jsonDecoder", new JsonObjectDecoder(maxRequestSize, false));
    p.addLast("handler", jsonRpcHandler);
    p.remove(this);
}

@Override
        public void initChannel(final SocketChannel ch) throws Exception {
            final ChannelPipeline p = ch.pipeline();
            //p.addLast("timeout",    new IdleStateHandler(0, 0, 60));  // TODO: configurable

            p.addLast("httpcodec",    new HttpClientCodec());
            p.addLast("inflater",   new HttpContentDecompressor());
            //p.addLast("aggregator", new HttpObjectAggregator(1048576));
            p.addLast("qdecoder", queryResultDecoder);
//          p.addLast("logging", loggingHandler);
        }

/**
     * {@inheritDoc}
     * @see io.netty.channel.pool.ChannelPoolHandler#channelCreated(io.netty.channel.Channel)
     */
    @Override
    public void channelCreated(final Channel ch) throws Exception {
        log.debug("Channel Created: {}", ch);
        channelGroup.add(ch);
        final ChannelPipeline p = ch.pipeline();
        //p.addLast("timeout",    new IdleStateHandler(0, 0, 60));  // TODO: configurable       
        p.addLast("httpcodec",    new HttpClientCodec());
        p.addLast("inflater",   new HttpContentDecompressor());
//      p.addLast("deflater",   new HttpContentCompressor());
        p.addLast("aggregator", new HttpObjectAggregator(20485760));
//      p.addLast("logging", loggingHandler);
        p.addLast("qdecoder", queryResultDecoder);

    }

@Override
public void accept(ChannelPipeline pipeline, ContextHandler<Channel> c) {
    pipeline.addLast(NettyPipeline.HttpCodec, new HttpClientCodec());
    if (options.acceptGzip()) {
        pipeline.addAfter(NettyPipeline.HttpCodec,
                NettyPipeline.HttpDecompressor,
                new HttpContentDecompressor());
    }
}

@Override
protected void initChannel(SocketChannel ch) throws Exception {
    ChannelPipeline p = ch.pipeline();
    if (sslCtx != null) {
        p.addLast(sslCtx.newHandler(ch.alloc()));
    }
    p.addLast("log", new LoggingHandler(LogLevel.TRACE));
    p.addLast("codec", new HttpClientCodec());
    p.addLast("inflater", new HttpContentDecompressor());
    // p.addLast("aggregator", new HttpObjectAggregator(10 * 1024 * 1024));
    p.addLast("handler", handler);
}

@Override
protected JndiRegistry createRegistry() throws Exception {
    JndiRegistry registry = super.createRegistry();
    List<ChannelHandler> decoders = new ArrayList<ChannelHandler>();
    decoders.add(new HttpContentDecompressor());
    registry.bind("myDecoders", decoders);
    return registry;
}

@Override
public void initChannel(SocketChannel ch) {
    ChannelPipeline p = ch.pipeline();      
    if (sslCtx != null) {
        p.addLast(sslCtx.newHandler(ch.alloc()));
    }
    p.addLast(new HttpClientCodec());
    p.addLast(new HttpContentDecompressor());       
    p.addLast(handler);
}

@Override
public void initChannel(SocketChannel ch) {
    ChannelPipeline p = ch.pipeline();      
    if (sslCtx != null) {
        p.addLast(sslCtx.newHandler(ch.alloc()));
    }
    p.addLast(new HttpClientCodec());
    p.addLast(new HttpContentDecompressor());       
    p.addLast(handler);
}

@Override
public void initChannel(SocketChannel ch) {
    ChannelPipeline p = ch.pipeline();      
    if (sslCtx != null) {
        p.addLast(sslCtx.newHandler(ch.alloc()));
    }
    p.addLast(new HttpClientCodec());
    p.addLast(new HttpContentDecompressor());       
    p.addLast(handler);
}