springboot webflux flux 使用示例（聚合操作）

快来打我* 2023-02-21 04:49 64阅读 0赞

--------------------

### springboot webflux flux 使用示例（聚合操作） ###

### \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* ###

**group**

public class Test {
    
        public static void main(String[] args){
            Flux.just(1,2,3,4,5,6).groupBy(value -> value<3)
                    .subscribe(flux -> {
                        if (Objects.equals(flux.key(),Boolean.TRUE)){
                            System.out.print("key为"+flux.key()+"的个数为：");
                            flux.count().subscribe(System.out::println);
                        }
                    });
        }
    }

**\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\***

**控制台输出**

key为true的个数为：2

### \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* ###

**sort、distinct、count**

public class Test2 {
    
        public static void main(String[] args){
            Flux.just(1,20,31,4,5,6,65,23,12,32).sort()
                    .subscribe(value ->System.out.print(value+"  "));
    
            System.out.println("\n\n***************");
            Flux.just("瓜田李下","瓜田李下2","hello world","hello world","gtlx","瓜田李下")
                    .distinct()
                    .subscribe(value -> System.out.print(value+"  "));
    
            System.out.println("\n\n***************");
            Flux.just("瓜田李下","瓜田李下2","hello world","hello world2")
                    .count()
                    .subscribe(value -> System.out.println("元素的个数为："+value));
        }
    }

**\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\***

**控制台输出**

1  4  5  6  12  20  23  31  32  65  
    
    ***************
    瓜田李下  瓜田李下2  hello world  gtlx  
    
    ***************
    元素的个数为：4

### \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* ###

**reduce**

public class Test3 {
    
        public static void main(String[] args){
            Flux.just(1,2,3,4).reduce(Integer::sum).subscribe(System.out::println);
            Flux.just(1,2,3,4).reduce(10,Integer::sum).subscribe(System.out::println);
        }
    }

**\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\***

**控制台输出**

10
    20