lixueqiang 2 anni fa
parent
commit
e28b2114b8

+ 5 - 3
kxs-gateway/src/main/java/com/kxs/gateway/api/filter/RequestDecoderFilter.java

@@ -5,8 +5,6 @@ import cn.hutool.crypto.symmetric.AES;
 import com.kxs.common.core.constant.enums.ErrorTypeEnum;
 import com.kxs.common.core.exception.AesDecodeException;
 import com.kxs.common.core.exception.CheckedException;
-import com.kxs.common.core.exception.ValidateCodeException;
-import io.netty.handler.codec.json.JsonObjectDecoder;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.cloud.gateway.filter.GatewayFilter;
@@ -29,7 +27,7 @@ import reactor.core.publisher.Mono;
 
 import java.lang.reflect.Field;
 import java.net.URI;
-import java.util.Map;
+import java.util.concurrent.atomic.AtomicReference;
 
 
 /**
@@ -66,6 +64,9 @@ public class RequestDecoderFilter extends AbstractGatewayFilterFactory<Object> {
 			if (method != HttpMethod.POST) {
 				return chain.filter(exchange);
 			}
+
+
+
 			// 2 获取请求体,修改请求体
 			ServerRequest serverRequest = ServerRequest.create(exchange,
 					HandlerStrategies.withDefaults().messageReaders());
@@ -130,3 +131,4 @@ public class RequestDecoderFilter extends AbstractGatewayFilterFactory<Object> {
 	}
 
 }
+

+ 22 - 22
kxs-gateway/src/main/resources/application.yml

@@ -2,50 +2,40 @@
 server:
   port: 9999
 spring:
-  profiles:
-    active: @profiles.active@
-  application:
-    name: kxs-gateway
   cloud:
     gateway:
       routes:
         #ADMIN 模块
-        - id: kxs-system-biz  # 唯一的服务ID
-          uri: lb://kxs-system-biz # instances下的服务名称,实现负载均衡
+        - id: kxs-system-biz
+          uri: lb://kxs-system-biz
           predicates:
-            - Path=/v1/kxs/admin/** #当前服务的请求前缀,
+            - Path=/v1/kxs/admin/**
           filters:
             # 过滤前缀
             - StripPrefix=3
             # 限流配置
             - name: RequestRateLimiter
               args:
-                key-resolver: '#{@remoteAddrKeyResolver}' #SPEL表达式去的对应的bean
-                redis-rate-limiter.replenishRate: 100 # 令牌桶每秒填充平均速率
-                redis-rate-limiter.burstCapacity: 200 # 令牌桶总容量
+                key-resolver: '#{@remoteAddrKeyResolver}'
+                redis-rate-limiter.replenishRate: 100
+                redis-rate-limiter.burstCapacity: 200
             # 验证码处理
-#            - ValidateCodeGatewayFilter #如果该服务需要验证码则开启此过滤器
+#            - ValidateCodeGatewayFilter
             # 解密过滤器
 #            - RequestDecoderFilter
-
         # 代码生成模块
         - id: kxs-codegen
-          uri: lb://kxs-codegen
+          uri: lb://kxs-codegen:5002
           predicates:
             - Path=/v1/kxs/gen/**
           filters:
             # 过滤前缀
             - StripPrefix=3
-
         # 定时任务成模块
-        - id: kxs-quartz
-          uri: lb://kxs-quartz
+        - id: sky-quartz
+          uri: lb://sky-quartz
           predicates:
-            - Path=/v1/kxs/job/**
-          filters:
-            # 过滤前缀
-            - StripPrefix=3
-
+            - Path=/job/**
         # 固定路由转发配置 无修改
         - id: openapi
           uri: lb://sky-gateway
@@ -54,6 +44,16 @@ spring:
           filters:
             - RewritePath=/v3/api-docs/(?<path>.*), /$\{path}/$\{path}/v3/api-docs
 
+
+    discovery:
+      client:
+        simple:
+          instances:
+            kxs-system-biz: #负载均衡
+              - uri: http://127.0.0.1:8080
+            kxs-codegen:
+              - uri: http://127.0.0.1:5002
+
 gateway:
   aes:
     encode-key: 'CBTU1dD4Kd5pyiGWTsI10jRQ3SvKusSV'
@@ -62,4 +62,4 @@ gateway:
     encode-padding: 'PKCS7Padding'
   #不校验验证码的客户端
   ignore-clients:
-    - kxs
+    - sky