A Study in Spring WebFlux

README.md

A Study in Spring WebFlux

リアクティブシステムとは

• ノンブロッキング（InputStream/OutputStream → 非ブロックモードのChannel）
• バックプレッシャー
• 非同期

参考:

• リアクティブ宣言

Spring WebFluxとは……の前にSpring Web MVCは知っている？

• 昔から存在するSpringのWebフレームワーク
• サーブレットがベース

@RestController
public class HelloController {

    @GetMapping("/hello")
    public String getHello() {
        return "Hello World";
    }

    @PostMapping("/hello")
    public Hello postHello(@RequestBody final YourName yourName) {
        return new Hello("Hello " + yourName.getName());
    }
}

public final class YourName {

    private final String name;

    public YourName(@JsonProperty("name") final String name) {
        this.name = Objects.requireNonNull(name);
    }

    public String getName() {
        return name;
    }
}

public final class Hello {

    private final String message;

    public Hello(@JsonProperty("message") final String message) {
        this.message = Objects.requireNonNull(message);
    }

    public String getMessage() {
        return message;
    }
}

Spring WebFluxとは

• Spring Frameworkでリアクティブシステムを構築するためのWebフレームワーク
• Reactor（Flux/Mono）
• Annotated ControllersとFunctional Endpoints

https://backpaper0.github.io/ghosts/reactive/

Annotated Controllers

@RestController
public class HelloController {

    @GetMapping("/hello")
    public Mono<String> getHello() {
        return Mono.just("Hello World");
    }

    @PostMapping("/hello")
    public Mono<Hello> postHello(@RequestBody final YourName yourName) {
        return Mono.just(yourName.getName())
                .map(name -> "Hello " + name)
                .map(Hello::new);
    }
}

Functional Endpoints

public class HelloHandler {

    public Mono<ServerResponse> getHello(final ServerRequest request) {
        return ServerResponse.ok().contentType(TEXT_PLAIN)
                .syncBody("Hello Functional World");
    }

    public Mono<ServerResponse> postHello(final ServerRequest request) {
        final var yourName = request.bodyToMono(YourName.class);
        final var hello = yourName
                .map(YourName::getName)
                .map(name -> "HELLO " + name)
                .map(Hello::new);
        return ServerResponse.ok().contentType(APPLICATION_JSON)
                .body(hello, Hello.class);
    }
}

@Configuration
public class HelloRouter {

    @Bean
    public RouterFunction<ServerResponse> routerFunction() {
        final var handler = handler();
        return route()
                .GET("/fn/hello", handler::getHello)
                .POST("/fn/hello", handler::postHello)
                .build();
    }

    @Bean
    public HelloHandler handler() {
        return new HelloHandler();
    }
}

ポイント

スレッドに強く関連付けたスタイルから、スレッドに依存しないスタイルへの転換

• ThreadLocalでDBコネクションやHttpServletRequestを引回す、といった手法は捨て去る
• 1リクエストを1トランザクションで囲む手法（トランザクションスクリプト）は捨て去る

手続き型プログラミングから、関数型プログラミングへの転換

• forやifを使ったコードから、高階関数を使ったコードへ
• 処理をキューに追加して、空いているスレッドで順次処理していくため（処理が関数だとキューに追加しやすい）

関数型プログラミングの世界へ入門するには:

• Scalaスケーラブルプログラミング
• 型無しラムダ計算を学ぶ（GroovyでFizzBuzzやってみた）
• リストを書く（filter map flatMap を定義してみる、flatMap をベースに filter map を定義してみる、foldLeftを定義してみる、foldLeftをベースにflatMapを定義してみる）

リンク

• https://docs.spring.io/spring/docs/current/spring-framework-reference/web-reactive.html
• https://projectreactor.io/
• https://github.com/backpaper0/spring-webflux-example
• https://github.com/backpaper0/reactive-webclient-sample