小编Chr*_*nte的帖子

假设我们有 3 个不同的服务生成事件，每个服务都发布到自己的事件存储。

这些服务中的每一个都会消耗其他生产者服务事件。这是因为每个服务都必须处理另一个服务的事件并创建自己的投影。每个服务都在多个实例上运行。

（对我来说）最直接的方法是在每个 ES 前面放置“一些东西”，它正在挑选事件并将它们发布（发布/订阅）到每个其他服务的队列中。

这是完美的，因为每个服务都可以订阅它喜欢的每个主题，而事件发布者正在执行这项工作，并且如果服务不可用，事件仍然会传递。在我看来，这保证了高可扩展性和可用性。

我的问题是队列。我无法获得一个可轻松扩展的队列来保证消息的排序。它实际上保证了至少一次交付的“轻微失序”：需要明确的是，它是 AWS SQS。

因此，排序问题是：

• 不保证同一事件流中的事件之间的顺序。
• 不保证来自同一 ES 的事件之间的顺序。
• 不保证来自不同 ES（不同服务）的事件之间的顺序。

我想我可以通过跟踪来自同一 ES 的事件的“序列号”来解决前两个问题。这可以通过跟踪我们消费事件的每个主题的最后一个序列号来完成。这应该很容易对事件做出反应并构建我们的投影。然后，当我从队列中弹出一个事件时，如果eventSequenceNumber > previousAppliedEventSequenceNumber + 1我将其重新排队（或使其在一段时间内不可见）。

但事实证明，使用这个解决方案，当事件以高速率产生时，它会破坏性能（我可以使用可见性超时或其他东西，结果应该是相同的）。

这是因为当我期待事件 10 并暂时忽略事件 11 时，我还应该忽略序列号在事件 11 之后的所有事件（来自 ES），直到事件 11 再次出现并得到有效处理。

其他困难是：

• 在哪里跟踪事件的序列号以构建投影。
• 如何跟踪事件的序列号以构建投影，以便在应用它时，我有一个一致的lastSequenceNumber.

我缺少什么？

PS：对于第三个问题，请考虑以下场景。我们有 aUserService和 a CartService。它CartService有一个投影，每个用户都可以跟踪购物车中的产品。UserCreated每个购物车的投影还必须包含来自.NET 发布的事件的用户名和其他信息UserService。如果UserCreated出现在ProductAddedToCart正常流程之后，则需要抛出异常，因为用户尚不存在。

我在微服务和事件来源方面还是个新手，我试图找出一种在AWS上部署整个系统的方法。

据我所知，有两种方法可以实现事件驱动的体系结构：

• 使用AWS Kinesis数据流
• 使用AWS SNS + SQS

因此，我的基本策略是将每个命令转换为存储在DynamoDB中的事件，并利用DynamoDB流将新事件通知其他微服务。但是如何？我应该使用前两个解决方案中的哪一个？

第一个优点是：

• 消息排序
• 至少一次交货

但是缺点非常成问题：

• 没有内置的自动缩放功能（您可以使用触发器来实现）
• 没有消息可见性功能（显然是要求确认）
• 没有主题订阅
• 非常严格的读取事务：您可以使用我在这里阅读的内容使用多个分片来改进它，您必须具有数量不明确的，具有不同调用优先级的lamda，并且必须具有明确的策略，以避免在同一微服务的多个实例之间进行重复处理。

第二个优点是：

• 完全管理
• TPS很高
• 主题订阅
• 邮件可见性功能

缺点：

• SQS消息是尽力而为的排序，仍然不知道它们的含义。它说：“标准队列会尽最大努力保持消息的顺序，但是可能会不按顺序地传递消息的多个副本”。这是否意味着给n条消息的副本，与其他消息的副本相比，第一个副本按顺序交付，而其他副本按无序交付？还是“不止一个”可以是“全部”？

非常感谢您的各种建议！