反应式编程在Java框架中的性能优化策略

Mono<String> deferredMono = Mono.defer(() -> Mono.just("Deferred value"));

Flux<Integer> limitedFlux = Flux.interval(Duration.ofMillis(10))
    .limitRate(10);

Flux<String> errorResumedFlux = Flux.just("abc", "123")
    .map(Integer::parseInt)
    .onErrorResume(NumberFormatException.class, Mono.just(0));

@RestController
public class ExampleController {

    // 使用 Mono.defer() 避免阻塞
    @PostMapping("/data")
    public Mono<String> createData() {
        return Mono.defer(() -> {
            // 執行資料儲存並返回資料
            return Mono.just("Data saved successfully");
        });
    }

    // 使用 Schedulers.elastic() 優化调度器
    @GetMapping("/items")
    public Flux<Item> getItems() {
        return Flux.fromIterable(items)
            .subscribeOn(Schedulers.elastic());
    }

    // 使用 Mono/Flux.limitRate() 实现限流
    @GetMapping("/updates")
    public Flux<Update> getUpdates() {
        return Flux.interval(Duration.ofMillis(10))
            .limitRate(10);
    }

    // 使用 onErrorMap() 处理错误
    @PostMapping("/order")
    public Mono<Order> createOrder(@RequestBody Order order) {
        return Mono.just(order)
            .onErrorMap(NumberFormatException.class, e -> new InvalidOrderException("Invalid number"));
    }

}