我正在尝试使用@RabbitListener来监听从属性加载的来自不同主机的几个队列。这些队列是相同的，并且需要相同的消息处理。 我设法“静态地”声明了我的工厂，如下所示： @Bean
public ConnectionFactory defaultConnectionFactory() {
CachingConnectionFactory cf = new CachingConnectionFactory();
cf.setAddresses(hosts);
cf.setPort(port);
浏览 88提问于2019-01-23得票数 0
回答已采纳
可以让@AliasFor注解将参数传递给嵌套注解吗？将name()的值传递给@RabbitListener中的嵌套@Queue注释？我基本上希望为相同的交换指定多个具有相同绑定参数的队列，并且只改变队列名称。 ?
浏览 53提问于2021-11-17得票数 0
回答已采纳
我有一个@RabbitListener(id="example", queues={"a", "b"})监听器，我把它复制到代码中的多个位置，贯穿不同的模块。我想创建一个别名，例如：
@Target({ ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE })
@Retention(RetentionPolicy.RUNTIME)
@MessageMapping
@Documented
public @interface MyRabbitListener {
浏览 8提问于2017-10-13得票数 1
回答已采纳
有没有一种方法可以不使用AspectJ来拦截带有@RabbitListener注释的bean方法的调用。
代码是这样的
@OtherAnnotation
@RabbitListener
public void do(Message message)
我需要拦截对@RabbitListener方法的所有调用，如果该方法有@OtherAnnotation注释的话。
更新：
我用加里·罗素的解决方案成功了。
public class CustomRabbitListenerAnnotationBeanPostProcessor extends RabbitListenerAnnotationBean
浏览 1提问于2016-10-13得票数 1
回答已采纳
我正在尝试创建一个简单的元注释，它应该充当一个@RabbitListener。
以下是我的尝试：
@Retention(RetentionPolicy.RUNTIME)
@Target({ ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE })
@RabbitListener(errorHandler = "workerRabbitErrorHandler", returnExceptions = "true")
public @interface RabbitListenerEp
浏览 3提问于2019-12-31得票数 1
您能建议一种方法来动态获取rabbitMQ rabbitMQ RabbitListener RabbitListener所听的队列列表吗？
下面是我的侦听器的示例，它处理来自许多队列的消息(可以在属性文件中更新列表)，我希望在另一个服务中动态地获取列表：
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;
@Service
pub
浏览 3提问于2020-11-19得票数 2
回答已采纳
我有spring应用程序的application.properties文件，其中包含一些简单的属性：
queue=my.test.q
在java代码中，我需要指定@RabbitListener的队列：
@Component
public class Handler {
@RabbitListener(queues = "my.test.q")
public void handleMessage(Message message) {
...
}
这是可行的，但我想将参数传递给注释，我尝试了以下方法，但都不起作用。
@Compo
浏览 0提问于2015-08-21得票数 17
回答已采纳
我想使用一个特定的模式来使用队列名，比如project.{queue-name}.queue。为了保持这个模式的坚实性，我编写了一个助手类来从一个简单的标识符中生成这个名称。因此，foo将生成一个名为project.foo.queue的队列。很简单。
但是，注释RabbitListener需要一个常量字符串，并使用我的助手类给出一个错误。如何使用RabbitListener注释来实现这一点(或者是另一种方法)？
@Component
public class FooListener {
// it doesn't work
@RabbitListener(queues
浏览 0提问于2018-04-18得票数 9
回答已采纳
我们使用@RabbitListener侦听队列，当有消息时，我们处理它们。但是，当队列为空时，我想做一些报告任务，当我们的应用程序处理队列中的大量消息而暂时没有消息时，就会发生这种情况。这是我要报告的时间。我怎么能用@RabbitListener做到这一点呢？
这是我的代码：
@RabbitListener(queues = "${consumer.queue}", containerFactory = "ListenerContainerFactory")
public void handleMessage(Message message) {
浏览 3提问于2015-10-11得票数 0
回答已采纳
当应用程序开始收集消息时，我希望将匿名队列绑定到扇出交换，但是消息的实际处理应该在稍后(在其他地方初始化之后)进行。我试过：
@RabbitListener(autoStartup="false",
bindings = @QueueBinding(value = @Queue,
exchange = @Exchange(name="myexchange",
type=ExchangeTypes.FAN
浏览 1提问于2018-03-21得票数 0
回答已采纳
我正在使用spring-amqp并测试RabbitListener#AcknowledgeMode。
当我设置RabbitListener#AcknowledgeMode#AUTO，时，我通过刺穿RabbitListener中的一个异常来触发nack响应。
当我将defaultRequeueRejected设置为true(它意味着消息将请求)时，由wireshark打包：
最后两位表示这两个属性.
当我将defaultRequeueRejected设置为false(这意味着消息不会请求)时，由wireshark打包：
Requeue应该是false.So，这是wireshark的错
浏览 0提问于2020-01-16得票数 2
回答已采纳
问题：I正在从MessageListener接口impl迁移到@RabbitListener。我有这样的逻辑:在由几个类继承的MessageListener上进行“预”和“后”消息处理。
示例：
public AbstractMessageListener implements MessageListener {
@Override
public void onMessage(Message message) {
//do some pre message processing
process(Message message);
浏览 5提问于2015-12-29得票数 12
回答已采纳
我在我的项目中使用了spring amqp，并且我使用implements ChannelAwareMessageListener来重发和处理异常，以使兔监听器更稳定：
public abstract class AbstractMessageListener implements ChannelAwareMessageListener {
@Autowired
private Jackson2JsonMessageConverter messageConverter;
@Autowired
private RedisTemplate<Stri
浏览 0提问于2018-01-23得票数 0
我有一个Spring @RabbitListner
class MyConsumer {
@RabbitListener(queues = "myQueue")
public void handleMessage(Message message){
doSomething(message)
}
}
如何使RabbitListener获得一个列表，而不是一条消息，可能根据预取计数或其他类似的配置？
浏览 3提问于2020-08-05得票数 0
我正在尝试在spring中配置并发使用者以使用来自RabbitMQ的消息，以便通过两种方式配置使用者。
1.用@RabbitListener(=“队列名称”)注释了一个方法
2.实现"MessageListener“接口并覆盖onMessage(消息消息)
在我的例子中，这两种方法都运行得很好，但我无法弄清楚使用@RabbitListener()启动消费者的优点/缺点是什么。
此外，我还在配置中配置了"DirectMessageListenerContainer“，并将其映射到"MessageListener”实现以实现并发使用者，我在这里的问题是，我们能否为通过@Ra
浏览 5提问于2021-05-13得票数 1
使用Spring boot @RabbitListener，我们能够处理AMQP消息。无论何时发送到队列的消息都会立即发布到目的地交换。使用@RabbitListener，我们能够立即处理消息。但是我们只需要在特定的时间点之间处理消息。如何做到这一点呢？
浏览 2提问于2019-08-29得票数 0
当存在属性时，我希望创建一个RabbitListener，但是@ConditionOnProperty不能与@RabbitListener组合。现在我有了一个解决办法。有没有更好的方法？
@Bean
@ConditionalOnProperty(name = "pmc.multiple.hypervisor.reply.routerkey.kvm")
public SimpleMessageListenerContainer kvmReplyQueueConsumer() {
return getSimpleMessageListenerContainer(enviro
浏览 9提问于2015-10-21得票数 0
回答已采纳
我已经通过application.yaml和spring configurationProperties配置了我的兔子属性。因此，当我配置交换、队列和绑定时，我可以使用属性的getter
@Bean Binding binding(Queue queue, TopicExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(properties.getQueue());
}
@Bean Queue queue() {
return new Queue(properties.getQueue
浏览 83提问于2018-03-02得票数 1
1回答
我使用SpringAMQP2.1.6和SpringBoot2.1.5，我正在寻找配置Spring的推荐方法，以便通过指数退避重新尝试反应性组件(Mono)的业务异常。例如：
@RabbitListener
public Mono<Void> myListener(MyMessage myMessage) {
Mono<Void> mono = myService.doSomething(myMessage);
return mono;
}
如果doSomething返回错误，我希望spring自动重试。通常，在设置容器工厂时，可以将其配置为阻塞Rabbi
浏览 2提问于2019-05-22得票数 1
回答已采纳
是否有方法将所有@RabbitListener注释配置为使用与属性replyPostProcessor的值相同的bean？
这是使用此属性的一个示例：
@RabbitListener(queues = "test.header", group = "testGroup", replyPostProcessor = "echoCustomHeader")
public String capitalizeWithHeader(String in) {
return in.toUpperCase();
}
@Bean
public Reply
浏览 5提问于2022-02-16得票数 0
回答已采纳
1回答
在文档中我看到了
@RabbitListener(bindings = @QueueBinding(
value = @Queue(value = "myQueue", durable = "true"),
exchange = @Exchange(value = "auto.exch", ignoreDeclarationExceptions = "true"),
key = "orderRoutingKey")
)
public void processO
浏览 4提问于2018-05-08得票数 4
回答已采纳
我正在使用@RabbitListener来使用来自RabbitMQ的消息。我希望能够基于某个阈值暂停/恢复消息消耗过程。
按照和发布的方式，我可以使用RabbitListenerEndpointRegistry并根据需要获取容器列表和暂停/恢复消费。我还理解，为了能够注册到RabbitListenerEndpointRegistry，我需要指定一个id到@RabbitListener注释。
但是，我在@RabbitListener注释中添加了一个id，而RabbitListenerEndpointRegistry.getListenerContainers() 仍然返回一个空集合。
我不确定，
浏览 1提问于2019-08-26得票数 1
考虑到这段代码
@Bean
open fun exchange(): TopicExchange {
return TopicExchange("amq.topic")
}
@RabbitListener(queues = [Amqp.BODY_WEIGHT_NEW])
open fun record(entity: Collection<BodyWeight>) {
log.trace("saving: {}", entity)
}
@Bean
ope
浏览 0提问于2019-04-30得票数 0
回答已采纳
1回答
使用@RabbitListener端点从RabbitMQ文档异步接收消息： "The easiest way to receive a message asynchronously is to use the annotated listener endpoint infrastructure. In a nutshell, it allows you to expose a method of a managed bean as a Rabbit listener endpoint." @RabbitListener(queues = "myQueue")
浏览 28提问于2019-01-22得票数 1
回答已采纳
是否可以使用逗号分隔的属性来定义要侦听的队列？目的是在不更改代码的情况下更改队列名称和队列数。
我在application.properties中定义了队列，如下所示：
my.aggregate.queues=/some/queue,/some/other/queue
通过使用，我可以将队列名作为列表包括在内：
@Value("#{'${my.aggregate.queues}'.split(',')}")
但是，当我试图使用@RabbitListener注释侦听队列时，我发现我必须单独定义队列。使用
@RabbitListener(queues
浏览 0提问于2015-09-03得票数 4
回答已采纳
1回答
我有一个使用RabbitMQ ( Spring Starter)的spring应用程序。
我想知道是否可以跨不同的类使用@RabbitListener注释。
我现在有两个类：Receiver和DeadLetterQueue
Receiver.java
@Component
@Slf4j
public class Receiver {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
@RabbitListener(queues = "queueName")
public
浏览 1提问于2020-01-13得票数 2
我已经成功地使用了一种使用@RabbitListener注释返回业务对象的方法。
注册的Jackson2JsonMessageConverter bean名为messageConverter，它启动并完美地将传入的JSON消息转换为我期望的类型，并将返回的业务对象转换为JSON。
// This works!!
@RabbitListener(...)
@SendTo("#{responseDestination})
MyBusinessResponseObject handle(MyBusinessRequestObject request) {
...
...
...
浏览 0提问于2018-08-07得票数 0
回答已采纳
我希望只在侦听特定队列的特定侦听器上使用重试策略(在特定情况下为DLQ)。
@RabbitListener(queues = "my_queue_dlq", concurrency = "5")
public void listenDLQ(Message dlqMessage) {
// here implement logic for resend message to original queue (my_queue) for n times with a certain interval, and after n times
浏览 4提问于2022-09-30得票数 0
回答已采纳
我试图使用来自退出队列的消息，该队列类型为Direct (在exchange和路由密钥的帮助下创建)。我只有交换名、和路由密钥、和，而没有队列名。虽然支持普通Java，但是没有地方可以找到Spring。
@RabbitListener
@RabbitHandler
public void consumeMessage(Object message) {
LOGGER.debug("Message Consumed.... : {}", message.toString());
}
如何使用具有路由密钥和交换名称的消息，而不是@Rabbit
浏览 0提问于2019-09-12得票数 1
回答已采纳
1回答
我有一个RM队列test-queue。在那里，我需要为3个独立的服务中的3个独立进程处理3个独立的消息(message-1, message-2, message-3)。
我使用如下所示的@RabbitListener来访问消息
@RabbitListener(queues = "test-queue")
public void getMessage1(Message message) {
System.out.println(message);
}
但是我只需要在这个函数中访问特定的消息ex:message-1。
有什么头绪吗？
浏览 20提问于2021-02-15得票数 0
回答已采纳
实际上，我有一个使用@RabbitListener消费rabbitMQ消息的on引导应用程序，并且我已经将相同的应用程序迁移到azure，后者使用@JMSListener来消耗AzureServiceBus消息。
我们对酒店和Azure都有相同的代码。因此，由于这两个侦听器，我计划在两个具有相同内容的不同类中复制相同的使用者代码，并使用两个不同的侦听器
消费者与JMSListener:
@JmsListener(destination = "${queue}", concurrency = "${threads}", containerFactory =
浏览 1提问于2020-09-11得票数 1
回答已采纳
我有一个遗留系统，可以向RabbitMQ发送消息。系统只使用一个队列：q.finance.invoice，但是它有两种类型的消息，其中消息的类型在报头上可用。
第一类
Type : invoice.created
{
"field_1" : "",
"field_2" : "",
}
第二类
Type : invoice.paid
{
"field_5" : "",
"field_6" : "",
}
因此，现在我的使用者需要根据数据类型有选择地处理
浏览 0提问于2019-06-20得票数 1
回答已采纳
我没有找到任何类似的东西，所以我在这里询问，以防有人知道它是否可能。
这个场景很简单，使用Spring Boot和RabbitMQ来支持一个项目；要侦听队列，您可以使用如下代码：
@RabbitListener(queues = "example-queue")
public void receiveQueueMessage(String message) {
System.out.println("[x] Received: '" + message + "'");
}
那么，有没有一种方法可以像这样使用regex呢？：
浏览 48提问于2021-02-26得票数 1
回答已采纳
我在Kubernetes集群中有一个服务和RabbitMQ。我想要做的是，我希望服务的不同实例(或副本)在启动时声明一个全新的队列。这些队列将被绑定到相同的交换。 我能不能在这里加上最后一个变量： public static final String QUEUE_NAME = "queue-" + UUID.randomUUID().toString();
// ...
@RabbitListener(queues = QUEUE_NAME) 本质上，我只需要一种方法来创建一个具有生成的名称的队列，然后使用@RabbitListener监听这个队列。
浏览 92提问于2020-08-21得票数 0
回答已采纳
我正面临被覆盖的问题，更准确地说，是在我的一个RabbitListener中的containerFactory中。 假设我有一个projectA，它的一个依赖项(库B)在运行时实例化了以下配置。 @Configuration
public class AmqpConfiguration {
@Bean
public static BeanPostProcessor bpp() {
return new BeanPostProcessor() {
@Override
public Object postProce
浏览 149提问于2021-07-06得票数 0
回答已采纳
在@RabbitListener注释方法处理之前，我如何过滤消息？
如果信息是给你的。例如。是“复制”，因为包含一个具有确定性值的标头，我希望返回"ack“并跳过处理。(跳过@RabbitListener方法的主体)
我试图在MessagePostProcessor (使用addAfterReceivePostProcessors)中执行它，但不能跳过对ex的执行。基于消息属性(标头)。这是MessageProcessor的签名：
Message postProcessMessage(Message message) throws AmqpException;
我想在这里返回一
浏览 24提问于2022-10-04得票数 0
每一个RabbitListenerContainerFactory都有一个@RabbitListener。除非注释中另有规定，否则将使用默认值。
还可以使用rabbitListenerAnnotationBeanPostProcessor.setContainerFactoryBeanName()更改默认设置。
我正在寻找一种方法，为应用程序中的每个 ContainerFactory 设置一个 @RabbitListener (如果已经通过原始注释设置，甚至覆盖)( ContainerFactory将根据要侦听的队列名称进行设置)。
额外的问题是:如何设置(在这种情况下) ContainerF
浏览 11提问于2022-06-22得票数 0
1回答
我想使用java.util.Function方法来回复通过RabbitTemplate.convertSendAndReceive发送的请求。它在RabbitListener中运行得很好，但我无法让它使用功能方法。
客户(工作)
class Client(private val template RabbitTemplate) {
fun send() = template.convertSendAndReceive(
"rpc-exchange",
"rpc-routing-key",
"pay
浏览 9提问于2021-03-11得票数 0
回答已采纳
我希望能够使用RabbitListener注释将一个队列绑定到多个交换，但到目前为止没有成功。
我现在拥有的是：
@RabbitListener(bindings = @QueueBinding(value =
@Queue(
value = "${subscriber.queueInbound}", durable = "true", autoDelete = "false", exclusive = "false"),
exchange = @Exchange(value = "
浏览 5提问于2017-11-01得票数 1
我使用SpringAMQP2.1.6来使用RabbitListener返回Mono<Void>的消息。例如：
@RabbitListener
public Mono<Void> myListener(MyMessage myMessage) {
Mono<Void> mono = myService.doSomething(myMessage);
return mono;
}
阅读，它说：
侦听器容器工厂必须配置为AcknowledgeMode.MANUAL，这样使用者线程就不会破坏消息；相反，异步完成将在异步操作完成时对消息进行包装或na
浏览 0提问于2019-05-21得票数 4
回答已采纳
我知道可以在这里设置SimpleMessageListenerContainer bean并设置预取计数和消息侦听器，如下所示：
@Bean
public SimpleMessageListenerContainer messageListenerContainer(
ConnectionFactory rabbitConnectionFactory,
Receiver receiver) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
浏览 4提问于2016-06-01得票数 12
回答已采纳
1回答
当使用Spring并手动创建MessageListenerContainer时，其吞吐量要比使用@RabbitListener方法慢得多。据我所知，在使用@RabbitListener时，容器是由BeanPostProcessor创建的，我所做的应该是相同的，但出于某种原因，情况并非如此。我在下面添加了这两种方法来说明我的意思。
我的方法的吞吐量非常慢，在使用下面的配置时大约是30/s，在使用注释时，吞吐量非常快。我做错了什么？
application.properties
spring.rabbitmq.listener.type=direct
spring.rabbitmq.listene
浏览 0提问于2019-01-25得票数 2
回答已采纳
我有一个spring应用程序，它在cloudfoundry上运行在多个实例中。这些实例共享一个数据库。它们的RabbitListener配置如下：
@RabbitListener(queues = "${items.updated.queue}", exclusive = true)
如果需要从某个源重新导入项，队列将收到消息。
我只想要一个实例来执行导入。据我所知，这可以通过专用标志来实现。
现在，如果当前的exclusive consumer崩溃，会发生什么？另一个正在运行的实例是否会将自己注册为新的exclusive consumer？还是只有在申请启动时才进行注册？
浏览 2提问于2017-02-16得票数 3
回答已采纳
1回答
有没有可能把这个注释 @RabbitListener(
bindings = [QueueBinding(
key = [Amqp.FOLEY_NEW],
value = Queue(Amqp.FOLEY_NEW),
exchange = Exchange(name = "amq.topic", type = ExchangeTypes.TOPIC )
)]
) 转换成一个简单地接受队列名称作为参数的自定义注释？ 试一试，但我看不出我可以引用Listener.value @Target(AnnotationTa
浏览 13提问于2019-05-02得票数 0
回答已采纳
我不确定我对errorHandler和returnExceptions的理解是否正确。
但我的目标是:我从App_A发送了一条消息，使用@RabbitListener在App_B中接收消息。
据医生说
如果APP_B在处理消息过程中有业务异常，通过在@RabbitListener上正确地设置errorHandler和returnExceptions，可以将异常返回到App_A。
我的理解正确吗？
如果我是严格的，如何正确地使用它？
使用我的代码，我在APP_A中什么也得不到。
这是我在APP_B中的代码
errorHandler：
@Component(value = "errorHa
浏览 0提问于2018-12-19得票数 4
回答已采纳
我使用的是spring 2.1.1发行版和spring starter，@@RabbitListener虽然工作正常，但停止了使用消息。当我重新启动使用者API时，它开始正常工作。
此外，在管理用户界面中，它没有显示此队列中的任何使用者。
Java1.8版本
RabbitMQ 3.7.11集群(3个节点)
库伯内斯
在java客户端或rabbitmq服务器端没有例外。
我试图通过rabbitmqctl重新同步队列，但是它仍然不起作用。
@Component public class接收器{ Logger logger = Logger.getLogger(Receiver.
浏览 0提问于2019-09-13得票数 1
是否可以有一个@RabbitListener，例如：
@RabbitListener(queues = STORAGE_REQUEST_QUEUE_NAME)
public FindApplicationByIdResponse findApplicationById(FindApplicationByIdRequest request) {
return repository.findByUuid(request.getId())
.map(e -> new FindApplicationByIdResponse(conversionService.co
浏览 28提问于2017-07-13得票数 4
回答已采纳
1回答
我有一个项目，在这个项目中，我们将有数百个(潜在的数千个)队列在兔子中，每个队列都需要由一个消费者池来使用。
在兔子(使用spring)中，您有一个rabbitlistener注释，它允许我静态地分配特定使用者将要处理的队列。
我的问题是--对于兔子和spring，是否有一种干净的方法来抓取一部分队列(比如以are开头的队列)，然后侦听在消费者运行时创建的任何队列。
示例(开始时)：
蚂蚁队列
苹果队列
猫队列
当消费者在运行时：
添加蝙蝠队列
下面是我目前拥有的(非常简单)代码：
@Component
public class MessageC
浏览 1提问于2019-01-08得票数 11
回答已采纳
下面的场景:我有一个@RabbitListener接收来自RabbitMQ的消息。有时，由于找不到相关的业务对象，消息会出现错误。在这种情况下，我没有可能回复发件人，所以我只想忽略这条消息后，一定数量的重试。
我的解决方案:在我的@RabbitListener中，每当找不到业务对象时，我就抛出一个自定义运行时异常。在我的配置中，我有一个最大尝试的RetryOperationsInterceptor和一个自定义恢复程序。
处理这类案件的最佳做法是什么？当有多个@RabbitListener时，我可以配置不同的恢复器类吗？
请参阅我的配置：
@Bean
public SimpleRabbitLis
浏览 2提问于2017-03-28得票数 1
回答已采纳
我使用@RabbitListner注解从RabbitMq队列接收消息。如何让线程接收消息的频率不超过1秒？ @RabbitListener(queues = "message", priority = "3",concurrency = "2")
public void receiveCheck(RequestMessage message){
}
浏览 55提问于2020-12-12得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
