1 Mono 創(chuàng)建

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 當(dāng)訂閱成功或失敗后 返回另外一個publisherMono.zip(string -> string.length, Mono.just(1)).map(getIntegerIntegerFunction()).doOnSuccess(integer -> System.out.println("成功了")).doOnTerminate((a, e) -> System.out.println("結(jié)束了")).then(() -> Mono.just(888)).subscribe(System.out::println);System.out.println("---------- 分割線3 ----------");//冷/懶加載 當(dāng)deferMono被訂閱時，才會觸發(fā)1的feeService()Mono.defer(() -> Mono.just(feeService())) // 1.map(integer -> integer + 1).subscribe(System.out::println);//熱加載 Mono.just時，直接觸發(fā)了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在訂閱者取消或者異常時 能執(zhí)行3將資源清理// true&false暫時沒看到區(qū)別Mono.using(() -> 1, // 1 數(shù)據(jù)源integer -> Mono.just(2 + integer), // 2 最終返回integerSource -> System.out.println("清理結(jié)果是：" + integerSource), //3 根據(jù)4執(zhí)行3false)// 4 完成前調(diào)用 還是 完成后調(diào)用.flatMap(integer -> Mono.just(integer + 3)).subscribe(integer -> System.out.println("最終結(jié)果是：" + integer));Mono.using(() -> 1, // 1 數(shù)據(jù)源integer -> Mono.just(2 + integer), // 2 最終返回integerSource -> System.out.println("清理結(jié)果是：" + integerSource), //3 根據(jù)4執(zhí)行3true)// 4 完成前調(diào)用 還是 完成后調(diào)用.flatMap(integer -> Mono.just(integer + 3)).subscribe(integer -> System.out.println("最終結(jié)果是：" + 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()));

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。