Spring Cloud Gateway与spring-cloud-circuitbreaker集成与理解

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.cloud.gateway.filter.factory.rewrite.CipherFilter;
import org.springframework.core.Ordered;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
import java.nio.charset.StandardCharsets;
 
public class CustomCipherFilter implements GlobalFilter, Ordered {
 
    private final CipherFilter cipherFilter;
 
    public CustomCipherFilter(CipherFilter cipherFilter) {
        this.cipherFilter = cipherFilter;
    }
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        return chain.filter(exchange).then(Mono.defer(() -> {
            ServerHttpResponse response = exchange.getResponse();
            // 这里可以添加自定义逻辑，比如记录响应数据等
            return response.getBody();
        }));
    }
 
    @Override
    public int getOrder() {
        // 设置过滤器顺序
        return cipherFilter.getOrder();
    }
}

这个代码示例展示了如何自定义一个全局过滤器，它将在Spring Cloud Gateway中拦截请求和响应。这个过滤器使用了CipherFilter的顺序，并添加了自定义逻辑。在实际应用中，你可以在then方法中添加任何你需要的操作，比如记录响应数据或者修改响应体。