如何保护/锁定每个订阅之间的反应式管道中的实体

问题描述

如何在每个订阅之间的响应式上下文中锁定实体？

我有一个取消订单的端点。在流程中，我调用了一些其他服务来取消升级，依此类推，最后，我将Order标记为cancelled并将其保留。

... // order is retrieved by some repository
return Flux.concat(
    cartService.defrost(order.getCartId()),// 1
    promotionsService.cancel(order.getRedemption()),// 2
    Mono.fromrunnable(() -> orderService.cancelOrder(order)),// 3
).then();

我想确保当并发调用进入时（Reactive管道中的另一个订阅），并且启动了另一个线程来检查和修改同一订单的状态时，它不会再次调用外部服务。我认为当我已经完成步骤3时，脏写是可以的，但是当事务1仅到达步骤1和2时，当事务2进入时，还为时过早。

我在Reactor 3中有一些运算符，还是只能依靠Postgres中的悲观锁定？顺便说一句，如果我真的想锁定行级别，设置隔离级别只是Postgresql 11的提示，还是会锁定它？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）