如何为Elasticsearch 7实现带指数退避的重试策略（Spring Data环境）

由于你使用Spring Data框架访问ES7，优先选择Spring生态内的应用层实现方案，完全不需要修改ES或Spring Data ES的源码，可覆盖混沌测试的断网、容器宕机、响应延迟等场景：

方案1：使用Spring Retry（推荐，最轻量适配） #

Spring Retry是Spring官方提供的重试组件，原生支持指数退避配置，可通过注解零侵入实现重试逻辑：

• 第一步引入依赖（以Spring Boot项目为例）

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-retry</artifactId>
</dependency>

• 第二步启用重试功能：在项目启动类上添加@EnableRetry注解
• 第三步配置重试规则：在调用ES的业务方法或者ES Repository接口方法上添加@Retryable注解，直接配置指数退避参数

import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Retryable;
import org.springframework.retry.annotation.Recover;
import java.net.ConnectException;
import java.net.SocketTimeoutException;

// ES操作业务类示例
@Service
public class EsOperationService {

    // 配置重试规则：最大重试6次，初始退避延迟2000ms，乘数为2，最大延迟不超过64000ms，指定触发重试的异常类型
    @Retryable(
            maxAttempts = 6,
            backoff = @Backoff(delay = 2000, multiplier = 2, maxDelay = 64000),
            retryFor = {ConnectException.class, SocketTimeoutException.class, RuntimeException.class}
    )
    public void esOperate() {
        // 这里写原有调用ES的业务逻辑
        elasticsearchOperations.save(doc);
    }

    // 重试全部失败后的兜底处理逻辑，对应原来的onFailure回调
    @Recover
    public void retryFailed(RuntimeException e) {
        // 自定义失败处理逻辑，比如告警、落盘补偿数据等
        log.error("ES操作重试全部失败", e);
    }
}

方案2：自定义AOP切面实现（无需额外依赖） #

如果不想引入Spring Retry依赖，可自定义环绕切面，切点配置为所有Spring Data ES的操作方法，在切面内实现你原有指数退避逻辑：

• 定义切点匹配ElasticsearchOperations的所有公共方法，或者自定义的ES Repository接口的所有方法
• 环绕通知内捕获执行异常，按照你原有逻辑实现指数退避重试，重试失败后执行兜底逻辑

• 扩大重试异常覆盖范围：除了通用RuntimeException外，明确加入连接异常（ConnectException、NoRouteToHostException）、超时异常（SocketTimeoutException、ReadTimeoutException）、ES服务端异常（状态码为5xx的ElasticsearchException），覆盖杀容器、加延迟等所有混沌测试场景
• 增加退避抖动：在原有指数退避时间基础上增加0~1000ms的随机偏移，避免多个应用实例同时重试导致ES集群压力突增
• 匹配ES客户端超时配置：将ES客户端的连接超时、读取超时调整为和重试策略匹配的合理值，避免单请求阻塞时间过长
• 非幂等操作增加校验：写入类非幂等操作重试前可增加唯一性校验，避免重复写入脏数据

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