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;
????}
????//判斷是否已經(jīng)秒殺到了
????MiaoshaOrder?order?=?orderService.getMiaoshaOrderByUserIdGoodsId(user.getId(),?goodsId);
????if?(order?!=?null)?{
????????return;
????}
????miaoshaService.miaosha(user,?goods);?//這是一個(gè)事務(wù)?事務(wù)的失敗導(dǎo)致生產(chǎn)者不停發(fā)送這條消息
}
添加回答
舉報(bào)
0/150
提交
取消