• Mono 实现了 org.reactivestreams.Publisher 接口，代表0到1个元素的发布者
    • Flux 同样实现了 org.reactivestreams.Publisher 接口，代表0到N个元素的发布者

    export PATH=/Users/tlc/tools/mongodb-5.0.3/bin:$PATH

    2. @RestController
    3. @Slf4j
    4. public class TestController {
    6.     @GetMapping("/1")
    7.     private String get1() {
    8.         log.info("get1 start");
    9.         String result = createStr();
    10.         log.info("get1 end.");
    11.         return result;
    12.     }
    14.     @GetMapping("/2")
    15.     private Mono<String> get2() {
    16.         log.info("get2 start");
    17.         Mono<String> result = Mono.fromSupplier(() -> createStr());
    18.         log.info("get2 end.");
    19.         return result;
    20.     }
    22.     /**
    23.      * Flux : 返回0-n个元素
    24.      * 
    25.      * @return
    26.      */
    27.     @GetMapping(value = "/3", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    28.     private Flux<String> flux() {
    29.         Flux<String> result = Flux
    30.                 .fromStream(IntStream.range(1, 5).mapToObj(i -> {
    31.                     try {
    32.                         TimeUnit.SECONDS.sleep(1);
    33.                     } catch (InterruptedException e) {
    34.                     }
    35.                     return "flux data--" + i;
    36.                 }));
    37.         return result;
    38.     }
    40.     private String createStr() {
    41.         try {
    42.             TimeUnit.SECONDS.sleep(5);
    43.         } catch (InterruptedException e) {
    44.         }
    45.         return "some string";
    46.     }
    48. }