Spring 零基础入门WebFlux框架体系

Spring 零基础入门WebFlux框架体系攻略

什么是WebFlux

Spring WebFlux是Spring框架的一个子项目，它提供了一种处理响应式HTTP请求的方式，支持反应式流和异步编程模型。使用WebFlux，我们可以编写非阻塞的、响应式的应用程序，可以处理大量的并发请求而不会像传统的Servlet容器一样阻塞线程。

如何使用WebFlux

首先需要初始化一个Spring Boot项目，并引入WebFlux相关依赖（具体可以参考Spring官方文档）。

然后需要创建一个Handler来处理请求，并将Handler注册到路由中。

@Component
public class MyHandler {

    public Mono<ServerResponse> hello(ServerRequest request) {
        return ServerResponse.ok().body(BodyInserters.fromObject("Hello, WebFlux!"));
    }
}

@Configuration
public class RouterConfig {

    @Autowired
    private MyHandler myHandler;

    @Bean
    public RouterFunction<ServerResponse> routerFunction() {
        return RouterFunctions.route(RequestPredicates.GET("/hello"), myHandler::hello);
    }

}

在上面的代码中，MyHandler是我们自己编写的处理器，它实现了hello方法来处理请求。RouterConfig用来注册路由，并将hello方法绑定到路径/hello上。

最后我们将应用程序的端口映射到8080端口，并启动应用程序。

@SpringBootApplication
public class Application {

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

}

接下来我们可以使用浏览器或者curl工具发送一个GET请求到http://localhost:8080/hello，就能看到服务端返回的"Hello, WebFlux!"文本了。

简单的示例

上面的代码已经能够完成一个简单的请求响应了，接下来我们看一下如何将请求的参数带入到处理器中。

@Component
public class MyHandler {

    public Mono<ServerResponse> hello(ServerRequest request) {
        String name = request.queryParam("name").orElse("World");
        return ServerResponse.ok().body(BodyInserters.fromObject("Hello, " + name + "!"));
    }
}

在上面的代码中，我们使用queryParam方法从请求中获取名为name的参数。如果请求中没有该参数，则设置默认值为World。

上面的代码和之前的代码在RouterConfig中的注册方式相同，我们只需要发送一个GET请求到http://localhost:8080/hello?name=Tom，就能够看到服务端返回的"Hello, Tom!"文本了。

复杂的示例

上面的示例都是很简单的请求响应，实际的项目中可能需要有更多的处理逻辑，比如使用数据库来持久化数据。

@Service
public class UserService {

    private UserRepository userRepository;

    @Autowired
    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }

    public Mono<User> getById(String id) {
        return userRepository.findById(id);
    }

    public Flux<User> getAll() {
        return userRepository.findAll();
    }

    public Mono<Void> create(User user) {
        return userRepository.save(user).then();
    }

    public Mono<Void> deleteById(String id) {
        return userRepository.deleteById(id);
    }

    public Mono<Void> update(User user) {
        return userRepository.save(user).then();
    }
}

@Component
public class UserHandler {

    private UserService userService;

    @Autowired
    public UserHandler(UserService userService) {
        this.userService = userService;
    }

    public Mono<ServerResponse> getById(ServerRequest request) {
        String id = request.pathVariable("id");
        Mono<User> userMono = userService.getById(id);
        return ServerResponse.ok().body(userMono, User.class);
    }

    public Mono<ServerResponse> getAll(ServerRequest request) {
        Flux<User> userFlux = userService.getAll();
        return ServerResponse.ok().body(userFlux, User.class);
    }

    public Mono<ServerResponse> create(ServerRequest request) {
        Mono<User> userMono = request.body(BodyExtractors.toMono(User.class));
        Mono<Void> voidMono = userMono.map(userService::create).then();
        return ServerResponse.ok().body(voidMono, Void.class);
    }

    public Mono<ServerResponse> deleteById(ServerRequest request) {
        String id = request.pathVariable("id");
        Mono<Void> voidMono = userService.deleteById(id);
        return ServerResponse.ok().body(voidMono, Void.class);
    }
}

@Configuration
public class RouterConfig {

    @Autowired
    private UserHandler userHandler;

    @Bean
    public RouterFunction<ServerResponse> routerFunction() {
        return RouterFunctions.route()
                .GET("/users", userHandler::getAll)
                .GET("/users/{id}", userHandler::getById)
                .POST("/users", userHandler::create)
                .DELETE("/users/{id}", userHandler::deleteById)
                .build();
    }

}

在上面的代码中，我们定义了一个UserService来处理对用户的增删改查操作，同时定义了一个UserHandler来处理请求。在RouterConfig中注册了路由，并将路由与UserHandler的方法绑定。

上面的示例展示了如何使用WebFlux来处理复杂的业务逻辑，同时体现了响应式编程的一些特点。具体实现细节和Spring Boot的相关配置可以参考Spring官方文档。