如何解决队列多消耗并发问题？

Question

我们的程序正在使用队列。多个消费者正在处理消息。

消费者执行以下操作：

1. 从队列接收打开或关闭状态消息。
2. 从存储库中获取最新状态。
3. 比较存储库的状态和从消息接收到的状态。
4. 如果开/关状态不同，则更新数据。（此时其他相关数据也更新。）

假设此过程由多个使用者处理，则预计会出现以下问题。

1. 生产者发送消息1： on、2： off和3： on。
2. 消费者A接收消息#1并将消息#1存储在存储中，因为没有最新数据。
3. 消费者A收到消息#2。
4. 此时，消费者B同时接收到消息#3。
5. 消费者A和B同时从存储中读取最新数据（消息1）。
6. 消费者B首先完成处理。不要更新存储库，因为开/关状态不变。（1： on，3： on）
7. 然后消费者A完成处理。开/关状态发生了变化，因此它处理并保存了工作。（1： on，2： off）

在正常情况下，html" target="_blank">数据库中剩余的最新数据应处于打开状态
（这是因为消息是按on的顺序发送的-

有什么好办法解决这个问题吗？作为参考，我们使用的队列使用AWS Amazon MQ，存储使用AWS dynamoDB。使用Spring靴。

Answer 1

这里的基本问题是，您需要按顺序使用这些“状态”消息，但您使用的是并发消费者，这会导致竞争条件和无序的消息处理。简而言之，您使用并发使用者的基本架构导致了这个问题。

您可能会在数据库中使用注释中建议的时间戳来制定某种解决方案，但这对客户机和存储在数据库中的额外数据来说是额外的工作，而这并不是严格必要的。

解决这个问题的最简单方法是串行地而不是并发地使用消息。有几种不同的方法可以做到这一点，例如：

• 仅为具有“状态”消息的队列定义1个消费者。
• 使用ActiveMQ的“独家消费者”功能来确保只有一个消费者接收消息。
• 使用消息组将所有“状态”消息分组在一起，以确保它们被串行处理（即按顺序）。