从 Spring AMQP Rabbit Consumer 捕获异常

问题描述

我正在尝试使用 this tutorial 创建 RPC 服务。

我想捕捉异常。目前，当 doJob 抛出异常时，生产者会收到超时异常，并且该异常未记录在服务器的控制台上。

我尝试了 container.setErrorHandler，但没有结果。 如何在生产者和消费者中捕获异常？

我是说

public String doJob(int clientId) {
    String uuid = UUID.randomUUID().toString();
    log.info("UUID {} generated on node {} upon request from client {}",uuid,nodeId,clientId);
    return uuid;
}

可以返回异常。我怎样才能在这部分抓住它们：

        String payload = proxy.doJob(clientId);
        log.info("Client {} received payload: {}",clientId,payload);
        Thread.sleep(2000);

解决方法

您正在使用具有异步消息传递的请求/响应模式。因此，生产者和消费者在逻辑上是分开的。这种分离是明确的，因为它有很多好处。这是异步消息传递的基本原则。

从消费者抛出的异常不会通过消息代理传播回发送消息的生产者。这将破坏客户端的逻辑分离。

生产者的超时异常表明消费者出了问题，导致它无法返回响应。由于生产者和消费者的逻辑分离，生产者永远不会知道为什么超时异常发生。同样，这是设计使然。