Как реализовать логику повторов на уровне приложения с помощью Spring AOP без изменения классов обслуживания? ⇐ JAVA

[Anonymous]

Я хочу реализовать механизм повтора на уровне приложения в приложении Spring Boot. Однако я не хочу добавлять @Retryable или вносить какие-либо изменения в методы службы или их классы. Моя цель — реализовать логику повтора с помощью Spring AOP и централизованной конфигурации, такой как RetryTemplate, для обеспечения единообразия во всем приложении.
Вот что я сделал на данный момент:< /p>
Класс аспекта
Я создал аспект, который использует RetryTemplate для обработки повторных попыток всех методов в классах @Service.< /p>

Код: Выделить всё

@Aspect
@Component
public class DbConnectionRetryAspect {

private final RetryTemplate retryTemplate;

public DbConnectionRetryAspect(RetryTemplate retryTemplate) {
this.retryTemplate = retryTemplate;
}

@Around("@within(org.springframework.stereotype.Service)")
public Object retry(ProceedingJoinPoint joinPoint) throws Throwable {
System.out.println("Aspect invoked for method: " + joinPoint.getSignature());

return retryTemplate.execute(context -> {
System.out.println("Retry attempt: " + context.getRetryCount());
try {
return joinPoint.proceed();
} catch (SQLTransientConnectionException e) {
System.out.println("Retryable exception caught: " + e.getMessage());
throw e; // Ensure the exception propagates for retries
}
});
}
}

Конфигурация RetryTemplate
Я создал bean-компонент RetryTemplate для определения логики повтора.

Код: Выделить всё

@Bean
public RetryTemplate retryTemplate() {
RetryTemplate retryTemplate = new RetryTemplate();

SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(
5,  // maxAttempts
Map.of(SQLTransientConnectionException.class, true)
);
retryTemplate.setRetryPolicy(retryPolicy);

FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
backOffPolicy.setBackOffPeriod(1000); // 1 second
retryTemplate.setBackOffPolicy(backOffPolicy);

return retryTemplate;
}

Класс обслуживания
Метод службы выдает исключение SQLTransientConnectionException при сбое операции. Я не хочу аннотировать этот метод @Retryable.

Код: Выделить всё

@Service
public class MyService {

public void performOperation() throws SQLTransientConnectionException {
System.out.println("Service method invoked");
throw new SQLTransientConnectionException("Simulated transient error");
}
}

Конфигурация
Я добавил следующую конфигурацию для включения AspectJ:

Код: Выделить всё

@Configuration
@EnableAspectJAutoProxy(proxyTargetClass = true)
public class AspectJConfig {
}

Проблема:
Во время вызова аспекта логика повтора не работает должным образом. В частности:

• Журналы RetryTemplate показывают, что предпринимаются повторные попытки (Повторная попытка: X), но метод службы вызывается только один раз. .
• Похоже, что исключение распространяется неправильно или логика повтора не применяется к методу службы.

В чем мне нужна помощь:
Как реализовать логику повтора на уровне приложения с помощью Spring AOP и RetryTemplate, чтобы:

• Механизм повтора работает должным образом.
• Никаких изменений в классах обслуживания или методах не требуется (например, никаких аннотаций типа @Retryable).
• Повторная попытка политики попыток и отсрочки настраиваются с помощью централизованного шаблона RetryTemplate.

Будем очень признательны за любые рекомендации и предложения.
Спасибо!

Подробнее здесь: https://stackoverflow.com/questions/793 ... t-modifyin