浏览器->Netty服务端->Netty客户端->后端服务

Author: skippyb1

Week_03/README.md

@@ -2,4 +2,4 @@
 
 1. Http后台结果分两次进入ChannelInboundHandlerAdapter，一次HttpResponse 一次HttpContent
 2. 后端服务返回ByteBuf 需要使用ByteBuf内部API复制比特数组，否则抛出异常
-3. 浏览器请求->Netty服务器->Netty客户端->Http后台 InBound OutBound 思路和顺序不清晰，导致结果无法返回到浏览器，最后还是没实现.
+3. 浏览器请求->Netty服务器->Netty客户端->Http后台 Netty客户端代码结构有欠缺 整体逻辑较完整

Week_03/code/java01/week03/outbound/httpclinet4/HttpOutboundHandler.java

@@ -80,7 +80,7 @@ private void fetchGet(final FullHttpRequest inbound, final ChannelHandlerContext
         URL uri = new URL(url);
         String host = uri.getHost();
         int port = uri.getPort();
-        NettyHttpClient.connect(host,port,inbound);
+        NettyHttpClient.connect(host,port,inbound,ctx);
 
       } catch (Exception e) {
 

Week_03/code/java01/week03/outbound/netty4/NettyHttpClient.java

@@ -1,10 +1,7 @@
 package com.guanqp.java01.week03.outbound.netty4;
 
 import io.netty.bootstrap.Bootstrap;
-import io.netty.channel.ChannelFuture;
-import io.netty.channel.ChannelInitializer;
-import io.netty.channel.ChannelOption;
-import io.netty.channel.EventLoopGroup;
+import io.netty.channel.*;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
@@ -13,7 +10,7 @@
 
 public class NettyHttpClient {
 
-    public static void connect(String host, int port,Object msg) throws Exception {
+    public static void connect(String host, int port,Object msg,final ChannelHandlerContext ctx) throws Exception {
         EventLoopGroup workerGroup = new NioEventLoopGroup();
 
         try {
@@ -28,7 +25,7 @@ public void initChannel(SocketChannel ch) throws Exception {
                     ch.pipeline().addLast(new HttpResponseDecoder());
                      //客户端发送的是httprequest，所以要使用HttpRequestEncoder进行编码
                     ch.pipeline().addLast(new HttpRequestEncoder());
-                    ch.pipeline().addLast(new NettyHttpClientOutboundHandler());
+                    ch.pipeline().addLast(new NettyHttpClientOutboundHandler(ctx));
                 }
             });
 

Week_03/code/java01/week03/outbound/netty4/NettyHttpClientOutboundHandler.java

@@ -11,7 +11,6 @@
 import io.netty.handler.codec.http.FullHttpResponse;
 import io.netty.handler.codec.http.HttpContent;
 import io.netty.handler.codec.http.HttpResponse;
-import io.netty.util.CharsetUtil;
 
 import static io.netty.handler.codec.http.HttpResponseStatus.NO_CONTENT;
 import static io.netty.handler.codec.http.HttpResponseStatus.OK;
@@ -20,7 +19,10 @@
 public class NettyHttpClientOutboundHandler  extends ChannelInboundHandlerAdapter {
 
     HttpResponseFilter filter = new HeaderHttpResponseFilter();
-
+    ChannelHandlerContext originCtx;
+    public NettyHttpClientOutboundHandler(ChannelHandlerContext originCtx){
+        this.originCtx = originCtx;
+    }
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg)
             throws Exception {
@@ -64,7 +66,7 @@ public void channelRead(ChannelHandlerContext ctx, Object msg)
                 response = new DefaultFullHttpResponse(HTTP_1_1, NO_CONTENT);
                 exceptionCaught(ctx, e);
             } finally {
-                ctx.writeAndFlush(response);
+                originCtx.writeAndFlush(response);
                 //ctx.close();
             }
         }