如何使用 Mutiny 处理整体补偿?

How to deal with whole compensation using Mutiny?

正在Quarkus and SmallRye Mutiny工作,不知道如何处理补偿。

我有一个员工列表,我必须更新数据库中的所有员工。数据访问对象 (EmployeeDao) 具有以下方法:public Uni<Boolean> update(Long id, String name, Long deptId)。它期望接收员工的字段。

此外,我必须 return 一个 Uni<Boolean> 来通知所有更新是否正常。如下所示:

public Uni<Boolean> updateEmployees(List<Employee> employees) {
    for(Employee employee: employees) {
        //TODO: Execute or compensate
    }
}

我的问题是,如何逐一迭代执行更新过程和处理补偿?

万一任何一个员工更新过程失败,我想尝试几次,然后,如果我无法更新一个员工,我必须撤消之前的所有员工 return荷兰国际集团任何回应。这个想法是让数据库保持一致的状态。

如何使用 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。然后我们把这些结合起来。如果一切都很好,我们就很好 return 是真的。如果发生不好的事情,我们会进行补偿并且 return false.