按特定顺序处理异步通知

Question

我正在使用javax。servlet获取关于用户完成的付款状态的异步通知。每个通知都包含需要在数据库中更新的信息，例如-用户详细信息、支付金额、付款id、付款状态等。。。

例如，id=1的一次付款的一组通知：

{user_msisdn='',      amount_paid=0.00, payment_id = 1, payment_state=NEW}
{user_msisdn=0012345, amount_paid=0.00, payment_id = 1, payment_state=PENDING}
{user_msisdn=0012345, amount_paid=2.00, payment_id = 1, payment_state=COMPLETED}

即使通知是异步的，数据库更新也必须是有序的，所以当我更新我的支付表时，id=1的支付条目必须首先更新为状态“新”，然后更新为“PENDING”，然后更新为“COMPLETED”。
其他一些内部操作是在我的代码中为每个payment_state完成的，所以这不仅仅是关于事务管理。

我的问题是，有时这些通知以毫秒为间隔到达，在这种情况下，当所需的操作（例如“NEW”通知）尚未完成，然后“PENDING”到达时，可能会先用“PENDING”状态更新数据库，然后用“NEW”覆盖数据库。。。

我正在寻找一种解决方案，它将同时处理不同付款ID的通知，但具有相同付款ID的通知以相同的顺序依次收到。

• 当前的实现是围绕通知处理方法使用Aspect，它可以防止同时执行对同一payment_id的调用。
• 我想过使用ActiveMQ，但是我必须为每个payment_id创建队列/主题，这太多了。
• 我也读了一些关于Spring Retor的文章，但我不确定我是否可以为每个payment_id动态创建一个调度程序
• 也许在payment_id上使用一些锁，这将阻止具有相同payment_id的其他通知被处理，直到完成？
• 还有其他想法吗？

谢谢你！

Answer 1

请看看生产者-消费者的概念

wiki/Producer–consumer\u问题

生产者-消费者-模式

如果您必须以特定顺序处理事件，您应该考虑消费者，如果您的订单要求不适合，它能够对传入事件进行排序/忽略。

如果您发现一个中断的订单，如PENDING is before NEW，则将PENDING再次添加到队列的末尾。下一个将是新的，您可以执行。下一个传入操作已完成，但由于尚未调用PENDING，因此您将COMPLETE也放在队列的末尾，并且顺序有效。

当然，你必须注意遗漏事件。否则，您会有总是无缘无故地再次添加的事件，但这是一种特殊的错误处理逻辑。