如何解决从 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);
解决方法
您正在使用具有异步消息传递的请求/响应模式。因此,生产者和消费者在逻辑上是分开的。这种分离是明确的,因为它有很多好处。这是异步消息传递的基本原则。
从消费者抛出的异常不会通过消息代理传播回发送消息的生产者。这将破坏客户端的逻辑分离。
生产者的超时异常表明消费者出了问题,导致它无法返回响应。由于生产者和消费者的逻辑分离,生产者永远不会知道为什么超时异常发生。同样,这是设计使然。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。