重试反应器中的特定异常

Question

我有一个微服务应用程序。为了协作，每个服务都使用异步消息传递。我知道，spring data jpa默认使用乐观锁。但是，如果这个锁方法不是由用户调用的，而是由另一个服务调用的(在我的例子中有验证服务，可以将对象的状态更新为有效或无效)，我想处理异常并重试更新对象。此外，我必须在这个微服务上使用webflux堆栈。现在我有这样的代码:

public void updateStatus(String id, EventStatus status) {
eventRepository.findById(id)
.doOnNext(eventDocument -> {
eventDocument.setStatus(status);
eventRepository.save(eventDocument).subscribe();
}).doOnError(OptimisticLockingFailureException.class, exception -> { //Retry in 2 sec if optimistic lock occurs on update
try {
Thread.sleep(2000);
} catch (InterruptedException ex) {
ex.printStackTrace();
}
updateStatus(id, status);
})
.subscribe();
}

这里我不喜欢递归。有更好的解决办法吗?

Answer 1

如果OptimisticLockingFailureException被抛出，下面每2秒重试一次。

private static final int MAX_ATTEMPTS = Integer.MAX_VALUE;
public void updateStatus(String id, EventStatus status) {
eventRepository.findById(id)
.map(eventDocument -> {
eventDocument.setStatus(status);
return eventDocument;
})
.flatMap(event -> Mono.defer(() -> eventRepository.save(eventDocument)
.retryWhen(Retry.backoff(MAX_ATTEMPTS, Duration.ofSeconds(2))
.filter(t -> t instanceof OptimisticLockingFailureException))))
.subscribe();
}