我需要微服务中的事务队列吗？

Question

我正在学习微服务，我知道在我的场景中，我希望微服务使用消息队列相互通信，并具有持久性。这意味着如果实例崩溃并且消息没有被消费，它将在实例反弹（或者可能被另一个实例）时消费。

现在，既然这些消息很关键，它们不应该是事务性的并参与微数据库事务吗？我看到使用 Kafka 或 RabbitMQ 的示例，但这些队列实现不实现事务。如果他们不这样做，很可能会丢失一些消息。

微服务真的需要事务吗？或者我应该以一种有弹性的方式设计我的微服务，以便它们可以丢失信息并从这种情况中恢复？

也许我的问题没有意义。也许我还在以隔离、锁定和事务为王的“单体”方式思考。

Answer 1

正如 Ivan Baranuk 在评论中所说。大多数消息代理都有acknowledgement。和死信队列 (DLQ)。

只要崩溃发生在acknowledgement 之前（可以由您正在使用的库处理，或者您可以手动处理），您就不会丢失您的消息，因为它会重新排队。如果多次后崩溃仍然发生并且超过maxRetryAttempt，它将被传递给DLQ以供您处理。

就像队列确认等同于数据库提交。

额外：我确实认为 DB 事务在使用消息时很重要。处理在使用消息时有多个 DB 写入的情况，然后在进程中间您的应用程序崩溃。当它崩溃时，消息不会是ack-ed，它会被重新排队，稍后会再次被消费。是为了防止消息第二次被消费时重复写入。