解决org.springframework.core.io.buffer.DataBufferLimitException: Exceeded limit on max bytes to buffer : 262144

gateway/src/main/java/com/xhkjedu/gateway/config/ConfigKey.java

@@ -38,4 +38,10 @@ public class ConfigKey {
         this.buildnum = buildnum;
     }
 
+    public static Integer paramsize;//参数大小限制
+
+    @Value("${paramsize}")
+    public void setParamsize(Integer paramsize) {
+        ConfigKey.paramsize = paramsize;
+    }
 }

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

@@ -20,6 +20,7 @@ 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.codec.ServerCodecConfigurer;
 import org.springframework.http.server.reactive.ServerHttpRequest;
 import org.springframework.http.server.reactive.ServerHttpRequestDecorator;
 import org.springframework.http.server.reactive.ServerHttpResponse;
@@ -27,12 +28,12 @@ import org.springframework.stereotype.Component;
 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 javax.annotation.PostConstruct;
 import javax.annotation.Resource;
 import java.util.List;
 import java.util.Map;
@@ -45,7 +46,7 @@ import java.util.stream.Collectors;
  **/
 @Component
 @Slf4j
-public class DecryptRequestionBodyFilter extends JedisUtil implements GlobalFilter, Ordered {
+public class DecryptRequestionBodyFilter implements GlobalFilter, Ordered {
     @Value("${Xh-St}")
     private String xhSt;
     @Value("${whitelistAPI}")
@@ -55,6 +56,16 @@ public class DecryptRequestionBodyFilter extends JedisUtil implements GlobalFilt
 
     @Resource
     private ModuleCheckMapper moduleCheckMapper;
+    @Resource
+    private ServerCodecConfigurer codecConfigurer;
+    @Resource
+    private JedisUtil jedisUtil;
+
+    @PostConstruct
+    public void init() {
+        ServerCodecConfigurer.ServerDefaultCodecs serverDefaultCodecs = codecConfigurer.defaultCodecs();
+        serverDefaultCodecs.maxInMemorySize(ConfigKey.paramsize);//设置限制50MB
+    }
 
     @SneakyThrows
     @Override
@@ -93,13 +104,13 @@ public class DecryptRequestionBodyFilter extends JedisUtil implements GlobalFilt
         String key = ApiUtil.listToStr(headers.get("Xh-Token-Key"));
         String token = ApiUtil.listToStr(headers.get("Xh-Token-Value"));
         if (!rtn) {//非白名单接口验证token
-            String redis_token = get(key);//系统缓存中保存的token
+            String redis_token = jedisUtil.get(key);//系统缓存中保存的token
 
             if (ApiUtil.isEmpty(token) || !token.equals(redis_token)
                     || ApiUtil.isEmpty(key) || !key.split("_")[1].equals(userid)) {
                 throw new GatewayException(2, "登录失效");
             } else {
-                refreshToken(key, redis_token);//刷新token
+                jedisUtil.refreshToken(key, redis_token);//刷新token
             }
         }
 
@@ -108,7 +119,7 @@ public class DecryptRequestionBodyFilter extends JedisUtil implements GlobalFilt
             SchoolVo schoolVo = moduleCheckMapper.getSchoolCloudByUserid(Integer.parseInt(userid));
             if(schoolVo.getUsertype() == 1 || schoolVo.getUsertype() == 0){
                 String umodule_key = schoolVo.getCloudcode() + "_module_" + schoolVo.getSchoolid() + "_" + userid;
-                String umodule_value = get(umodule_key);//获取用户的模块权限
+                String umodule_value = jedisUtil.get(umodule_key);//获取用户的模块权限
                 List<String> userModules = null;//用户模块全新啊
 
                 if(ApiUtil.isEmpty(umodule_value)){
@@ -116,7 +127,7 @@ public class DecryptRequestionBodyFilter extends JedisUtil implements GlobalFilt
                     userModules = moduleCheckMapper.listModuleurlsByUserid(Integer.parseInt(userid));
                     if(ApiUtil.isListNotEmpty(userModules)){
                         //用户有模块权限，存入缓存
-                        set(umodule_key, userModules, ConfigKey.redisumtime);
+                        jedisUtil.set(umodule_key, userModules, ConfigKey.redisumtime);
                     }else{
                         throw new GatewayException(1, "没有权限");
                     }
@@ -125,12 +136,12 @@ public class DecryptRequestionBodyFilter extends JedisUtil implements GlobalFilt
                 }
 
                 String allmodule_key = "modules_operate";//校验模块对应操作
-                String allmodule_value = get(allmodule_key);
+                String allmodule_value = jedisUtil.get(allmodule_key);
                 List<TModuleCheck> allModules = null;//校验模块对应操作
                 if(ApiUtil.isEmpty(allmodule_value)){
                     allModules = moduleCheckMapper.listAllModuleChecks();
                     if(ApiUtil.isListNotEmpty(allModules)){
-                        set(allmodule_key,allModules,ConfigKey.redismoduletime);
+                        jedisUtil.set(allmodule_key,allModules,ConfigKey.redismoduletime);
                     }
                 }else{
                     allModules = JSON.parseArray(allmodule_value,TModuleCheck.class);
@@ -187,7 +198,8 @@ public class DecryptRequestionBodyFilter extends JedisUtil implements GlobalFilt
     }
     private Mono<Void> readBody(ServerWebExchange exchange, GatewayFilterChain chain) {
         //重新构造request，参考ModifyRequestBodyGatewayFilterFactory
-        ServerRequest serverRequest = ServerRequest.create(exchange, HandlerStrategies.withDefaults().messageReaders());
+        //ServerRequest serverRequest = ServerRequest.create(exchange, HandlerStrategies.withDefaults().messageReaders());
+        ServerRequest serverRequest = ServerRequest.create(exchange, codecConfigurer.getReaders());
         MediaType mediaType = exchange.getRequest().getHeaders().getContentType();
         //重点
         Mono<String> modifiedBody = serverRequest.bodyToMono(String.class).flatMap(body -> {

gateway/src/main/java/com/xhkjedu/gateway/utils/JedisUtil.java

@@ -76,7 +76,7 @@ public class JedisUtil {
 		try {
 			return get(key, NOT_EXPIRE);
 		} catch (Exception e) {
-			return "0";
+			return "";
 		}
 	}
 

gateway/src/main/resources/application.properties

@@ -123,6 +123,8 @@ whitelistAPI=user/login,user/loginstu,/class_student/stu_class,/user/detail,/sta
   ,/section/get_zjr,/csw/add,/xz/import,/agora_token/rtc_token,/epqt/pqs,/eb/get_mn,/scan/save,/eps/sca,/eps/scaer\
   ,module/treelst,std/td_num,user/check_login
 
+#参数大小限制50M
+paramsize=52428800
 
 #版本号
 buildnum=300