关于事务中更新后不生效问题

Pumaly

我们在做一个抽奖系统中，每个用户只有一次抽奖机会，由于采用多实例部署，所以要对每次抽奖操作加锁，且判断用户是否有抽奖机会。在用户并发大的时候会出现用户进行了两次抽奖。并且间隔时间都有几分钟。具体代码如下:
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
public synchronized LotteryGift[] doLotteryGift(Wechat wechat, String ip) throws Exception {
  LotteryGift gift0 = null;// 主奖
  LotteryRecord lotteryRecord0 = null;
  LotteryGift gift1 = null;// 副奖2
  LotteryRecord lotteryRecord1 = null;
  LotteryGift gift2 = null;// 副奖2
  LotteryRecord lotteryRecord2 = null;
  LotteryGift gift3 = null;// 主奖
  LotteryRecord lotteryRecord3 = null;
  long startTime = System.currentTimeMillis();
  // 加锁 每次只允许一个实例抽奖
  SystemParamter systemParamter = new SystemParamter();
  systemParamter.setId(1);
  systemParamter.setSysValue(String.valueOf(System.currentTimeMillis()));
  systemParamterMapper.updateByPrimaryKey(systemParamter);
  // 更新抽奖机会
  int cnt = wechatMapper.updateLotteryFinish(wechat.getWechatId());
  if( cnt <= 0)
   throw new Exception("wechatId:" + wechat.getWechatId() + " openId:"
     + wechat.getOpenId() + " updateLotteryFinish cnt:"+cnt+ "没有抽奖机会....");
  logger.error("wechatId:" + wechat.getWechatId() + " openId:" + wechat.getOpenId()
    + " updateLotteryFinish cnt:"+cnt+" start lottery....");

  ....省略具体抽奖细节

  LotteryGift[] retGift = { gift0, gift1, gift2, gift3 };
  long endTime = System.currentTimeMillis();
  logger.error("wechatId:" + wechat.getWechatId() + " openId:" + wechat.getOpenId()
    + " finish lottery,giftId:" + (gift0 == null ? "" : gift0.getGiftId())
    + " " + (gift1 == null ? "" : gift1.getGiftId()) + " "
    + (gift2 == null ? "" : gift2.getGiftId()) + " "
    + (gift3 == null ? "" : gift3.getGiftId()) + " use Time:"+(endTime-startTime));
  return retGift;
}

Pumaly

采用spring+mybatis，日志显示，在两次wechatMapper.updateLotteryFinish的返回都是1，可以确定用户的抽奖次数为1，SQL代码如下：
  <!--用户抽奖次数减少 -->
  <update id="updateLotteryFinish" parameterType="int">
        update fd_wechat set remain_time = remain_time-1,finish_time=finish_time+1
        where wechat_id = #{wechatId,jdbcType=INTEGER} and remain_time > 0;
  </update>

所以怀疑第一次update根本没有成功。但是日志显示第一次整个方法完整的执行完成，没有异常也没有回滚。

Pumaly

这究竟是个什么鬼呢，有哪位大拿可以帮忙分析一下。

Pumaly

发现一个问题，在update前面加一个select似乎可以解决

kider

Pumaly 发表于 2016-1-15 08:39
发现一个问题，在update前面加一个select似乎可以解决