首页
/ 从阻塞到响应式：Spring Reactive Sample 全方位实战指南

从阻塞到响应式：Spring Reactive Sample 全方位实战指南

2026-01-29 12:30:15作者：晏闻田Solitary
spring-reactive-sample
Spring 5 Reactive playground
项目地址：https://gitcode.com/gh_mirrors/sp/spring-reactive-sample

你是否还在为传统 Spring 应用的性能瓶颈而烦恼？面对高并发场景下的资源耗尽和响应延迟，是否渴望一种更高效的编程范式？本文将带你深入探索 Spring Reactive Sample 项目，通过 20+ 实战案例解锁响应式编程的核心能力，让你的应用轻松应对百万级并发请求。

为什么选择响应式编程？

在传统的阻塞式编程模型中，每个 HTTP 请求都会占用一个线程直到处理完成，这在高并发场景下会导致严重的线程资源耗尽问题。而 响应式编程（Reactive Programming） 基于异步非阻塞模型，通过事件驱动和数据流处理，能够用更少的线程处理更多的请求，大幅提升系统吞吐量。

flowchart LR
    A[传统阻塞模型] -->|1000并发请求| B[创建1000线程]
    B --> C[线程上下文切换开销大]
    C --> D[响应延迟>500ms]
    
    E[响应式模型] -->|1000并发请求| F[仅需10-20线程]
    F --> G[事件驱动无阻塞]
    G --> H[响应延迟<50ms]
    
    style A fill:#ffcccc,stroke:#333
    style E fill:#ccffcc,stroke:#333

Spring Reactive Sample 项目作为 Spring 响应式编程的实践标杆，包含了从基础组件到高级应用的完整案例，覆盖 WebFlux、数据访问、安全认证、跨语言开发 等多个维度，是学习响应式编程的最佳实践资料库。

项目架构概览

Spring Reactive Sample 采用模块化设计，将不同场景的响应式实现拆分为独立子项目，主要分为三大类：

核心模块分类

模块类型 典型子项目 技术栈 应用场景
基础框架 vanilla、routes、rxjava3 Spring WebFlux、Reactor、RxJava3 响应式 API 开发、函数式路由定义
数据访问 data-mongo、data-redis、data-cassandra Spring Data Reactive、MongoDB、Redis 非阻塞数据库操作、响应式存储
Spring Boot 集成 boot-start、boot-data-mongo、boot-security Spring Boot 3.x、自动配置 快速开发响应式 Spring Boot 应用
安全认证 security、security-data-mongo Spring Security Reactive 响应式环境下的认证授权
跨语言开发 kotlin、groovy、kotlin-co Kotlin、Groovy、协程 多语言响应式编程实践

技术架构图

classDiagram
    class ReactiveCore {
        +Reactor
        +RxJava3
        +SmallRye Mutiny
    }
    
    class WebFlux {
        +RouterFunction
        +@Controller
        +WebClient
    }
    
    class DataAccess {
        +ReactiveMongoRepository
        +ReactiveRedisTemplate
        +ReactiveCassandraOperations
    }
    
    class SpringBoot {
        +AutoConfiguration
        +Starter Starters
        +Actuator
    }
    
    class Security {
        +ReactiveSecurityContext
        +JWT Authentication
        +Method Security
    }
    
    ReactiveCore <|-- WebFlux
    ReactiveCore <|-- DataAccess
    WebFlux <|-- SpringBoot
    WebFlux <|-- Security

快速上手：3 分钟启动第一个响应式应用

环境准备

# 克隆项目仓库
git clone https://gitcode.com/gh_mirrors/sp/spring-reactive-sample
cd spring-reactive-sample

# 构建基础模块
./mvnw clean package -pl vanilla -am -DskipTests

运行 vanilla 示例

# 进入 vanilla 模块
cd vanilla

# 启动应用
../mvnw spring-boot:run

应用启动后，访问 http://localhost:8080/hello，你将看到一个简单的响应式 API 返回：

{
  "message": "Hello Reactive World!",
  "timestamp": 1694300000000
}

核心代码解析

vanilla 模块展示了最基础的响应式控制器实现：

@RestController
public class HelloController {
    
    @GetMapping("/hello")
    public Mono<Map<String, Object>> hello() {
        return Mono.just(Map.of(
            "message", "Hello Reactive World!",
            "timestamp", System.currentTimeMillis()
        ));
    }
    
    @GetMapping("/stream")
    public Flux<Long> stream() {
        // 每秒发送一个递增的数字，持续10次
        return Flux.interval(Duration.ofSeconds(1))
                   .take(10)
                   .map(sequence -> sequence + 1);
    }
}
  • Mono：表示包含 0 或 1 个元素的异步序列
  • Flux：表示包含 0 到 N 个元素的异步序列
  • interval：创建一个按固定时间间隔发射递增数字的 Flux

核心场景实战

1. 响应式数据访问：MongoDB 集成

data-mongo 模块演示了如何使用 Spring Data Reactive 操作 MongoDB：

实体定义

@Document(collection = "posts")
public record Post(
    @Id String id,
    String title,
    String content,
    @CreatedDate Instant createdAt
) {}

响应式 Repository

public interface PostRepository extends ReactiveMongoRepository<Post, String> {
    // 响应式查询：按标题模糊查询
    Flux<Post> findByTitleContainingIgnoreCase(String title);
}

控制器实现

@RestController
@RequestMapping("/posts")
public class PostController {
    
    private final PostRepository posts;
    
    public PostController(PostRepository posts) {
        this.posts = posts;
    }
    
    @GetMapping
    public Flux<Post> all() {
        return posts.findAll();
    }
    
    @PostMapping
    public Mono<ResponseEntity<Post>> create(@RequestBody Mono<Post> post) {
        return post.flatMap(posts::save)
                   .map(saved -> ResponseEntity
                       .created(URI.create("/posts/" + saved.id()))
                       .body(saved));
    }
}

2. 函数式路由：RouterFunction 实践

routes 模块展示了 WebFlux 的函数式编程风格：

@Configuration
public class PostRouter {
    
    @Bean
    public RouterFunction<ServerResponse> routes(PostHandler handler) {
        return route()
            .GET("/posts", handler::getAll)
            .GET("/posts/{id}", handler::getById)
            .POST("/posts", handler::create)
            .PUT("/posts/{id}", handler::update)
            .DELETE("/posts/{id}", handler::delete)
            .build();
    }
    
    @Component
    public static class PostHandler {
        private final PostRepository posts;
        
        // 构造函数注入省略...
        
        public Mono<ServerResponse> getAll(ServerRequest req) {
            return ServerResponse.ok()
                .body(posts.findAll(), Post.class);
        }
        
        // 其他处理方法省略...
    }
}

3. 响应式安全认证

security 模块实现了响应式环境下的安全控制：

@Configuration
@EnableWebFluxSecurity
public class SecurityConfig {
    
    @Bean
    public SecurityWebFilterChain securityWebFilterChain(ServerHttpSecurity http) {
        return http
            .authorizeExchange(exchanges -> exchanges
                .pathMatchers("/public/**").permitAll()
                .pathMatchers("/admin/**").hasRole("ADMIN")
                .anyExchange().authenticated()
            )
            .httpBasic(withDefaults())
            .formLogin(withDefaults())
            .build();
    }
    
    @Bean
    public MapReactiveUserDetailsService userDetailsService() {
        UserDetails user = User.withUsername("user")
            .password("{noop}password")
            .roles("USER")
            .build();
            
        UserDetails admin = User.withUsername("admin")
            .password("{noop}password")
            .roles("ADMIN")
            .build();
            
        return new MapReactiveUserDetailsService(user, admin);
    }
}

高级特性：多响应式库支持

Spring Reactive Sample 不仅支持 Reactor（Spring 默认响应式库），还提供了多种响应式库的集成示例：

响应式库对比

库名称 特点 适用场景 示例模块
Reactor Spring 官方支持，与 Spring 生态深度整合 绝大多数响应式应用 vanilla、boot-start
RxJava3 丰富的操作符，成熟的社区生态 从 RxJava 迁移的项目 rxjava3
SmallRye Mutiny 轻量级，低学习成本 简单响应式场景 smallrye-mutiny
Kotlin Coroutines 协程支持，简化异步代码 Kotlin 项目 kotlin-co、boot-kotlin-co

RxJava3 集成示例

@RestController
public class RxJava3Controller {
    
    @GetMapping("/rxjava3/hello")
    public Single<Map<String, String>> hello() {
        return Single.just(Map.of("message", "Hello RxJava3"));
    }
    
    @GetMapping("/rxjava3/stream")
    public Flowable<Long> stream() {
        return Flowable.interval(1, TimeUnit.SECONDS)
                       .take(5);
    }
}

性能优化：响应式缓存策略

cache-caffeine 模块演示了如何在响应式环境中实现高效缓存：

@Service
public class PostService {
    
    private final PostRepository posts;
    private final CacheManager cacheManager;
    
    // 构造函数注入省略...
    
    @Cacheable(value = "posts", key = "#id")
    public Mono<Post> getPost(String id) {
        return posts.findById(id)
                    .doOnNext(post -> log.info("Loaded post from database: {}", id));
    }
    
    @CacheEvict(value = "posts", key = "#id")
    public Mono<Void> deletePost(String id) {
        return posts.deleteById(id);
    }
}

部署与扩展

Docker 容器化部署

项目根目录提供了 docker-compose.yml，支持一键启动所有依赖服务：

# 启动 MongoDB、Redis 等依赖服务
docker-compose up -d

# 运行带 MongoDB 支持的应用
./mvnw spring-boot:run -pl boot-data-mongo

多运行时环境支持

Spring Reactive Sample 支持多种服务器运行时，可通过 Maven 配置切换：

<!-- pom.xml -->
<profiles>
    <profile>
        <id>netty</id>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-reactor-netty</artifactId>
            </dependency>
        </dependencies>
    </profile>
    <profile>
        <id>jetty</id>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jetty</artifactId>
            </dependency>
        </dependencies>
    </profile>
</profiles>

学习路径与资源推荐

循序渐进学习路线

  1. 基础阶段：vanilla → routes → client
  2. 数据访问：data-mongo → data-redis → data-cassandra
  3. Spring Boot 集成：boot-start → boot-data-mongo → boot-security
  4. 高级特性：security-method → cache-caffeine → websocket
  5. 多语言开发：kotlin → kotlin-co → groovy

进阶资源

  • 官方文档：Spring WebFlux 参考文档
  • 实战书籍：《Spring 响应式编程》、《Reactive Programming with RxJava》
  • 视频课程：Spring 官方 YouTube 频道的响应式编程系列

总结与展望

Spring Reactive Sample 项目为开发者提供了从入门到精通的响应式编程实践指南，通过本文介绍的核心模块和实战案例，你已经掌握了构建高性能响应式应用的关键技术。随着 Spring 6 和 Spring Boot 3 的发布，响应式编程将在云原生、微服务等领域发挥更大作用。

立即行动：

  1. 克隆项目仓库，运行第一个响应式应用
  2. 尝试修改 vanilla 模块，添加自定义响应式端点
  3. 探索 boot-data-mongo 模块，实现完整的响应式 CRUD 应用

响应式编程不是银弹，但它为高并发、低延迟的现代应用提供了全新的解决方案。掌握 Spring Reactive Sample 项目中的技术，将让你在未来的技术竞争中占据先机。

提示：项目已更新至 Spring 6/Spring Boot 3.0，如需基于 Spring Boot 2.7.x 的代码，请查看 v1.0 标签。

spring-reactive-sample
Spring 5 Reactive playground
项目地址：https://gitcode.com/gh_mirrors/sp/spring-reactive-sample
登录后查看全文
热门项目推荐
相关项目推荐

项目优选

收起
kernelkernel
deepin linux kernel
C
27
11
docsdocs
OpenHarmony documentation | OpenHarmony开发者文档
Dockerfile
514
3.69 K
ops-mathops-math
本项目是CANN提供的数学类基础计算算子库，实现网络在NPU上加速计算。
C++
873
538
pytorchpytorch
Ascend Extension for PyTorch
Python
316
360
kernelkernel
openEuler内核是openEuler操作系统的核心，既是系统性能与稳定性的基石，也是连接处理器、设备与服务的桥梁。
C
333
152
RuoYi-Vue3RuoYi-Vue3
🎉 (RuoYi)官方仓库 基于SpringBoot，Spring Security，JWT，Vue3 & Vite、Element Plus 的前后端分离权限管理系统
Vue
1.31 K
732
flutter_flutterflutter_flutter
暂无简介
Dart
757
182
nop-entropynop-entropy
Nop Platform 2.0是基于可逆计算理论实现的采用面向语言编程范式的新一代低代码开发平台，包含基于全新原理从零开始研发的GraphQL引擎、ORM引擎、工作流引擎、报表引擎、规则引擎、批处理引引擎等完整设计。nop-entropy是它的后端部分，采用java语言实现，可选择集成Spring框架或者Quarkus框架。中小企业可以免费商用
Java
12
1
leetcodeleetcode
🔥LeetCode solutions in any programming language | 多种编程语言实现 LeetCode、《剑指 Offer（第 2 版）》、《程序员面试金典（第 6 版）》题解
Java
67
20
openHiTLSopenHiTLS
旨在打造算法先进、性能卓越、高效敏捷、安全可靠的密码套件，通过轻量级、可剪裁的软件技术架构满足各行业不同场景的多样化要求，让密码技术应用更简单，同时探索后量子等先进算法创新实践，构建密码前沿技术底座！
C
1.05 K
519