查询GCP Datastore超时或宕机时DatastoreRepository抛出的异常

对应的细粒度异常类型 #

在使用Spring Cloud GCP Datastore Repository时，你需要关注两类核心异常：

• Spring Data封装的上层异常：org.springframework.cloud.gcp.data.datastore.core.DatastoreDataAccessException
  这是Spring Cloud GCP针对Datastore操作抛出的统一Spring Data风格异常，所有DatastoreRepository操作抛出的异常都会被包装成这个类型，它的getCause()方法会返回底层的Google客户端异常。
• Google客户端底层异常：com.google.cloud.datastore.DatastoreException
  这是Google Cloud Java SDK抛出的原生Datastore异常，包含getCode()方法可以获取对应的HTTP状态码（比如500、503、504等），这正是你筛选5XX错误的关键依据。

用@Retryable实现精准重试 #

要只针对超时/连接类的5XX错误触发指数退避，你可以结合@Retryable的异常类型匹配和表达式判断，示例代码如下：

import org.springframework.retry.annotation.Retryable;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Recover;
import org.springframework.cloud.gcp.data.datastore.core.DatastoreDataAccessException;
import com.google.cloud.datastore.DatastoreException;

// 配置指数退避规则，仅捕获5XX类Datastore错误
@Retryable(
    include = DatastoreDataAccessException.class,
    // 表达式判断：底层异常是DatastoreException，且状态码属于5XX范围
    exceptionExpression = "#root.cause instanceof T(com.google.cloud.datastore.DatastoreException) && #root.cause.code >= 500 && #root.cause.code < 600",
    // 指数退避参数：初始延迟1秒，每次重试延迟翻倍
    maxAttempts = 3,
    backoff = @Backoff(delay = 1000, multiplier = 2)
)
public void executeDatastoreQuery() {
    // 调用你的DatastoreRepository查询方法
    yourDatastoreRepository.findXXX();
}

// 重试耗尽后的恢复方法（可选）
@Recover
public void recoverDatastoreError(DatastoreDataAccessException ex) {
    // 处理重试失败后的逻辑，比如日志告警、降级处理等
}

补充说明 #

• Datastore的5XX错误通常对应这些场景：服务不可用（503）、请求超时（504）、内部服务器错误（500），这些状态码都会通过DatastoreException.getCode()返回。
• 如果需要更精准的匹配（比如只针对503和504），可以修改表达式为#root.cause.code == 503 || #root.cause.code == 504。

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