ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏

这篇具有很好参考价值的文章主要介绍了ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

org.springframework.amqp.rabbit.support.ListenerExecutionFailedException: Listener method 'public void hospital.receiver.HospitalReceiver.receiver(hospital.vo.order.OrderMqVo,org.springframework.amqp.core.Message,com.rabbitmq.client.Ch

错误类型:org.springframework.amqp.rabbit.support.ListenerExecutionFailedException

annel) throws java.io.IOException' threw exception

在做一个尚医通项目时,需要用rabbitMQ处理用户的订单消息。然后就出现了刷屏,网上找了一些方法,都没法解决。研究了一段时间,解决了。下面是我的解决办法:

首先我的错误出现的原因是消息接受器无法处理队列中的消息,导致队列中消息无法被消费,接收器又一直去消费,陷入了死循环,导致了刷屏。

ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏,java-rabbitmq,rabbitmq,java

 解决办法. 修改两个地方的BUG

1.HospitalReceiver 中的receiver方法

//错误代码
Schedule schedule = scheduleService.getScheduleId(orderMqVo.getScheduleId());
产生原因: .getScheduleId 
课件上两次更新操作用的同一个方法根据scheduleId查,但是预约下单更新里的scheduleId是前端传过来的值,那个对应mongodb里的字段是_id;取消预约更新里的scheduleId是我们根据mysql查询科室查出来的排班id,对应mongodb里的字段是hosScheduleId;那都1用repository.findById(id).get();后者就会查不到数据,而Optionl没有经过ofNullable()就获取对象,如果对象为空的就会报错。
mq为什么循环报错这个有解释:

https//blog.csdn.net/lCSDNkingdoml/article/details/120425567:

ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏,java-rabbitmq,rabbitmq,java

解决方法:

1.HospitalReceiver 中的receiver方法

//订单消费者!
@RabbitListener(bindings = @QueueBinding(
        value = @Queue(value = MqConst.QUEUE_ORDER, durable = "true"),
        exchange = @Exchange(value = MqConst.EXCHANGE_DIRECT_ORDER),
        key = {MqConst.ROUTING_ORDER}
))
public void receiver(OrderMqVo orderMqVo, Message message, Channel channel) throws IOException {
    // 如果orderMqVo 为空则,不进行任何操作
    if(orderMqVo == null){
        return;
    }
    if(null != orderMqVo.getAvailableNumber()) {
        //下单成功更新预约数
        Schedule schedule = scheduleService.getScheduleReceiver(orderMqVo.getScheduleId());
        schedule.setReservedNumber(orderMqVo.getReservedNumber());
        schedule.setAvailableNumber(orderMqVo.getAvailableNumber());
        scheduleService.updateSchedule(schedule);

        //预约成功发送预约成功的短信通知
        MsmVo msmVo = orderMqVo.getMsmVo();
        if(null != msmVo) {
            //短信消息生成者! 生成短信信息到消息队列
            rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_MSM, MqConst.ROUTING_MSM_ITEM, msmVo);
        }

    } else {
        //取消预约更新预约数
        Schedule schedule = scheduleService.getScheduleReceiver(orderMqVo.getScheduleId());
        int availableNumber = schedule.getAvailableNumber().intValue() + 1;
        schedule.setAvailableNumber(availableNumber);
        scheduleService.updateSchedule(schedule);
        //取消预约可以做专门发送取消预约的短信通知,这里就不做了!
    }
}

1.2. 添加OrderServiceImple

// 根据排班的 hosScheduleId ,获取排班的详情
@Override
    public Schedule getScheduleReceiver(String hosScheduleId) {
        //会导致 取消预约更新预约数MQ刷屏报错
        Schedule schedule = scheduleRepository.getScheduleByHosScheduleId(hosScheduleId);
        return this.packageSchedule(schedule);
    } 

1.3 最后在 rabbitMq管理web界面,清空队列    Web管理界面 http://虚拟机IP:15672/# 账号密码都是 guest

ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏,java-rabbitmq,rabbitmq,java

2. 修改OrderServiceImpl类中public Long saveOrder(String scheduleId, Long patientId) 生成挂号订单 

//发送mq消息,号源更新和短信通知
//发送mq信息更新号源 错误的代码

OrderMqVo orderMqVo = new OrderMqVo();
orderMqVo.setScheduleId(scheduleId);  错误的
orderMqVo.setReservedNumber(reservedNumber);
orderMqVo.setAvailableNumber(availableNumber);

//正确的代码

OrderMqVo orderMqVo = new OrderMqVo();
orderMqVo.setScheduleId(scheduleOrderVo.getHosScheduleId());
orderMqVo.setReservedNumber(reservedNumber);
orderMqVo.setAvailableNumber(availableNumber);

错误原因:orderMqVo.setScheduleId(scheduleId); 保存的是传入的645ddd513d3a8a69f73a6a85
而我们 HospitalReceiver 中的receiver方法参数OrderMqVo的scheduleId 就是保存订单时候传入的scheduleId。而我们需要的hosScheduleId

ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏,java-rabbitmq,rabbitmq,java

修改之前:

ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏,java-rabbitmq,rabbitmq,java 修改后:

ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏,java-rabbitmq,rabbitmq,java文章来源地址https://www.toymoban.com/news/detail-687589.html

到了这里,关于ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包