未创建RabbitMQ直通队列
RabbitMQ是一个开源的消息中间件，它实现了高效的消息传递机制，可用于构建分布式系统、微服务架构以及异步通信等场景。RabbitMQ直通队列是RabbitMQ中的一种队列类型，它允许消息直接从生产者发送到消费者，而无需经过交换机的路由规则。
RabbitMQ直通队列的特点和优势包括：
- 简单快速：直通队列省略了交换机的路由过程，使消息传递更加高效。
- 低延迟：由于消息无需经过交换机，直通队列可以实现更低的消息传递延迟。
- 灵活性：直通队列可以根据具体需求进行配置，如设置消息持久化、优先级等。
- 可靠性：RabbitMQ提供了消息确认机制，确保消息的可靠传递。
RabbitMQ直通队列适用于以下场景：
- 简单的消息传递：当消息的路由规则简单且固定时，直通队列可以提供更高的性能。
- 低延迟要求：对于实时性要求较高的应用，直通队列可以减少消息传递的延迟。
- 简化架构：当系统架构相对简单，不需要复杂的消息路由规则时，直通队列可以简化系统设计。
腾讯云提供了消息队列（CMQ）服务，可以作为RabbitMQ直通队列的替代方案。CMQ是腾讯云提供的高可用、高可靠、高性能的消息队列服务，支持消息的发布与订阅、消息的持久化、消息的顺序性等特性。您可以通过腾讯云消息队列CMQ产品介绍了解更多信息：腾讯云消息队列CMQ。
相关·内容
我正在学习https://www.rabbitmq.com/tutorials/tutorial-one-python.html上的教程 我已经使用docker设置了RabbitMQ。在那里定义了交换，等等。 管理UI显示创建的exchange。当第一次执行发送者脚本时，队列也会显示在UI中。 我首先运行消费者&然后是发布者。但是，当消息被发布时(假设消息已经发布，因为send脚本没有抛出任何错误)，消费者不会收到任何消息。我可以看到AMQP连接被正确地建立和关闭(在发布者的情况下)。但是队列是空的。 管理UI还显示一个空队列。我尝试使用UI本身发布持久和非持久消息，但即使在那里，当
浏览 257提问于2021-10-24得票数 0
我使用MassTransit和RabbitMQ 仲裁队列进行应用程序集成。我用
var endpoint = await _bus.GetSendEndpoint(new Uri("exchange:TestCommand"));
await endpoint.Send(command1, stoppingToken);
如果“接收者应用程序”从未启动，队列将不会被创建，所有发送的消息都将丢失。
如果我在发送时使用前缀queue：
var endpoint = await _bus.GetSendEndpoint(new Uri("queue:TestCommand&#
浏览 1提问于2022-03-14得票数 0
回答已采纳
1回答
我通过生产者向RabbitMQ发送一条普通消息，然后发送第二条消息，并将expiration属性分配给一个值。然后使用rabbitmqctl list_queues命令监视消息的状态。
我发现，如果我先发送一条普通消息，然后发送一条带有expiration的消息，则rabbitmqctl list_queues总是显示队列中有两条消息处于挂起状态。当我消费它们时，我只得到一个。
另一方面，如果我只用expiration发送一条消息，一开始我会看到消息，然后在正确的过期时间之后，我发现它被删除了。
我的问题是，在第一种情况下，消息实际上是占用空间的吗？或者这是一个接口错误？
我的rabbitMQ
浏览 2提问于2015-01-17得票数 11
回答已采纳
我正在建立一个网站，接收足球比赛的实时更新。我正在使用RabbitMQ将更新发送到客户端(JS网站和安卓/iOS应用程序)。
客户端只应接收实时更新，换句话说，客户端只应在用户登录时接收更新。没有任何历史被保存。
为了实现这种行为，我考虑了以下体系结构：
RabbitMQ中的一个扇形交换。
每个用户都有一个专用队列，该队列绑定到交换。创建用户帐户时会创建此队列。
对于这些队列，将设置值为0的queue属性x-message-ttl。见下文。
当用户登录时，客户端将消耗相应用户的队列。
消息由后端发送到exchange，并转发到所有队列。当用户未登录时，消息将立即丢弃，因为x
浏览 0提问于2016-05-29得票数 4
回答已采纳
你好，朋友们，我想知道RabbitMQ中的expriation属性。如果我不设置这个属性。我是rabbitMQ新来的，请帮帮我。
AMQP.BasicProperties properties = new AMQP.BasicProperties();
properties.setExpiration("432000000");
浏览 2提问于2015-06-23得票数 1
回答已采纳
我正在使用Mule ESB和两个应用程序(一个通过rabbitMQ发布状态给另一个)。只有在我的生产环境中，我才会弹出这些amqp.gen- queue，但它们被锁定了，我看不到它们里面是什么。它们绑定到我的交易所(出版商)。
客户指出这是随机资产丢失的问题。我试图消除它们的发生，但没有任何线索。根据rabbitMQ教程，它们是在声明队列但不提供名称时创建的。然而，我不会这么做的。
更多信息:这两个应用程序使用不同的登录到rabbitMQ，队列是由我的应用程序(发布者)创建的，而不是消费者应用程序。我没有队列名称，我的队列声明如下所示：
<amqp:connector name="
浏览 4提问于2015-06-13得票数 0
5回答
我已经使用HA策略在单个windows机器上创建了RabbitMQ集群，并创建了两个磁盘、两个内存节点和一个统计节点。然后我运行了PerfTest (rabbitmq客户端测试实用程序)，结果令人失望，它大约是5000m/s。但是，当我在单个RabbitMQ节点上运行相同的测试时，它给出了很好的结果，即25000m/sec。我不知道发生了什么错误，如果在集群中运行，它的结果应该是令人印象深刻的，但事实恰恰相反。任何人都遇到过同样的情况，或者知道背后的原因。谢谢
浏览 12提问于2015-03-17得票数 2
? ? ? 我是rabbitmq和使用spring-amqp的消费者。现在，当我进入admin时，所有的连接都显示正在运行，但其中的通道都是空闲的(预取:250，未确认:250)。你能帮帮我吗？如何正确使用这个预取？我需要关闭连接吗？如何增加每个连接的通道。现在每个连接只有一个通道。以下是代码配置代码片段。我正在使用一个自定义的rabbitmq消息监听器来确认或取消确认消息。我正在使用if box spring amqp配置来处理大多数.Also。 <!-- RabbitMQ configuration -->
<rabbit:connection-factor
浏览 66提问于2020-03-25得票数 3
回答已采纳
2回答
我使用EC2上的spot实例来使用RabbitMQ队列中的数据。每个作业都需要几秒钟，并且需要手动“确认”。
销毁实例时会出现问题。没有时间干净利落地关闭AMQP消费者，所以我留下了RabbitMQ服务器，仍然认为死亡的消费者仍然存在。它不会重新提供他们的工作，它仍然会向他们发送新的工作。
如何让RabbitMQ自动使僵尸消费者超时，并将其从工作池中删除？
浏览 0提问于2012-11-16得票数 7
我在努力让气流工作人员执行任务。我开始提供服务：
airflow worker --debug
airflow webserver
airflow scheduler
airflow flower #to check celery queues in UI at localhost:5555
这些进程运行良好，但当调度程序将任务添加到队列中时，或者当我试图从气流UI运行任务时，调度程序和when服务器正在挂起-continuously加载，没有进一步执行--同时将任务添加到队列中：
我认为这个问题与调度程序/ and服务器和队列之间的通信有关。我在airflow.cfg文件中与代
浏览 2提问于2017-08-03得票数 5
回答已采纳
2回答
我试图让RabbitMQ与芹菜和Django一起执行一个EC2实例，以完成一些非常基本的后台处理。我正在一个大型EC2实例上运行rabbitmq-server 2.5.0。
我根据指令下载并安装了测试客户端(位于页面的最底部)。我一直在让测试脚本离开并得到预期的输出：
recving rate: 2350 msg/s, min/avg/max latency: 588078478/588352905/588588968 microseconds
recving rate: 1844 msg/s, min/avg/max latency: 588589350/588845737/58919534
浏览 2提问于2011-06-15得票数 12
回答已采纳
我对RabbitMQ和AMQP完全陌生，我正在寻找一种与队列、消息持久性和内存使用相关的解决方案。
我正在尝试在一个服务和多个客户端之间建立一个消息传递系统。他说，客户基本上是在手机上使用应用程序的人，所以我的第一个想法是创建：
1直接交换
一个持久队列+每个用户的相关绑定
这个决定是在阅读了选择性消费者模式(1个队列，多个消费者)后做出的，它似乎是 in RabbitMQ。
但是，我发现创建的每个队列都需要内存，考虑到我需要声明数千个队列(每个用户需要一个队列)，它需要大量的内存，因此对于我的情况来说，这绝对不是一个解决方案。
因此，我想知道，例如，当用户离线时，是否有可能保
浏览 0提问于2019-09-09得票数 1
我在rabbitmq上用芹菜。我已经向队列发送了数千条消息，这些消息正在成功处理，一切工作正常。然而，几个rabbitmq队列中的消息数量增长得相当大(队列中有数十万个项目)。这些队列被命名为celeryev.[...] (参见下面的屏幕截图)。这是适当的行为吗？这些队列的用途是什么?不应该定期清除它们吗？有没有办法更定期地清除它们，我认为它们占用了相当多的磁盘空间。
浏览 5提问于2013-07-22得票数 17
回答已采纳
我对使用RabbitMQ作为消息队列协议非常陌生，我已经编写了RabbitMQ教程中给出的发送者和消费者工作队列的代码。
[链接： ]
当我们在发送者之前启动消费者时，上面的事情运行得很好。但是，如果我们在运行发送器之后启动消费者，就会出现问题。这些消息都不会被那些在运行发送器之后启动的消费者使用。在研究了RabbitMQ的架构和AMQP相关的东西之后，它似乎相当困难。
1]有没有可能在发送者之后启动消费者，在发送者接收到队列中的消息后启动消费者？
2]如果这个东西是怎么被done.Is的，有没有什么技巧可以做到这一点？
浏览 0提问于2013-08-29得票数 1
2回答
您好，我创建了三个在EC2集群中运行的RabbitMQ服务器
我想要基于CPU利用率向外扩展RabbitMQ集群，但是当我发布消息时，只有一台服务器使用CPU，而其他RabbitMQ-server没有使用CPU。
那么，如何跨RabbitMQ群集分配负载呢
浏览 3提问于2012-05-05得票数 7
回答已采纳
我正在将遗留的spring应用程序切换到spring启动。
使用spring云流rabbitmq迁移rabbitmq代码存在一个问题。
在遗留系统中，通过给交换、routingKey和队列名来设置rabbitmq队列。
例如,
exchange name = mq-test.topic
routingKey = mq-test
queueName = aa.mq-test
因此，在rabbitmq管理视图中，我可以看到exchange是mq-test.topic，队列是aa.mq-test。
但是使用spring云流，队列名中点缀着目标，如
mq-test.topic.aa.mq-test
我
浏览 0提问于2019-05-30得票数 1
回答已采纳
我的队列是持久的，消息是持久的。我已经设置了3个RabbitMQ服务器集群，对所有服务器中的所有队列进行HA镜像。当我关闭RabbitmQ3时，我的主节点似乎是Rabbitmq3。我得到了以下错误。
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - home node 'rabbit@rabbitmq3' of dura
浏览 19提问于2017-08-02得票数 0
我正处于从RabbitMQ文档学习RabbitMQ/AMQP的阶段。有些事情我还不清楚，我想问问那些有亲身经验的人。为了平衡工作负载，我希望有多个使用者监听同一个队列。我需要的是接近。我希望使用者在完成处理后显式地确认消息，以保存消息，并在发生崩溃时委托给其他使用者。处理一条消息可能需要一段时间。我的问题是AMQP是否将下一个消息处理推迟到之前的消息被破坏？如果是这样的话，我如何实现多个工作人员之间的负载平衡，并保证消息不会丢失？
浏览 6提问于2013-07-24得票数 10
回答已采纳
我需要监听在另一个微服务中实现的来自rabbit的队列。假设第一次，我们切换到与流通信，而不是rest，并且另一个应用程序尚未启动，它的队列还没有出现在rabbitMq中。因此在看到例如'accountingResponseChannel.account‘队列不存在之后，尝试创建它，但它将由具有特定选项其他微服务创建。作为this post，你不能修改已存在的队列，所以我创建一个队列来跳过404错误是不好的。 最后我的问题是，当队列不存在时，如何静音@RabbitListener尝试创建未命中的队列？因为它面对的是错误！ 我的相关代码(如果需要)： @Configuration
@E
浏览 154提问于2021-11-22得票数 0
1回答
确认后重新投递
、、
为什么我的RabbitMQ消息在ACKd后会被重新发送给我的客户？我刚接触RabbitMQ，一定是用错了，或者Ruby amqp gem出了什么问题。
我有一个ruby脚本，它订阅一个队列并确认每条消息。如果我让它完全通过消息，消息确实会从队列中消失；它们不会重新传递。但是，如果我在脚本全部ACKd之前中断脚本，然后再次启动脚本，则传递将从第一条消息重新开始。
我在代码中看到的行为被RabbitMQ web管理界面准确地反映出来；队列有消息，尽管有ACK，但它们不会消失。
提示:我在队列中放置了大约5000条消息。如果我让消费者进行大量的ACK，有几条消息看起来确实从队列中删除了(与我上面所说
浏览 2提问于2012-11-07得票数 0
回答已采纳
下面的代码声明了一个队列test-amqp-queue。当我最初运行这段代码时，它可以自动创建队列。
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setHost(host);
connectionFactory.setPort(port);
connectionFactory.setUsername(username);
connectionFactory.setPassword(password);
connectionFactory.setVir
浏览 19提问于2022-05-19得票数 0
1回答
我正在开发客户端应用程序，它使用的是masstransit和rabbitmq。在应用程序启动时，我将创建具有唯一名称的新队列，以便通过masstransit(请求/响应模型)与服务器应用程序进行通信。在应用程序关闭时，我应该删除这个队列，但是如果客户端应用程序压缩队列，就会出现在rabbitmq上。
是否可以通过masstransit创建临时队列，当客户端断开队列时，rabbitmq将自动删除该队列？
浏览 1提问于2015-06-10得票数 3
回答已采纳
是否可以从RabbitMq管理控制台更改特定队列的节点名称？我试过了，但我认为这是我启动应用程序时创建的。我可以过后再换吗？我的队列在节点RabbitMQ1上，而我的连接在节点RabbitMQ2上，所以我不能从该队列读取消息。也许我可以改变我的连接节点？
浏览 19提问于2018-01-09得票数 0
回答已采纳
如何使用Python代码以编程方式列出在RabbitMQ broker上创建的当前队列以及连接到这些队列的工作进程的数量？它等同于：
rabbitmqctl list_queues name consumers
浏览 2提问于2014-06-12得票数 4
在我的节点服务器中，我使用amqplib ()与本地Rabbitmq服务器交互。我使用Rabbitmq中的库创建了一个队列。有没有办法删除队列？我在amqplib文档中找不到任何解决方案，我不确定是否有one...Can，我使用amqplib执行它，还是在Rabbitmq中节点js中有其他方法来创建和删除队列？
浏览 2提问于2019-08-21得票数 2
回答已采纳
当我使用RabbitMQ作为Flink DataStream源代码时，正如Flink文档所说的那样。
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// checkpointing is required for exactly-once or at-least-once guarantees
env.enableCheckpointing(...);
final RMQConnectionConfig connectionConfig = new RM
浏览 0提问于2018-05-13得票数 3
回答已采纳
我正在使用DirectMessageListenerContainer来使用来自RabbitMQ的数据。以下是我的场景：
我有两个与RabbitMQ交互的模块。第一个模块创建和删除队列，而第二个模块使用DirectMessageListenerContainer监听RabbitMQ中的队列。
当RabbitMQ中的任何队列被删除时，DirectMessageListenerContainer开始不断抛出异常，并尝试连接到已经删除的队列。
我的问题是，有没有什么方法可以处理异常并对其执行操作？
浏览 0提问于2019-03-18得票数 1
3回答
我在RabbitMQ队列中使用了不同的“每个消息TTL”，并且我希望具有不同TTL的消息应该在适当的时候由消费者处理。
为了提供这种行为，我使用具有巨大“x消息-TTL”的RabbitMQ队列，我将消息添加到这个队列中，其值为“每个消息TTL”(参见下面的代码)。例如，用TTL 30秒、20秒和10秒添加队列消息。
行为上的问题，RabbitMQ如何处理队列中不同“每个MessageTTL”的消息，最大TTL的消息以较少的TTL停止消息。因此，当最大的TTL到期时，消费者就会将所有的过程组合在一起。
发布消息代码：
$channel = new AMQPChannel($this->co
浏览 7提问于2014-02-04得票数 0
回答已采纳
1回答
我是Rabbitmq的新手，如果这是显而易见的，我很抱歉。那么在Rabbitmq中是否有一个队列池，或者我如何在Rabbitmq中实现一个队列池，类似于线程池，这意味着我预先创建了一个队列池以供将来使用？
我问这个的原因是因为在php示例代码中，我发现队列是按需创建的，当php进程完成时，队列将被回收。就使用队列而言，这似乎相当低效。但事实真的是这样吗？队列池是解决这个问题的方法，还是有其他方法？
浏览 14提问于2020-07-30得票数 1
默认情况下，MT在RabbitMQ中创建经典队列类型，我们正在考虑通过在消费者接收端点配置中将x- queue -type设置为quorum来更改为法定队列(因为建议使用这些队列类型，而不是RabbitMQ文档中的经典镜像队列)。
我只想知道这一变化会带来什么问题？在MT消费者中，我使用的是“ScheduledRedelivery”，使用的是RabbitMQ delayed插件，因此在此更改后，此插件是否继续工作而没有任何问题？
我只想知道，在使用MT的quorum队列中有什么我们需要注意的吗？您对更改为法定队列有什么建议？
我们的设置:具有3个节点的RabbitMQ集群
谢谢JB
浏览 9提问于2021-02-23得票数 2
回答已采纳
对于RabbitMQ，我正在做类似的事情：
channel.QueueDeclare(QueueName, true, false, false, null);
默认情况下，如果现有队列中没有一个与提供的名称匹配，RabbitMQ将创建一个新队列。我想要抛出一个异常。这有可能吗？
谢谢
浏览 1提问于2015-02-12得票数 10
回答已采纳
1回答
在localhost dev/testing场景中，我们遇到了与rabbitmq的突然连接关闭问题。在我们的开发环境中，我们在每个开发人员Windows 7机器上安装了rabbitmq，我们通过Spring库使用java客户端连接到它。一切都正常工作了一段时间，但是在某个时候，这个连接会被丢弃，在rabbitmq日志中有以下消息：
=WARNING REPORT==== 4-Jan-2016::14:39:37 ===
closing AMQP connection <0.3731.0> (127.0.0.1:50792 -> 127.0.0.1:5672):
connect
浏览 1提问于2016-01-04得票数 3
回答已采纳
3回答
我从上个月开始使用RabbitMQ，successfully.Messages是从队列中读取的，使用BasicConsume特性发布的RabbitMQ.The消息立即被相应的使用者使用。现在我创建了一个新的队列DelayedMsg，发布到这个队列的消息只能在5分钟delay.What之后读取，我应该这样做吗？
浏览 4提问于2016-10-14得票数 3
回答已采纳
我创建一个队列"a.1“，交换"a”，并通过一个rabbitmq通道将它们绑定在一起。该通道连接有大约3百channels.After，正常运行20-30分钟，绑定消失，队列绑定到默认交换。我在rabbitmq管理员中观看了它，我看到队列曾经关闭并自动恢复。在恢复之后，我可以看到通道是changed.channel info:ip:2341 (633)，端口被更改为ip:3350。但是队列绑定到默认的exchange.Why rabbitmq有这种奇怪的行为?如何避免它？
浏览 0提问于2016-03-03得票数 0
回答已采纳
所以目前我正在与RabbitMQ和Golang合作。我在RabbitMQ主页上开始了教程，并创建了队列和交换。但是我找不到任何教程来解释如何在Golang中实现Exchange头。
重要的是，我也想知道，如何将数据放在标题中，例如ID和名称？
浏览 3提问于2021-04-21得票数 1
回答已采纳
当使用default选项在RabbitMQ UI中创建队列时，它将显示在特性列D中用于持久，Args列中显示x-queue-type: classic。
通过代码创建它时，您可以在python：channel.queue_declare('QueueName', durable=True)中这样创建，但是它与UI创建的队列不同，没有x-queue-type: classic的Args特性，但是它的类型是一个典型的队列。
在python中，您可以创建一个与UI中默认创建的队列类似的队列：channel.queue_declare('QueueName', dura
浏览 0提问于2020-12-22得票数 3
回答已采纳
是否可以在手动删除队列后自动重新创建队列？ 我可以使用以下命令在启动时创建队列 @Bean
public Queue createRandomQueue(@Qualifier("exporterRabbitAdmin") RabbitAdmin exporterRabbitAdmin) {
Queue queue = createQueue("random.queue", exporterRabbitAdmin);
exporterRabbitAdmin.declareQueue(queue);
return queue;
} 但是，如
浏览 667提问于2020-07-10得票数 1
回答已采纳
1回答
我能够使用 RabbitMQ Java教程创建扇出交换，并且任何连接的消费者都将收到一份消息副本。我希望在连接任何使用者之前创建交换和绑定，而不是以动态/编程的方式声明交换和绑定。我已经通过RabbitMQ管理控制台完成了这项工作。然而，由于某些原因，我的消费者正在以循环方式接收消息，而不是所有接收消息的副本。我遗漏了什么？以下是一些代码片段：
出版商：
channel.basicPublish("public", "", null, rowId.getBytes("UTF-8"));
消费者：
QueueingConsumer consumer
浏览 1提问于2013-03-11得票数 8
回答已采纳
我正在开发一个使用版本2.0.4.RELEASE和版本3.7.7的Java应用程序。该应用程序将来自RabbitMQ的所有消息缓存在数据库中，并且在RabbitMQ中创建新队列时必须重新发送。目前，我成功地使用和队列名称捕获了队列创建。我使用将消息发送回RabbitMQ。
OutFlow
public IntegrationFlow outFlow(AmqpTemplate amqpTemplate) {
return IntegrationFlows.from(outputChannel())
.handle(Amqp.outboundAdapter(amqp
浏览 0提问于2018-08-20得票数 8
我使用了并尝试更新它以使用RabbitMQ
我已经从DockerHub下载了DockerHub:3图像，它应该正在收听amqp://localhost:5672。
我为RabbitMQ创建了一个名为rabbitmq.yaml的新组件文件，并将其放置在. .dapr/components目录中。我对RabbitMQ的组件配置是：
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: my-rabbitmq
spec:
type: pubsub.rabbitmq
version: v1
metadata:
- name
浏览 8提问于2020-12-30得票数 1
回答已采纳
你能帮我在日志中输入RabbitMQ吗？我的应用程序将代码的版本发送到rabbitmq，然后将其存储在弹性堆栈中。在rabbitmq中为app创建了队列名: app_version_queue；类型:经典；持久:真
然后用该配置配置logstash：
input {
rabbitmq {
id => "rabbitmyq_id"
# connect to rabbit
host => "localhost"
port => 5672
vhost => "/"
# INPU
浏览 3提问于2021-02-11得票数 1
回答已采纳
最近，我开始使用和RabbitMQ绑定。
如果当两个服务想要传递消息时，我正确地理解了一切，那么一个应该配置发送消息的源，另一个应该配置接收器来接收消息--两者都应该使用相同的通道。
我有个频道叫testchannel。不过，我注意到该源代码创建了RabbitMQ绑定：
交换testchannel，
路由密钥testchannel
队列testchannel.default (持久的)，
接收器创建了RabbitMQ绑定：
交换testchannel，
路由密钥#
队列testchannel.anonymous.RANDOM_ID (执行)。
为了简洁起
浏览 3提问于2016-02-05得票数 3
回答已采纳
RabbitMQ版本: 3.8.2 Erlang 22.2
由于一些问题，我不得不在服务器上重新安装RabbitMQ和Erlang。
尽管重新安装了应用程序，但来自上一个实例的队列仍然存在，并且正在创建新的队列( Guid's给出的队列名称因此是唯一的)。
这是正常行为吗？如何删除没有附加使用者的旧队列？我以这种方式得到了25000个队列：
谢谢
浏览 3提问于2020-03-21得票数 0
回答已采纳
我有代码来消费来自RabbitMQ的消息。如您所见，在switch/default上有logger。因此，如果路由关键字与任何路由关键字都不匹配，消息就会消失。如果没有匹配的路由键，我如何确认RabbitMQ？消息消失是不可接受的。我试图在"default“上抛出异常，但我认为这不是最好的处理方式。
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using RabbitMQ.Client;
using Ra
浏览 6提问于2021-06-22得票数 0
1回答
我正在尝试在RabbitMQ中实现一个dlx队列。这个场景很简单，我有两个队列: 1)活着2)死了(x- dead -letter-exchange："immediate"，x-message-ttl: 5000)
和一个“立即”的交换，它被绑定到1)活动中
我尝试运行这个示例：，但似乎消息在ttl过期后被删除，并且它们不会在交换上发布，所以我的活动队列总是空的。
我还尝试在管理控制台中手动创建队列，我得到了相同的行为。
我用Ubuntu/rabbitmq 3.0.0以及Mac OS X和rabbitmq 2.8.7测试了它
我是不是遗漏了什么？
浏览 0提问于2012-11-29得票数 7
回答已采纳
我让rabbitMQ broker作为集群在两个节点上运行。我观察到，如果已创建队列的节点关闭，则队列在其他节点上将不可用。如果我尝试发布来自其他节点的消息，它将失败。即使我从集群中删除故障节点(使用forget cluster命令)并尝试从其他节点发布消息，行为也是相同的。
在rabbitMQ中有什么方法可以实现这一点吗？
浏览 0提问于2017-06-29得票数 2
1回答
我知道“来宾”用户是RabbitMQ的默认用户，但我认为我已经配置了所有的东西以使用不同的名称。
我的堆栈是Django / Celery / RabbitMQ，在Docker中运行。
首先，每隔几秒钟我就会收到大量的错误：
rabbitmq_1 | 2020-07-29 08:28:00.775 [warning] <0.1234.0> HTTP access denied: user 'guest' - invalid credentials
rabbitmq_1 | 2020-07-29 08:28:05.775 [warning] &
浏览 4提问于2020-07-29得票数 2
回答已采纳
1回答
我可以使用RabbitMQ动态地创建队列吗？
在我的应用程序中，每当队列是full.can时，我希望队列动态地扩展--我用RabbitMQ做了吗？
提前谢谢。
浏览 4提问于2017-05-25得票数 0
回答已采纳
1回答
我需要配置我的应用程序，以发送和消费消息从//到一个队列上的阳极服务器上。我在my application.properties中有以下配置：
spring.rabbitmq.host=amqp://cloudamqp.com/...
spring.rabbitmq.port=5672
spring.rabbitmq.username=jpkszgmu
spring.rabbitmq.password=***********************
和我的控制器：
@Autowired
private RabbitTemplate rabbitTemplate;
@RequestMappin
浏览 2提问于2017-04-18得票数 1
回答已采纳
我一直在学习RabbitMQ的各种拓扑，但是，我找不到从生产者发出的动态队列创建(也称为声明队列)的任何引用。其想法是根据特定事件(例如HTTP请求)动态创建队列。队列将是临时的，设置为TTL，并以事件ID命名。然后，使用者可以订阅主题" event .*“并合并与其相关的所有消息。
示例：
HTTP贴子“创建用户”收到
生产者创建队列user.ID
推送队列中有关用户的所有后续消息(例如“添加用户名”、“添加电子邮件”.)
worker被分配到一个随机队列" user .*“，并将所有内容合并到用户帐户中。
队列在TTL过期后自动删除。
现在，这个
浏览 12提问于2014-01-21得票数 19
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
