当前位置: 首页 > 知识库问答 >
问题:

在队列之间移动消息rabbitMQ

郎飞航
2023-03-14

我希望能够在Rabbit中移动队列之间的消息(手动)。

例如:

first-queue has messages ['a','b','c','d','e','f']
second-queue has messages ['x','y']

我对rabbitmq和amqp还是个新手,但一直找不到关于如何做到这一点的文档(如果可能的话)。

多谢了。

共有1个答案

东方夕
2023-03-14

@dax-我在这里只是回答了这个同样的问题:是否可以在RabbitMQ队列之间移动/合并消息

我有一个很长的描述。为了避免重复的内容,我不想复制/粘贴。

听起来你要找的是rabbitmq铲插件。

rabbitmq-plugins enable rabbitmq_shovel
rabbitmq-plugins enable rabbitmq_shovel_management

看其他帖子给我deets!

 类似资料:
  • 概念 消费者完成一个任务可能需要一段时间,如果其中一个消费者处理一个长的任务并且只完成了一部分,如果它突然挂掉了,会发生什么情况? RabbitMQ一旦向消费者传递了一条消息,就会立即将该消息标记为删除。在这种情况下突然有个消费者挂掉了,将会丢失正在处理的信息,以及后续应该发送给该消费者的信息,因为该消费者无法接收到 为了保证消息在发送过程中不丢失,RabbitMQ引入消息应答机制 消息应答机制指

  • 对主题之间的消息的特别移动有什么建议(除了一个接一个的复制和粘贴?) 具体地说,该用例用于将截止日期主题中的消息移回原始主题进行再处理。

  • Work Queues 工作队列 工作队列(又称任务队列)的主要思想是避免立即执行资源密集型任务,而不得不等待它完成的情况。 相反我们安排任务在之后执行。把任务封装为消息并将其发送给到队列。在后台运行的工作进程将弹出任务并最终执行作业。当有多个工作线程时,这些工作线程将一起处理这些任务。 1 轮训分发消息 在这个案例中我们会启动两个线程,一个消息发送线程,我们来看看这两个工作线程是如何工作的 1.

  • 本文向大家介绍管道和消息队列之间的区别,包括了管道和消息队列之间的区别的使用技巧和注意事项,需要的朋友参考一下 Unix管道 Unix Pipes用于进程间通信。顾名思义,管道可提供单向信息流。数据从一端流向另一端。 消息队列 消息队列允许发送方进程将消息共享到另一个进程。消息队列被实现为消息的链接列表,并存储在内核中。每个消息都有一个唯一的消息队列标识符。内核会记录系统中存在的消息队列。 以下是

  • 为什么已经拥有了共享内存时需要消息队列呢? 这将是多种原因,让我们将其分解为多个点来简化 - 据了解,一旦消息被一个进程接收到,它将不再可用于任何其他进程。 而在共享内存中,数据可供多个进程访问。 如果想使用小信息格式进行通信。 当多个进程同时进行通信时,共享内存数据需要同步保护。 使用共享内存的写入和读取频率很高,那么实现功能将会非常复杂。 在这种情况下不值得使用。 如果所有的进程不需要访问共享

  • 一、消息模型 点对点 发布/订阅 二、使用场景 异步处理 流量削锋 应用解耦 三、可靠性 发送端的可靠性 接收端的可靠性 参考资料 一、消息模型 点对点 消息生产者向消息队列中发送了一个消息之后,只能被一个消费者消费一次。 发布/订阅 消息生产者向频道发送一个消息之后,多个消费者可以从该频道订阅到这条消息并消费。 发布与订阅模式和观察者模式有以下不同: 观察者模式中,观察者和主题都知道对方的存在;