高并发场景下用户购票数量的优化限制方案

在查询节目详情的getDetail方法和getDetailV2方法中都执行了预先加载用户节目订单数量的操作

preloadAccountOrderCount(programVo.getId());

private void preloadAccountOrderCount(Long programId){
    //获取userId
    String userId = BaseParameterHolder.getParameter(USER_ID);
    //平台code
    String code = BaseParameterHolder.getParameter(CODE);
    if (StringUtil.isEmpty(userId) || StringUtil.isEmpty(code)) {
        return;
    }
    //获取用户登录状态
    Boolean userLogin =
            redisCache.hasKey(RedisKeyBuild.createRedisKey(RedisKeyManage.USER_LOGIN, code, userId));
    //如果不是登录状态，则直接返回
    if (!userLogin) {
        return;
    }
    //异步执行
    BusinessThreadPool.execute(() -> {
        try {
            //如果redis中不存在，则调用订单服务
            if (!redisCache.hasKey(RedisKeyBuild.createRedisKey(RedisKeyManage.ACCOUNT_ORDER_COUNT,userId,programId))) {
                AccountOrderCountDto accountOrderCountDto = new AccountOrderCountDto();
                accountOrderCountDto.setUserId(Long.parseLong(userId));
                accountOrderCountDto.setProgramId(programId);
                ApiResponse<AccountOrderCountVo> apiResponse = orderClient.accountOrderCount(accountOrderCountDto);
                if (Objects.equals(apiResponse.getCode(), BaseCode.SUCCESS.getCode())) {
                    //调用订单服务成功，则将数据放入到redis中
                    Optional.ofNullable(apiResponse.getData())
                            .ifPresent(accountOrderCountVo -> redisCache.set(
                                    RedisKeyBuild.createRedisKey(RedisKeyManage.ACCOUNT_ORDER_COUNT,userId,programId),
                                    accountOrderCountVo.getCount(), tokenExpireManager.getTokenExpireTime() + 1,
                                    TimeUnit.MINUTES));
                }else {
                    log.warn("orderClient.accountOrderCount 调用失败 apiResponse : {}",JSON.toJSONString(apiResponse));
                }
            }
        }catch (Exception e) {
            log.error("预热加载账户订单数量失败",e);
        }
    });
}

• 首先获取从gateway网关传过来的userId和code
• 异步执行更新逻辑
• 用户必须是登录中的状态
• 如果redis中不能存在，则调用订单服务数据
• 然后将数据更新到缓存中

调用订单服务统计

@ApiOperation(value = "账户下某个节目的订单数量(不提供给前端调用，只允许内部program服务调用)")
@PostMapping(value = "/account/order/count")
public ApiResponse<AccountOrderCountVo> accountOrderCount(@Valid @RequestBody AccountOrderCountDto accountOrderCountDto) {
    return ApiResponse.ok(orderService.accountOrderCount(accountOrderCountDto));
}

public AccountOrderCountVo accountOrderCount(AccountOrderCountDto accountOrderCountDto) {
    AccountOrderCountVo accountOrderCountVo = new AccountOrderCountVo();
    //通过userId和programId查询出订单数量
    accountOrderCountVo.setCount(orderMapper.accountOrderCount(accountOrderCountDto.getUserId(),
            accountOrderCountDto.getProgramId()));
    return accountOrderCountVo;
}

<mapper namespace="com.damai.mapper.OrderMapper">
    <select id="accountOrderCount" resultType="java.lang.Integer">
        select
            count(*)
        from d_order
        where ( order_status = 1 or order_status = 3)
        and user_id = #{userId,jdbcType=BIGINT}
        and program_id = #{programId,jdbcType=BIGINT}
    </select>
</mapper>

根据userId和programId从订单表中查询出数量，注意 订单表中的user_id和program_id这两个字段一定要建立好索引

在订单服务中查询好结果后，就可以返回给节目服务了