微服务架构 - 在订单无关紧要时通过服务传递消息

Tl;博士：“我如何通过一堆异步，无序的微服务推送消息，并知道该消息何时通过它们？”

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

我在开始队列中有一条消息。让我们说一个带有序列化JSON的RabbitMQ消息 我需要该消息来通过任意数量的微服务 这些微服务中的每一个都是长期运行的，必须是独立的，并且可以以各种语言实现 消息所经过的服务顺序无关紧要。实际上，它不应该是同步的。 每个服务都可以将数据附加到原始消息，但其他服务会忽略该数据。应该没有合并冲突（每个服务写一个唯一的密钥）。任何服务都不会改变或破坏数据。 一旦所有服务轮到他们，就应该使用原始数据和新数据将消息发布到第二个RabbitMQ队列。 微服务没有其他副作用。如果这些都在一个单片应用程序中（并且使用相同的语言），那么函数式编程将是完美的。

那么，问题是，通过各种服务管理该消息的适当方式是什么？我不想一次做一个，订单并不重要。但是，如果是这种情况，那么系统如何知道所有服务何时发生了重击并且最终消息可以写入结束队列（以使下一批服务完成它们）。

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

让第一个遇到消息的服务将该消息写入公共存储（比如mongodb） 让每个服务做它的事情，标记它已完成该消息，然后检查所有服务是否已经轮到他们 如果是这样，那最后一个服务将发布该消息

但是，这仍然需要每个服务都知道所有其他服务，并要求每个服务留下其标记。这些都不是必需的。

我对某种“牧羊人”服务持开放态度。

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

谢谢。