在rabbitmq中实现消息处理器来处理接收到的消息

Question

最近我正在尝试使用 DDD 来实现我的应用程序。我使用 rabbitmq 代理来发布我的事件。 假设我有 2 个域 A B 。每个域都有其数据库。我想向 A 数据库添加一条记录，并且 A 域应该发布一个事件以将该记录插入 B 数据库。

在实现中，当我在 A 数据库中插入记录时，我应该从 A 域调用 recordinserted 事件，但我的问题是我的 B 域应该如何调用 messagehandler 来处理该消息？我的意思是我应该调用一个线程来监听rabbitmq 队列吗？

Answer 1

您可以自己实现消息处理，也可以使用服务总线。我有一个名为 Shuttle.Esb 的开源服务总线项目：

• Documentation
• GitHub

如果 Shuttle.Esb 没有引起你的共鸣，你可以看看其他的。