修改经过Spring Gateway的Json数据

背景

使用Spring Cloud Gateway作为网关时经常会需要对报文内的json数据进行修改，但是目前看到的实现方法看起来都很复杂，这里提供一种使用Spring官方提供的ModifyRequestBodyGatewayFilterFactory类来修改json报文的方法
依赖

• Spring Boot版本：2.7.15
  
• Hutool: 5.8.21
  
• Java: 11
  

实现逻辑

实现分为两个部分

• filter：在自定义的filter内注入ModifyRequestBodyGatewayFilterFactory类，然后调用，该类会自动完成对修改结果的重新包装。
  
• service: 自定义的service实现ModifyRequestBodyGatewayFilterFactory类的RewriteFunction接口完成对json数据的处理
  

自定义filter

1. @Component
2. @Slf4j
3. public class RequestModifyFilter implements GlobalFilter, Ordered {
4.     @Autowired
5.     private ModifyRequestBodyGatewayFilterFactory modifyRequestBodyFilter;
6.     @Autowired
7.     private JsonRequestBodyRewriteService jsonRequestBodyRewriteService;
9.     @Override
10.     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
11.         MediaType mediaType = exchange.getRequest().getHeaders().getContentType();
12.         if (MediaType.APPLICATION_json.isCompatibleWith(mediaType)) {
13.             // 纯json报文处理逻辑
14.             return modifyRequestBodyFilter
15.                     .apply(
16.                             new ModifyRequestBodyGatewayFilterFactory.Config()
17.                                     .setRewriteFunction(byte[].class, byte[].class, jsonRequestBodyRewriteService))
18.                     .filter(exchange, chain);
19.         } else {
20.             return filter(exchange, chain);
21.         }
23.     }
25.     @Override
26.     public int getOrder() {
27.         return OrderConstant.REQUEST_MODIFY_FILTER.getOrder();
28.     }
29. }

复制代码

自定义service

1. @Service
2. @Slf4j
3. public class JsonRequestBodyRewriteService implements RewriteFunction<byte[], byte[]> {
4.     @Override
5.     public Publisher<byte[]> apply(ServerWebExchange exchange, byte[] body) {
6.         jsonObject request = jsonUtil.parseObj(body);
7.         log.info("原始报文:{}", request.toString());
8.         try {
9.             request.set("empId", "2345");
10.             request.set("department", "Engineering");
12.             log.info("修改后报文:{}", request);
13.             return Mono.just(request.toString().getBytes());
14.         } catch (Exception e) {
15.             log.error("修改报文时出错",e);
16.             throw e;
17.         }
18.     }
19. }

复制代码

相关代码

https://github.com/eastcukt/demo-gatway
参考

https://amitkhurana92.medium.com/request-body-transformation-in-spring-cloud-gateway-bb9c234d5f3d

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！