- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我正在尝试解决 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/
我在使用以下代码时遇到问题: function http_file_exists($url){ $f=fopen($url,"r"); if($f){ fclose($f); retu
我已经通过 Git 部署到 Azure 几个月了,没有出现重大问题,但现在我似乎遇到了一个无法克服的错误。 我创建了一个新的 Azure 网站,为正在开发的项目创建单独的预览链接。我在新站点上设置了
我已经通过flutter创建了一个App并完成了它,我想在flutter文档中阅读时进行部署。 我收到此错误: FAILURE: Build failed with an exception. * W
我在Windows 10中使用一些简单的Powershell代码遇到了这个奇怪的问题,我认为这可能是我做错了,但我不是Powershell的天才。 我有这个: $ix = [System.Net.Dn
我正在尝试使用 RapidJSON 解析从服务器接收到的数据。以下是收到的确切字符串: [ { "Node": "9478149a08f9", "Address": "172.17
我尝试为 ios 编译 OpenCV。我总是收到这些错误。我用不同版本的opencv试了一下,结果都是一样的。 我运行这个:python 平台/ios/build_framework.py ios_o
我在一台机器上做基本的发布/订阅,我的客户端是 StackExchange-Redis 的 C# 客户端,我在同一台机器上运行基于 Windows 的 Redis 服务器(服务器版本 2.8.4) 当
我有这段代码,但无法执行,请帮我解决这个问题 连接 connect_error) { die ("connection failed: " . $terhubung->connect_erro
我在 tomcat 上运行并由 maven 编译的 Web 应用程序给出了以下警告和错误。我可以在本地存储库中看到所有 JAR,但有人可以帮忙吗。 WARNING: Failed to scan JA
我正在 Windows 8 上使用 Android Studio 开发一个 android 应用程序,我正在使用一些 native 代码。突然间我无法编译我的 C 文件。当我运行 ndk-build
下面的代码对类和结构的成员进行序列化和反序列化。序列化工作正常,但我在尝试使用 oarch >> BOOST_SERIALIZATION_NVP(outObj); 反序列化时遇到了以下错误; 代码中是
如果我运行此命令“rspec ./spec/requests/api/v1/password_reset_request_spec.rb”,此文件中的所有测试都会通过。 但是,当我运行“rspec”时
我在尝试执行测试以使用 Protractor 上传文件时出错,我的代码是这个 it('it should be possible to upload a file', function() {
System.loadLibrary("nativefaceswap"); 当我运行我的应用程序时,我在 Android Studio 中发现了此类错误。在logcat中显示: java.lang.U
我希望有人能帮助我!使用任何方法或命令行的任何 SSL/HTTPS 调用均无效。 我在 Windows 10 中使用 Ubuntu Server 18.04 作为子系统。我的问题是昨天才开始出现的,因
通过删除这两个值将日期字段从 null=True 和 Blank=True 更改为 required 时,使用 db.alter 命令时遇到问题。 当以下行被注释掉时,迁移运行不会出现问题。
我第一次使用 Heroku 尝试创建应用程序(使用 SendGrid 的 Inbound Parse Webhook"和 Twilio SMS 通过电子邮件发送和接收 SMS 消息)。通过 Virtu
我正在将我的 swift 项目更新到 Xcode 7 上的 Swift 2.0。xcode 在构建项目时报告了以下错误: 命令/Applications/Xcode.app/Contents/Deve
在我的代码中,SSL 库函数 SSL_library_init() 没有按预期返回 1。我如何才能看到它返回了什么错误? 我在 SSL_library_init() 之后调用了 SSL_load_er
我正在尝试运行在以下链接中找到的答案: Asynchronously Load the Contents of a Div 但是当我这样做时,我会遇到我不太理解的错误。 我的代码: $(documen
我是一名优秀的程序员,十分优秀!