RabbitMQ-最佳实践

Question

我正在尝试同步我拥有的三个微服务。

为此，我实现了RabbitMQ。看起来好像事情目前是可行的，但我不确定我是否遵循了最佳实践，而且我找不到一个参考，也许有人能帮我做这件事？

我正在尝试做的简要说明：我有一个服务谁应该更新另外两个，每个服务应该接收发送的消息。我有两种类型的消息（保存和删除资源）。*发生故障时，队列应恢复并重新发送消息。

我目前正在做的事情：我已经建立了一个交换，我的每个消费者都连接到两个不同的队列，一个队列对应于每种类型的消息（保存/删除）。我使用了一个直接交换来过滤以后的消息，尽管目前我不需要过滤它们。

每个队列都被命名，交换和消息都是持久的，我正在处理我已经使用的消息。

问题是应该为每种类型的事件设置不同的队列，还是应该在同一队列中发送消息并对其进行过滤？使用上面描述的RabbitMQ是解决问题的正确方法。最佳实践是什么？

Answer 1

您的设置是正确的。

在rabbit中设计队列时的一个常见规则是，一个队列对应于消费者的一种类型（这里的类型表示不同的处理逻辑）。既然你有两种类型的消费者。对于不同类型的事件（保存/删除），它们有不同的逻辑，每个队列都是正确的。

如果您希望只有一种类型的使用者，它可以同时处理save和delete事件，那么使用一个队列也是可以的。

但两种类型的使用者和一个共享队列将无法工作。因为当多个消费者订阅一个队列时，事件会以循环的方式发送给消费者，所以任何一个消费者只能接收到一半的事件。