从 Spring AMQP Rabbit Consumer 捕获异常

Question

我正在尝试使用 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;
}

可以return例外。我怎样才能在这部分抓住他们：

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

Answer 1

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

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

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

从 Spring AMQP Rabbit Consumer 捕获异常

Catching exceptions from Spring AMQP Rabbit Consumer

java

spring-rabbit

spring-amqp