《rabbitmq》专题

我正在翻阅Rabbitmq官方站点给出的AMQP的文档。上面说 但是，当Message broker崩溃时，我对以下情况感到困惑：- 消息由生产者传递到消息交换，但不路由到标记为持久的队列。 消息由生产者传递给消息交换，消息交换又路由到标记为持久的队列，但消息在队列中，使用者不使用。 消息由生产者传递到消息交换，消息交换继而路由到标记为持久的队列，但消息在队列中并由使用者使用，但使用者未向队列发送

我正在尝试同步我拥有的三个微服务。 为此，我实现了RabbitMQ。看起来好像事情目前是可行的，但我不确定我是否遵循了最佳实践，而且我找不到一个参考，也许有人能帮我做这件事？ 我正在尝试做的简要说明：我有一个服务谁应该更新另外两个，每个服务应该接收发送的消息。我有两种类型的消息（保存和删除资源）。*发生故障时，队列应恢复并重新发送消息。 我目前正在做的事情：我已经建立了一个交换，我的每个消费者都连

我对Spring和RabbitMQ有以下配置： 为了防止这种情况，我想创建持久队列（因为这些队列的持久度设置为false，自动删除设置为true）。如果不是，我想在这些队列上设置一些过期时间（例如，1小时或其他时间）。从RabbitMQ文档来看，我们似乎可以在头中传递这些值，但是，这只适用于版本3.6.0以后的版本，因为我们有3.5.4，它不是一个选项。 有没有其他方法可以配置它？（另一种方法是为

我希望能够在Rabbit中移动队列之间的消息（手动）。 例如： 我对rabbitmq和amqp还是个新手，但一直找不到关于如何做到这一点的文档（如果可能的话）。 多谢了。

保罗·菲茨。

> 应用程序A在Q1中发布消息。 应用程序B使用来自Q1的消息，进行一些处理，并在Q2中发布其他消息。B仅在Q2中成功发布消息后才对来自Q1的消息进行ACK。 应用程序C使用来自Q2的消息，进行一些处理，并将一些内容写入数据库。 如果我能限制每个队列的内存和磁盘使用量，而不是限制整个RabbitMQ的内存和磁盘使用量，我想这是可以解决的。有没有办法做到这一点，或者另一种方法来解决我的问题？ 如果需

我正在使用RabbitMQ作为面向服务的体系结构中的消息队列，其中许多单独的web服务发布绑定到RabbitMQ队列的消息。这些队列依次由执行后台工作的各种消费者订阅；RabbitMQ的一个非常普通的用例。 现在我想更改一些队列参数（特别是，我想用某个路由键将队列绑定到一个新的死信交换）。我的问题是，由于以下几个原因，在生产系统上进行这种更改是有问题的。 在生产系统中不丢失消息的情况下，转换到这些

我正在尝试设置到系统中所有节点的广播消息。当一个新节点加入系统时，它会向其他所有节点发布一条消息来宣布它的加入。我设计的方式是，存在一个交换，所有节点都将绑定到它自己的队列。每当一个新节点加入系统时，它就会将其队列绑定到exchange并将消息发布到exchange。所有节点都会收到这个消息（包括自身），所有其他节点（除了这个消息）都会发送一个“ACK”消息，这样新节点就会了解系统中可用的节点。但

我正在创建一个API来发布和使用来自RabbitMQ的消息。在我当前的设计中，发布者将发出一个POST请求。我的API会将POST请求路由到Exchange。这样，发布者在发布时就不必知道服务器地址、exchange名称等。 现在消费者部分是我不确定如何继续的地方。 开始时不会排队。当一个新的消费者想要订阅一个主题时，那么我将创建一个队列并将其绑定到交换。我需要一些问题的答案- 一旦我为使用者创建

在proxy中,我要发送给RabbitMQ： 在endpoint： 但当我将它发送到rabbitMQ服务器时,我发现了一个错误： [2016-06-27 17:07:00,388]warn-faulthandler ERROR_EXCEPTION:org.apache.synapse.synapseexception：发送消息时出现意外错误[2016-06-27 17:07:00,388]warn

我有一个CXF webservice，它支持基于JMS的SOAP，在这里我使用ActiveMQ作为消息代理系统。soap消息被发送到请求队列，soap响应被发送回回复队列。现在我计划用ActiveMQ替换RabbitMQ。但我面临的问题是RabbitMQ没有实现JMS API。我们可以将RabbitMQ用于SOAP/JMS Web服务吗？ 注意：我使用的是org。阿帕奇。cxf。运输jms。JMS

我有两个独立的应用程序，一个是生产者，一个是具有交换类型默认（DIRECT）的消费者。 下面是带有死信队列设置的Rabbit MQ Producer的配置。 现在，这里是单独应用程序中Rabbit MQ listener的代码。 现在，当我运行消费者服务时，它会创建一个同名的重复队列。如下图所示 Rabbit MQ GUI 我也在消费者中尝试了以下设置，但结果相同 注意：当我在生产者中添加死信队列

我的应用程序使用来自RabbitMQ的一些消息并对其进行处理。我有大约10个队列，每个队列最多有10个消费者（线程）。我有5次预回迁。我正在Heroku中使用CloudAMQP插件（RabbitMQ作为服务）运行安装程序。 我使用默认心跳和连接超时设置（60秒）运行。 我的java应用程序是一个使用sping-Rabbit库的Spring Boot应用程序。 版本： 问题是对于一个特定队列的消费者

我有Spring Cloud Stream Rabbit项目，它将消息发送到兔子交换以防流中出现错误。我想定期（5分钟一次）从队列中监听并处理它。 有什么方法可以让我有一个可轮询的？或者我可以配置一个RabbitMQ，这样我就可以用轮询器构建一个？