问题描述
在Quarkus和SmallRye Mutiny上工作,我不知道如何处理补偿金。
我有一个员工列表,我必须更新数据库中的所有员工。数据访问对象(EmployeeDao)具有以下方法:public Uni<Boolean> update(Long id,String name,Long deptId)
。它希望接收员工的字段。
此外,我必须返回Uni<Boolean>
来通知所有更新是否正常。如下所示:
public Uni<Boolean> updateEmployees(List<Employee> employees) {
for(Employee employee: employees) {
//Todo: Execute or compensate
}
}
我的问题是,我该如何一步一步地执行更新过程并处理补偿问题?
万一员工更新过程失败,我想尝试几次,然后,如果我无法更新员工,我必须撤消所有员工,然后返回任何响应。目的是使数据库保持一致状态。
如何使用Mutiny处理全部补偿?
解决方法
如果我理解正确,那么您想执行一组异步操作并将其组合。 为此,您可以执行以下操作:
List<Uni<?>> list = new ArrayList();
for(Employee employee: employees) {
Uni<Void> uni = update(employee);
list.add(uni);
}
return Uni.combine().all().unis(list)
.with(list -> { /* all employees have been updated */ return true; })
.onFailure().call(failure -> {
Uni<?> uni = compensate();
return uni.onItem().transform(x -> false);
});
第一眼为每个更新收集Unis。然后,我们将这些结合起来。如果一切都很好,我们就很好,并返回true。如果发生不良情况,我们将赔偿并返回false。