如何创建WebFlux

WebFlux是Spring框架的一部分，它是一个完全响应式的、基于函数式编程模型的Web服务器端库，用于构建轻量级、非阻塞的应用程序。以下是创建WebFlux应用程序的基本步骤：

1. 添加依赖：首先，在你的Maven或Gradle项目中添加Spring WebFlux的相关依赖。例如，如果你使用的是Spring Boot，只需在`pom.xml`或`build.gradle`文件中包含`spring-boot-starter-webflux`。

<!-- Maven -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

// Gradle (Kotlin DSL)
implementation("org.springframework.boot:spring-boot-starter-webflux")

2. 创建控制器：创建一个`ReactiveController`，它是处理HTTP请求的入口点。这个类通常会继承`WebFluxController`。

import org.springframework.web.reactive.function.server.RequestPredicates
import org.springframework.web.reactive.function.server.RouterFunction
import org.springframework.web.reactive.result.view.View
import org.springframework.web.reactive.result.view.freemarker.FreeMarkerViewResolver

@Controller
class MyWebFluxController {

    @GetMapping("/hello")
    fun hello(): Mono<View> {
        return Mono.just(View.render("helloTemplate"))
    }

    // 更复杂的例子，这里返回一个响应流
    @PostMapping("/greeting")
    suspend fun greeting(name: String): Flux<String> = Flux.just("Hello, $name!")
}

在这里，`Mono`和`Flux`是反应式编程的核心组件，分别表示单个值和可以生成多个值的序列。

3. 配置视图解析：如果需要支持模板渲染，还需要配置FreeMarker或者其他视图引擎。

@Bean
public FreeMarkerViewResolver freeMarkerViewResolver() {
    FreeMarkerViewResolver resolver = new FreeMarkerViewResolver();
    resolver.setCache(false);
    resolver.setContentType(MediaType.TEXT_HTML_VALUE);
    resolver.setPrefix("/templates/"); // 设置模板路径前缀
    resolver.setSuffix(".ftl");
    return resolver;
}

4. 启动应用：最后，通过启动类运行WebFlux应用程序。

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}