Spring R2DBC项目中如何以响应式方式执行jOOQ存储过程？

你的当前实现存在核心问题：用Mono.fromRunnable包装同步的routine.execute()调用，会直接阻塞事件循环线程，违背响应式编程的非阻塞原则，在高并发场景下会严重拖垮系统性能。

最优实现方案 #

jOOQ 3.14及以上版本原生支持R2DBC响应式API，你需要改用jOOQ提供的异步执行方法，彻底避免同步阻塞。

修改后的代码示例 #

private final DSLContext dslContext;

@Override
public Mono<Void> upsertJobContent(UpsertJobContentData data) {
    var routine = toUpsertJobBaseDataRoutine(data);
    // 推荐方式：使用DSLContext的响应式routine API执行，风格更统一
    return Mono.fromCompletionStage(dslContext.routine(routine))
               .then(); // 转换为Mono<Void>适配方法返回值

    // 备选方式：直接调用存储过程生成类的executeAsync方法
    // return Mono.fromCompletionStage(routine.executeAsync(dslContext.configuration()))
    //            .then();
}

private UpsertJobBaseData toUpsertJobBaseDataRoutine(UpsertJobContentData data) {
    UpsertJobBaseData procedure = new UpsertJobBaseData();
    procedure.setPCompanyId(data.getCompanyId());
    procedure.setPTitle(data.getJobTitle());
    // 补充其他参数设置...
    return procedure;
}

关键注意事项 #

• 确认你的DSLContext是基于R2DBC连接工厂配置的响应式实例（比如通过DSL.using(r2dbcConnectionFactory)创建）
• 如果存储过程有输出参数或返回值，可以在响应式流中直接获取结果：

  return Mono.fromCompletionStage(dslContext.routine(routine))
             .map(result -> result.getPOutputParam()) // 替换为你的输出参数getter方法
             // 后续可继续处理返回值，无需调用then()
  

• 绝对禁止在响应式流中调用同步的execute()方法，必须使用带Async后缀的异步方法或响应式DSL API

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