我有一个队列接收“事件”消息，导致重新计算一个或多个共享资源 . 这些消息的排序在特定资源中很重要，并且队列可以同时包含同一资源的多个消息 .
我想以这样的方式设计系统，以便将来可以添加多个消费者（即扇出），而不必担心消息被无序处理（对于他们所属的特定资源而言）
我可以想到几种解决问题的方法，包括资源锁和每个资源批量处理未完成的消息，但我的问题是：是否存在描述此问题解决方案的现有模式或白皮书？
这个问题与技术无关，但我将使用SQS .
您的事件将需要某种资源的序列号，允许消费者确定他们何时收到无序消息 . 对此的一个很好的参考是Message Sequence模式 .
您将需要一些由扩展的消费者共享的存储（例如，数据库），其中最后处理的消息的序列号保持在那里，以便每个消费者具有上次处理的消息的一致视图 . （您可能已经为消费者提供了一些共享存储，用于重复数据删除和域数据 . ）
有了这个，你有几个选择：
实施Resequencer . 这听起来就像你在问题中提到的想法一样 . 此模式的缺点是您可能需要格外小心以确保重定序器以持久的方式存储消息 . 这可能比它的 Value 更麻烦 .
我认为存在一个更简单的解决方案：如果消费者确定它已经收到了一个无序的消息，它就不会将其从队列中删除 . 在SQS可见性超时到期之前，消费者不会再次接收该消息 . 在此期间，可以接收和处理序列中的其他消息 . 一旦可见性超时到期，旧消息将再次可用于处理，此时它可能是序列中的下一条消息 . 如果没有，它将被简单地留在队列中，直到处理序列中的下一条消息 .
1 回答
您的事件将需要某种资源的序列号，允许消费者确定他们何时收到无序消息 . 对此的一个很好的参考是Message Sequence模式 .
您将需要一些由扩展的消费者共享的存储（例如，数据库），其中最后处理的消息的序列号保持在那里，以便每个消费者具有上次处理的消息的一致视图 . （您可能已经为消费者提供了一些共享存储，用于重复数据删除和域数据 . ）
有了这个，你有几个选择：
实施Resequencer . 这听起来就像你在问题中提到的想法一样 . 此模式的缺点是您可能需要格外小心以确保重定序器以持久的方式存储消息 . 这可能比它的 Value 更麻烦 .
我认为存在一个更简单的解决方案：如果消费者确定它已经收到了一个无序的消息，它就不会将其从队列中删除 . 在SQS可见性超时到期之前，消费者不会再次接收该消息 . 在此期间，可以接收和处理序列中的其他消息 . 一旦可见性超时到期，旧消息将再次可用于处理，此时它可能是序列中的下一条消息 . 如果没有，它将被简单地留在队列中，直到处理序列中的下一条消息 .