Spring Boot中GCP+R2DBC操作Spanner遇DEADLINE_EXCEEDED问题求助

问题描述 #

在Spring Boot应用中使用GCP Spanner + R2DBC，执行单条记录的existsById()或findById()操作时，约19秒后触发DEADLINE_EXCEEDED错误；同时出现GCP库抛出的"Spanner health check failed"提示。

当前场景细节：

• 仅操作单条记录（约10列，单字段内容少于255字符），执行查询、保存或更新
• 开发环境CPU使用率约1.5%，负载极低
• 同项目中PubSub订阅功能正常，排除网络连通性问题
• 未使用阻塞调用，但GCP文档提及的blockingStub重试配置不适用当前R2DBC异步场景

简化后的核心代码：

public class WidgetDetailsCustomRepositoryImpl implements WidgetDetailsCustomRepository {

    private final WidgetDetailsRepository widgetDetailsRepository;

    private final R2dbcEntityTemplate r2dbcEntityTemplate;

    private Mono<WidgetDetailsModel> saveWidgetDetails(WidgetDetailsModel widgetDetailsModel) {
        Mono<WidgetDetailsModel> result = widgetDetailsRepository.existsById(widgetDetailsModel.getWidgetTrackingNumber())
                .flatMap(widgetExists -> {
                    if (widgetExists) {
                        log.info("Updating WidgetDetails: {}", widgetDetailsModel.getWidgetTrackingNumber());
                        return r2dbcEntityTemplate.update(widgetDetailsModel);
                    } else {
                        log.info("Inserting WidgetDetails: {}", widgetDetailsModel.getWidgetTrackingNumber());
                        return r2dbcEntityTemplate.insert(widgetDetailsModel);
                    }
                });

        return result;
    }
}

解决方案 #

1. 配置R2DBC Spanner RPC超时与重试参数 #

在application.yml中添加以下配置，调整底层gRPC客户端的超时和重试策略：

spring:
  r2dbc:
    url: r2dbc:spanner://projects/[你的项目ID]/instances/[你的实例ID]/databases/[你的数据库ID]
    properties:
      grpc:
        deadline: 10s  # 缩短默认超时，避免长时间等待报错
        retry:
          max-attempts: 3
          initial-backoff: 100ms
          max-backoff: 500ms

这些参数会直接作用于R2DBC Spanner的gRPC客户端，覆盖默认设置，有效减少DEADLINE_EXCEEDED触发概率。

2. 调整Spanner健康检查配置 #

针对"Spanner health check failed"提示，可修改健康检查超时或临时关闭：

management:
  health:
    spanner:
      enabled: true
      timeout: 5s  # 缩短健康检查超时时间

若开发环境无需健康检查，可直接关闭：

management:
  health:
    spanner:
      enabled: false

3. 优化代码逻辑减少RPC调用 #

当前existsById()+插入/更新的逻辑存在竞态条件，且多一次RPC调用。改用Spanner的upsert操作，通过R2DBC的冲突处理实现原子性操作：

private Mono<WidgetDetailsModel> saveWidgetDetails(WidgetDetailsModel widgetDetailsModel) {
    return r2dbcEntityTemplate.insert(widgetDetailsModel)
            .onConflict(Conflict.of("widgetTrackingNumber"))
            .doUpdate()
            .all()
            .then(Mono.just(widgetDetailsModel));
}

该逻辑将查询+写入合并为一次RPC操作，既避免竞态问题，又提升性能。

4. 显式配置SpannerOptions（兜底方案） #

若上述配置不生效，可通过自定义Bean显式配置SpannerOptions：

@Bean
public SpannerConnectionFactory spannerConnectionFactory(SpannerOptions spannerOptions) {
    SpannerOptions.Builder optionsBuilder = spannerOptions.toBuilder();
    // 配置重试策略
    optionsBuilder.setRetrySettings(
            RetrySettings.newBuilder()
                    .setMaxAttempts(3)
                    .setInitialRetryDelay(Duration.ofMillis(100))
                    .setMaxRetryDelay(Duration.ofMillis(500))
                    .build()
    );
    // 设置RPC超时
    optionsBuilder.setDeadline(Duration.ofSeconds(10));
    return new SpannerConnectionFactory(optionsBuilder.build(), "[你的数据库ID]");
}

直接通过底层API配置参数，确保设置生效。

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