tl；博士：“我如何通过一堆异步、无序的微服务推送消息，并知道该消息何时通过每个微服务？”

我正在努力为特定的微服务体系结构找到合适的消息传递系统/协议。这不是一个“哪个是最好的”问题，而是一个关于我的设计模式/协议选项的问题。

• 我在开始队列上有一条消息。假设带有序列化JSON的RabbitMQ消息
• 我需要该消息通过任意数量的微服务
• 这些微服务中的每一个都是长时间运行的，必须是独立的，并且可以用多种语言实现
• 消息经过的服务顺序并不重要。事实上，它不应该是同步的。
• 每个服务都可以将数据附加到原始消息中，但其他服务会忽略该数据。不应该有合并冲突（每个服务都写入一个唯一的密钥）。任何服务都不会更改或销毁数据。
• 一旦轮到所有服务，消息应该发布到第二个RabbitMQ队列，其中包含原始数据和新数据。
• 微服务不会有其他副作用。如果这一切都在一个单体应用程序中（并且使用相同的语言），函数式编程将是完美的。

所以，问题是，通过各种服务管理该消息的适当方式是什么？我不想一次做一个，而且顺序也不重要。但是，如果是这样的话，系统如何知道所有服务何时都已完成，并且最终消息可以写入到结束队列中（以便让下一批服务完成）。

我唯一能想到的半优雅的解决方案是

1. 要让第一个遇到消息的服务将该消息写入公共存储（例如mongoDB）
2. 让每个服务做它的事情，标记它已完成该消息，然后检查是否所有服务都已轮到它们
3. 如果是这样，最后一个服务将发布消息

但这仍然要求每个服务都知道所有其他服务，并要求每个服务都留下自己的印记。这两个都不是我们想要的。

我愿意接受某种“牧羊人”服务。

我很感激我错过的任何选择，并愿意承认它们可能是一个更好的基本设计。

非常感谢。