从多个Flux中查找重复元素及其计数

import reactor.core.publisher.Flux;
import reactor.util.function.Tuple2;

public class DuplicateElementFinder {
    public static void main(String[] args) {
        // 创建多个Flux
        Flux<Integer> flux1 = Flux.just(1, 2, 3, 4, 5);
        Flux<Integer> flux2 = Flux.just(4, 5, 6, 7, 8);
        Flux<Integer> flux3 = Flux.just(7, 8, 9, 10, 11);

        // 合并多个Flux为一个Flux
        Flux<Integer> mergedFlux = Flux.concat(flux1, flux2, flux3);

        // 从合并的Flux中查找重复元素及其计数
        mergedFlux
                .groupBy(key -> key) // 按照元素的值进行分组
                .flatMap(groupedFlux -> groupedFlux.count().map(count -> new Tuple2<>(groupedFlux.key(), count))) // 计算元素的数量
                .filter(tuple -> tuple.getT2() > 1) // 筛选出数量大于1的元素
                .subscribe(tuple -> {
                    System.out.println("重复元素：" + tuple.getT1() + "，数量：" + tuple.getT2());
                    // 在这里可以添加推荐的腾讯云相关产品和产品介绍链接地址
                });
    }
}