请确保仅删除空的RabbitMQ队列，如果该队列仍有消息，则删除失败
RabbitMQ是一个开源的消息队列中间件，它实现了高效的消息传递机制，常用于分布式系统中的消息通信和解耦。在使用RabbitMQ时，如果想要删除一个队列，但又不希望丢失队列中的消息，可以通过以下步骤来确保仅删除空的RabbitMQ队列：
- 连接到RabbitMQ服务器：使用RabbitMQ提供的客户端库，如AMQP协议的pika库（Python）、RabbitMQ Java客户端等，建立与RabbitMQ服务器的连接。
- 检查队列是否为空：通过调用RabbitMQ的API或客户端库提供的方法，获取指定队列的消息数量。如果消息数量为0，则表示该队列为空。
- 删除空队列：如果队列为空，调用RabbitMQ的API或客户端库提供的方法，删除该队列。
以下是一些相关概念和步骤的详细说明：
概念：
- RabbitMQ：一个开源的消息队列中间件，实现了高效的消息传递机制。
- 队列：RabbitMQ中用于存储消息的容器，消息发送者将消息发送到队列，消息接收者从队列中获取消息进行处理。
- 消息：在RabbitMQ中传递的数据单元，包含消息体和一些附加属性。
步骤：
- 连接到RabbitMQ服务器：使用RabbitMQ提供的客户端库，建立与RabbitMQ服务器的连接。连接参数包括RabbitMQ服务器的地址、端口、用户名和密码等。
- 检查队列是否为空：通过调用RabbitMQ的API或客户端库提供的方法，获取指定队列的消息数量。例如，使用pika库的
channel.queue_declare方法可以获取队列的消息数量。
import pika
# 建立与RabbitMQ服务器的连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# 获取队列的消息数量
queue_name = 'my_queue'
queue_declare_result = channel.queue_declare(queue=queue_name, passive=True)
message_count = queue_declare_result.method.message_count
# 关闭与RabbitMQ服务器的连接
connection.close()- 删除空队列：如果消息数量为0，表示队列为空。调用RabbitMQ的API或客户端库提供的方法，删除该队列。例如，使用pika库的
channel.queue_delete方法可以删除队列。
import pika
# 建立与RabbitMQ服务器的连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# 删除空队列
queue_name = 'my_queue'
channel.queue_delete(queue=queue_name)
# 关闭与RabbitMQ服务器的连接
connection.close()推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云云服务器 CVM：https://cloud.tencent.com/product/cvm
- 腾讯云云数据库 CDB：https://cloud.tencent.com/product/cdb
- 腾讯云云原生容器引擎 TKE：https://cloud.tencent.com/product/tke
- 腾讯云云安全中心 SSC：https://cloud.tencent.com/product/ssc
- 腾讯云云点播 VOD：https://cloud.tencent.com/product/vod
- 腾讯云人工智能 AI：https://cloud.tencent.com/product/ai
- 腾讯云物联网平台 IoT Explorer：https://cloud.tencent.com/product/ioe
- 腾讯云移动开发 MSDK：https://cloud.tencent.com/product/msdk
- 腾讯云云存储 COS：https://cloud.tencent.com/product/cos
- 腾讯云区块链服务 TBC：https://cloud.tencent.com/product/tbc
- 腾讯云元宇宙服务 TUS：https://cloud.tencent.com/product/tus
请注意，以上链接仅供参考，具体产品选择应根据实际需求和情况进行评估。
相关·内容
我对RabbitMQ如何处理在直接模式下从已断开连接的队列中的交换转发的持久消息感到有点困惑。
情况是这样的。
-> Exclusive Queue -> Client 1
/
Exch -
\
-> Exclusive Queue -> Client 2
持久消息被发送到交换，交换将它们分发到独占队列。客户端1死于破坏它的独占队列。
我的问题是，如果队列中有消息，它们会丢失吗？还是他们对交易所怀有敌意？
或者这是个坏主意？让每个客户端连接到单个队列是不是更好？(这需要持久的消息和高吞吐量，所以不确定这是不是一个选项
浏览 2提问于2013-01-12得票数 1
最近，我开始使用和RabbitMQ绑定。
如果当两个服务想要传递消息时，我正确地理解了一切，那么一个应该配置发送消息的源，另一个应该配置接收器来接收消息--两者都应该使用相同的通道。
我有个频道叫testchannel。不过，我注意到该源代码创建了RabbitMQ绑定：
交换testchannel，
路由密钥testchannel
队列testchannel.default (持久的)，
接收器创建了RabbitMQ绑定：
交换testchannel，
路由密钥#
队列testchannel.anonymous.RANDOM_ID (执行)。
为了简洁起
浏览 3提问于2016-02-05得票数 3
回答已采纳
我在OpenShift上运行了一个MQTV3.6.10实例，并启用了RabbitMQ插件。我有多个Spring Boot应用程序，使用来自RabbitMQ队列的消息。所有消费者都使用MqttDefaultFilePersistence。将持久化数据写入到持久化卷上的目录/tmp/mqtt，配额为100M。这是我为连接到RabbitMQ队列而编写的代码：
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName(username);
options.setPassword(pass
浏览 1提问于2017-11-24得票数 0
我实现了一个使用者，如果基础连接关闭，它将在一段时间后自动重新连接到代理。我的情况如下：
成功启动RabbitMQ服务器。
成功启动消费者。
发布了一条消息，并成功地接收到了它。
停止RabbitMQ服务器，使用者将显示异常：
com.rabbitmq.client.ShutdownSignalException:连接错误；原因：{#方法(回-代码=541，回-文本=内部_ERROR，类-id=0，方法-id=0)，null，“}。
然后消费者会在重新连接之前睡上60秒。
再次启动RabbitMQ服务器。
成功发布消息，命令'list_queues‘的结
浏览 2提问于2013-08-09得票数 4
回答已采纳
1回答
我刚刚安装了RabbitMQ，我正在与logstash一起使用它。我一直在发送信息，但我丢失了很多数据。我不知道该怎么解决这个问题。我在rabbitMQ中使用默认配置。
这些是logstash中的输出和logstash中的输入：
output {
rabbitmq {
host => "IPHOST"
exchange => "logstash-rabbitmq"
exchange_type => "direct"
key => "logstash-key"
浏览 1提问于2015-12-02得票数 0
回答已采纳
我试图通过调用AWS函数将s3event消息发送到rabbitmq。我已经将SQS配置为我的死信队列(DLQ)。我知道，当lambda调用失败或超时或资源约束等情况发生时，该消息将发送给DLQ。我的问题是，我想在一定条件下从lambda函数内部向DLQ发送事件消息，比如如果rabbitmq关闭或其他我感兴趣的条件。有同样的可能性吗？我是应该抛出异常，还是有其他更好的方法向DLQ发送事件消息。
我使用java进行开发，并通过lambda函数连接到rabbitmq。
浏览 0提问于2018-03-21得票数 6
回答已采纳
我设置了从服务器(NodeJS)向持久队列发送消息，而客户端(android app)监听各自队列中的消息(每个android设备监听其对应的队列，这是唯一的)。
根据RabbitMQ文档，当我们尝试连接到一个名称为空的队列(即"")时，RabbitMQ会生成一个名称以"amq.gen-“开头的随机队列。但是，从客户端或服务器代码中看不到任何地方，我试图连接到一个名称为空的队列，但仍然看到生成了许多随机队列。
有没有人能帮我理解一下，还有哪些场景可能会创建名为"amq.gen-*“的随机队列？
浏览 3提问于2014-03-05得票数 13
回答已采纳
1回答
使用RabbitMQ 3.7.16和spring-amqp 2.2.3.RELEASE。
多个客户端使用唯一的路由密钥将消息发布到我们的DataExchange服务器中的RabbitMQ主题交换。在没有任何绑定的情况下，交换将通过AE将所有消息路由到data.queue.generic。
当某个客户端(图中的客户端ID 1和2 )发布大量消息时，为了独立于其他客户端来扩展它们的消息消耗，我们启动了使用者，并分配给他们只处理他们的客户机ID，为了实现这一点，每个客户端-使用者都定义了一个新的队列，并将其绑定到主题交换与路由密钥events.<clientID>。
因此，扩大规模是涵盖
浏览 0提问于2020-02-11得票数 2
回答已采纳
1回答
我使用的是RabbitMQ管理码头图像。问题是在大约1周的正常运行时间之后，磁盘空间和内存几乎耗尽。我需要再次终止并重新启动它才能正常工作，但是这样做，队列中的所有现有消息都会丢失。
用于启动rabbitmq服务器的命令是：docker run --rm -it --hostname my-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management
我使用的是持久消息和持久队列。不是的。排队人数将在70人左右。每秒的连接可能从5到100不等。
我使用 npm模块使用Nodejs与RabbitMQ交互。
我做错了什么吗？或者，如果使用
浏览 5提问于2020-11-13得票数 0
1回答
我目前正在寻找建立一个消息传递服务，其中用户可以发送和接收彼此之间的私人消息。我可能需要多用户聊天，但在大多数情况下，我只希望单个收件人能够阅读发送给他们的消息。
看看RabbitMQ，使用一个交换，并在用户登录时为每个用户创建一个队列，然后在注销时销毁每个队列，这有意义吗？为每个用户创建队列是否存在主要的性能问题，或者是否有更好的替代方案？
我正在构建一个REST API，并计划让用户通过端点(/send)向其他用户发送消息，并通过websockets或类似的东西订阅自己的消息流。我可能也会将消息存储在MongoDB中，这样用户就可以访问他们以前的所有消息。任何关于结构的建议都是值得感谢的。
浏览 2提问于2015-07-28得票数 2
1回答
理想情况下，当队列变为空时，我希望删除RabbitMQ中的队列。基本上，我希望队列包含消息的待办事项，然后当发生什么事情时，这些消息将被发送出去，直到队列为空。一旦队列为空，我想删除它。
这个是可能的吗？我在用Node。
浏览 0提问于2015-09-18得票数 5
回答已采纳
我让rabbitMQ broker作为集群在两个节点上运行。我观察到，如果已创建队列的节点关闭，则队列在其他节点上将不可用。如果我尝试发布来自其他节点的消息，它将失败。即使我从集群中删除故障节点(使用forget cluster命令)并尝试从其他节点发布消息，行为也是相同的。
在rabbitMQ中有什么方法可以实现这一点吗？
浏览 0提问于2017-06-29得票数 2
1回答
我使用rabbitmq和masstransit来交换消息，使用请求/响应机制，每件事情都工作得很好。一个应用程序使用持久队列，另一个应用程序在创建rabbitmq磁盘警报时使用临时队列.but，该应用程序被标记为“不健康”，并自动重新启动该队列，然后在重新启动并标记为“健康”(释放的磁盘空间)之后，具有持久队列的应用程序无法重新连接。在我使用了临时队列而不是持久队列之后，porblem就消失了，因为应用程序每次重新连接时都会重新创建队列，但是当rabbitmq容器失败或被杀死时，所有消息都会消失。应用程序被阻塞等待响应。
问题:
如何确保应用程序在每一次rabbitmq失败时重新连接，并保持数
浏览 10提问于2022-10-03得票数 2
1回答
我正在尝试部署Spring Boot微服务应用程序，使用Azure AKS中的K8s集群上的RabbitMQ来生产和消费数据。当我运行生产者应用程序并通过邮递员向队列生成一条消息时，我得到了200OK响应，但是在RabbitMQ管理UI中，我没有得到队列，并且在RabbitMQ容器日志中我看到了下面的错误 o.s.a.r.c.CachingConnectionFactory : Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-t
浏览 44提问于2020-07-04得票数 1
回答已采纳
我需要知道是否有更多的消息开始为这个消费者。
现在我数数队列上的消息。但这只给了我剩下的，而不是预先取走的。
@RabbitListener(queues = QUEUENAME)
public void recieve(Message message, Channel channel) throws IOException {
long messagesOnQueue = channel.messageCount(QUEUENAME);
if(messagesOnQueue>1) {
//add message to list
}
else {
浏览 0提问于2019-05-27得票数 0
回答已采纳
我正在使用Rabbitmq 3.7.17，我需要重命名一个已经包含了一些消息的现有队列。有简单的方法来重命名队列吗？
浏览 1提问于2019-09-03得票数 4
回答已采纳
我在rabbitmq上用芹菜。我已经向队列发送了数千条消息，这些消息正在成功处理，一切工作正常。然而，几个rabbitmq队列中的消息数量增长得相当大(队列中有数十万个项目)。这些队列被命名为celeryev.[...] (参见下面的屏幕截图)。这是适当的行为吗？这些队列的用途是什么?不应该定期清除它们吗？有没有办法更定期地清除它们，我认为它们占用了相当多的磁盘空间。
浏览 5提问于2013-07-22得票数 17
回答已采纳
场景:我有一个使用MassTransit从MessageBus读取消息的windows服务。可以将MessageBus配置为RabbitMQ或AzureService总线。如果消息在5次之后仍然失败，消息将被移动到另一个队列"publishToXYZ_Error“
问:我想用MassTransit删除"publishToXYZ_Error“中超过90天的所有消息。或者，有没有一种方法可以使用MassTransit过滤和使用超过90天的邮件。
示例有效负载
{
"messageId": "acdc0000-0e07-28f1-43d2-08d87c0a
浏览 0提问于2021-01-21得票数 1
背景
我正在设置一个用于实时日志分析的，使用RabbitMQ作为代理。我正在使用一个名为RabbitMQ的python项目将日志文件传送到。值得注意的是：
使用exchange_type: "direct"
使用queue_durable: 1 (不确定这是否值得一提)
使用exchange_durable: 1 (不确定这是否值得一提)
RabbitMQ
我从他们的网站下载了最新的RabbitMQ，并使用rabbitmq.config文件运行它。我在配置文件中包含的唯一内容是：
tcp_listeners -> {"0.0.0.0"
浏览 3提问于2014-09-01得票数 1
我正在做Rabbitmq。我是这个话题的新手。我有一个成功的发送者和接收者。我在这方面没有问题，但我注意到如果有一个失败的代码消息卡在一个队列中。 如果我详细解释，当我从队列中获取消息时，该消息应该被删除。有没有失败都无关紧要。因为queue cant会告知此消息是否成功处理。队列只会递送，对吧？因此，地狱队列是如何理解程序代码中存在故障并保留消息的。:D所以我一次又一次地收到消息。 如果你们能帮我了解Rabbitmq的基础知识。我会很高兴的。祝你们都有愉快的一天：
浏览 82提问于2020-07-27得票数 1
回答已采纳
队列中的第一条消息总是失败。从第二个开始，一切都很好！
不确定这是否可读，所以：
Created new connection: rabbitConnectionFactory#1b940034:0/SimpleConnection@2c52fbff [delegate=amqp://guest@10.0.0.10:5672/, localPort= 36370]
Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PREC
浏览 5提问于2018-05-23得票数 2
回答已采纳
我已经设置了Sensu，其中的API和服务器运行在一个实例上，RabbitMQ运行在单独的实例上。这对我们非常有用；但是，如果服务器或api与RabbitMQ的连接松散，则server不会发送任何通知。我希望服务器为这个场景中的每个客户端发送No keep-alive sent from client in over 120 seconds通知。就我们现在的设置而言，如果RabbitMQ失败(或连接失败)，所有监视都将悄然失败。
当服务器或API处理到传输(RabbitMQ)的松散连接时，Sensu如何配置为发送通知？一般来说，监测软件的最佳做法是什么？
浏览 0提问于2014-11-19得票数 3
回答已采纳
在我的系统中，我使用spring-cloud-stream和RabbitMQ来发送和接收事件。我的RabbitMQ运行，服务A up和服务B停机。服务A向服务B发送事件。然后我打开了我的服务B，现在我希望兔子会对这一事件感到高兴--但什么也没发生。行为正确吗？我是RabbitMQ的新手，但我认为它应该保证所有事件最终都能找到它的接收者。我的应用程序很简单，基于，没有额外的配置。我错过了什么？
浏览 1提问于2017-12-12得票数 0
回答已采纳
我正在使用Spring 和RabbitMQ。
使用RabbitMQ启动码头后：
sudo docker run -t -i --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
我执行了发行者和订阅者应用程序的示例来观察消息的行为。
我在管理面板()中注意到的一件事是，在启动订阅服务器时创建的队列被配置为auto-delete: true。因此，当没有订阅服务器运行时，队列就不会创建，发布者发送的每一条消息都是丢弃的。这不是我所期望的默认配置！
因此，我想将创建的队列更改为auto-delete: false，因为这
浏览 2提问于2018-02-15得票数 1
回答已采纳
我试图理解RabbitMQ中消息删除的逻辑。
我的目标是使消息保持不变，即使没有连接到读取它们的客户端，以便当客户端重新连接时，消息正在等待它们。我可以使用持久的、懒惰的队列，以便将消息持久化到磁盘，并且可以使用HA复制来确保多个节点获得所有排队消息的副本。
我希望使用主题或头路由将消息转到两个或多个队列，并让一个或多个客户端读取每个队列。
我有两个队列，A和B，由报头交换提供。队列A接收所有消息。队列B只获取带有“归档”头的消息。队列A有3个用户正在阅读。队列B有一个消费者。如果B的使用者死了，但是A的使用者继续确认消息，RabbitMQ会删除这些消息还是继续存储它们？在重新启动B之前，队列
浏览 2提问于2018-02-15得票数 4
回答已采纳
我正在使用MassTransit和RabbitMQ创建一个简单的发布者/订阅服务器。发布服务器有以下代码来初始化总线：
/** create the bus */
var bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
var host = cfg.Host(new Uri("rabbitmq://localhost/"), h =>
{
h.Username("guest");
h.Password("guest");
});
})
浏览 1提问于2016-01-12得票数 5
回答已采纳
我想在两个节点之间配置一个RabbitMQ集群，我的目标是采用主动/被动方法，如果主RabbitMQ由于某种原因而停机，我将将所有流量路由到被动RabbitMQ (通过RabbitMQ或其他方式)。
基本上，我不希望将消息复制到被动brocker，我只需要元数据(队列/交换/绑定)，是否有人知道是否有一种方法只同步这两只兔子之间的元数据(消息)？
谢谢
浏览 1提问于2014-03-09得票数 0
我正在编写一个移动应用程序，并考虑为RabbitMQ提供用户间消息传递。据我所知，每个客户端都可以侦听它的唯一队列(例如，在用户id之后命名)，并通过发布到其他客户端队列的方式向其他客户机发送消息。但我担心这样的模式是不可靠的，因为讨厌的客户可能，比如说，从别人的队列中读出，从而扰乱整个计划。
是否有一种方法将基本的读写权限强加于RabbitMQ队列/交换，从而提供安全性？还是我搞错了整个概念，而点对点的交流并不是设计的目的？
浏览 3提问于2017-10-20得票数 0
我在Spring应用程序中使用Camel并与RabbitMQ集成，但遇到了奇怪的行为。
我的应用程序有Restful端点，它将http请求转换为RabbitMQ消息，并将其发布到预定义的交换中。有一个单独的消费应用程序，它监听队列并处理消息。
我故意输入了一个不正确的rabbitmq交换名(失效)，以检查如果交换不存在，应用程序是否会失败，但是，camel上下文将在没有错误的情况下启动，并且当我发送第一个请求时不会报告任何错误。由于没有匹配的RabbitMQ交换，此消息将丢失。当我提交一个第二个请求时，我会收到以下异常，这是我在路由启动时所期望的。
com.rabbitmq.client.Al
浏览 0提问于2015-03-09得票数 0
我对使用RabbitMQ作为消息队列协议非常陌生，我已经编写了RabbitMQ教程中给出的发送者和消费者工作队列的代码。
[链接： ]
当我们在发送者之前启动消费者时，上面的事情运行得很好。但是，如果我们在运行发送器之后启动消费者，就会出现问题。这些消息都不会被那些在运行发送器之后启动的消费者使用。在研究了RabbitMQ的架构和AMQP相关的东西之后，它似乎相当困难。
1]有没有可能在发送者之后启动消费者，在发送者接收到队列中的消息后启动消费者？
2]如果这个东西是怎么被done.Is的，有没有什么技巧可以做到这一点？
浏览 0提问于2013-08-29得票数 1
你好，朋友们，我想知道RabbitMQ中的expriation属性。如果我不设置这个属性。我是rabbitMQ新来的，请帮帮我。
AMQP.BasicProperties properties = new AMQP.BasicProperties();
properties.setExpiration("432000000");
浏览 2提问于2015-06-23得票数 1
回答已采纳
根据下列员额：
通过执行以下步骤，可以备份并恢复持久排队消息：
要备份，我们必须：
1- (狂犬病)服务器：# rabbitmqctl stop_app
2- (Tar)文件夹"/var/lib/rabbitmq/mnesia/"：# tar -cvf mnesia.tar /var/lib/rabbitmq/mnesia/
3- 启动(狂犬病)服务器：# rabbitmqctl start_app
然后，要还原，我们必须：
1- (狂犬病)服务器：# rabbitmqctl stop_app
2- 复制(untar)文件夹"/var/lib/rabbit
浏览 3提问于2014-11-24得票数 5
回答已采纳
我有一个简单的NestJs微服务应用程序，它正在侦听来自Rabbitmq服务的消息。
async function bootstrap() {
dotenv.config();
// TODO: Check for ENV valid
const rabbitOptions = {
urls: [`amqp://${process.env.MQ_HOSTNAME}:${process.env.MQ_PORT}`],
queue: process.env.TASK_QUEUE_NAME,
queueOptions: { durable: false },
浏览 3提问于2020-01-17得票数 1
4回答
我已经通过RabbitMQ获得了类似于作业队列的东西，在请求取消作业时，我想收回尚未开始处理的任务(它们的消息还没有被确认)，这对应于从它们被路由到的队列中收回这些消息。
我还没有在AMQP或RabbitMQ应用程序接口中找到这个功能；也许我搜索得还不够好？或者我必须使用一种变通方法(这并不难，但仍然)？
浏览 4提问于2010-09-21得票数 16
1回答
我们有一个只会在一天结束时运行的作业。在EOD期间，它将读取来自RabbitMQ的所有消息并生成一个文件。成功生成文件后，我们需要删除RabbitMQ中的所有消息。有没有一种方法可以通过Java代码做到这一点？
我们使用的是channel.basicGet(QueueName,false);
如果我将autoAck作为true而不是false传递，那么它将删除消息，但是如果在处理过程中有任何异常，那么消息将会丢失。
为了克服这个问题，我使用了channel.queuepurge(QueueName);，但它不起作用。
所以我们的要求是，我们需要从队列中读取消息，在成功生成文件后生成一个文件，然
浏览 65提问于2021-06-07得票数 0
我过去常常在RabbitMQ管理的概述部分看到队列中的消息和显示一段时间内消息数量的消息警报。但现在我遇到了一个问题，当我发布消息时，无法在消息队列概述中看到消息。有人能帮我一下吗？
浏览 2提问于2015-02-10得票数 1
2回答
我有一个使用+ RabbitMQ的项目。我们还处于早期开发阶段，因此我们正在快速地改变集成体系结构的拓扑结构，包括RabbitMQ配置。
我们也在努力跟踪连续部署，一个免费部署。
我在spring配置中声明了一个<rabbit:admin />元素，它很好地负责添加新的交换或队列。
但是，当我部署一个更改现有exchange /队列配置的更新时，我发现它失败了。
最近，一些部署失败，因为：
我们将一个直接队列切换到一个FanOut交换
我们为直接队列上的消息更改了声明的TTL。
在这两种情况下，都需要对现有配置进行更改，而不仅仅是创建一个新实例。这些更新没有应用，导
浏览 3提问于2013-05-30得票数 0
1回答
我已经使用指数退避策略配置了死信交换。在进行了这些更改之后，我开始在rabbitmq消费者中得到一个异常，反复抛出以下异常：
Received shutdown signal for consumer tag=amq.ctag--Qn9jFNOd3vxhaHvEw8Nrw
com.rabbitmq.client.ShutdownSignalException: connection error
at com.rabbitmq.client.impl.AMQConnection.startShutdown(AMQConnection.java:715)
at com.rabbitmq.clien
浏览 1提问于2015-02-05得票数 1
1回答
在面向服务的体系结构中，我使用RabbitMQ作为消息队列，其中许多单独的web服务发布绑定到RabbitMQ队列的消息。这些队列反过来又被执行后台工作的各种消费者订阅；这是RabbitMQ的一个很普通的用例。
现在，我想更改一些队列参数(具体来说，我希望将队列绑定到一个新的带有特定路由密钥的死信交换中)。我的问题是，在生产系统上进行这种改变是有问题的，原因有几个。
在生产系统中，向这些新队列过渡而又不丢失消息的最佳方法是什么？
我已经考虑了从版本化队列名到使用新设置创建新的vhost，再到执行所有适当的更改。
以下是我面临的一些问题：
因为RabbitMQ队列是幂等的，所以不同的web服
浏览 3提问于2014-08-12得票数 21
回答已采纳
1回答
我使用了Java的rabbitmq客户机()，我需要实现以下场景：
在接收兔子消息时，如果我怀疑所有等待数据都不适合内存，则可能需要暂停特定队列的Rabbitmq消费。
在处理了一些消息之后，我需要再次打开以下消息集的消费。
根据需要重复一遍。
使用库从RabbitMQ队列实现暂停/恢复侦听的最佳方法是什么？
浏览 3提问于2017-12-30得票数 4
回答已采纳
注意事项:使用RabbitMQ .NET库
我的RabbitMQ上有一个名为FXTO.HK的主题交换，以及服务器将消息发布到此队列的FXTO.#绑定键。
在客户端，队列具有唯一和随机的名称，但使用相同的FXTO.#绑定键。
我们使用客户端库中的订阅类，它工作得很好:即。该消息由所有客户端同时接收。
但是，在RabbitMQ管理UI中，服务器队列(FXTO.HK)显示队列中的所有消息(它们没有从队列中删除)。
我在我的设置中做错什么了吗？何时从服务器队列中删除这些消息？
浏览 2提问于2011-11-15得票数 1
我有两个RabbitMQ队列：
incoming_message =>，在这里，我推送我以后要处理的所有消息。
incoming_message_dlx =>，其中我推送处理失败的消息。
正如您可以使用其名称所设想的那样，incoming_message_dlx队列使用特性，这意味着当消息过期时，它将被请求到我的incoming_message。
我试图实现的是，每次处理失败时增加消息的expiration，并将它们推送到DLX队列。
问题是，即使消息过期，它也不会被请求到我的incoming_message，而不是在队列的底部(头)。因此，如果DLX队列中有一条过
浏览 0提问于2017-08-10得票数 2
我有一个spring boot应用程序，它连接到一个RabbitMQ集群(作为cloud foundry中的一个服务)。当集群中的主节点发生故障，并且由于某种原因，该节点没有出现，但应用程序(消息使用者)正在尝试连接到出现故障的节点，而不尝试连接到其他可用节点时。有人能建议一些弹簧配置来解决这个问题吗？ 17:36:23.829: [APP/PROC/WEB.0] Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>
浏览 89提问于2020-10-01得票数 0
回答已采纳
1回答
我有服务器向MQ发送消息。当工作人员应答时，消息从队列中移除：
channel.basic_ack(delivery_tag=method_frame.delivery_tag)
但是，当工人产生错误时，它不会回答关于好的交付。是否可以将此消息路由到其他工作人员或将此消息发送到队列的末尾，然后稍后再试。是RabbitMQ有设置消息超时的机制。当超时结束时，请再次发送消息，还是我需要自己实现它？
浏览 0提问于2012-12-21得票数 1
回答已采纳
2回答
我计划通过遵循这两个链接 来延迟队列中消息的处理。所以，正如链接中所建议的。我已经用x-dead-letter-exchange和x-dead-letter-routing-key args声明了原始队列。它将消息发布到所谓的dead-letter-queue中，当消息被使用者处理失败或发生ttl或队列长度超过时。现在，在dead-letter-queue中，类似的args与ttl参数一起被设置。它应该在ttl超出后将消息重新发布到原始队列。但问题是它放弃了所有的信息。
此外，这里有一个陷阱。如果我显式地将失败消息从原始队列发布到死信队列。然后，在ttl之后，将消息重新发布到原始队列。为什么会
浏览 4提问于2016-04-08得票数 1
回答已采纳
1回答
我目前正在使用RabbitMQ () at 通过GitHub API导入关于GitHub repos的元信息。根据GitHub恢复的次数，一个任务可以花几秒钟的时间查看，最多几分钟。我创建了如下新消息/任务：
queue.publish( msg, :persistent => true )
其中一名工人将收到消息并执行任务。工作人员在Memcached中设置他的状态(运行，完成)。这样我就知道什么时候完成任务了！
我想在这个过程中摆脱Memcached。我想从RabbitMQ获得一个msg的状态。像这样的东西是理想的：
status = queue.publish( msg, :per
浏览 2提问于2014-09-14得票数 4
回答已采纳
5回答
我在RabbitMQ中使用芹菜。最近，我注意到出现了大量的临时队列。
因此，我进行了实验，发现当任务失败(即任务引发异常)时，将形成一个具有随机名称(如c76861943b0a4f3aaa6a99a6db06952c)的临时队列，并且该队列仍然存在。
在rabbitmqadmin中找到的临时队列的一些属性如下：
auto_delete :真消费者:0持久:假消息:1 messages_ready :1
每次任务失败(即引发异常)时，都会生成一个这样的临时队列。如何避免这种情况？因为在我的生产环境中，会形成大量这样的队列。
浏览 1提问于2011-08-22得票数 21
回答已采纳
1回答
我有几个Java客户端使用RabbitMQ默认交换向队列发送消息。
我希望能够分析队列中的消息(如果消息没有明显地被消耗)，标识消息的发送方，如果客户端发送的消息太多，那么就绑定一个特殊的队列，以便该客户端向该队列发送消息。
我是RabbitMQ的新手，所以我想知道的是：
是否可以在RabbitMQ中将客户端ID作为头添加？
如何为工作量大的客户端创建特殊队列？
是否可以分析驻留在队列中的消息？
任何帮助都将不胜感激。
浏览 4提问于2016-07-02得票数 0
3回答
使用RabbitMQ web UI，当我在没有当前队列绑定的情况下发布到主题交换时，rabbitmq表示消息已经发布，但没有路由。
使用amqp.node时，当我将一个队列绑定到交换并使用"#“(all)开始消费时，我什么也得不到。
我希望收到之前发布但未路由的消息。这个是可能的吗？
浏览 22提问于2016-08-17得票数 3
我正在处理来自rabbitMQ的记录。为了避免丢失来自rabbitMQ的消息，我使用了rabbitMQ确认策略。出于测试目的，我在向rabbitMQ返回确认的代码之前引发了异常。根据我所写的代码，在执行代码中的行，即"c.ack(delivery_info.delivery_tag)“之前，rabbitMQ不应该从队列中删除消息。下面是我的代码
begin
MessageService.with_channel do |c|
queue = c.queue(QUEUE_NAME, :durable => true)
exchange = c.topic(TOPIC_N
浏览 6提问于2016-10-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
