接口解密放到gateway中处理

gateway/pom.xml

@@ -33,6 +33,17 @@
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.24</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-webmvc</artifactId>
+        </dependency>
+
     </dependencies>
     <dependencyManagement>
         <dependencies>

gateway/src/main/java/com/xhkjedu/gateway/interceptors/DecryptRequestBodyAdvice.java

@@ -0,0 +1,116 @@
+//package com.xhkjedu.gateway.interceptors;
+//
+//import com.xhkjedu.gateway.utils.AES;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.core.MethodParameter;
+//import org.springframework.http.HttpHeaders;
+//import org.springframework.http.HttpInputMessage;
+//import org.springframework.http.converter.HttpMessageConverter;
+//import org.springframework.util.CollectionUtils;
+//import org.springframework.util.StreamUtils;
+//import org.springframework.web.bind.annotation.ControllerAdvice;
+//import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
+//
+//import javax.crypto.BadPaddingException;
+//import javax.crypto.IllegalBlockSizeException;
+//import javax.crypto.NoSuchPaddingException;
+//import java.io.ByteArrayInputStream;
+//import java.io.IOException;
+//import java.io.InputStream;
+//import java.io.UnsupportedEncodingException;
+//import java.lang.reflect.Type;
+//import java.security.InvalidKeyException;
+//import java.security.NoSuchAlgorithmException;
+//import java.util.List;
+//
+///**
+// * @ClassName DecryptRequestBodyAdvice
+// * Description TODO AES解密  （在网关中不可用）
+// * Author WN
+// * Date 2021/5/12 11:34
+// **/
+//@Slf4j
+//@ControllerAdvice
+//public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
+//
+//    private static String AES_KEY = "XINGHUOLIAOYUAN7";
+//
+//    /** 此处如果返回false , 则不执行当前Advice的业务 */
+//    @Override
+//    public boolean supports(MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
+////       log.info("----support----");
+//        return true;
+//    }
+//
+//    /**
+//     * @title 读取参数前执行
+//     * @description 在此做些编码 / 解密 / 封装参数为对象的操作
+//     **/
+//    @Override
+//    public HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) throws IOException {
+////        log.info("----beforeBodyRead----");
+//
+//        //AES解密，false不需要解密
+//        List<String> decrypts = httpInputMessage.getHeaders().get("st");
+//        String decrypt = isListNotEmpty(decrypts)?decrypts.get(0):"false";
+//        if (!decrypt.equals("true")) {
+//            return httpInputMessage;
+//        }
+//        // 读取加密的请求体
+//        byte[] body = StreamUtils.copyToByteArray(httpInputMessage.getBody());
+//        String str = new String(body,"utf-8");
+//
+//        try {
+//            // 使用AES解密
+//            body = AES.decryptForByte(str, AES_KEY);
+//        } catch (InvalidKeyException | NoSuchAlgorithmException | NoSuchPaddingException | IllegalBlockSizeException |
+//                BadPaddingException | UnsupportedEncodingException e) {
+//            e.printStackTrace();
+//            throw new RuntimeException(e);
+//        } catch (Exception e){
+//            e.printStackTrace();
+//            throw new RuntimeException(e);
+//        }
+//
+//        // 使用解密后的数据，构造新的读取流
+//        InputStream rawInputStream = new ByteArrayInputStream(body);
+//        return new HttpInputMessage() {
+//            @Override
+//            public HttpHeaders getHeaders() {
+//                return httpInputMessage.getHeaders();
+//            }
+//
+//            @Override
+//            public InputStream getBody() throws IOException {
+//                return rawInputStream;
+//            }
+//        };
+//    }
+//
+//    /**
+//     * @title 读取参数后执行
+//     * @author Xingbz
+//     */
+//    @Override
+//    public Object afterBodyRead(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
+////        log.info("afterBodyRead:----");
+//        return o;
+//    }
+//
+//    /**
+//     * @title 无请求时的处理
+//     */
+//    @Override
+//    public Object handleEmptyBody(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
+////        log.info("handleEmptyBody:----");
+//        return o;
+//    }
+//
+//    private static boolean isListNotEmpty(List list) {
+//        if (CollectionUtils.isEmpty(list)){
+//            return false;
+//        } else {
+//            return true;
+//        }
+//    }
+//}

gateway/src/main/java/com/xhkjedu/gateway/interceptors/DecryptRequestionBodyFilter.java

@@ -0,0 +1,145 @@
+package com.xhkjedu.gateway.interceptors;
+
+import com.xhkjedu.gateway.utils.AES;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cloud.gateway.filter.GatewayFilterChain;
+import org.springframework.cloud.gateway.filter.GlobalFilter;
+import org.springframework.cloud.gateway.filter.factory.rewrite.CachedBodyOutputMessage;
+import org.springframework.cloud.gateway.support.BodyInserterContext;
+import org.springframework.core.Ordered;
+import org.springframework.core.io.buffer.DataBuffer;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.http.server.reactive.ServerHttpRequest;
+import org.springframework.http.server.reactive.ServerHttpRequestDecorator;
+import org.springframework.http.server.reactive.ServerHttpResponse;
+import org.springframework.stereotype.Component;
+import org.springframework.util.AntPathMatcher;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.reactive.function.BodyInserter;
+import org.springframework.web.reactive.function.BodyInserters;
+import org.springframework.web.reactive.function.server.HandlerStrategies;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.server.ServerWebExchange;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.util.List;
+
+/**
+ * @Description 请求参数解密
+ * @Author WN
+ * Date 2023/2/1 14:22
+ **/
+@Component
+@Slf4j
+public class DecryptRequestionBodyFilter implements GlobalFilter, Ordered {
+
+    private static String AES_KEY = "XINGHUOLIAOYUAN7";
+
+    private AntPathMatcher antPathMatcher= new AntPathMatcher();
+
+    @SneakyThrows
+    @Override
+    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
+
+        ServerHttpRequest request = exchange.getRequest();
+        ServerHttpResponse response = exchange.getResponse();
+        String path = request.getURI().getPath(); // 当前调用方法的url
+        HttpHeaders headers = request.getHeaders();
+//        log.info("HttpMethod:{},Url:{}", request.getMethod(), request.getURI().getRawPath());
+        List<String> decrypts = headers.get("st");
+        String decrypt = isListNotEmpty(decrypts)?decrypts.get(0):"false";
+        if (!decrypt.equals("true")) {
+            return chain.filter(exchange);
+        }else{
+            return readBody(exchange, chain);
+        }
+
+//        //  登录跳过网关验证，检查白名单（配置）最好把不拦截路径放入配置文件，此处通过正则
+//        if(antPathMatcher.match("/**/api/login/auth/**",path)){
+//            return readBody(exchange, chain);
+//        }
+//        // 处理参数
+//        MediaType contentType = headers.getContentType();
+//        long contentLength = headers.getContentLength();
+//        if (contentLength > 0) {
+//            if (MediaType.APPLICATION_JSON.equals(contentType) || MediaType.APPLICATION_JSON_UTF8.equals(contentType)) {
+//                return readBody(exchange, chain);
+//            }
+//        }
+//        return chain.filter(exchange);
+    }
+
+    ServerHttpRequestDecorator decorate(ServerWebExchange exchange, HttpHeaders headers, CachedBodyOutputMessage outputMessage) {
+        return new ServerHttpRequestDecorator(exchange.getRequest()) {
+            public HttpHeaders getHeaders() {
+                long contentLength = headers.getContentLength();
+                HttpHeaders httpHeaders = new HttpHeaders();
+                httpHeaders.putAll(super.getHeaders());
+                if (contentLength > 0L) {
+                    httpHeaders.setContentLength(contentLength);
+                } else {
+                    httpHeaders.set("Transfer-Encoding", "chunked");
+                }
+                return httpHeaders;
+            }
+            public Flux<DataBuffer> getBody() {
+                return outputMessage.getBody();
+            }
+        };
+    }
+
+
+    private Mono<Void> returnMononew(GatewayFilterChain chain, ServerWebExchange exchange){
+        return chain.filter(exchange).then(Mono.fromRunnable(()->{
+        }));
+    }
+    private Mono<Void> readBody(ServerWebExchange exchange, GatewayFilterChain chain) {
+        //重新构造request，参考ModifyRequestBodyGatewayFilterFactory
+        ServerRequest serverRequest = ServerRequest.create(exchange, HandlerStrategies.withDefaults().messageReaders());
+        MediaType mediaType = exchange.getRequest().getHeaders().getContentType();
+        //重点
+        Mono<String> modifiedBody = serverRequest.bodyToMono(String.class).flatMap(body -> {
+            //因为约定了终端传参的格式，所以只考虑json的情况，如果是表单传参，请自行增加
+            if (MediaType.APPLICATION_JSON.isCompatibleWith(mediaType) || MediaType.APPLICATION_JSON_UTF8.isCompatibleWith(mediaType)) {
+                String newBody = null;
+                try{
+                    // 解密body
+                    newBody = AES.decrypt(body, AES_KEY);
+                }catch (Exception e){
+                    e.getMessage();
+                    log.error("解密参数出错："+e.getMessage());
+                }
+                return Mono.just(newBody);
+            }
+            return Mono.empty();
+        });
+        BodyInserter bodyInserter = BodyInserters.fromPublisher(modifiedBody, String.class);
+        HttpHeaders headers = new HttpHeaders();
+        headers.putAll(exchange.getRequest().getHeaders());
+        //猜测这个就是之前报400错误的元凶，之前修改了body但是没有重新写content length
+        headers.remove("Content-Length");
+        //MyCachedBodyOutputMessage 这个类完全就是CachedBodyOutputMessage，只不过CachedBodyOutputMessage不是公共的
+        CachedBodyOutputMessage outputMessage = new CachedBodyOutputMessage(exchange, headers);
+        return bodyInserter.insert(outputMessage, new BodyInserterContext()).then(Mono.defer(() -> {
+            ServerHttpRequest decorator = this.decorate(exchange, headers, outputMessage);
+            return returnMononew(chain, exchange.mutate().request(decorator).build());
+        }));
+    }
+
+
+    @Override
+    public int getOrder() {
+        return 0;
+    }
+
+    private boolean isListNotEmpty(List list) {
+        if (CollectionUtils.isEmpty(list)){
+            return false;
+        } else {
+            return true;
+        }
+    }
+}

scommons/src/main/java/com/xhkjedu/utils/AES.java → gateway/src/main/java/com/xhkjedu/gateway/utils/AES.java

@@ -1,11 +1,6 @@
-package com.xhkjedu.utils;
+package com.xhkjedu.gateway.utils;
 
-import javax.crypto.BadPaddingException;
-import javax.crypto.Cipher;
-import javax.crypto.IllegalBlockSizeException;
-import javax.crypto.KeyGenerator;
-import javax.crypto.NoSuchPaddingException;
-import javax.crypto.SecretKey;
+import javax.crypto.*;
 import javax.crypto.spec.SecretKeySpec;
 import java.io.UnsupportedEncodingException;
 import java.security.InvalidAlgorithmParameterException;

sapi/src/main/java/com/xhkjedu/sapi/interceptors/DecryptRequestBodyAdvice.java

@@ -1,109 +0,0 @@
-package com.xhkjedu.sapi.interceptors;
-
-
-import com.xhkjedu.utils.AES;
-import com.xhkjedu.utils.N_Utils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.core.MethodParameter;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpInputMessage;
-import org.springframework.http.converter.HttpMessageConverter;
-import org.springframework.util.StreamUtils;
-import org.springframework.web.bind.annotation.ControllerAdvice;
-import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
-
-import javax.crypto.BadPaddingException;
-import javax.crypto.IllegalBlockSizeException;
-import javax.crypto.NoSuchPaddingException;
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.UnsupportedEncodingException;
-import java.lang.reflect.Type;
-import java.security.InvalidKeyException;
-import java.security.NoSuchAlgorithmException;
-import java.util.List;
-
-/**
- * @ClassName DecryptRequestBodyAdvice
- * Description TODO AES解密
- * Author WN
- * Date 2021/5/12 11:34
- **/
-@Slf4j
-@ControllerAdvice
-public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
-
-    private static String AES_KEY = "XINGHUOLIAOYUAN7";
-
-    /** 此处如果返回false , 则不执行当前Advice的业务 */
-    @Override
-    public boolean supports(MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//       log.info("----support----");
-        return true;
-    }
-
-    /**
-     * @title 读取参数前执行
-     * @description 在此做些编码 / 解密 / 封装参数为对象的操作
-     **/
-    @Override
-    public HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) throws IOException {
-//        log.info("----beforeBodyRead----");
-
-        //AES解密，false不需要解密
-        List<String> decrypts = httpInputMessage.getHeaders().get("st");
-        String decrypt = N_Utils.isListNotEmpty(decrypts)?decrypts.get(0):"false";
-        if (!decrypt.equals("true")) {
-            return httpInputMessage;
-        }
-        // 读取加密的请求体
-        byte[] body = StreamUtils.copyToByteArray(httpInputMessage.getBody());
-        String str = new String(body,"utf-8");
-
-        try {
-            // 使用AES解密
-            body = AES.decryptForByte(str, AES_KEY);
-        } catch (InvalidKeyException | NoSuchAlgorithmException | NoSuchPaddingException | IllegalBlockSizeException |
-                BadPaddingException | UnsupportedEncodingException e) {
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        } catch (Exception e){
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        }
-
-        // 使用解密后的数据，构造新的读取流
-        InputStream rawInputStream = new ByteArrayInputStream(body);
-        return new HttpInputMessage() {
-            @Override
-            public HttpHeaders getHeaders() {
-                return httpInputMessage.getHeaders();
-            }
-
-            @Override
-            public InputStream getBody() throws IOException {
-                return rawInputStream;
-            }
-        };
-    }
-
-    /**
-     * @title 读取参数后执行
-     * @author Xingbz
-     */
-    @Override
-    public Object afterBodyRead(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("afterBodyRead:----");
-        return o;
-    }
-
-    /**
-     * @title 无请求时的处理
-     */
-    @Override
-    public Object handleEmptyBody(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("handleEmptyBody:----");
-        return o;
-    }
-}

sclass/src/main/java/com/xhkjedu/sclass/interceptors/DecryptRequestBodyAdvice.java

@@ -1,108 +0,0 @@
-package com.xhkjedu.sclass.interceptors;
-
-import com.xhkjedu.utils.AES;
-import com.xhkjedu.utils.N_Utils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.core.MethodParameter;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpInputMessage;
-import org.springframework.http.converter.HttpMessageConverter;
-import org.springframework.util.StreamUtils;
-import org.springframework.web.bind.annotation.ControllerAdvice;
-import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
-
-import javax.crypto.BadPaddingException;
-import javax.crypto.IllegalBlockSizeException;
-import javax.crypto.NoSuchPaddingException;
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.UnsupportedEncodingException;
-import java.lang.reflect.Type;
-import java.security.InvalidKeyException;
-import java.security.NoSuchAlgorithmException;
-import java.util.List;
-
-/**
- * @ClassName DecryptRequestBodyAdvice
- * Description TODO AES解密
- * Author WN
- * Date 2021/5/12 11:34
- **/
-@Slf4j
-@ControllerAdvice
-public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
-
-    private static String AES_KEY = "XINGHUOLIAOYUAN7";
-
-    /** 此处如果返回false , 则不执行当前Advice的业务 */
-    @Override
-    public boolean supports(MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//       log.info("----support----");
-        return true;
-    }
-
-    /**
-     * @title 读取参数前执行
-     * @description 在此做些编码 / 解密 / 封装参数为对象的操作
-     **/
-    @Override
-    public HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) throws IOException {
-//        log.info("----beforeBodyRead----");
-
-        //AES解密，false不需要解密
-        List<String> decrypts = httpInputMessage.getHeaders().get("st");
-        String decrypt = N_Utils.isListNotEmpty(decrypts)?decrypts.get(0):"false";
-        if (!decrypt.equals("true")) {
-            return httpInputMessage;
-        }
-        // 读取加密的请求体
-        byte[] body = StreamUtils.copyToByteArray(httpInputMessage.getBody());
-        String str = new String(body,"utf-8");
-
-        try {
-            // 使用AES解密
-            body = AES.decryptForByte(str, AES_KEY);
-        } catch (InvalidKeyException | NoSuchAlgorithmException | NoSuchPaddingException | IllegalBlockSizeException |
-                BadPaddingException | UnsupportedEncodingException e) {
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        } catch (Exception e){
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        }
-
-        // 使用解密后的数据，构造新的读取流
-        InputStream rawInputStream = new ByteArrayInputStream(body);
-        return new HttpInputMessage() {
-            @Override
-            public HttpHeaders getHeaders() {
-                return httpInputMessage.getHeaders();
-            }
-
-            @Override
-            public InputStream getBody() throws IOException {
-                return rawInputStream;
-            }
-        };
-    }
-
-    /**
-     * @title 读取参数后执行
-     * @author Xingbz
-     */
-    @Override
-    public Object afterBodyRead(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("afterBodyRead:----");
-        return o;
-    }
-
-    /**
-     * @title 无请求时的处理
-     */
-    @Override
-    public Object handleEmptyBody(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("handleEmptyBody:----");
-        return o;
-    }
-}

sexam/src/main/java/com/xhkjedu/sexam/interceptors/DecryptRequestBodyAdvice.java

@@ -1,109 +0,0 @@
-package com.xhkjedu.sexam.interceptors;
-
-
-import com.xhkjedu.utils.AES;
-import com.xhkjedu.utils.N_Utils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.core.MethodParameter;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpInputMessage;
-import org.springframework.http.converter.HttpMessageConverter;
-import org.springframework.util.StreamUtils;
-import org.springframework.web.bind.annotation.ControllerAdvice;
-import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
-
-import javax.crypto.BadPaddingException;
-import javax.crypto.IllegalBlockSizeException;
-import javax.crypto.NoSuchPaddingException;
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.UnsupportedEncodingException;
-import java.lang.reflect.Type;
-import java.security.InvalidKeyException;
-import java.security.NoSuchAlgorithmException;
-import java.util.List;
-
-/**
- * @ClassName DecryptRequestBodyAdvice
- * Description TODO AES解密
- * Author WN
- * Date 2021/5/12 11:34
- **/
-@Slf4j
-@ControllerAdvice
-public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
-
-    private static String AES_KEY = "XINGHUOLIAOYUAN7";
-
-    /** 此处如果返回false , 则不执行当前Advice的业务 */
-    @Override
-    public boolean supports(MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//       log.info("----support----");
-        return true;
-    }
-
-    /**
-     * @title 读取参数前执行
-     * @description 在此做些编码 / 解密 / 封装参数为对象的操作
-     **/
-    @Override
-    public HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) throws IOException {
-//        log.info("----beforeBodyRead----");
-
-        //AES解密，false不需要解密
-        List<String> decrypts = httpInputMessage.getHeaders().get("st");
-        String decrypt = N_Utils.isListNotEmpty(decrypts)?decrypts.get(0):"false";
-        if (!decrypt.equals("true")) {
-            return httpInputMessage;
-        }
-        // 读取加密的请求体
-        byte[] body = StreamUtils.copyToByteArray(httpInputMessage.getBody());
-        String str = new String(body,"utf-8");
-
-        try {
-            // 使用AES解密
-            body = AES.decryptForByte(str, AES_KEY);
-        } catch (InvalidKeyException | NoSuchAlgorithmException | NoSuchPaddingException | IllegalBlockSizeException |
-                BadPaddingException | UnsupportedEncodingException e) {
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        } catch (Exception e){
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        }
-
-        // 使用解密后的数据，构造新的读取流
-        InputStream rawInputStream = new ByteArrayInputStream(body);
-        return new HttpInputMessage() {
-            @Override
-            public HttpHeaders getHeaders() {
-                return httpInputMessage.getHeaders();
-            }
-
-            @Override
-            public InputStream getBody() throws IOException {
-                return rawInputStream;
-            }
-        };
-    }
-
-    /**
-     * @title 读取参数后执行
-     * @author Xingbz
-     */
-    @Override
-    public Object afterBodyRead(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("afterBodyRead:----");
-        return o;
-    }
-
-    /**
-     * @title 无请求时的处理
-     */
-    @Override
-    public Object handleEmptyBody(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("handleEmptyBody:----");
-        return o;
-    }
-}

slive/src/main/java/com/xhkjedu/slive/interceptors/DecryptRequestBodyAdvice.java

@@ -1,108 +0,0 @@
-package com.xhkjedu.slive.interceptors;
-
-import com.xhkjedu.utils.AES;
-import com.xhkjedu.utils.N_Utils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.core.MethodParameter;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpInputMessage;
-import org.springframework.http.converter.HttpMessageConverter;
-import org.springframework.util.StreamUtils;
-import org.springframework.web.bind.annotation.ControllerAdvice;
-import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
-
-import javax.crypto.BadPaddingException;
-import javax.crypto.IllegalBlockSizeException;
-import javax.crypto.NoSuchPaddingException;
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.UnsupportedEncodingException;
-import java.lang.reflect.Type;
-import java.security.InvalidKeyException;
-import java.security.NoSuchAlgorithmException;
-import java.util.List;
-
-/**
- * @ClassName DecryptRequestBodyAdvice
- * Description TODO AES解密
- * Author WN
- * Date 2021/5/12 11:34
- **/
-@Slf4j
-@ControllerAdvice
-public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
-
-    private static String AES_KEY = "XINGHUOLIAOYUAN7";
-
-    /** 此处如果返回false , 则不执行当前Advice的业务 */
-    @Override
-    public boolean supports(MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//       log.info("----support----");
-        return true;
-    }
-
-    /**
-     * @title 读取参数前执行
-     * @description 在此做些编码 / 解密 / 封装参数为对象的操作
-     **/
-    @Override
-    public HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) throws IOException {
-//        log.info("----beforeBodyRead----");
-
-        //AES解密，false不需要解密
-        List<String> decrypts = httpInputMessage.getHeaders().get("st");
-        String decrypt = N_Utils.isListNotEmpty(decrypts)?decrypts.get(0):"false";
-        if (!decrypt.equals("true")) {
-            return httpInputMessage;
-        }
-        // 读取加密的请求体
-        byte[] body = StreamUtils.copyToByteArray(httpInputMessage.getBody());
-        String str = new String(body,"utf-8");
-
-        try {
-            // 使用AES解密
-            body = AES.decryptForByte(str, AES_KEY);
-        } catch (InvalidKeyException | NoSuchAlgorithmException | NoSuchPaddingException | IllegalBlockSizeException |
-                BadPaddingException | UnsupportedEncodingException e) {
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        } catch (Exception e){
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        }
-
-        // 使用解密后的数据，构造新的读取流
-        InputStream rawInputStream = new ByteArrayInputStream(body);
-        return new HttpInputMessage() {
-            @Override
-            public HttpHeaders getHeaders() {
-                return httpInputMessage.getHeaders();
-            }
-
-            @Override
-            public InputStream getBody() throws IOException {
-                return rawInputStream;
-            }
-        };
-    }
-
-    /**
-     * @title 读取参数后执行
-     * @author Xingbz
-     */
-    @Override
-    public Object afterBodyRead(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("afterBodyRead:----");
-        return o;
-    }
-
-    /**
-     * @title 无请求时的处理
-     */
-    @Override
-    public Object handleEmptyBody(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("handleEmptyBody:----");
-        return o;
-    }
-}

sstudy/src/main/java/com/xhkjedu/sstudy/interceptors/DecryptRequestBodyAdvice.java

@@ -1,109 +0,0 @@
-package com.xhkjedu.sstudy.interceptors;
-
-
-import com.xhkjedu.utils.AES;
-import com.xhkjedu.utils.N_Utils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.core.MethodParameter;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpInputMessage;
-import org.springframework.http.converter.HttpMessageConverter;
-import org.springframework.util.StreamUtils;
-import org.springframework.web.bind.annotation.ControllerAdvice;
-import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
-
-import javax.crypto.BadPaddingException;
-import javax.crypto.IllegalBlockSizeException;
-import javax.crypto.NoSuchPaddingException;
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.UnsupportedEncodingException;
-import java.lang.reflect.Type;
-import java.security.InvalidKeyException;
-import java.security.NoSuchAlgorithmException;
-import java.util.List;
-
-/**
- * @ClassName DecryptRequestBodyAdvice
- * Description TODO AES解密
- * Author WN
- * Date 2021/5/12 11:34
- **/
-@Slf4j
-@ControllerAdvice
-public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
-
-    private static String AES_KEY = "XINGHUOLIAOYUAN7";
-
-    /** 此处如果返回false , 则不执行当前Advice的业务 */
-    @Override
-    public boolean supports(MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//       log.info("----support----");
-        return true;
-    }
-
-    /**
-     * @title 读取参数前执行
-     * @description 在此做些编码 / 解密 / 封装参数为对象的操作
-     **/
-    @Override
-    public HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) throws IOException {
-//        log.info("----beforeBodyRead----");
-
-        //AES解密，false不需要解密
-        List<String> decrypts = httpInputMessage.getHeaders().get("st");
-        String decrypt = N_Utils.isListNotEmpty(decrypts)?decrypts.get(0):"false";
-        if (!decrypt.equals("true")) {
-            return httpInputMessage;
-        }
-        // 读取加密的请求体
-        byte[] body = StreamUtils.copyToByteArray(httpInputMessage.getBody());
-        String str = new String(body,"utf-8");
-
-        try {
-            // 使用AES解密
-            body = AES.decryptForByte(str, AES_KEY);
-        } catch (InvalidKeyException | NoSuchAlgorithmException | NoSuchPaddingException | IllegalBlockSizeException |
-                BadPaddingException | UnsupportedEncodingException e) {
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        } catch (Exception e){
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        }
-
-        // 使用解密后的数据，构造新的读取流
-        InputStream rawInputStream = new ByteArrayInputStream(body);
-        return new HttpInputMessage() {
-            @Override
-            public HttpHeaders getHeaders() {
-                return httpInputMessage.getHeaders();
-            }
-
-            @Override
-            public InputStream getBody() throws IOException {
-                return rawInputStream;
-            }
-        };
-    }
-
-    /**
-     * @title 读取参数后执行
-     * @author Xingbz
-     */
-    @Override
-    public Object afterBodyRead(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("afterBodyRead:----");
-        return o;
-    }
-
-    /**
-     * @title 无请求时的处理
-     */
-    @Override
-    public Object handleEmptyBody(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("handleEmptyBody:----");
-        return o;
-    }
-}

suser/src/main/java/com/xhkjedu/suser/interceptors/DecryptRequestBodyAdvice.java

@@ -1,108 +0,0 @@
-package com.xhkjedu.suser.interceptors;
-
-import com.xhkjedu.utils.AES;
-import com.xhkjedu.utils.N_Utils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.core.MethodParameter;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpInputMessage;
-import org.springframework.http.converter.HttpMessageConverter;
-import org.springframework.util.StreamUtils;
-import org.springframework.web.bind.annotation.ControllerAdvice;
-import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
-
-import javax.crypto.BadPaddingException;
-import javax.crypto.IllegalBlockSizeException;
-import javax.crypto.NoSuchPaddingException;
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.UnsupportedEncodingException;
-import java.lang.reflect.Type;
-import java.security.InvalidKeyException;
-import java.security.NoSuchAlgorithmException;
-import java.util.List;
-
-/**
- * @ClassName DecryptRequestBodyAdvice
- * Description TODO AES解密
- * Author WN
- * Date 2021/5/12 11:34
- **/
-@Slf4j
-@ControllerAdvice
-public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
-
-    private static String AES_KEY = "XINGHUOLIAOYUAN7";
-
-    /** 此处如果返回false , 则不执行当前Advice的业务 */
-    @Override
-    public boolean supports(MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//       log.info("----support----");
-        return true;
-    }
-
-    /**
-     * @title 读取参数前执行
-     * @description 在此做些编码 / 解密 / 封装参数为对象的操作
-     **/
-    @Override
-    public HttpInputMessage beforeBodyRead(HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) throws IOException {
-//        log.info("----beforeBodyRead----");
-
-        //AES解密，false不需要解密
-        List<String> decrypts = httpInputMessage.getHeaders().get("st");
-        String decrypt = N_Utils.isListNotEmpty(decrypts)?decrypts.get(0):"false";
-        if (!decrypt.equals("true")) {
-            return httpInputMessage;
-        }
-        // 读取加密的请求体
-        byte[] body = StreamUtils.copyToByteArray(httpInputMessage.getBody());
-        String str = new String(body,"utf-8");
-
-        try {
-            // 使用AES解密
-            body = AES.decryptForByte(str, AES_KEY);
-        } catch (InvalidKeyException | NoSuchAlgorithmException | NoSuchPaddingException | IllegalBlockSizeException |
-                BadPaddingException | UnsupportedEncodingException e) {
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        } catch (Exception e){
-            e.printStackTrace();
-            throw new RuntimeException(e);
-        }
-
-        // 使用解密后的数据，构造新的读取流
-        InputStream rawInputStream = new ByteArrayInputStream(body);
-        return new HttpInputMessage() {
-            @Override
-            public HttpHeaders getHeaders() {
-                return httpInputMessage.getHeaders();
-            }
-
-            @Override
-            public InputStream getBody() throws IOException {
-                return rawInputStream;
-            }
-        };
-    }
-
-    /**
-     * @title 读取参数后执行
-     * @author Xingbz
-     */
-    @Override
-    public Object afterBodyRead(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("afterBodyRead:----");
-        return o;
-    }
-
-    /**
-     * @title 无请求时的处理
-     */
-    @Override
-    public Object handleEmptyBody(Object o, HttpInputMessage httpInputMessage, MethodParameter methodParameter, Type type, Class<? extends HttpMessageConverter<?>> aClass) {
-//        log.info("handleEmptyBody:----");
-        return o;
-    }
-}