Spring Boot插入Couchbase文档后线程无限等待问题求助

问题分析 #

Spring Data Couchbase 4.x底层基于Reactor响应式框架实现，CouchbaseRepository的同步方法（如save）内部通过Mono.block()将响应式调用转为阻塞。当响应式流未正常完成时，线程会持续等待CountDownLatch触发，导致卡顿。

可能的触发点：

• 响应式流的下游处理未完成，比如Couchbase客户端的异步回调未正常触发
• 连接池或超时配置不合理，导致确认信号无法及时返回
• 实体生命周期钩子（如@PostPersist）存在阻塞或未捕获异常
• Couchbase集群的异步确认机制出现异常

解决方案 #

1. 切换到响应式Repository #

放弃同步阻塞的CouchbaseRepository，改用ReactiveCouchbaseRepository，直接使用响应式API处理，避免block()调用：

public interface CatalogLockRepository extends ReactiveCouchbaseRepository<CatalogLock, String> {}

// 调用方式
return lockRepository.save(lock)
                     .map(CatalogLock::getId)
                     .blockOptional()
                     .orElseThrow(() -> new RuntimeException("保存失败"));

2. 配置合理的超时时间 #

在application.properties中添加Couchbase操作超时配置，避免无限等待：

# KV操作超时
spring.data.couchbase.timeouts.kv=5s
# 连接超时
spring.data.couchbase.timeouts.connect=3s
# 查询超时
spring.data.couchbase.timeouts.query=10s

3. 排查实体生命周期钩子 #

检查CatalogLock类是否有@PrePersist、@PostPersist等注解的方法，确保这些方法不会阻塞或抛出未捕获的异常，否则会导致响应式流停滞。

4. 启用Reactor调试模式 #

添加JVM启动参数-Dreactor.debug=true，获取完整的响应式流调用栈，定位具体哪个环节导致流未完成。

5. 检查Couchbase集群状态 #

确认Couchbase集群节点健康状态，查看集群日志是否有慢操作、网络异常或资源不足的情况。即使文档插入成功，若集群的异步确认信号未正常返回，也会导致阻塞等待。

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