1回答
Rabbitmq:代理重新启动后未删除的消息
rabbitmq、spring-amqp、spring-rabbit
我们观察了RabbitMQ的以下行为，并试图了解它是否正确以及如何解决它。
附带注意:在兔子管理UI中，我可以看到现在存在两个通道。在代理重新启动之前创建的“死”消息，包含未加标记的消息和健康的新消息。
这种行为会是这样吗？在我看来，“正确”的方式是，
浏览 1提问于2018-02-21得票数 3
0回答
php rabbitmq使用者重新连接
php、rabbitmq、haproxy
我有一个使用RabbitMQ的PHP应用程序。为了实现冗余，我创建了一对RabbitMQ服务器，并将它们加入到一个集群中。我还有一个运行HAProxy的VyOS故障转移集群，用于对连接进行负载平衡，并在发生故障转移时提供重新路由。
昨天，我们的VyOS集群决定需要故障转移(可能是短暂的网络中断)。我检查了运行的机器，消费者仍然在运行PHP。我离开他们一段时间，看看他们是否会重新连接，但他们没有。我必须杀死PHP脚本并重启它们，它们立即
浏览 15提问于2016-07-07得票数 3
回答已采纳
1回答
如何与缓慢的消费者打交道
rabbitmq、masstransit
我使用MASSERSIT7.0.0与使用者一起处理来自RabbitMQ的消息。我已经观察到，当使用者处理消息的速度很慢时，或者当我将调试点放在visual studio中供使用者使用时，过了一段时间，我的使用者再次收到消息。在我的例子中，我的使用者在与外部端点交谈时处理消息的速度有时很慢，但是处理时间大约是30-40秒，而不是分钟。
请您解释一下，如何知道用户是如何通过崩溃(或任何其他方式)重新发送消息的？如果它等待一定时间等待ack，那么在任何地方设置这个时间是否只是
浏览 2提问于2020-08-25得票数 1
回答已采纳
1回答
RabbitMQ，在节点编写的pub子模型中请求拒绝消息。
node.js、rabbitmq、message-queue
服务器启动时将建立rabbitMQ连接。
在消费时，如果套接字是活动的，那么通过它发送&确认它。如果没有，请确认并重新排队。console.log(`[x] Sent ${message} to the exchange with routingKey ${routingKey}`);
浏览 2提问于2019-02-21得票数 0
4回答
RabbitMQ在用户重新连接之前丢失消息
rabbitmq、amqp
我实现了一个使用者，如果基础连接关闭，它将在一段时间后自动重新连接到代理。我的情况如下：
com.rabbitmq.client.ShutdownSignalException:连接错误；原因：{#方法(回-代码=541，回-文本=内部_ERROR然后消费者会在重新<em
浏览 2提问于2013-08-09得票数 4
回答已采纳
1回答
在重新连接时使用node-amqplib取消订阅特定队列
node.js、typescript、node-amqplib
问题:远程系统重新连接到多个节点的websocket服务器，为每个系统创建/使用RabbitMQ中的专用队列。如果不存在活动连接，则应自动删除队列。Websocket连接/断开事件处理程序是异步的，相当繁重，观察到断开事件处理程序在重新连接后完成的问题，使系统不一致。主要的问题是RabbitMQ队列-最初的解决方案是为每个连接创建唯一的队列，并在断开连接时删除它们。看起来很重。第二种方法是为每个远
浏览 59提问于2021-01-14得票数 0
1回答
为什么在RabbitMQ中连接恢复之后会出现重复的使用者？
java、rabbitmq、amqp
我正在使用：
在我的应用程序中，有一个异步使用者通过回调接收消息。当我试图通过禁用与代理的网络通信来模拟连接失败时，会发生此问题。在重新建立连接之后，队列(在web管理接口中)显示两个消费者连接到
浏览 2提问于2015-07-06得票数 5
1回答
使用xdebug从rabbitmq队列执行Debug php
php、rabbitmq、xdebug
我正在尝试调试由RabbitMQ使用者执行的PHP代码。php_ini_loaded_file()它打印：localhost10
/etc/php5/cli/php</e
浏览 2提问于2016-02-25得票数 1
2回答
当RabbitMQ使用者崩溃时，获取消息会发生什么？
queue、rabbitmq、message-queue、amqp
如果我有一个RabbitMQ使用者批量检索100条消息，但在将这些消息标记为已处理之前就会崩溃，那么这些消息是否丢失了？我希望队列中的每条消息至少处理一次。RabbitMQ是否以某种方式将它们重新放到了队列中，或者我需要做些什么来实现它呢？
浏览 8提问于2017-02-21得票数 11
我正在使用spring-integration-amqp 4.1.4和rabbitmq amqp-client 3.5.3。消息正在正常传递，但回复消息检索引发以下异常。org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer -使用者引发异常，如果连接工厂支持，则可以重新启动处理
java.lang.NoClassDefFoundError: com/rabbitmq/client/imp
浏览 0提问于2015-06-14得票数 5
1回答
如何更改RabbitMQ心跳而不重新启动
rabbitmq、consumer、heartbeat、rabbitmqctl
这里有几个关于RabbitMQ心跳的问题，但我还没有找到一个解决如何实际更改60 seconds (早期版本中的580 seconds)的默认心跳值的方法。如果消费者的运行时间超过60 seconds，并且无法产生任何可算作心跳的通信量(例如，)，则RabbitMQ将关闭连接，考虑到消费者已死亡，但使用者可能继续运行，当它试图生成ACK时，连接被关闭，您将得到如下错误消息：
可以将使用者端的心跳设置为较高的值，例如1800 seconds，但是如
浏览 0提问于2019-07-04得票数 5
回答已采纳
2回答
管理RabbitMQ用户
symfony、rabbitmq
我计划使用RabbitMQ、Symfony2和RabbitMqBundle编写一个日志处理应用程序。我正在使用的工具必须是高度可用的，并且必须每天处理数百万条条目，因此重要的是，使用者始终处于启动和运行状态(短暂的休息时间是可以的)，否则我的队列可能会在一段时间后溢出。在如何管理使用者(用PHP编写)、在发生错误时启动/重新启动消费者等方面有最佳实践吗？
谢谢
浏览 2提问于2013-11-05得票数 5
回答已采纳
1回答
Rabbitmq重新加载/刷新新证书而不重新启动
rabbitmq、ssl-certificate、spring-amqp、spring-rabbit、rabbitmqctl
我现在正在尝试更新/使用新的SSL证书、SSL密钥和信任存储库，但我不希望重新启动正在运行的rabbitmq服务器，因为我的应用程序应该继续运行。我在网上查看了在运行时刷新/重新加载erlang/rabbitmq的解决方案，以读取/重新加载这些新的SSL证书，我偶然发现了它们建议使用- rabbitmqctl eval "ssl:stop(),该命令运行良好，无需重新启动就刷新了新的SSL证书，但是使用者/<e
浏览 0提问于2018-07-04得票数 8
1回答
消息传递系统可靠性
rabbitmq、jms、activemq、amqp、spring-jms
我了解到，每个消息传递平台(rabbitmq，activemq)都提供了某种机制，以保证服务器(rabbitmq)和使用者之间的消息传递，因此如果使用者停机，消息仍将处于队列中并重新传递。但是，如果消息传递平台关闭，而客户端(消息的生产者)无法将消息传递给平台(Rabbitmq)，会发生什么呢？在这种情况下，需要一个重试方法来重新传递消息，但是我不确定我是否必须自己实现它，或者客户机库有这个选项，它是否声明为连接/通道创建中的一个参数？这是
浏览 0提问于2018-10-06得票数 0
回答已采纳
1回答
兔子MQ虚拟主题？
rabbitmq、virtual-topic
在兔子MQ中，是否存在与活动MQ虚拟主题相同的内容？或者任何其他机制都可以实现队列语义。一些主题订阅者需要在返回联机时传递持久消息，并进行负载平衡。有多个消费者，他们中的很少有可能丢失消息，因为他们只在实时的基础上采取行动；很少有人不这样做，因为他们需要历史数据。
浏览 3提问于2015-07-22得票数 2
回答已采纳
1回答
RabbitMQ用户消息消费的优先顺序
php、python、rabbitmq
我正在使用RabbitMQ进行一个项目，并将许多消费者连接到一个队列中。我想知道是否有一种方法来指定哪个使用者在使用来自队列的消息时获得“优先级”。我正在使用RabbitMQ的最新版本(截至编写时)。我有一个PHP发布者和Python使用者。
谢谢你的帮助!
浏览 1提问于2020-01-02得票数 0
回答已采纳
1回答
RabbitMQ关闭时的重连接策略
.net、rabbitmq、masstransit
我有以下几种不同的情景： RabbitMQ起来了。RabbitMQ倒下了。如果消费者试图订阅busControl.Start();，那么它将正确地重新连接。
RabbitMQ倒下了
消费者上升并尝试使用b
浏览 3提问于2020-03-06得票数 1
1回答
我应该如何构造RabbitMQ？
symfony、docker、rabbitmq、docker-compose、amqp
我正在尝试将我们的单块PHP Symfony应用程序迁移到一个更可伸缩的Docker解决方案中。为每个RabbitMQ使用者创建一个单独的Docker容器有意义吗？不让rabbitmq服务器知道用于处理队列的语言/工具是“正确的”和“干净的”。我想出了(docker-compose.yml的相关部分)： # my php-fpm app container
container_nameextends: ap
浏览 2提问于2017-07-05得票数 5
回答已采纳
2回答
RabbitMQ之间的区别到期和自动删除？
rabbitmq、amqp
第19页的"RabbitMQ in Action“一书给出了这些排他性和自动删除的描述：
“过期”策略控制队列在自动删除之前可以使用多长时间。未使用意味着队列没有使用者，队列最近没有重新声明(重新声明续订租约)，并且至少在过期期间没有调用basic.get
浏览 13提问于2019-09-30得票数 4
2回答
如何使用RabbitMQ java客户端库从错误连接恢复？
java、rabbitmq、amqp
我想知道其他人如何使用官方的RabbitMQ java客户端库从错误的连接中恢复。因此，让我们看看解决这个问题的一些方法：让每个使用者都有自己的连接，并在连接终止时注册触发的事件，然后处理重新连接。
让每个使用者使用相同的连接，并订阅其连接</em
浏览 7提问于2013-10-30得票数 14
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云点播
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号