Spring Reactor合并vs Concat

问题描述

我在玩Spring Reactor，我看不到 concat 和 merge 运算符

I´m playing with Spring reactor, and I cannot see any differences between concat and merge operator

这是我的例子

    @Test
    public void merge() {
        Flux<String> flux1 = Flux.just("hello").doOnNext(value -> {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        Flux<String> flux2 = Flux.just("reactive").doOnNext(value -> {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        Flux<String> flux3 = Flux.just("world");
        Flux.merge(flux1, flux2, flux3)
                .map(String::toUpperCase)
                .subscribe(System.out::println);
    }

    @Test
    public void concat() {
        Flux<String> flux1 = Flux.just("hello").doOnNext(value -> {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        Flux<String> flux2 = Flux.just("reactive").doOnNext(value -> {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        Flux<String> flux3 = Flux.just("world");
        Flux.concat(flux1, flux2, flux3)
                .map(String::toUpperCase)
                .subscribe(System.out::println);
}

两者的行为完全相同.有人可以解释这两种操作之间的区别吗?

Both behave exactly the same. Can someone explain the difference between the two operations?

推荐答案

merge和concat之间的本质区别是在合并中，两个流都是实时的.如果使用concat，则首先终止流，然后将另一流连接到该流.

The essential difference between merge and concat is that in merge, both streams are live. In case of concat, first stream is terminated and then the other stream is concatenated to it.

这篇关于Spring Reactor合并vs Concat的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！