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
修改之前:
修改后:文章来源:https://www.toymoban.com/news/detail-687589.html
文章来源地址https://www.toymoban.com/news/detail-687589.html
到了这里,关于ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!