gpt4 book ai didi

spring-mvc - spring 中 rabbitmq 监听器的异常处理

转载 作者:行者123 更新时间:2023-12-03 17:39:25 30 4
gpt4 key购买 nike

使用 spring,我是 rabbitmq 的新手,我想知道我哪里错了。

我已经编写了一个 rabbitmq 连接工厂和一个包含监听器的监听器容器。我还为监听器容器提供了错误处理程序,但它似乎不起作用。

我的 Spring Bean :

<rabbit:connection-factory id="RabbitMQConnectionFactory" virtual-host="${rabbitmq.vhost}" host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}" password="${rabbitmq.password}"/>
<rabbit:listener-container missing-queues-fatal="false" declaration-retries="0" error-handler="errorHandlinginRabbitMQ" recovery-interval="10000" auto-startup="${rabbitmq.apc.autostartup}" max-concurrency="1" prefetch="1" concurrency="1" connection-factory="RabbitMQConnectionFactory" acknowledge="manual">
<rabbit:listener ref="apcRabbitMQListener" queue-names="${queue.tpg.rabbitmq.destination.apc}" exclusive="true" />
</rabbit:listener-container>
<bean id="errorHandlinginRabbitMQ" class="RabbitMQErrorHandler"/>

这是我的 RabbitMQErrorHandler 类:

public class RabbitMQErrorHandler implements ErrorHandler
{
@Override
public void handleError(final Throwable exception)
{
System.out.println("error occurred in message listener and handled in error handler" + exception.toString());
}
}

我假设的是,如果我向连接工厂提供无效凭据,则 RabbitMQErrorHandler 类的 handleError 方法应该执行,并且服务器应该正常启动,但是,当我尝试运行服务器时,该方法不会执行(控制台中抛出异常)并且服务器无法启动。我在哪里遗漏了什么?

最佳答案

错误处理程序用于处理消息传递过程中的错误;由于您尚未连接,因此没有要处理错误的消息。

要获得连接异常,你应该实现ApplicationListener<ListenerContainerConsumerFailedEvent>如果您将失败作为一个 bean 添加到应用程序上下文中,您将收到失败作为事件。

如果您实现 ApplicationListener<AmqpEvent>,您将获得其他事件(消费者启动、消费者停止等) .

编辑

<rabbit:listener-container auto-startup="false">
<rabbit:listener id="fooContainer" ref="foo" method="handleMessage"
queue-names="si.test.queue" />
</rabbit:listener-container>

<bean id="foo" class="com.example.Foo" />

富:

public class Foo {

public final CountDownLatch latch = new CountDownLatch(1);

public void handleMessage(String foo) {
System.out.println(foo);
this.latch.countDown();
}

}

应用:

@SpringBootApplication
@ImportResource("context.xml")
public class So43208940Application implements CommandLineRunner {

public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(So43208940Application.class, args);
context.close();
}

@Autowired
private SimpleMessageListenerContainer fooContainer;

@Autowired
private CachingConnectionFactory connectionFactory;

@Autowired
private RabbitTemplate template;

@Autowired
private Foo foo;

@Override
public void run(String... args) throws Exception {
this.connectionFactory.setUsername("junk");
try {
this.fooContainer.start();
}
catch (Exception e) {
e.printStackTrace();
}
Thread.sleep(5000);
this.connectionFactory.setUsername("guest");
this.fooContainer.start();
System.out.println("Container started");
this.template.convertAndSend("si.test.queue", "foo");
foo.latch.await(10, TimeUnit.SECONDS);
}

}

关于spring-mvc - spring 中 rabbitmq 监听器的异常处理,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43208940/

30 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com