修复线程并发的bug

Author: wangqifox

src/main/java/love/wangqi/filter/SendForwardFilter.java

@@ -28,7 +28,7 @@ public int filterOrder() {
     }
 
     @Override
-    public void filter(FullHttpRequest httpRequest) throws Exception {
+    public synchronized void filter(FullHttpRequest httpRequest) throws Exception {
         HttpRequestBuilder httpRequestBuilder = config.getHttpRequestBuilder()
                 .setRouteMapper(config.getRouteMapper());
 

src/main/java/love/wangqi/handler/GatewayRunner.java

@@ -95,7 +95,7 @@ String getNamePrefix() {
             30L, TimeUnit.MILLISECONDS,
             new LinkedBlockingQueue<>(), new PreRouteThreadFactory());
 
-    private static ExecutorService routePool = new ThreadPoolExecutor(1, 1,
+    private static ExecutorService routePool = new ThreadPoolExecutor(5, 10,
             30L, TimeUnit.MILLISECONDS,
             new LinkedBlockingQueue<>(), new RouteThreadFactory());