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.core.io.buffer.NettyDataBufferFactory;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.http.ResponseCookie;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
import java.nio.charset.StandardCharsets;
 
@Component
public class EncryptResponseGlobalFilter implements GlobalFilter {
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpResponse originalResponse = exchange.getResponse();
        
        // 使用Decorator模式来自定义ServerHttpResponse
        ServerHttpResponseDecorator decoratedResponse = new ServerHttpResponseDecorator(originalResponse) {
            @Override
            public Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {
                if (body instanceof Flux) {
                    Flux<? extends DataBuffer> fluxBody = (Flux<? extends DataBuffer>) body;
 
                    return super.writeWith(fluxBody.map(dataBuffer -> {
                        // 对数据进行加密
                        byte[] content = new byte[dataBuffer.readableByteCount()];
                        dataBuffer.read(content);
                        // 假设这里的encrypt是加密逻辑，将content加密后返回
                        byte[] encryptedContent = encrypt(content);
 
                        // 使用NettyDataBufferFactory重新构建DataBuffer
                        NettyDataBufferFactory nettyDataBufferFactory = new NettyDataBufferFactory(ByteBufAllocator.DEFAULT);
                        DataBuffer encryptedDataBuffer = nettyDataBufferFactory.wrap(encryptedContent);
                        return encryptedDataBuffer;
                    }));
                }
 
                // 否则，直接写入原始响应
                return super.writeWith(body);
            }
        };
 
        // 将修改后的ServerHttpResponse设置回exchange
        return chain.filter(exchange.mutate().response(decoratedResponse).build());
    }
 
    // 这里是一个加密的示例方法，实际使用时需要替换为真实的加密逻辑
    private byte[] encrypt(byte[] content) {
        // 加密逻辑...