update

Author: kimmking

02nio/nio02/pom.xml

@@ -52,6 +52,11 @@
             <artifactId>httpasyncclient</artifactId>
             <version>4.1.4</version>
         </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
 
         <!--
         <dependency>

02nio/nio02/src/main/java/io/github/kimmking/gateway/NettyServerApplication.java

@@ -8,19 +8,22 @@
 public class NettyServerApplication {
 
     public final static String GATEWAY_NAME = "NIOGateway";
-    public final static String GATEWAY_VERSION = "1.0.0";
+    public final static String GATEWAY_VERSION = "3.0.0";
 
     public static void main(String[] args) {
-        String proxyServer = System.getProperty("proxyServer","http://localhost:8088");
+
         String proxyPort = System.getProperty("proxyPort","8888");
-        
-          //  http://localhost:8888/api/hello  ==> gateway API
-          //  http://localhost:8088/api/hello  ==> backend service
+
+//        String proxyServer = System.getProperty("proxyServer","http://localhost:8088");
+//          //  http://localhost:8888/api/hello  ==> gateway API
+//          //  http://localhost:8088/api/hello  ==> backend service
+        // java -Xmx512m gateway-server-0.0.1-SNAPSHOT.jar  #作为后端服务
+
 
         int port = Integer.parseInt(proxyPort);
         System.out.println(GATEWAY_NAME + " " + GATEWAY_VERSION +" starting...");
         HttpInboundServer server = new HttpInboundServer(port, Arrays.asList("http://localhost:8801","http://localhost:8802"));
-        System.out.println(GATEWAY_NAME + " " + GATEWAY_VERSION +" started at http://localhost:" + port + " for server:" + proxyServer);
+        System.out.println(GATEWAY_NAME + " " + GATEWAY_VERSION +" started at http://localhost:" + port + " for server:" + server.toString());
         try {
             server.run();
         }catch (Exception ex){

02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpRequestFilter.java

@@ -0,0 +1,12 @@
+package io.github.kimmking.gateway.filter;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.FullHttpRequest;
+
+public class HeaderHttpRequestFilter implements HttpRequestFilter {
+
+    @Override
+    public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
+        fullRequest.headers().set("mao", "soul");
+    }
+}

02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java

@@ -1,5 +1,6 @@
 package io.github.kimmking.gateway.inbound;
 
+import io.github.kimmking.gateway.filter.HeaderHttpRequestFilter;
 import io.github.kimmking.gateway.filter.HttpRequestFilter;
 import io.github.kimmking.gateway.outbound.httpclient4.HttpOutboundHandler;
 import io.netty.channel.ChannelHandlerContext;
@@ -16,12 +17,11 @@ public class HttpInboundHandler extends ChannelInboundHandlerAdapter {
     private static Logger logger = LoggerFactory.getLogger(HttpInboundHandler.class);
     private final List<String> proxyServer;
     private HttpOutboundHandler handler;
-    private HttpRequestFilter filter;
+    private HttpRequestFilter filter = new HeaderHttpRequestFilter();
 
-    public HttpInboundHandler(List<String> proxyServer, HttpRequestFilter filter) {
+    public HttpInboundHandler(List<String> proxyServer) {
         this.proxyServer = proxyServer;
-        this.filter = filter;
-        handler = new HttpOutboundHandler(this.proxyServer);
+        this.handler = new HttpOutboundHandler(this.proxyServer);
     }
 
     @Override

02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundInitializer.java

@@ -28,7 +28,6 @@ public void initChannel(SocketChannel ch) {
 		p.addLast(new HttpServerCodec());
 		//p.addLast(new HttpServerExpectContinueHandler());
 		p.addLast(new HttpObjectAggregator(1024 * 1024));
-		p.addLast(new HttpInboundHandler(this.proxyServer,
-				(fullRequest, ctx) -> fullRequest.headers().set("mao", "soul")));
+		p.addLast(new HttpInboundHandler(this.proxyServer));
 	}
 }

02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java

@@ -10,12 +10,13 @@
 import io.netty.channel.socket.nio.NioServerSocketChannel;
 import io.netty.handler.logging.LogLevel;
 import io.netty.handler.logging.LoggingHandler;
+import lombok.Data;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.util.List;
 
-
+@Data
 public class HttpInboundServer {
 
     private int port;
@@ -45,7 +46,8 @@ public void run() throws Exception {
                     .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
 
             b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)
-                    .handler(new LoggingHandler(LogLevel.INFO)).childHandler(new HttpInboundInitializer(this.proxyServers));
+                    .handler(new LoggingHandler(LogLevel.DEBUG))
+                    .childHandler(new HttpInboundInitializer(this.proxyServers));
 
             Channel ch = b.bind(port).sync().channel();
             System.out.println("开启netty http服务器，监听地址和端口为 http://127.0.0.1:" + port + '/');

02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java

@@ -40,9 +40,9 @@ public class HttpOutboundHandler {
 
     public HttpOutboundHandler(List<String> backends) {
 
-        this.backendUrls = backendUrls.stream().map(this::formatUrl).collect(Collectors.toList());
+        this.backendUrls = backends.stream().map(this::formatUrl).collect(Collectors.toList());
 
-        int cores = Runtime.getRuntime().availableProcessors() * 2;
+        int cores = Runtime.getRuntime().availableProcessors();
         long keepAliveTime = 1000;
         int queueSize = 2048;
         RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy();//.DiscardPolicy();

02nio/nio02/src/main/java/io/github/kimmking/gateway/router/RandomHttpEndpointRouter.java

@@ -7,7 +7,7 @@ public class RandomHttpEndpointRouter implements HttpEndpointRouter {
     @Override
     public String route(List<String> urls) {
         int size = urls.size();
-        Random random = new Random(size);
-        return urls.get(random.nextInt());
+        Random random = new Random(System.currentTimeMillis());
+        return urls.get(random.nextInt(size));
     }
 }