Mono\Flux上map和subscribe的区别？_flatmap和map的区别_map和flatmap的区别 - 腾讯云开发者社区

Mono 和 Flux 的 map 和 subscribe 区别

基础概念

Mono 和 Flux 是 Project Reactor 中的两个核心类，用于处理异步数据流。Mono 表示一个单一的数据元素，而 Flux 表示多个数据元素的流。

Mono：表示一个单一的、可能是延迟的结果。
Flux：表示一个包含 0 到 N 个元素的异步序列。

map 操作

map 是一个操作符，用于对数据流中的每个元素进行转换。它接受一个函数作为参数，这个函数会被应用到每个元素上，生成一个新的元素。

Flux<Integer> flux = Flux.just(1, 2, 3);
Flux<String> mappedFlux = flux.map(i -> "Value: " + i);

在这个例子中，map 将每个整数转换为字符串。

subscribe 操作

subscribe 是一个终端操作，用于启动数据流的消费过程。它接受一个或多个订阅者（Subscriber），这些订阅者会处理数据流中的元素。

Flux<Integer> flux = Flux.just(1, 2, 3);
flux.subscribe(
    i -> System.out.println("Received: " + i),
    err -> System.err.println("Error: " + err),
    () -> System.out.println("Done")
);

在这个例子中，subscribe 启动了数据流的处理，并定义了如何处理每个元素、错误和完成事件。

区别

目的：
- map：用于对数据流中的每个元素进行转换，生成一个新的数据流。
- subscribe：用于启动数据流的消费过程，定义如何处理数据流中的元素。

返回值：
- map：返回一个新的 Flux 或 Mono，表示转换后的数据流。
- subscribe：不返回任何值，它只是启动数据流的处理。
链式操作：
- map：可以与其他操作符（如 filter、flatMap）链式调用，形成复杂的数据处理流程。
- subscribe：是终端操作，不能与其他操作符链式调用。

应用场景

map：当你需要对数据流中的每个元素进行某种转换（如类型转换、数据格式化）时，使用 map。
subscribe：当你准备好消费数据流并处理其中的元素时，使用 subscribe。

示例代码

import reactor.core.publisher.Flux;

public class MapVsSubscribeExample {
    public static void main(String[] args) {
        Flux<Integer> flux = Flux.just(1, 2, 3);

        // 使用 map 进行转换
        Flux<String> mappedFlux = flux.map(i -> "Value: " + i);

        // 使用 subscribe 消费数据流
        mappedFlux.subscribe(
            s -> System.out.println("Received: " + s),
            err -> System.err.println("Error: " + err),
            () -> System.out.println("Done")
        );
    }
}