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 @@
 publicclassNettyServerApplication{
 
 publicfinalstaticStringGATEWAY_NAME = "NIOGateway";
-publicfinalstaticStringGATEWAY_VERSION = "1.0.0";
+publicfinalstaticStringGATEWAY_VERSION = "3.0.0";
 
 publicstaticvoidmain(String[] args){
-StringproxyServer = System.getProperty("proxyServer","http://localhost:8088");
+
 StringproxyPort = 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 #作为后端服务
+
 
 intport = Integer.parseInt(proxyPort);
 System.out.println(GATEWAY_NAME + " " + GATEWAY_VERSION +" starting...");
 HttpInboundServerserver = newHttpInboundServer(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 (Exceptionex){

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

@@ -0,0 +1,12 @@
+packageio.github.kimmking.gateway.filter;
+
+importio.netty.channel.ChannelHandlerContext;
+importio.netty.handler.codec.http.FullHttpRequest;
+
+publicclassHeaderHttpRequestFilterimplementsHttpRequestFilter{
+
+@Override
+publicvoidfilter(FullHttpRequestfullRequest, ChannelHandlerContextctx){
+fullRequest.headers().set("mao", "soul");
+ }
+}

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

@@ -1,5 +1,6 @@
 packageio.github.kimmking.gateway.inbound;
 
+importio.github.kimmking.gateway.filter.HeaderHttpRequestFilter;
 importio.github.kimmking.gateway.filter.HttpRequestFilter;
 importio.github.kimmking.gateway.outbound.httpclient4.HttpOutboundHandler;
 importio.netty.channel.ChannelHandlerContext;
@@ -16,12 +17,11 @@ public class HttpInboundHandler extends ChannelInboundHandlerAdapter{
 privatestaticLoggerlogger = LoggerFactory.getLogger(HttpInboundHandler.class);
 privatefinalList<String> proxyServer;
 privateHttpOutboundHandlerhandler;
-privateHttpRequestFilterfilter;
+privateHttpRequestFilterfilter = newHeaderHttpRequestFilter();
 
-publicHttpInboundHandler(List<String> proxyServer, HttpRequestFilterfilter){
+publicHttpInboundHandler(List<String> proxyServer){
 this.proxyServer = proxyServer;
-this.filter = filter;
-handler = newHttpOutboundHandler(this.proxyServer);
+this.handler = newHttpOutboundHandler(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(newHttpServerCodec());
 //p.addLast(new HttpServerExpectContinueHandler());
 p.addLast(newHttpObjectAggregator(1024 * 1024));
-p.addLast(newHttpInboundHandler(this.proxyServer,
- (fullRequest, ctx) -> fullRequest.headers().set("mao", "soul")));
+p.addLast(newHttpInboundHandler(this.proxyServer));
  }
 }

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

@@ -10,12 +10,13 @@
 importio.netty.channel.socket.nio.NioServerSocketChannel;
 importio.netty.handler.logging.LogLevel;
 importio.netty.handler.logging.LoggingHandler;
+importlombok.Data;
 importorg.slf4j.Logger;
 importorg.slf4j.LoggerFactory;
 
 importjava.util.List;
 
-
+@Data
 publicclassHttpInboundServer{
 
 privateintport;
@@ -45,7 +46,8 @@ public void run() throws Exception{
  .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
 
 b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)
- .handler(newLoggingHandler(LogLevel.INFO)).childHandler(newHttpInboundInitializer(this.proxyServers));
+ .handler(newLoggingHandler(LogLevel.DEBUG))
+ .childHandler(newHttpInboundInitializer(this.proxyServers));
 
 Channelch = 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{
 
 publicHttpOutboundHandler(List<String> backends){
 
-this.backendUrls = backendUrls.stream().map(this::formatUrl).collect(Collectors.toList());
+this.backendUrls = backends.stream().map(this::formatUrl).collect(Collectors.toList());
 
-intcores = Runtime.getRuntime().availableProcessors() * 2;
+intcores = Runtime.getRuntime().availableProcessors();
 longkeepAliveTime = 1000;
 intqueueSize = 2048;
 RejectedExecutionHandlerhandler = newThreadPoolExecutor.CallerRunsPolicy();//.DiscardPolicy();

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

@@ -7,7 +7,7 @@ public class RandomHttpEndpointRouter implements HttpEndpointRouter{
 @Override
 publicStringroute(List<String> urls){
 intsize = urls.size();
-Randomrandom = newRandom(size);
-returnurls.get(random.nextInt());
+Randomrandom = newRandom(System.currentTimeMillis());
+returnurls.get(random.nextInt(size));
  }
 }