摘要：是一個(gè)全新的非堵塞的函數(shù)式框架，可以用來(lái)構(gòu)建異步的非堵塞的事件驅(qū)動(dòng)的服務(wù)。上面是一個(gè)簡(jiǎn)單的只相應(yīng)了一個(gè)字符串上面是對(duì)應(yīng)的對(duì)應(yīng)的是匹配一個(gè)方式的請(qǐng)求，然后調(diào)用中的方法向?yàn)g覽器輸出一個(gè)文本類型的字符串再來(lái)一個(gè)例子賬號(hào)或密碼錯(cuò)誤無(wú)效

Spring 5.0 Spring webflux 是一個(gè)全新的非堵塞的函數(shù)式 Reactive Web 框架，可以用來(lái)構(gòu)建異步的、非堵塞的、事件驅(qū)動(dòng)的服務(wù)。
springboot2.0發(fā)布不久，最近研究了一下springboot2.0的新特性,其中就發(fā)現(xiàn)了webflux。

使用webflux和MVC的區(qū)別就是在artifacId后面加上flux

    org.springframework.boot
    spring-boot-starter-parent
    2.0.0.RELEASE


    org.springframework.boot
    spring-boot-starter-webflux

@RestController
public class HelloController {
    @GetMapping("/hello")
    public String hello() {
        return "hello world";
    }
}

在webflux中有Handler和Router 的概念，分別與springmvc中的controllerr和equest mapper相對(duì)應(yīng),通俗的將就是handler就是真正處理請(qǐng)求的bean，可以在handler中編寫(xiě)處理請(qǐng)求的邏輯，而Router就是如何讓請(qǐng)求找到對(duì)應(yīng)的handler中的方法處理，下面我們來(lái)實(shí)現(xiàn)一個(gè)簡(jiǎn)單的handler和router。

@Component
public class HelloWorldHandler {

    public Mono helloWorld(ServerRequest request){
        return ServerResponse.ok()
                .contentType(MediaType.TEXT_PLAIN)
                .body(BodyInserters.fromObject("hello flux"));
    }
    
}

上面是一個(gè)簡(jiǎn)單的handler只相應(yīng)了一個(gè)“hello flux” 字符串！

@Configuration
public class RouterConfig {

    @Autowired
    private HelloWorldHandler helloWorldHandler;

    @Bean
    public RouterFunction helloRouter() {
        return RouterFunctions.route(RequestPredicates.GET("/hello"), helloWorldHandler::helloWorld);
    }

}

上面是對(duì)應(yīng)的router對(duì)應(yīng)的是匹配一個(gè)get方式的/hello請(qǐng)求，然后調(diào)用helloWorldHandler中的helloWorld方法向?yàn)g覽器輸出一個(gè)文本類型的字符串

再來(lái)一個(gè)例子

@Component
public class UserHandler {

    @Autowired
    private ReactiveRedisConnection connection;

    public Mono getTime(ServerRequest request) {
        return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
                .body(Mono.just("Now is " + new SimpleDateFormat("HH:mm:ss").format(new Date())), String.class);
    }
    public Mono getDate(ServerRequest request) {
        return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
                .body(Mono.just("Today is " + new SimpleDateFormat("yyyy-MM-dd").format(new Date())), String.class);
    }

    public Mono sendTimePerSec(ServerRequest request) {
        return ServerResponse.ok().contentType(MediaType.TEXT_EVENT_STREAM)
                .body(Flux.interval(Duration.ofSeconds(1)).map(l -> new SimpleDateFormat("HH:mm:ss").format(new Date())), String.class);
    }


    public Mono register(ServerRequest request) {
        Mono

@Configuration
public class RouterConfig {

    @Autowired
    private HelloWorldHandler helloWorldHandler;

    @Bean
    public RouterFunction helloRouter() {
        return RouterFunctions.route(RequestPredicates.GET("/hello"), helloWorldHandler::helloWorld);
    }

    @Autowired
    private UserHandler userHandler;

    @Bean
    public RouterFunction timerRouter() {
        return RouterFunctions.route(RequestPredicates.GET("/time"), userHandler::getTime)
                .andRoute(RequestPredicates.GET("/date"), userHandler::getDate);
    }

    @Bean
    public RouterFunction routerFunction() {
        return RouterFunctions.route(RequestPredicates.GET("/hello"), helloWorldHandler::helloWorld)
                .andRoute(RequestPredicates.POST("/register"), userHandler::register)
                .andRoute(RequestPredicates.POST("/login"), userHandler::login)
                .andRoute(RequestPredicates.GET("/times"), userHandler::sendTimePerSec);
    }

}