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处理用户的订单消息。然后就出现了刷屏，网上找了一些方法，都没法解决。研究了一段时间，解决了。下面是我的解决办法：

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

 解决办法. 修改两个地方的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：

解决方法：

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

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

修改之前：

 修改后：