[Spring Cloud] gateway整体加解密

在Spring Cloud Gateway中实现整体加解密，通常需要自定义过滤器来处理加解密逻辑。以下是一个简单的例子，展示了如何创建一个自定义过滤器来处理加解密。

1. 创建一个自定义过滤器：

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.server.reactive.ServerHttpRequestDecorator;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
import java.nio.charset.StandardCharsets;
 
public class EncryptDecryptFilter implements GlobalFilter {
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 从请求体中读取数据进行解密
        return DataBufferUtils.join(exchange.getRequest().getBody())
                .flatMap(dataBuffer -> {
                    byte[] bytes = new byte[dataBuffer.readableByteCount()];
                    dataBuffer.read(bytes);
                    // 假设decrypt是自定义的解密方法
                    String decryptedBody = decrypt(new String(bytes, StandardCharsets.UTF_8));
                    ServerHttpRequestDecorator decorator = new ServerHttpRequestDecorator(exchange.getRequest()) {
                        @Override
                        public Flux<DataBuffer> getBody() {
                            return Flux.just(buffer(decryptedBody.getBytes(StandardCharsets.UTF_8)));
                        }
                    };
                    return chain.filter(exchange.mutate().request(decorator).build());
                });
    }
 
    // 自定义解密逻辑
    private String decrypt(String encryptedBody) {
        // 实现解密逻辑
        // ...
        return "解密后的数据";
    }
}

2. 注册自定义过滤器：

import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class GatewayConfig {
 
    @Bean
    public EncryptDecryptFilter encryptDecryptFilter() {
        return new EncryptDecryptFilter();
    }
 
    // 其他配置...
}

3. 在需要应用过滤器的路由中使用：

spring:
  cloud:
    gateway:
      routes:
        - id: my_route
          uri: http://myservice
          filters:
            - EncryptDecryptFilter