使用Spring AMQP监听许多短暂的、动态创建的队列
Spring AMQP是一个基于AMQP（Advanced Message Queuing Protocol）的框架，用于构建可靠、可扩展的消息传递应用程序。它提供了一种轻量级的、松耦合的方式来实现消息的生产和消费，并且支持动态创建短暂的队列。
动态创建的短暂队列在消息传递应用程序中具有以下优势：
- 灵活性：动态创建队列允许根据需求自动创建和销毁队列，从而实现更灵活的消息处理。无需手动创建和配置每个队列，减少了操作的复杂性。
- 高效性：由于队列是短暂的，只在需要时才会创建和使用，可以避免队列的长时间占用，提高资源利用率和系统性能。
- 解耦合：使用动态创建的短暂队列可以实现生产者和消费者的解耦合。生产者只需要发送消息到交换机，而不需要关心具体的队列，消费者则可以根据自己的需要动态创建队列进行消息消费。
- 可靠性：Spring AMQP提供了丰富的消息确认机制和容错机制，保证消息的可靠传递和处理。即使动态创建的队列消失或出现问题，消息仍然可以通过交换机进行转发或者投递到备用队列。
在云计算中，使用Spring AMQP监听许多短暂的、动态创建的队列可以应用于以下场景：
- 异步任务处理：将耗时的任务放入消息队列，并通过动态创建的短暂队列进行消费。这样可以避免任务堆积和阻塞，提高系统的并发能力和响应速度。
- 实时数据处理：通过动态创建的短暂队列接收实时数据，并进行实时处理和分析。可以根据数据的产生速率和处理能力动态调整队列的数量和规模，实现高效的实时数据处理。
- 微服务架构：在微服务架构中，各个服务之间通过消息队列进行通信和解耦合。使用Spring AMQP监听动态创建的短暂队列，可以实现服务之间的异步通信和高度可伸缩性。
腾讯云提供了云原生应用开发和部署的解决方案，包括云原生容器服务（Tencent Kubernetes Engine）、云原生应用服务（Tencent Serverless Cloud Function）等。这些产品可以与Spring AMQP结合使用，提供高可用、可扩展的云原生应用开发和部署环境。更多关于腾讯云的产品介绍和详细信息，请访问腾讯云官网：https://cloud.tencent.com/product
另外，我了解云计算领域的名词和词汇，这些名词包括但不限于：虚拟化、容器化、弹性扩展、自动化部署、负载均衡、高可用、备份和恢复、数据隔离、安全性、服务级别协议（SLA）、监控和日志管理等。
相关·内容
1回答
在我的项目中，我有一个听众：
@Service
@RequiredArgsConstructor
@Slf4j
public class ConsumerService {
@RabbitListener(queues = "${queue.treatment.request}")
public void handleQueueTreatmentRequestMessageReception(AppointmentPayloadDTO myAppointment) {
log.info(" ======================
浏览 6提问于2020-05-10得票数 0
是否可以在手动删除队列后自动重新创建队列？ 我可以使用以下命令在启动时创建队列 @Bean
public Queue createRandomQueue(@Qualifier("exporterRabbitAdmin") RabbitAdmin exporterRabbitAdmin) {
Queue queue = createQueue("random.queue", exporterRabbitAdmin);
exporterRabbitAdmin.declareQueue(queue);
return queue;
} 但是，如
浏览 667提问于2020-07-10得票数 1
回答已采纳
3回答
我有一个远程RabbitMQ服务器，它有一些我想要侦听的队列。我试过这个：
@RabbitListener(queues = "queueName")
public void receive(String message) {
System.out.println(message);
}
但是它试图创建一个新的队列。结果是可预测的-访问被拒绝。
o.s.a.r.listener.BlockingQueueConsumer : Failed to declare queue: queueName
我没有以任何其他方式宣布任何排队。
如何侦听远程服务器上的现有队列？另外
浏览 1提问于2018-08-30得票数 2
回答已采纳
我正在使用RabbitMQ/Spring/Spring AMQP构建一个应用程序，并且在处理我的队列布局时遇到了问题。 从本质上讲，我有一个每个消费者都会监听的队列，每个消息基本上都说“这个队列已经准备好由一个消费者来处理了”。然后，使用者将侦听消息中指示的队列，使用该队列中的所有消息，最后在完成时将其删除。 这些短暂的队列都是在数据进入处理时动态创建的，不能被多个使用者使用(无论哪个消费者获得了‘就绪’队列中的消息)。 在这种情况下，我很难优雅地处理消费者。现在，我只是在消费者每次从“就绪”队列中获得消息时创建一个新的DirectMessageListenerContainer，然后在它获
浏览 41提问于2019-10-02得票数 0
回答已采纳
我需要监听在另一个微服务中实现的来自rabbit的队列。假设第一次，我们切换到与流通信，而不是rest，并且另一个应用程序尚未启动，它的队列还没有出现在rabbitMq中。因此在看到例如'accountingResponseChannel.account‘队列不存在之后，尝试创建它，但它将由具有特定选项其他微服务创建。作为this post，你不能修改已存在的队列，所以我创建一个队列来跳过404错误是不好的。 最后我的问题是，当队列不存在时，如何静音@RabbitListener尝试创建未命中的队列？因为它面对的是错误！ 我的相关代码(如果需要)： @Configuration
@E
浏览 154提问于2021-11-22得票数 0
从生产者，我必须发送消息到RabbitMQ交换。此消息将包含特定属性，例如队列名，根据此属性，我必须动态决定发送此message.queue的队列，以绑定exchange，以发送此特定消息。
有没有办法截获到达RabbitMQ交换的消息，使用spring集成，目前，我有以下spring集成配置文件。
我不知道如何创建一个bean来获取交换消息，并将消息路由到smsQueue、emailQueue等队列。
感谢您的建议和回复。
http://www.springframework.org/schema/integration
http://www.springframew
浏览 1提问于2013-07-21得票数 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
回答已采纳
我正在尝试将旧的Qpid设置(基于AMQP0-X)升级到基于AMQP1.0的Qpid的最新质子版本，并且遇到了从客户端动态创建持久或非持久队列/主题的问题。我们过去可以利用Spring的jms-generic:queue:someQueueName (在某些情况下是主题)来实现这一点，在通过动态目标解析器之后，它最终会为我们创建队列或主题。然而，情况似乎不再是这样，因为createQueue/Topic不再创建实际的队列或主题(至少我在关于createQueue/Topic的JMS文档中读到的)。
因此，我的担忧最终归结为：
1)是否仍然可以使用最新的Qpid JMS和Broker-J动态创建
浏览 15提问于2019-03-28得票数 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回答
我花了整整一天的时间来尝试启动spring示例项目，并在一个对接版本的rabbitmq上运行。我只是在运行标准的兔子码头。虽然我在连接上没有问题，但我总是会遇到与创建队列相关的异常，而且在这一点上，我已经尝试了所有可能的变体。
我试图像样例项目一样声明配置中的队列。我已经尝试显式地配置一个RabbitAdmin。我已经尝试过显式地配置整个自动配置的混乱。我在rabbitmq中创建了一个新用户，并显式地分配了权限。我尝试过只使用队列名，而不实际声明队列bean。我尝试将队列和RabbitAdmin注入到其他bean中，只是为了强制创建它们。
无论我如何尝试，我都会遇到以下错误：
2017-04-
浏览 6提问于2017-04-25得票数 2
2回答
我有一个正在运行的ActiveMQ AMQP服务器，并且只有一个消费者在监听队列
现在我有三个不同的制作人
生产者%1生产到队列%1生产者%2生产到队列%2生产者%3生产到队列%3
所有这三个队列都来自同一服务器。
问题是
我可以让单个消费者监听所有这三个队列吗？
如果是，如何在Spring中制作
目前，我的使用者通过以下连接配置成功
<bean id="blazeDestination" class="org.apache.qpid.amqp_1_0.jms.impl.QueueImpl">
<constructor-arg
浏览 3提问于2013-04-29得票数 0
回答已采纳
1回答
我正在使用spring开发RabbitMQ。
我有两个不同的虚拟主机，一个叫做d和p。
在d代码中，它有@注释。
在p代码中，我使用QueueBuilder自动创建队列。在启动spring应用程序时，我注意到newQueue是在d虚拟主机整数中创建的。如何使newQueue (自动创建队列)在p虚拟主机中创建？
下面是d配置
package com.example.config;
import lombok.Data;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
imp
浏览 37提问于2022-08-26得票数 0
1回答
我遵循Stock Trading示例的说明，其中概述了如何在spring-amqp：中使用请求/回复消息
我调整了示例指令以创建一个客户机，它应该使用convertSendAndReceive而不是convertAndSend：来等待回复
现在，即使回复被放到responseQueue上，而且我已经更新了超时rabbitTemplate.setReplyTimeout(60000);，使其比5秒的默认时间长……在我的客户端，我收到null作为回复。
有人知道这是怎么回事吗？
Update#1
有人建议我将一个<reply-listener/>添加到<rabbit:templ
浏览 0提问于2013-06-13得票数 0
回答已采纳
1回答
我们的系统中有几个RabbitMQ队列，我们使用Spring Integration amqp:inbound-channel-adapter来使用消息。Spring应用程序在5个JBoss节点上运行(不在集群中)
RabbitMQ端是一个具有负载均衡器、持久队列的两个集群节点，在应用程序端的监听器定义相当简单，连接工厂定义如下：
<rabbit:connection-factory id="amqpConnectionFactory" username="${orts.rabbitmq.username}" password="${orts.ra
浏览 0提问于2016-08-30得票数 0
我有一个有3个节点的兔集群。一个节点有一个持久的、非镜像的经典队列，名为test-queue。
我有一个使用spring默认连接工厂new CachingConnectionFactory()的spring引导应用程序，它首先确保队列存在，然后订阅它的消息。一切都很好
然后，我开始了对rabbitmq集群的滚动更新，在该集群中，节点被一个接一个地重新启动。
在此过程中，我从日志中观察到：
一开始，我看到输出低于
Received shutdown signal for consumer tag=amq.ctag-pzPHM_GEd5e-J5Y_L2W7_g com.rabbitmq.clien
浏览 45提问于2022-04-08得票数 0
回答已采纳
当将org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer配置为作为集群工作并重新启动主节点时，RabbitMQ将无法恢复，也无法使用(来自RabbitMQ的)消息。
春兔版:1.3.3
RabbitMQ版本: 3.3.1
当重新启动集群的主节点时，我们会得到以下异常：
2014-10-03 17:36:00,136 [WARN] SimpleMessageListenerContainer(1099): Consumer raised exception, processing can restart i
浏览 2提问于2014-10-03得票数 0
回答已采纳
1回答
兔子配置：
package com.rabbitMQ;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.annotation.EnableRabbit;
import org.springframework.amqp.rabbit.connection.C
浏览 3提问于2019-12-25得票数 0
回答已采纳
1回答
我们有一个要求，我们在应用程序启动时通过直接交换在rabbitMq中创建队列，然后必须为每个队列分配一个侦听器。我们使用Spring AMQP实现了这一点，配置如下
@Bean(name= {"dispatcherListener"})
public SimpleMessageListenerContainer dispatcherListener() {
SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer();
listenerConta
浏览 10提问于2016-08-31得票数 1
如何禁用自动创建的amqp队列？在Mule ActiveMQ中，我获得了一个"disableTemporaryReplyToDestinations“属性，通过将其设置为'true‘并执行单向交换模式，我能够实现异步消息传递。
现在，对于AMQP/RabbitMQ，这是一个不同的故事，我确实有单向交换模式，但是我没有任何属性可以设置在MuleStudio内部的组件端，它告诉我禁用那些，我甚至不能从RabbitMQ面板中禁用它。
如何禁用异步实现不需要的tempQueues (在AMQP中称为AMQP)？
这是我的测试XML
<mule xmlns:amqp="ht
浏览 3提问于2013-09-16得票数 0
回答已采纳
2回答
我构建spring应用程序并将其发送到RabbitMQ。现在我想在Mule ESB中建立项目，侦听队列并处理信息，如果有变量a(例如) ->流程到aa流程等，->将响应转换为JSON ->发送回RabbitMQ。-
1)它将需要是RabbitMQ或其他可能的? 2)如何做到这一点-侦听特定的队列并处理它? 3)之后，如何返回？
我看过一些例子，但不能完美地理解这个主题。
`* </amqp:queue-profile> -->
<flow name="amqpChoiceAckNackService">
<amqp:i
浏览 0提问于2015-05-04得票数 0
我们正在从现有的经典队列迁移到仲裁队列，其中一个要求是必须将队列使用声明为“被动”(即queueDeclarePassive)。目的是确保我们不动态地创建任何队列，只检查它是否存在(如果不存在就失败)，然后连接。
我们有一个使用spring的遗留服务，我们将SimpleMessageListenerContainer设置如下：
SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
SimpleMessa
浏览 33提问于2022-04-20得票数 1
回答已采纳
我有一个spring的amqp应用程序，我想使用，但我似乎不知道如何让它来注册我的听众服务。这是我的基于注释的配置文件。
package com.jerry.configuration;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbi
浏览 1提问于2017-12-20得票数 0
回答已采纳
我有一个简单的弹簧引导应用程序，一个兔子发送者和一个接收者。我想编写一些接收器测试，当我作为Junit类规则(Junit，)运行一个rabbitmq 实例时，然后使用rabbitTemplate发送一条消息，测试将验证接收方是否接收到相同的消息。但我得到了以下例外：
Caused by: org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.amqp.rabbit.config.internalRabbitListenerEndpointReg
浏览 5提问于2017-10-25得票数 2
回答已采纳
1回答
我的NodeJS rabbitmq worker经常抛出异常，如下所示：
events.js:72
throw er; // Unhandled 'error' event
Error: PRECONDITION_FAILED - unknown delivery tag 3
at Queue._onMethod (/Users/Rana/WebstormProjects/TS/ts-worker/node_modules/amqp/amqp.js:1720:15)
at Queue.Channel._onChannel
浏览 0提问于2015-04-12得票数 0
我有一个场景，客户端通过STOMP将消息发布到RabbitMQ /queue或/topic目的地。
在另一端，我有一个服务器进程，它通过AMQP连接到RabbitMQ。是否可以从AMQP访问"STOMP-channels“，或者将它们隔离到自己的名称空间中？
看起来可以通过/amq/queue/从STOMP访问AMQP通道，但我没有发现另一个方向的情况。
浏览 15提问于2017-07-13得票数 2
回答已采纳
我正在尝试在我的spring-core开发的应用程序中实现rabbitmq。下面是我的pom.xml
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>5.2.6.RELEASE</version>
</dependency>
<depen
浏览 665提问于2020-05-29得票数 1
在我(有限的)经验中，如果您为一个尚不存在的队列创建了一个新的侦听器，那么该队列将被自动创建。我正在尝试使用Spring AMQP项目和rabbit mq来设置一个侦听器，但是我得到了一个错误。这是我的xml配置：
<rabbit:connection-factory id="rabbitConnectionFactory" host="172.16.45.1" username="test" password="password" />
<rabbit:listener-container connectio
浏览 3提问于2013-05-04得票数 21
回答已采纳
我本打算把这个问题贴出来，但我想我找到了答案。我希望有人能提供一个原因，为什么要进一步了解公众。
我正在将RabbitMQ集成到我的Spring Boot应用程序中。
在启动我的Spring引导应用程序时，我一直得到这个堆栈跟踪
org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused (Connection refused)
at org.springframework.amqp.rabbit.support.RabbitExceptionTranslato
浏览 3提问于2018-09-01得票数 0
我有一个使用RabbitMQ绑定器的Spring Cloud Stream应用程序，构建在Spring Boot 1.5和Spring Cloud Edgware.SR4上。由于某种原因，Spring Cloud Bus无法从至少30秒的网络中断中恢复(持续时间可能取决于您的环境)。如果网络中断的时间足够长，以至于RabbitMQ删除了独占队列，则应用程序能够重新声明匿名队列。这似乎是一个重复发生的事件，与RabbitMQ服务器的系统修补/重新启动一致。
通过连接到远程服务器并断开笔记本电脑上的网络连接，我复制了此RabbitMQ中的错误。拥有来自测试的整个标准输出。
以下是事件的概要：
声明
浏览 291提问于2018-12-18得票数 3
我正在开发具有1个磁盘和2个ram节点的集群环境。谁能解释一下如何在RabbitMQ broker中使用Spring AMQP注解来配置策略来创建镜像队列。
提前谢谢。
浏览 4提问于2013-10-03得票数 1
我创建了一个带有消息过期args的队列，但在启动服务器时得到了以下错误。
[SimpleAsyncTaskExecutor-1] o.s.a.r.c.RabbitAdmin [RabbitAdmin.java:375] Auto-declaring a non-durable Queue (TEST_QUEUE). It will be redeclared if the broker stops and is restarted while the connection factory is alive, but all messages will be lost.
pool-1-threa
浏览 0提问于2016-07-07得票数 2
回答已采纳
1回答
使用Spring Spring与Spring
在这里，我试图实现死信交换。我正在向队列发送消息，如果出现业务异常，则应该将消息发送到"dlq“队列，并在那里等待5秒，然后再进入队列进行处理……试了5次，它应该从容器里出来。
请找出这份信任
application.yml
spring:
rabbitmq:
host: localhost
username: guest
password: guest
port: 5672
server:
port: 8081
MQ Config
import java.util.HashMap;
import jav
浏览 5提问于2017-01-11得票数 2
回答已采纳
1回答
我以这种方式使用rabbitTemplate：
<bean id="rabbitConnFactory" class="org.springframework.amqp.rabbit.connection.SingleConnectionFactory">
<constructor-arg>
<value>localhost</value>
</constructor-arg>
</bean>
<!-- Spring AMQP Template --&
浏览 0提问于2013-05-05得票数 1
由于某些原因，即使我在Spring AMQP队列配置中指定了该设置，我的队列也没有创建为持久队列：
@Bean
Queue queue() {
//durable queue - true
return new Queue(queueName, true);
}
我正在使用Spring AMQP连接到RabbitMQ并在Direct Exchange上监听该队列。
@Bean
DirectExchange exchange() {
return new DirectExchange(exchangeName);
}
@Bean
Binding binding(Queu
浏览 0提问于2016-01-22得票数 0
使用Spring-AMQP抽象API，如何实现工作或任务队列？我只有一个生产者和多个工人消费者。消费者从队列中挑选下一项并对其进行处理。当您直接使用Spring时，这是受支持的，但我在RabbitMQ -AMQP中看不到任何支持。我是不是漏掉了什么？有没有其他实现工作队列的方法？
浏览 0提问于2015-04-17得票数 2
我有一个Spring应用程序，包含许多@Service组件，用于处理事件类型的AMQP消息。这些消息由另一个组件发布到由路由密钥分隔的单个ExchangeTopic中。
当应用程序启动并避免维护大规模配置时，我应该如何创建和订阅TopicExchange队列？
浏览 3提问于2016-06-18得票数 0
回答已采纳
我使用了带有AMQP的Spring的2.1.0.RELEASE版本。不幸的是，我需要连接到几个不同的RabbitMQ服务器。我不得不排除RabbitAutoConfiguration.class，因为上面的spring版本发生了变化，如果没有一个ConnectionFactory bean作为主服务器启动是不可能的，但是即使我将其中一个设置为@Primary，它也显然不起作用，因为amqp/spring如何知道要在哪个服务器上创建哪个队列.
那么，是否可以在不同的服务器上自动创建禁用自动配置的队列？
浏览 1提问于2019-05-17得票数 0
回答已采纳
如何模拟spring rabbitmq/amqp，使其在自动创建交换/队列时不会在Spring Boot测试中失败？ 假设我有一个简单的RabbitListener，它将导致队列和交换被自动创建，如下所示： @Component
@RabbitListener(bindings = {
@QueueBinding(
value = @Queue(value = "myqueue", autoDelete = "true"),
exchange = @Exchange(value
浏览 60提问于2016-08-03得票数 22
回答已采纳
我有spring引导 rabbitmq应用程序，其中我必须发送一个Employee对象来排队。然后，我设置了一个侦听器应用程序。对employee对象执行一些处理，并将该对象放入回叫队列中。
为此，我在我的应用程序中创建了下面的对象。
创建了ConnectionFactory。
使用RabbitAdmin创建ConnectionFactory对象。
请求队列。
回调队列。
直接交换。
请求队列绑定。
回调队列绑定。
MessageConverter。
RabbitTemplate对象
最后是SimpleMessageListenerContainer的对
浏览 0提问于2018-03-17得票数 6
回答已采纳
1回答
我使用py-amqplib来访问RabbitMQ。应用程序不时收到关于侦听某些MQ主题的请求。
当它第一次收到这样的请求时，它会创建一个AMQP连接和一个通道，并启动一个新线程来侦听消息：
connection = amqp.Connection(host = host, userid = "guest", password = "guest", virtual_host = "/", insist = False)
channel = connection.channel()
listener = AMQPListen
浏览 1提问于2009-11-27得票数 3
我使用3个队列(rabbitmq)在mule中运行一个流。下面是我的配置xml
<mule xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns:amqp="http://www.mulesoft.org/schema/mule/amqp" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracki
浏览 3提问于2014-03-07得票数 0
在创建了一个基本的spring设置之后，我发现对于我想发送的每一种消息(使用message )，我都需要在spring配置中声明队列。
因此，每一对这样的：
amqpTemplate.convertAndSend("queue1", new MessageType1(...));
@RabbitListener(queues = "queue1")
public void handleMessage(MessageType1 msg) {...}
我需要在spring配置中有这样一个条目：
<rabbit:queue name="queue1&#
浏览 0提问于2014-11-24得票数 5
回答已采纳
1回答
我有一个多绑定弹簧云流应用程序，实现与文档中解释的实现完全类似。
我打算重新尝试配置的次数，并最终放弃。
但
如果错误类似于下面的错误，它甚至不会进入监听器代码来应用x-death计数逻辑。因此，问题是如何放弃带有反序列化和消息转换错误的消息：
2018-09-06 16:41:11.889 ERROR [data-connector,671345aea4270626,48dd1100d9e332f9,false] 8866 --- [rdedStarGroup-1] o.s.integration.handler.LoggingHandler : org.springframework.
浏览 0提问于2018-09-06得票数 1
回答已采纳
我正试图在春季使用RabbitMQ创建一个出版商和消费者应用程序。每件东西都正常工作，当发布者发送消息时，使用者接收到它并成功地使用它。但是，正如您在下面的图片中所看到的，RabbitMQ接口没有向我展示创建的队列和交换。
不排队
不交换
这就是我写的代码：
RABBITMQ配置(在PUBLISHER应用程序和消费者应用程序中相同)
package com.example.rabbitmq.springrabbitmqconsumer.configuration;
import org.springframework.amqp.core.Binding;
import o
浏览 3提问于2022-01-15得票数 1
1回答
我试图为DLX (绑定到另一个队列的配置)的rabbitMQ队列编写一个简单的使用者。我现在用的是骆驼3.14.5。
我的骆驼路线声明看起来是：
from("spring-rabbitmq:my-exchange?connectionFactory=#rabbitMQConnectionFactory&queues=my-queue")
.onException(Exception.class)
.log(LoggingLevel.ERROR, "Something went wrong!")
浏览 18提问于2022-09-20得票数 0
回答已采纳
我想知道与使用Spring AMQP手动接收消息相比，使用SimpleMessageListenerContainer的优点和缺点。另一个问题是，当我们创建SimpleMessageListenerContainer设置一个队列时，rabbitmq是否调用listeneradaptor，或者SimpleMessageListenerContainer是否一直轮询队列以检查消息，并在消息为message时调用已注册的适配器。
浏览 4提问于2014-06-12得票数 0
其中有一个包含10000条消息的队列。启动使用者(autoack=true)时，我可以从rabbitmq_management中看到消息数量迅速变为零。这是否意味着所有10000条消息都在消费者一方？它存放在哪里(我正在使用Spring-AMQP)？如果我的使用者配置的并发性是1，并且处理一条消息需要很长时间，那么是否有可能耗尽内存(如果消息的数量很大)？
浏览 5提问于2021-02-19得票数 0
回答已采纳
我对spring引导amqp库很陌生，当我正在寻找一个解决方案时，我可以通过这个属性.Can来解释这个属性的用途。
.createListenerContainer();
container.setStartConsumerMinInterval(3000); ```
浏览 9提问于2022-09-12得票数 0
我有如下所示的amqp_URI amqp://sds:%23%23%45%56%65%56%56%@myserver:5672 我需要从Spring boot application.properties文件访问此服务器。我已经尝试过spring.rabbitmq.addresses property .But，但没有成功。 如有任何建议，将不胜感激。
浏览 16提问于2021-02-01得票数 0
回答已采纳
如何在yii 2 queue AMQP Interop (rabbitmq)中使用retryable作业？
浏览 0提问于2019-04-22得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
