什么是Spring RetrySpring Retry帮你自动重试那些「这次失败、下次可能就成功」的操作省得你手写循环。一、Spring Retry 有一个问题问题当一次重试流程最终仍然失败时Spring Retry 默认并不会帮我们完成失败记录等后续处理。本文将深入 Spring Retry 源码在不改变核心重试机制的基础上进行升级实现对最终重试失败场景的统一处理。二、RetryListener 是什么RetryListener是框架定义的一个用于监听整个重试生命周期的接口。他不会参与具体的重试逻辑只是一个观察者角色。在重试开始失败成功以及结束都会进行回调。我们可直接在结束时根据上下文信息进行记录(RetryContext)。三、RetryListener 的生命周期因此RetryListener 可以理解为 Spring Retry 预留的一组扩展钩子。我们可以基于这些回调在不直接修改业务代码的情况下因此RetryListener 可以理解为 Spring Retry 预留的一组扩展钩子。我们可以基于这些回调在不直接修改业务代码的情况下对重试过程进行日志记录、监控统计、异常记录以及最终失败处理等。本文也会基于这一扩展点对 Spring Retry 的最终失败场景进行二次改造。创建一个实现RetryListener接口的BeanSpring Retry框架内部会对此进行管理Component public class MysqlRetryListener implements RetryListener { /** * 一次 Retry 流程开始。 */ Override public T, E extends Throwable boolean open( } /** * 每一次失败都会进入这里。 */ Override public T, E extends Throwable void onError( } /** * 整个 Retry 流程结束。 * * throwable null * 最终成功 * throwable ! null * 最终失败 */ Override public T, E extends Throwable void close( } }我们只需实现最终窗口close即可例如protected T, E extends Throwable void doClose( RetryContext context, MethodInvocationRetryCallbackT, E callback, Throwable throwable) { // 最终成功不记录 if (throwable null) { return; } Method method callback.getInvocation().getMethod(); Object[] args callback.getInvocation().getArguments(); String name resolveName(context, callback); String uniqueName name _ System.currentTimeMillis() _ (int) (Math.random() * 10000); String methodName method.getName(); String methodClass method.getDeclaringClass().getName(); String methodArgs serializeArgs(args); String exceptionClass throwable.getClass().getName(); String exceptionMessage throwable.getMessage(); int retryCount context.getRetryCount(); saveToMysql(...);最终就能够形成一条完整的失败记录。后续待补充....