优化Spring Webflux Controller中对请求体对象的访问策略

@PostMapping("url")
public Mono<MyResponse> getMyResponse(@RequestBody Mono<MyRequest> myRequestMono) {
    return urlService.getUrl(myRequestMono)
            .doOnNext(url -> {
                // 此时无法直接访问 myRequestMono 内部的 MyRequest 字段
                System.out.println("Generated URL: Successfully ");
            })
            .map(dto -> MyResponse.builder().url(dto).build())
            .doOnError(e -> System.out.println("Error " + e));
}

import reactor.core.publisher.Mono;
import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("/api")
public class MyController {

    private final UrlService urlService; // 假设 UrlService 已经注入

    public MyController(UrlService urlService) {
        this.urlService = urlService;
    }

    @PostMapping("url")
    public Mono<MyResponse> getMyResponse(@RequestBody MyRequest myRequest) {
        // myRequest 对象在此处已完全反序列化并可用
        System.out.println("Received request with field: " + myRequest.getSomeField()); // 示例访问

        // 如果服务层需要 Mono<MyRequest>，则将其包装
        return urlService.getUrl(Mono.just(myRequest))
                .doOnNext(url -> {
                    // 此时 myRequest 对象在闭包中仍然可访问
                    System.out.println("Generated URL: Successfully for request with ID: " + myRequest.getId());
                })
                .map(dto -> MyResponse.builder().url(dto).build())
                .doOnError(e -> System.out.println("Error occurred: " + e.getMessage()));
    }
}

import reactor.core.publisher.Mono;
import org.springframework.stereotype.Service;

@Service
public class UrlService {

    public Mono<String> getUrl(Mono<MyRequest> myRequestMono) {
        return myRequestMono.map(myRequest -> {
            // 在这里可以继续处理 myRequest
            System.out.println("Service processing request for ID: " + myRequest.getId());
            callSomething(); // 假设这是一个业务逻辑方法
            return "something"; // 返回处理结果
        });
    }

    private void callSomething() {
        // 模拟一些耗时操作
        System.out.println("Calling external service...");
    }
}

// MyRequest.java
public class MyRequest {
    private String id;
    private String someField;

    // 构造函数、Getter、Setter
    public MyRequest() {}

    public MyRequest(String id, String someField) {
        this.id = id;
        this.someField = someField;
    }

    public String getId() { return id; }
    public void setId(String id) { this.id = id; }
    public String getSomeField() { return someField; }
    public void setSomeField(String someField) { this.someField = someField; }

    @Override
    public String toString() {
        return "MyRequest{" +
               "id='" + id + '\'' +
               ", someField='" + someField + '\'' +
               '}';
    }
}

// MyResponse.java
public class MyResponse {
    private String url;

    // 构造函数、Getter、Setter
    public MyResponse() {}

    public MyResponse(String url) { this.url = url; }

    public String getUrl() { return url; }
    public void setUrl(String url) { this.url = url; }

    public static Builder builder() { return new Builder(); }

    public static class Builder {
        private String url;
        public Builder url(String url) { this.url = url; return this; }
        public MyResponse build() { return new MyResponse(url); }
    }
}