Spring AMQP-将消息返回到队列的开头
我想知道是否有任何方法可以将消息返回到队列中的原始位置。例如，假设我们有这样的顺序：
A-B-C-D，A为头，D为尾。通常情况下，当我们使用nack或拒绝，请求=true时，它只是将消息排在当前尾部之后。在这种情况下，当重新执行A时，新的排序变为B-C-D-A。然而，我想知道是否有任何方法可以排队到队列的开头。因此，如果A被“发回”，它将被放置在队列的开头，在其原始位置。
我使用Spring AMQP搜索解决方案。
共有1个答案
您需要将预取（qos）设置为1。否则，任何预取的邮件都将在A的重新送达之前送达。
然而，这将影响性能。
-
我有交换和排队。生产者不需要消费确认，但在某些情况下，由于缺乏其他数据，消费者在当前时刻可能无法处理消息。因此，我想将这些消息返回到队列的末尾。怎么做？还是在我拒绝邮件时自动完成？ 流量： Message1被使用并在数据库中创建一些记录 所以存在消息排序问题，在一般情况下，我会按顺序获取消息，因为大多数组件都能正确地传递消息。我想解决一个潜在的问题，当Message1的制作人由于负载过重或其他原因
-
我主要在RPC模式下使用rabbitMq，但我还想将请求和响应消息复制到另一个队列。 最后，我想实现的是，外部消费者可以通过听一个队列来查看所有流量，我们称之为“日志队列”。 复制传入消息是可以的，我只需要使用扇出交换，或者使用与RPC调用使用的路由密钥相同的路由密钥将日志队列绑定到使用过的交换。 但我无法找到通过直接回复功能“扇出”发送的消息的方法。 到目前为止，我了解到响应消息以amqp的形式
-
我已经设置了Apache camel，在其中我使用来自一个队列的消息并对其进行某种操作，然后将其传输到其他队列。 现在，如果异常来了，我希望它应该回滚，然后在6次尝试后，它发送到死信队列，目前回滚发生5-6次，但我的消息没有转移到死信队列。 这里会发生什么-->Queue1->>（消耗）-->Operation（引发异常）-->Rollback-->Queue1->>（消耗）-->Operatio
-
为什么已经拥有了共享内存时需要消息队列呢？ 这将是多种原因，让我们将其分解为多个点来简化 - 据了解，一旦消息被一个进程接收到，它将不再可用于任何其他进程。 而在共享内存中，数据可供多个进程访问。 如果想使用小信息格式进行通信。 当多个进程同时进行通信时，共享内存数据需要同步保护。 使用共享内存的写入和读取频率很高，那么实现功能将会非常复杂。 在这种情况下不值得使用。 如果所有的进程不需要访问共享
-
一、消息模型 点对点 发布/订阅 二、使用场景 异步处理 流量削锋 应用解耦 三、可靠性 发送端的可靠性 接收端的可靠性 参考资料 一、消息模型 点对点 消息生产者向消息队列中发送了一个消息之后，只能被一个消费者消费一次。 发布/订阅 消息生产者向频道发送一个消息之后，多个消费者可以从该频道订阅到这条消息并消费。 发布与订阅模式和观察者模式有以下不同： 观察者模式中，观察者和主题都知道对方的存在；
-
一个线程会从消息队列中收取消息，另一个线程会定时给消息队列发送普通消息和紧急消息 一个线程会从消息队列中收取消息，另一个线程会定时给消息队列发送普通消息和紧急消息 源码/* * Copyright (c) 2006-2018, RT-Thread Development Team * * SPDX-License-Identifier: Apache-2.0 * * Change Logs: *