1 Mono 創建

Mono.just(1).mergeWith(Flux.just(1, 2, 3)).subscribe(System.out::print); System.out.println(); Mono.fromSupplier(() -> "Hello").subscribe(System.out::println); Mono.justOrEmpty(Optional.of("Hello")).subscribe(System.out::println); Mono.create(sink -> sink.success("Hello")).subscribe(System.out::println);

2 Mono 操作符

// zip 將多個Mono合并成一個MonoMono.zip(string -> string.length, Mono.just(1), Mono.just(2)).subscribe(System.out::println);System.out.println("---------- 分割線2 ----------");// then 當訂閱成功或失敗后 返回另外一個publisherMono.zip(string -> string.length, Mono.just(1)).map(getIntegerIntegerFunction()).doOnSuccess(integer -> System.out.println("成功了")).doOnTerminate((a, e) -> System.out.println("結束了")).then(() -> Mono.just(888)).subscribe(System.out::println);System.out.println("---------- 分割線3 ----------");//冷/懶加載 當deferMono被訂閱時，才會觸發1的feeService()Mono.defer(() -> Mono.just(feeService())) // 1.map(integer -> integer + 1).subscribe(System.out::println);//熱加載 Mono.just時，直接觸發了1的feeService()Mono.just(feeService()) //1.map(integer -> integer + 1).subscribe(System.out::println);System.out.println("---------- 分割線4 ----------");Mono.delay(Duration.ofMillis(3)).subscribe(System.out::println);TimeUnit.SECONDS.sleep(1);System.out.println("---------- 分割線5 ----------");// using在訂閱者取消或者異常時 能執行3將資源清理// true&false暫時沒看到區別Mono.using(() -> 1, // 1 數據源integer -> Mono.just(2 + integer), // 2 最終返回integerSource -> System.out.println("清理結果是：" + integerSource), //3 根據4執行3false)// 4 完成前調用 還是 完成后調用.flatMap(integer -> Mono.just(integer + 3)).subscribe(integer -> System.out.println("最終結果是：" + integer));Mono.using(() -> 1, // 1 數據源integer -> Mono.just(2 + integer), // 2 最終返回integerSource -> System.out.println("清理結果是：" + integerSource), //3 根據4執行3true)// 4 完成前調用 還是 完成后調用.flatMap(integer -> Mono.just(integer + 3)).subscribe(integer -> System.out.println("最終結果是：" + integer));Mono<Void> when = Mono.when();Mono.when(Mono.just(1), Mono.just(2), (m1, m2) -> m1 + m2).subscribe(System.out::println);Mono.just(1).concatWith(Mono.just(2)).subscribe(System.out::println);}private static Integer feeService() {//doSomething//call db//calculate feereturn 1; }private static Function<Integer, Integer> getIntegerIntegerFunction() {return integer -> {integer = integer + 1;System.out.println("----->" + integer);return integer;}; }

返回異常：

Mono.just(1).doOnError(e -> Mono.error(e.getMessage()));

總結

以上是生活随笔為你收集整理的Reactor3 Mono的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。