将 Flux 数据收集到 Mono 中的 List 对象-java教程-PHP中文网

将 Flux 数据收集到 Mono 中的 List 对象

花韻仙語

发布： 2025-10-08 09:50:12

原创

478人浏览过

将 flux 数据收集到 mono 中的 list 对象

本文将介绍如何使用 Project Reactor 将一个 Flux<Item> 中的数据收集到一个 List<Item> 对象，并将其设置到 Mono<Person> 中的 Person 对象的 items 属性中。通过 collectList() 操作符，我们可以将 Flux 中的元素收集成一个 List，然后将其映射到 Mono 中，从而实现数据的转换和赋值。

在使用 Project Reactor 进行响应式编程时，经常会遇到需要将 Flux 中的数据收集到 List 中的场景，然后将这个 List 对象设置到 Mono 中的某个属性。下面将详细介绍如何实现这个功能。

示例代码

假设我们有以下 Person 类：

import java.util.List;

public class Person {

    private List<Item> items;

    public List<Item> getItems() {
        return items;
    }

    public void setItems(List<Item> items) {
        this.items = items;
    }
}

登录后复制

以及 Item 类（假设）：

public class Item {
    private String name;

    public Item(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

登录后复制

现在，我们有一个 Flux<Item>，需要将其收集到一个 List<Item> 中，然后将这个 List 设置到 Mono<Person> 中的 Person 对象的 items 属性中。

Boomy

AI音乐生成工具，创建生成音乐,与世界分享.

272

查看详情

以下是实现这个功能的代码：

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.util.List;

public class FluxToListExample {

    public Mono<Person> createPersonFromReceivedItems(Flux<Item> items) {
        Mono<List<Item>> collectedItems = items.collectList();
        Mono<Person> result = collectedItems.map(itemList -> {
            Person p = new Person();
            p.setItems(itemList);
            return p;
        });

        return result;
    }

    public static void main(String[] args) {
        // 模拟 service 层返回的 Flux<Item>
        Flux<Item> items = Flux.just(new Item("Item1"), new Item("Item2"), new Item("Item3"));

        FluxToListExample example = new FluxToListExample();
        Mono<Person> personMono = example.createPersonFromReceivedItems(items);

        // 订阅 Mono<Person> 并输出结果
        personMono.subscribe(person -> {
            System.out.println("Person items: " + person.getItems().toString());
        });
    }
}

登录后复制

代码解释

Flux<Item> items = service.getItems();: 获取 Flux<Item> 数据流（在本示例的 main 方法中，直接创建了一个 Flux<Item> 用于演示）。
Mono<List<Item>> collectedItems = items.collectList();: 使用 collectList() 操作符将 Flux<Item> 中的所有元素收集到一个 List<Item> 中，并将其封装成一个 Mono<List<Item>>。collectList() 会等待 Flux 完成，然后发出包含所有元素的列表。
Mono<Person> result = collectedItems.map(itemList -> { ... });: 使用 map 操作符将 Mono<List<Item>> 转换为 Mono<Person>。在 map 操作符中，我们创建一个新的 Person 对象，并将收集到的 List<Item> 设置到 Person 对象的 items 属性中。

注意事项

collectList() 操作符会等待 Flux 完成后才会发出 List。如果 Flux 是一个无限流，collectList() 将永远不会完成。
如果 Flux 发出错误，collectList() 也会发出错误。
使用 collectList() 操作符需要注意内存消耗，因为需要将 Flux 中的所有元素都存储到内存中。如果 Flux 中的元素数量非常大，可能会导致内存溢出。在这种情况下，可以考虑使用其他操作符，例如 window 和 flatMap，将 Flux 分成多个小块进行处理。

总结

通过使用 collectList() 操作符，我们可以方便地将 Flux 中的数据收集到一个 List 中，并将其设置到 Mono 中的某个属性。这种方法适用于需要将多个元素组合成一个对象的情况。在实际应用中，需要根据具体情况选择合适的操作符，以避免出现性能问题。

以上就是将 Flux 数据收集到 Mono 中的 List 对象的详细内容，更多请关注php中文网其它相关文章！