zoukankan      html  css  js  c++  java
  • 记录一次,事务遇到消息发送,疏忽给自己挖坑

    场景:一个异步重算功能(任务新建后发送消息到RocketMq),每次重算单条记录的时候,可以计算正确,但是当多条记录批量重算时,结果总是莫名其妙的不对。排查了很久,终于找到原因

    原因:在新建重算任务方法上添加了事务注解,而发送消息也在该方法中,导致事务未提交,消息已经发出去了。

    源代码:

        @Transactional
        public void updateGiftCostByTradeList(ShopShard shopShard, List<Trade> tradeList) {
            Preconditions.checkArgument(null != shopShard && !CollectionUtils.isEmpty(tradeList));
    
            for (Trade trade : tradeList) {
                if (TradeSpecialTypeEnum.getSpecialTypes().contains(trade.getTradeSpecialType())) {
                    continue;
                }
                long giftCost = getGiftCostFromZhanggui(shopShard.getShopId(), trade);
                giftCost = giftCost > 0 ? giftCost : getGiftCostFromCaiwu(shopShard.getShopId(), trade);
    
                if ((trade.getGiftFee() == null ? 0 : trade.getGiftFee()) == giftCost) {
                    continue;
                }
                tradeService.updateTradeGiftFee(shopShard.getShopId(), trade.getId(), giftCost);
                SendMsgToMqUtil.sendTradeMsgToTradeFeeTopic(rocketMqProducer, shopShard, trade);
            }
        }

    更改后:

     @Transactional
        public void updateGiftCostByTradeList(ShopShard shopShard, List<Trade> tradeList) {
            Preconditions.checkArgument(null != shopShard && !CollectionUtils.isEmpty(tradeList));
    
            for (Trade trade : tradeList) {
                if (TradeSpecialTypeEnum.getSpecialTypes().contains(trade.getTradeSpecialType())) {
                    continue;
                }
                long giftCost = getGiftCostFromZhanggui(shopShard.getShopId(), trade);
                giftCost = giftCost > 0 ? giftCost : getGiftCostFromCaiwu(shopShard.getShopId(), trade);
    
                if ((trade.getGiftFee() == null ? 0 : trade.getGiftFee()) == giftCost) {
                    continue;
                }
                tradeService.updateTradeGiftFee(shopShard.getShopId(), trade.getId(), giftCost);
            }
        }
    
    
    private void doProcessCostRule(ShopShard shopShard, CostRule costRule) {
         commonCostRuleService.updateGiftCostByTradeList(shopShard, pageInfo.getList());
         pageInfo.getList().forEach(trade -> {
           if (!recalStatPoolCommonServcie.sendMqToRecalStatPoolByTrade(trade, TradeStatRecalSourceEnum.GIFT_COST)) {
                 log.error("process costRule trade send recalstatpool false shopId={}|trade={}", shopShard.getShopId(), JSON.toJSONString(trade));
           }
         });
    }
  • 相关阅读:
    LibreOJ 6282 数列分块入门 6(在线插入在线查询)
    LibreOJ 6281 数列分块入门 5(分块区间开方区间求和)
    LibreOJ 6280 数列分块入门 4(分块区间加区间求和)
    LibreOJ 6279 数列分块入门 3(分块+排序)
    LibreOJ 6278 数列分块入门 2(分块)
    LibreOJ 6277 数列分块入门 1(分块)
    BZOJ 2301 Problem b(莫比乌斯反演+分块优化)
    MD5Untils加密工具类
    20160418javaweb之 Filter过滤器
    20160417javaweb之servlet监听器
  • 原文地址:https://www.cnblogs.com/JoeyWong/p/11011294.html
Copyright © 2011-2022 走看看