1 import io.netty.bootstrap.Bootstrap; 2 import io.netty.channel.Channel; 3 import io.netty.channel.EventLoopGroup; 4 import io.netty.channel.nio.NioEventLoopGroup; 5 import io.netty.channel.socket.nio.NioSocketChannel; 6 import io.netty.handler.codec.http.ClientCookieEncoder; 7 import io.netty.handler.codec.http.DefaultCookie; 8 import io.netty.handler.codec.http.DefaultFullHttpRequest; 9 import io.netty.handler.codec.http.HttpHeaders;10 import io.netty.handler.codec.http.HttpMethod;11 import io.netty.handler.codec.http.HttpRequest;12 import io.netty.handler.codec.http.HttpVersion;13 import io.netty.handler.ssl.SslContext;14 import io.netty.handler.ssl.util.InsecureTrustManagerFactory;15 import java.net.URI;16 17 /**18  * A simple HTTP client that prints out the content of the HTTP response to19  * {@link System#out} to test {@link HttpSnoopServer}.20  */21 public final class HttpSnoopClient {22 23     static final String URL = System.getProperty("url", "http://www.baidu.com/s");24     static final String PARAM = "?wd=罗龙龙";25 26     public static void main(String[] args) throws Exception {27         URI uri = new URI(URL);28         String scheme = uri.getScheme() == null? "http" : uri.getScheme();29         String host = uri.getHost() == null? "127.0.0.1" : uri.getHost();30         int port = uri.getPort();31         if (port == -1) {32             if ("http".equalsIgnoreCase(scheme)) {33                 port = 80;34             } else if ("https".equalsIgnoreCase(scheme)) {35                 port = 443;36             }37         }38 39         if (!"http".equalsIgnoreCase(scheme) && !"https".equalsIgnoreCase(scheme)) {40             System.err.println("Only HTTP(S) is supported.");41             return;42         }43 44         // Configure SSL context if necessary.45         final boolean ssl = "https".equalsIgnoreCase(scheme);46         final SslContext sslCtx;47         if (ssl) {48             sslCtx = SslContext.newClientContext(InsecureTrustManagerFactory.INSTANCE);49         } else {50             sslCtx = null;51         }52 53         // Configure the client.54         EventLoopGroup group = new NioEventLoopGroup();55         try {56             Bootstrap b = new Bootstrap();57             b.group(group)58              .channel(NioSocketChannel.class)59              .handler(new HttpSnoopClientInitializer(sslCtx));60 61             // Make the connection attempt.62             Channel ch = b.connect(host, port).sync().channel();63             System.out.println("*************"+uri.getRawQuery()+"*************");64             // Prepare the HTTP request.65             HttpRequest request = new DefaultFullHttpRequest(66                     HttpVersion.HTTP_1_1, HttpMethod.GET, uri.getRawPath()+PARAM);67             request.headers().set(HttpHeaders.Names.HOST, host);68             request.headers().set(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.CLOSE);69             request.headers().set(HttpHeaders.Names.ACCEPT_ENCODING, HttpHeaders.Values.GZIP);70 71             // Set some example cookies.72             request.headers().set(73                     HttpHeaders.Names.COOKIE,74                     ClientCookieEncoder.encode(75                             new DefaultCookie("my-cookie", "foo"),76                             new DefaultCookie("another-cookie", "bar")));77 78             // Send the HTTP request.79             ch.writeAndFlush(request);80 81             // Wait for the server to close the connection.82             ch.closeFuture().sync();83         } finally {84             // Shut down executor threads to exit.85             group.shutdownGracefully();86         }87     }88 }

import io.netty.channel.ChannelHandlerContext;import io.netty.channel.SimpleChannelInboundHandler;import io.netty.handler.codec.http.HttpContent;import io.netty.handler.codec.http.HttpHeaders;import io.netty.handler.codec.http.HttpObject;import io.netty.handler.codec.http.HttpResponse;import io.netty.handler.codec.http.LastHttpContent;import io.netty.util.CharsetUtil;public class HttpSnoopClientHandler extends SimpleChannelInboundHandler<HttpObject> {    @Override    public void channelRead0(ChannelHandlerContext ctx, HttpObject msg) {        if (msg instanceof HttpResponse) {            HttpResponse response = (HttpResponse) msg;            System.err.println("STATUS: " + response.getStatus());            System.err.println("VERSION: " + response.getProtocolVersion());            System.err.println();            if (!response.headers().isEmpty()) {                for (String name: response.headers().names()) {                    for (String value: response.headers().getAll(name)) {                        System.err.println("HEADER: " + name + " = " + value);                    }                }                System.err.println();            }            if (HttpHeaders.isTransferEncodingChunked(response)) {                System.err.println("CHUNKED CONTENT {");            } else {                System.err.println("CONTENT {");            }        }        if (msg instanceof HttpContent) {            HttpContent content = (HttpContent) msg;            System.err.print(content.content().toString(CharsetUtil.UTF_8));            System.err.flush();            if (content instanceof LastHttpContent) {                System.err.println("} END OF CONTENT");                ctx.close();            }        }    }    @Override    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {        cause.printStackTrace();        ctx.close();    }}

 1 import io.netty.channel.ChannelInitializer; 2 import io.netty.channel.ChannelPipeline; 3 import io.netty.channel.socket.SocketChannel; 4 import io.netty.handler.codec.http.HttpClientCodec; 5 import io.netty.handler.codec.http.HttpContentDecompressor; 6 import io.netty.handler.ssl.SslContext; 7  8 public class HttpSnoopClientInitializer extends ChannelInitializer<SocketChannel> { 9 10     private final SslContext sslCtx;11 12     public HttpSnoopClientInitializer(SslContext sslCtx) {13         this.sslCtx = sslCtx;14     }15 16     @Override17     public void initChannel(SocketChannel ch) {18         ChannelPipeline p = ch.pipeline();19 20         // Enable HTTPS if necessary.21         if (sslCtx != null) {22             p.addLast(sslCtx.newHandler(ch.alloc()));23         }24 25         p.addLast(new HttpClientCodec());26 27         // Remove the following line if you don‘t want automatic content decompression.28         p.addLast(new HttpContentDecompressor());29 30         // Uncomment the following line if you don‘t want to handle HttpContents.31         //p.addLast(new HttpObjectAggregator(1048576));32 33         p.addLast(new HttpSnoopClientHandler());34     }35 }