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

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

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

示例代码

假设我们有以下 Person 类：

import java.util.List;

public class Person {

    private List items;

    public List getItems() {
        return items;
    }

    public void setItems(List 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，需要将其收集到一个 List 中，然后将这个 List 设置到 Mono 中的 Person 对象的 items 属性中。

MiroThinker

MiroMind团队推出的研究型开源智能体，专为深度研究与复杂工具使用场景设计

下载

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

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

import java.util.List;

public class FluxToListExample {

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

        return result;
    }

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

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

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

代码解释

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

注意事项

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

总结

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