RabbitMQ常见异常处理（踩了一路坑）

时间  2021-08-14
标签 java spring bash markdown oop 学习 spa code component orm 栏目 RabbitMQ 繁體版
原文   原文链接

异常一：方法不匹配异常

Listener method 'no match' threw exception刷屏java

2020-03-26 11:00:07.747 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#1-1] WARN org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler.log(117) - Execution of Rabbit message listener failed.
org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener method 'no match' threw exception
	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:204)
	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:129)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1542)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1468)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1456)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1451)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1400)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:870)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:854)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$1600(SimpleMessageListenerContainer.java:78)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.mainLoop(SimpleMessageListenerContainer.java:1137)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1043)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.springframework.amqp.AmqpException: No method found for class [B
	at org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler.getHandlerForPayload(DelegatingInvocableHandler.java:149)
	at org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler.invoke(DelegatingInvocableHandler.java:129)
	at org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:61)
	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:196)
	... 12 common frames omitted
复制代码

先上个人代码：spring

@Slf4j
@Component
@RabbitListener(queues = "mall.order.cancel")
public class CancelOrderReceiver {

    @Autowired
    private OmsPortalOrderService portalOrderService;

    @Resource
    private CancelOrderSender cancelOrderSender;

    @RabbitHandler
    public void handler(Long orderId){
        try {
            log.info("process orderId:{}", orderId);
            portalOrderService.cancelOrder(orderId);
        } catch (Exception e) {
            log.error(ExceptionUtils.getStackTrace(e));
            // 异常处理
            cancelOrderSender.sendFailedMessage(orderId);
        }
    }
}
复制代码

为何会出现方法未匹配呢？缘由在@RabbitListener身上，当此注解放到类上时，会根据数据类型去匹配@RabbitHandler注解的方法，个人handler方法入参是Long类型，若是传入的是String类型就会报Listener method 'no match' threw exception了，找到了问题（RabbitMQ的requeue机制），下面给出解决方法：bash

解决方法1：

再增长一个handler(String orderId)方法，不管传入的是Long型仍是String型都会获得处理，这种方式比较笨，不推荐使用markdown

解决方法2（推荐）：

将@RabbitListener注解放到方法上，以下代码：oop

@Slf4j
@Component
public class CancelOrderReceiver {

    @Autowired
    private OmsPortalOrderService portalOrderService;

    @Resource
    private CancelOrderSender cancelOrderSender;

    @RabbitHandler
    @RabbitListener(queues = "mall.order.cancel")
    public void handler(Long orderId){
        try {
            log.info("process orderId:{}", orderId);
            portalOrderService.cancelOrder(orderId);
        } catch (Exception e) {
            log.error(ExceptionUtils.getStackTrace(e));
            // 异常处理
            cancelOrderSender.sendFailedMessage(orderId);
        }
    }
}
复制代码

这样不管你传入的数据类型是什么，都会进入此方法，不用担忧刷屏了。固然若是传入的类型不匹配，也会报错的。因此要与消费发送者约束好数据类型是很是有必要的。学习

解决方法3：

将rabbitmq的“requeue”配置为false。这种方式简单粗暴，但异常很差捕获，后续的异常处理难进行spa

异常二：监听方法内异常

Listener method '***' threw exception刷屏code

2020-03-26 11:46:22.789 [org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-1] WARN org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler.log(117) - Execution of Rabbit message listener failed.
org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener method 'public void com.macro.mall.portal.component.CancelOrderReceiver.handler(java.lang.Long)' threw exception
	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:204)
	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:129)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1542)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1468)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1456)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1451)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1400)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:870)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:854)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$1600(SimpleMessageListenerContainer.java:78)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.mainLoop(SimpleMessageListenerContainer.java:1137)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1043)
	at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.NumberFormatException: For input string: "嘿嘿嘿"
	at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
	at java.lang.Integer.parseInt(Integer.java:580)
	at java.lang.Integer.parseInt(Integer.java:615)
	at com.macro.mall.portal.component.CancelOrderReceiver.handler(CancelOrderReceiver.java:31)
	at sun.reflect.GeneratedMethodAccessor122.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171)
	at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120)
	at org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:50)
	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:196)
	... 12 common frames omitted
复制代码

看个人代码：component

@RabbitHandler
    @RabbitListener(queues = "mall.order.cancel")
    public void handler(Long orderId){
        Integer.parseInt("嘿嘿嘿"); // 演示异常使用
        try {
            log.info("process orderId:{}", orderId);
            portalOrderService.cancelOrder(orderId);
        } catch (Exception e) {
            log.error(ExceptionUtils.getStackTrace(e));
            // 异常处理
            cancelOrderSender.sendFailedMessage(orderId);
        }
    }
复制代码

很明显Integer.parseInt("嘿嘿嘿")会报错，致使异常刷屏orm

解决方法：

将监听方法内的全部代码用try...cache包裹，并在cache中增长异常处理，以下代码：

@RabbitHandler
    @RabbitListener(queues = "mall.order.cancel")
    public void handler(Long orderId){
        try {
            Integer.parseInt("嘿嘿嘿"); // 演示异常使用
            log.info("process orderId:{}", orderId);
            portalOrderService.cancelOrder(orderId);
        } catch (Exception e) {
            log.error(ExceptionUtils.getStackTrace(e));
            // 异常处理
            cancelOrderSender.sendFailedMessage(orderId);
        }
    }
复制代码

先写这么多吧，后续遇到问题会继续更新，若是有好的方案欢迎给我留言，共同窗习共同进步

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程