为了账号安全,请及时绑定邮箱和手机立即绑定

rabbitMQ消费问题,消费者方法有一个事务,事务失败,消费者认为这个消息没有被消费掉,导致生产者重发

rabbitMQ消费问题,消费者方法有一个事务,事务失败,消费者认为这个消息没有被消费掉,导致生产者重发

噼喱啪啦 2019-03-01 20:58:58
public void sendMiaoshaMessage(MiaoshaMessage mm) {    String msg = RedisService.beanToString(mm);    log.info("send message:"+msg);    amqpTemplate.convertAndSend(MQConfig.MIAOSHA_QUEUE, msg); } @RabbitListener(queues = MQConfig.MIAOSHA_QUEUE) public void receive(String message) {     log.info("receive message:" + message);     MiaoshaMessage mm = RedisService.stringToBean(message, MiaoshaMessage.class);     MiaoshaUser user = mm.getUser();     long goodsId = mm.getGoodsId();     GoodsVo goods = goodsService.getGoodsVoByGoodsId(goodsId);     int stock = goods.getStockCount();     if (stock <= 0) {         return;     }     //判断是否已经秒杀到了     MiaoshaOrder order = orderService.getMiaoshaOrderByUserIdGoodsId(user.getId(), goodsId);     if (order != null) {         return;     }     miaoshaService.miaosha(user, goods); //这是一个事务 事务的失败导致生产者不停发送这条消息 }
查看完整描述

3 回答

?
HansonQ

TA贡献223条经验 获得超56个赞

不做日志记录么?

查看完整回答
反对 回复 2019-03-27
  • 3 回答
  • 0 关注
  • 3014 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信