《rabbitmq》专题

在队列选项卡的rabbitMQ web界面上，我看到了“概述”面板，我在其中找到了以下内容： 排队消息： 准备好了 未确认 总数 我猜“总数”是多少。但什么是“准备就绪”和“未确认”？“准备好了”——传递给消费者的信息？“未确认”-？ 消息费率： 发表 交付 重新交付 承认 这些信息是什么？尤其是“重新交付”和“确认”？这是什么意思？

有什么方法可以声明惰性加载队列吗？

这种需求类似于通过公开的REST服务API（Spring Boot）处理来自死信队列的消息。以便一旦调用REST服务,就会从DL队列中消耗一条消息,并将再次发布到主队列中进行处理。@RabbitListener(queues=“queue_name”）立即使用消息，这在场景中是不需要的。该消息只需由REST服务API使用。有什么建议或解决办法吗？

我们的应用程序使用RabbitMQ提供的几个队列中的数据。为了提高吞吐量，我们在每个队列中启动多个线程，这些线程从这些队列中进行阻塞。 对于一个新的服务，我们希望使用Spring Boot，并且每个队列都有几个线程从这些队列中获取数据。下面是用于处理从某个队列到达的数据的规范Spring Boot代码：

我知道这个问题以前有人问过，但我找不到任何合适的解决办法，因此再次张贴。 我只有一个简单的producer类，它使用上面的amqpTemplate发送一条消息。但当我尝试运行我的生产者应用程序时，我得到的只是：在vhost“/”错误中没有exchange“my.exchange” 如果你能在这方面提供帮助，我将不胜感激。多谢了。

我有一个带有PublisherReturn回调的RabbitTemplate。 如果我向没有队列绑定的routingKey发送消息，则正确调用返回回调。当发生这种情况时，我希望将消息发送到另一个路由密钥。但是，如果我在ReturnCallback中使用RabbitTemplate，它就会挂起。我没有看到任何消息可以/不能发送，RabbitTemplate没有将控制返回给我的ReturnCallba

我目前正在从事一个项目，涉及使用来自RabbitMQ Brocker的消息。不过，我对Spring集成、AMQP和RabbitMQ还是个新手。我有一个问题是使用错误的消息格式。当我的使用者接收到一个格式错误的消息时，它将其返回队列，然后RabbitMQ将其返回，这就产生了一个无休止的循环。在Spring Integration文档中，有一些配置可以实现，使得这种消息不会返回到队列中。

我正在尝试设置我的第一个RabbitMQ死信交换，下面是我通过web管理界面使用的步骤： 创建名称为“dead.letter.test”的新直接交换 创建新队列“dead.letter.queue” 将“dead.letter.queue”绑定到“dead.letter.test” 创建新队列“test1”，并将死信交换设置为“dead.letter.test” 将消息发送到“test1” NAC

交换：1个类型为“direct”的交换 队列：1个队列 绑定：队列绑定到Exchange 每当消息被发送到exchange时，它就会被传递到队列，辅助进程就会得到它们的任务。 每件东西都要经久耐用。 null 交换：1个具有“扇出”类型的交换 队列：n个队列，每个使用者一个 绑定：每个队列都需要绑定到Exchange 那么是谁安排了什么？在我看来： 生产者创建交换 使用者创建队列（因为它是自己的队

我有一个RabbitMQ队列用于生成文档。基本上，每个文档都有和（新建、处理、就绪），因此我使用主题交换和路由键，如。每次文档更改时，我都会将带有上一个文档描述的消息发送到exchange上，并且它工作得很好。 null

我已经学习了RabbitMQ的基础知识。有一件事我想出来了，发布者并不直接在队列上发布。exchange根据和exchange类型（下面的代码使用默认exchange）来决定应该发布消息的队列。我还找到了Publisher的示例代码。

使用主题交换,我希望有一个具有以下特性的发布/订阅消息传递模式： 是否实现了“发布者确认”。 让使用者在处理完每条消息后也确认该消息。 使用路由密钥将邮件路由到一个或多个使用者。 具有持久的使用者队列，因此如果使用者应用程序暂时关闭，它可以在重新启动时从其队列中拾取消息。 所以我创建了2个控制台应用程序（发送和接收）来测试上面的内容。 } 接收 问题是我的Send程序中的OnBasicAcks只会

我有一个使用RabbitMQ构建的发布-订阅场景。有一个交换,其中消息由发布者发送,订阅该交换的任何使用者在其各自的队列中接收这些消息。这是一个扇出场景，其中有一个生产者，但有多个消费者。 现在我愿意在系统中集成一个死信队列，以便稍后处理被拒绝的消息。我的问题是 1）我应该为每个使用者配置一个单独的死信队列，还是应该有一个单独的死信队列来处理来自所有使用者的所有被拒绝的消息？ 2）如果两者都有可能

Edit：基础要求是，我有多个Web服务服务器进程接收来自Web服务客户端的请求，执行一些处理（我希望使用工作队列进行的处理），然后将结果返回给相应的客户端。但是，我希望能够等待这个队列的使用者在超时内获取已发布的请求。如果此超时过期，那么我希望原始webservice进程接收到此通知，以便它能够反馈给客户机。 我有多个发布服务器将邮件发布到同一Exchange 此交换机上有多个使用者从同一队列（

我将与一起使用中的这个库。所有使用者均为,所有队列均为（4小时）。 我有很多队列没有任何挂起的ack，但仍然保存着数百条消息。此外，队列不会在应该过期时过期，这将在几天后产生性能问题。我没有找到任何理由来解释为什么消息在ack处理之后仍然在队列中。 谢谢 管理工具中的一些快照：