webflux test

Author: Janloong-Doo

jdk-study/src/main/java/com/janloong/javabase/streamapi/sortString.java

@@ -9,6 +9,7 @@
 
 package com.janloong.javabase.streamapi;
 
+import java.util.*;
 import java.util.stream.Stream;
 
 /**

request/spring-demo/webflux.http

@@ -1,5 +1,14 @@
 ###
-GET http://localhost:8080/hello
+GET http://localhost:8080/home/hello
+
+###
+GET http://localhost:8080/home/async
+
+###
+GET http://localhost:8080/home/flux
+
+###
+GET http://localhost:8080/home/flux2
 
 ###
 

spring-demo/spring-webflux/src/main/java/com/janloong/demo/controller/HomeController.java

@@ -0,0 +1,68 @@
+package com.janloong.demo.webflux.controller;
+
+
+import com.janloong.common.utils.ResponseResult;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+ * @date 2020-03-24 21:57
+ */
+@RestController
+@RequestMapping("/home")
+@Slf4j
+public class HomeController {
+
+    /**
+     * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+     * @date 2020/3/24 0024 21:57
+     **/
+    @GetMapping("/hello")
+    public Mono<ResponseResult> hello() {
+        return Mono.just(ResponseResult.success("hello, webflux"));
+    }
+
+    /**
+     * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+     * @date 2020/3/25 10:08
+     **/
+    @RequestMapping("/async")
+    //public Mono<ResponseResult> async() {
+    public Mono<Object> async() {
+
+        return Mono.create(monoSink -> {
+            log.info("mono创建");
+            monoSink.success(ResponseResult.success("hello, mono created"));
+        })
+                .doOnSubscribe(subscription -> { //当订阅者去订阅发布者的时候，该方法会调用
+                    log.info("被订阅了?");
+                    log.info("{}", subscription);
+                }).doOnNext(o -> { //当订阅者收到数据时，改方法会调用
+                    log.info("订阅者收到消息");
+                    log.info("{}", o);
+                });
+    }
+
+    /**
+     * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+     * @date 2020/3/25 10:19
+     **/
+    @RequestMapping("/flux")
+    public Flux<String> flux() {
+        return Flux.just("hello", "webflux", "spring", "boot");
+    }
+
+    /**
+     * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+     * @date 2020/3/25 10:19
+     **/
+    @RequestMapping("/flux2")
+    public Flux<ResponseResult> flux2() {
+        return Flux.just(ResponseResult.success("hello"), ResponseResult.success("webflux"), ResponseResult.success("spring"), ResponseResult.success("boot"));
+    }
+}

spring-demo/spring-webflux/src/main/java/com/janloong/demo/webflux/controller/HomeController.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) 2020  All Rights Reserved.
+ * ProjectName: cloud
+ * FileName: HomeHandler.java
+ * Author: janloongdoo@gmail.com
+ * Website: www.janloong.com
+ * Date: 2020/3/25 上午9:50
+ * LastModify: 2020/3/25 上午9:50
+ */
+
+package com.janloong.demo.webflux.controller.handler;
+
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.BodyInserters;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.ServerResponse;
+import reactor.core.publisher.Mono;
+
+/**
+ * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+ * @version V1.0
+ * @date 2020-03-25 09:50
+ **/
+//@Component
+public class HomeHandler {
+
+    public Mono<ServerResponse> helloHome(ServerRequest request) {
+        return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
+                .body(BodyInserters.fromObject("Hello, City!"));
+    }
+}

spring-demo/spring-webflux/src/main/java/com/janloong/demo/webflux/controller/handler/HomeHandler.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright (c) 2020  All Rights Reserved.
+ * ProjectName: cloud
+ * FileName: HomeRouter.java
+ * Author: janloongdoo@gmail.com
+ * Website: www.janloong.com
+ * Date: 2020/3/25 上午9:54
+ * LastModify: 2020/3/25 上午9:54
+ */
+
+package com.janloong.demo.webflux.controller.router;
+
+import com.janloong.demo.webflux.controller.handler.HomeHandler;
+import org.springframework.context.annotation.Bean;
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.server.RequestPredicates;
+import org.springframework.web.reactive.function.server.RouterFunction;
+import org.springframework.web.reactive.function.server.RouterFunctions;
+import org.springframework.web.reactive.function.server.ServerResponse;
+
+/**
+ * @author <a href ="mailto: janloongdoo@gmail.com">Janloong</a>
+ * @version V1.0
+ * @date 2020-03-25 09:54
+ **/
+//@Configuration
+public class HomeRouter {
+
+    @Bean
+    public RouterFunction<ServerResponse> routeCity(HomeHandler homeHandler) {
+        return RouterFunctions
+                .route(RequestPredicates.GET("/hello")
+                                .and(RequestPredicates.accept(MediaType.TEXT_PLAIN)),
+                        homeHandler::helloHome);
+    }
+}