gpt4 book ai didi

java - 我如何(我可以?)检测 RabbitMQ 队列创建失败?

转载 作者:太空宇宙 更新时间:2023-11-04 09:45:22 24 4
gpt4 key购买 nike

我正在尝试解决 RabbitMQ 中与服务器在网络/套接字断开连接后未及时获取独占队列相关的竞争条件,这会导致客户端中的恢复代码失败。这不是我设计或编写的代码,而且我对 RabbitMQ 和 Spring 相当陌生。我们还使用旧版本的 spring-rabbit 1.7.0.RELEASE,因此我可以用来解决该问题的许多新功能都不可用。升级到最新的代码是一种选择,但需要一整套回归测试,我们更喜欢更简单的东西作为短期修复,这样我们就可以快速摆脱困境。然后,我们可以将升级和所需的更改滚动到更高版本中,以便我们有时间对其进行正确测试。

问题很简单。我们有一个 java 服务器应用程序,它创建一个所有客户端都可以向其发送消息的命名队列。我们的 Java 客户端每个都会创建一个命名(基于主机的名称)、独占、自动删除队列来接收来自服务器的消息。它被设置为独占,因为我们不希望任何其他客户端使用相同的队列,因为发送到该队列的所有消息都是针对创建该队列的客户端的。我知道创建这样的命名独占队列是一个坏主意,并且服务器生成的队列名称是首选,但这就是系统的实现方式,现在修复它需要大量向后不兼容的更改和更多的测试...

问题发生在网络故障时,套接字连接消失。客户端检测到这一点并尝试重新建立连接和队列等。似乎存在竞争条件,即在客户端多次重试创建队列、失败并关闭连接之前,RabbitMQ 服务器无法获取现有队列。 RabbitMQ 服务器最终确实获得了队列,但那时客户端已经失败并且无法恢复。

为了解决这个问题,我尝试创建非独占队列,并将消费者设置为独占(实际上已经是这样了)。这工作正常并解决了竞争条件。然而,使队列不具有排他性可能会在排他队列可以避免的错误情况下导致显着的副作用。如果第二个客户端 (client2) 配置不正确并尝试使用另一个客户端 (client1) 已使用的队列名称,则队列创建会失败,但连接保持打开状态,因此 client2 仍然可以向服务器发送消息,就像 client1 一样。

队列的排他性导致连接失败,从而破坏了整个连接,导致 client2 无法在任一方向与 Rabbit 服务器进行通信。删除队列独占性并依赖消费者独占性意味着 client2 无法使用 client1 队列中的任何消息,但它仍然可以像 client1 一样向我们的服务器发送消息。当服务器从两个不同的客户端获取冲突的状态信息时,这会导致对 client1 的控制严重破坏。

短期内,我想做的是尝试检测 client2 上的队列创建失败,并关闭连接,就像独占队列失败时发生的情况一样,以便 client2 失败,但不会导致 client1 失败。但是,我不知道如何检测故障。有没有办法做到这一点?我似乎在文档或 Spring AMQP 代码中找不到任何内容。

建议?

最佳答案

首先,1.7.0已经有两年多的历史了;您至少应该使用最新的 1.7.x,在撰写本文时为 1.7.13。

SimpleMessageListenerContainer 有一个属性 missingQueuesFatal,默认情况下为 true。如果设置为 false,容器应继续无限期地尝试。

关于java - 我如何(我可以?)检测 RabbitMQ 队列创建失败?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55480066/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com