Spring WebFlux，Spring生态中的响应式Web框架，通过其独特的非阻塞I/O模型，引领了Java Web开发新潮流。它利用 @EnableWebFlux注解激活响应式编程模式，结合 @RestController和 @RequestMapping注解，为开发人员提供了构建异步、事件驱动Web应用的能力。Spring WebFlux背后的 ProjectReactor库，通过 Flux和 Mono这样的响应式类型，简化了异步数据流的管理。此外，它还支持 @MessageMapping和 @SendTo注解，方便WebSocket通信。 @ControllerAdvice和 @ExceptionHandler注解则为全局异常处理提供了强大支持。Spring WebFlux的这些注解和功能，共同构成了一个强大而灵活的响应式编程平台，为开发高性能Web应用提供了坚实基础。

肖哥弹架构 跟大家“弹弹” 框架注解使用，需要代码关注

欢迎 点赞，关注，评论。

关注公号Solomon肖哥弹架构获取更多精彩内容

历史热点文章

• 28个验证注解，通过业务案例让你精通Java数据校验(收藏篇)
• Java 8函数式编程全攻略：43种函数式业务代码实战案例解析(收藏版)
• 69 个Spring mvc 全部注解：真实业务使用案例说明(必须收藏)
• 24 个Spring bean 全部注解：真实业务使用案例说明(必须收藏)
• MySQL索引完全手册：真实业务图文讲解17种索引运用技巧(必须收藏)
• 一个项目代码讲清楚DO/PO/BO/AO/E/DTO/DAO/ POJO/VO

1、webFlux架构关系

• Spring Web 是基础模块，为Spring MVC和Spring WebFlux提供基础Web功能。
• Spring MVC 是Spring Web的一个子模块，使用Servlet API，基于注解，适用于传统的Web应用程序。
• Spring WebFlux 也基于Spring Web，但它使用Reactive Streams，支持异步非阻塞，适用于需要处理高并发的响应式应用程序。
• Spring MVC和Spring WebFlux分别指向了不同类型的应用程序，表明了它们的适用场景。

2、WebFlux 架构图

• 客户端通过Web服务器发送请求。
• Web服务器将请求传递给处理器函数进行业务逻辑处理。
• 处理器函数可能需要调用其他服务或数据库。
• 处理结果通过发布者模型返回给Web服务器。
• Web服务器将结果发送回客户端。

WebFlux核心组件包括：

• DispatcherHandler：中央处理器，用于请求的路由和处理。
• HandlerMapping：将请求映射到相应的处理器。
• HandlerAdapter：调用具体的处理器方法。
• WebHandler：处理程序的顶级接口。
• HttpHandler：适配不同的HTTP服务容器API。
• WebFilter：提供Web请求的过滤功能。
• ServerCodecConfigurer：配置编解码器。

3、启动WebFlux

@EnableWebFlux

• 注解作用介绍

@EnableWebFlux 注解用于在Spring应用中启用WebFlux功能，它是响应式编程的配置标记，表明该应用将使用WebFlux作为其Web请求处理的基础。

• 注解属性介绍

此注解没有属性，它作为一个开关来激活WebFlux特定的自动配置。

• 注解业务案例

import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.config.EnableWebFlux;

@Configuration
@EnableWebFlux
public class WebFluxConfig {
    // 在这里可以添加WebFlux特定的配置，例如定义RouterFunctions或自定义过滤器
}

4、WebFlux 应用案例

启动响应式Web应用程序

• 业务介绍： Spring WebFlux 允许通过 @EnableWebFlux 注解来创建响应式 Web 应用程序。此注解激活响应式编程支持，并配置应用程序使用 Netty 作为其服务器。
• 代码实现：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.embedded.netty.reactor.NettyReactiveWebServerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.web.reactive.config.EnableWebFlux;

@SpringBootApplication
@EnableWebFlux
public class ReactiveApplication {

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

    @Bean
    public NettyReactiveWebServerFactory nettyFactory() {
        return new NettyReactiveWebServerFactory(8080); // 指定端口
    }
}

定义响应式控制器

• 业务介绍： 使用 @RestController 和 @RequestMapping 注解定义响应式控制器，处理 HTTP 请求并返回响应式结果。
• 代码实现：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;

@RestController
public class HelloController {

    @GetMapping("/hello/{name}")
    public Mono<String> sayHello(@PathVariable String name) {
        return Mono.just("Hello " + name);
    }
}

配置响应式数据库访问

• 业务介绍： Spring WebFlux 支持响应式数据库访问，使用 R2DBC 作为其数据库连接池和客户端。
• 代码实现：

@Configuration
public class DatabaseConfig {

    @Bean
    publicConnectionFactory connectionFactory() {
        // 创建 R2DBC 连接工厂
    }

    @Bean
    public R2dbcEntityTemplate template(ConnectionFactory connectionFactory) {
        return new R2dbcEntityTemplate(connectionFactory);
    }
}

实现响应式服务

• 业务介绍： 服务层可以实现为响应式，以便非阻塞地处理业务逻辑，例如用户验证、订单处理等。
• 代码实现：

@Service
public class UserService {

    @Autowired
    private UserRepository userRepository;

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

响应式数据访问层

• 业务介绍： 使用响应式仓库接口，如 ReactiveCrudRepository，实现非阻塞的数据访问。
• 代码实现：

public interface UserRepository extends ReactiveCrudRepository<User, Long> {
    Mono<User> findByEmail(String email);
}

全局异常处理

• 业务介绍： 通过 @ControllerAdvice 注解类捕获和处理整个应用程序的异常。
• 代码实现：

@ControllerAdvice
public class GlobalExceptionHandler {

    @ExceptionHandler(ResourceNotFoundException.class)
    public Mono<ServerResponse> handleResourceNotFound(ResourceNotFoundException ex) {
        return ServerResponse.notFound().body(from(ex.getMessage()));
    }
}

响应式WebClient

• 业务介绍： 使用 WebClient 发起异步的 HTTP 请求，与外部服务或资源进行通信。
• 代码实现：

@Service
public class ExternalServiceClient {

    private final WebClient webClient = WebClient.create();

    public Mono<ExternalData> fetchExternalData(String url) {
        return webClient.get()
                .uri(url)
                .retrieve()
                .bodyToMono(ExternalData.class);
    }
}

WebSocket 消息处理

• 业务介绍： 使用 @Controller 和 @MessageMapping 注解处理 WebSocket 消息。
• 代码实现：

@Controller
public class WebSocketController {

    @Autowired
    private SimpMessagingTemplate messagingTemplate;

    @MessageMapping("/greeting")
    public Mono<String> handleGreetingMessage(String message) {
        return Mono.just("Hello " + message);
    }

    @GetMapping("/ws/greeting")
    public String handleWebSocketPath() {
        // 配置 WebSocket 路由
    }
}

服务器发送事件（SSE）

• 业务介绍： 通过 @RestController 和 SseEmitter 实现服务器发送事件，用于推送实时更新到客户端。
• 代码实现：

@RestController
public class SseController {

    @GetMapping("/events")
    public SseEmitter streamEvents() {
        SseEmitter emitter = new SseEmitter();
        // 配置并发送事件
        return emitter;
    }
}