java响应式编程

// 引入必要的库
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class ReactiveProgrammingExample {

    // 使用Flux处理多个元素的流
    public void fluxExample() {
        Flux<String> stringFlux = Flux.just("Hello", "Reactive", "World");

        // 订阅并打印每个元素
        stringFlux.subscribe(System.out::println);
    }

    // 使用Mono处理单个元素的流
    public void monoExample() {
        Mono<String> stringMono = Mono.just("Hello Reactive Mono");

        // 订阅并打印单个元素
        stringMono.subscribe(System.out::println);
    }

    public static void main(String[] args) {
        ReactiveProgrammingExample example = new ReactiveProgrammingExample();

        // 执行Flux示例
        System.out.println("Flux Example:");
        example.fluxExample();

        // 执行Mono示例
        System.out.println("Mono Example:");
        example.monoExample();
    }
}

解释说明

1. 引入库：我们使用了reactor库中的Flux和Mono类，它们是响应式编程的核心组件。

   • Flux用于处理0到N个元素的异步序列。
   • Mono用于处理0或1个元素的异步序列。

2. Flux 示例：

   • Flux.just("Hello", "Reactive", "World")创建了一个包含三个字符串的Flux对象。
   • subscribe(System.out::println)订阅了这个流，并将每个元素打印出来。

3. Mono 示例：

   • Mono.just("Hello Reactive Mono")创建了一个包含单个字符串的Mono对象。
   • subscribe(System.out::println)订阅了这个流，并将单个元素打印出来。

4. main 方法：

   • 创建了一个ReactiveProgrammingExample实例，并分别调用了fluxExample和monoExample方法来展示如何使用Flux和Mono。