Spring WebFlux+响应式DB2：如何从Hikari数据源与JDBC迁移？

• 首选方案：使用IBM官方提供的R2DBC DB2驱动，对接Spring Data R2DBC生态。这套实现完全遵循响应式流规范，和WebFlux的Reactor内核原生兼容，没有线程模型冲突问题，是目前WebFlux对接DB2最稳定、改造成本最低的纯响应式方案。
• 过渡方案：保留现有JdbcTemplate + HikariCP的逻辑，将所有阻塞的JDBC调用通过Schedulers.boundedElastic()调度到专用弹性阻塞线程池执行，避免阻塞WebFlux的Netty EventLoop线程。这种方案不需要替换数据库驱动，改造成本极低，适合存量代码临时兼容，缺点是本质还是阻塞调用，没法发挥纯响应式栈的吞吐优势。
• Vertx DB2 Client适配方案：你之前遇到的协同问题基本是用法问题——Vertx DB2 Client本身是响应式实现，但默认返回Vertx自定义的Future类型，没有自动适配Reactor的发布者类型，也没有做线程上下文对齐，才会出现和WebFlux协同异常的情况。手动做类型转换和线程调度后可以正常使用，但适配成本高于R2DBC方案，非特殊技术栈要求不推荐。

1. 引入Maven依赖 #

<dependencies>
    <!-- Spring WebFlux 核心依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-webflux</artifactId>
    </dependency>
    <!-- Spring Data R2DBC 依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-r2dbc</artifactId>
    </dependency>
    <!-- DB2 R2DBC 官方驱动 -->
    <dependency>
        <groupId>com.ibm.db2</groupId>
        <artifactId>r2dbc-db2</artifactId>
        <version>1.1.0</version>
    </dependency>
</dependencies>

2. 添加R2DBC连接配置 #

在application.yml中添加如下配置，将占位符替换为实际的DB2连接信息，注意R2DBC的URL前缀和JDBC不同：

spring:
  r2dbc:
    url: r2dbc:db2://<DB2服务地址>:<端口>/<数据库名>
    username: <连接用户名>
    password: <连接密码>

3. 编写业务代码 #

以用户表查询场景为例：

1. 定义和DB2表映射的实体类

public class User {
    private Long id;
    private String username;
    private Integer age;

    public User() {}
    public User(Long id, String username, Integer age) {
        this.id = id;
        this.username = username;
        this.age = age;
    }

    // 自行补充所有字段的getter、setter
}

2. 定义Repository层接口，直接复用Spring Data的方法名派生查询能力

import org.springframework.data.r2dbc.repository.R2dbcRepository;
import reactor.core.publisher.Flux;

public interface UserRepository extends R2dbcRepository<User, Long> {
    Flux<User> findByAgeGreaterThan(Integer age);
}

3. 编写Web层接口，直接返回Reactor响应式类型

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

@RestController
@RequestMapping("/users")
public class UserController {

    private final UserRepository userRepository;

    public UserController(UserRepository userRepository) {
        this.userRepository = userRepository;
    }

    @GetMapping("/{id}")
    public Mono<User> getUserById(@PathVariable Long id) {
        return userRepository.findById(id);
    }

    @GetMapping("/age/{age}")
    public Flux<User> getUsersOlderThan(@PathVariable Integer age) {
        return userRepository.findByAgeGreaterThan(age);
    }
}

避坑提醒：

1. 不要在类路径下引入JDBC驱动和spring-boot-starter-jdbc依赖，否则Spring Boot会自动配置JDBC数据源，和R2DBC配置产生冲突。
2. 如果使用过渡方案调度JDBC阻塞调用，一定要加subscribeOn(Schedulers.boundedElastic())，不要直接在响应式流里裸调用JdbcTemplate方法，否则会占用Netty事件循环线程导致服务吞吐暴跌，示例写法：

public Mono<User> getUserByJdbc(Long id) {
    return Mono.fromCallable(() -> jdbcTemplate.queryForObject("SELECT * FROM USER WHERE ID = ?", User.class, id))
            .subscribeOn(Schedulers.boundedElastic());
}

3. R2DBC DB2驱动目前支持DB2 10.5及以上版本，低版本DB2需要先升级数据库再使用。

内容的提问来源于stack exchange，提问作者Jjufi21