SOA / SEDA - 循环架构

Question

我有一个现实生活中的 SOA 问题，我似乎无法以干净的 SOA 方式解决。

我有许多分布式的“更新事物”消息生产者，这些消息被“事物管理器”使用。

“事物管理器”的功能之一是向主题发布“事物”已更改的通知。这允许其他感兴趣的服务对更改做出反应。

“更新事物”生产者之一本身就是该主题的听众。它只对来自其他系统的“事物更新”真正感兴趣。但它发现自己消耗和处理来自“事物管理器”的更新，这是它自己首先引起的（因此已经知道）。幸运的是，反馈回路在那一点上被打破了。

如何以干净的 SOA 方式最好地解决这个问题？我不会将元数据添加到指示消息源的消息中作为一个干净的解决方案；消息消费者永远不必知道消息来自哪里或要去哪里。

Answer 1

当“更新事物”订阅“事物管理器”时，它应该能够针对想要订阅的“事物”设置过滤器。所有“更新事物”都应设置的一个过滤器是不要向我发送任何源自我自己的东西。那么“更新事物”将不知道消息的来源，但“事物管理器”会。