在Spring webflux Webfilter上完成服务后执行某些操作

import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilter;
import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Mono;

@Component
public class MyFilter implements WebFilter {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
        // 对请求进行修改或添加额外的处理逻辑
        exchange.getRequest().mutate().header("X-Custom-Header", "Custom Value");

        // 在完成服务后执行某些操作
        return chain.filter(exchange).doOnSuccess(aVoid -> {
            // 执行一些清理操作
            System.out.println("Request processed successfully");
        }).doOnError(throwable -> {
            // 处理异常情况
            System.out.println("Error occurred during request processing");
        }).onErrorResume(throwable -> {
            // 返回自定义的响应
            exchange.getResponse().setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);
            return exchange.getResponse().setComplete();
        });
    }
}