并发幂等性防抖

并发幂等性防抖提交数据,以极快的速度点多次,相同的数据,在并发的情况,如果不做处理那么就会产生多次操作或者记录,或者主键重复报错。为了解决这个问题,先是做了前端防抖,但是前端并不保险,能绕过或者说是网络不好的情况,后端也是需要做防抖的处理:1、做切面环绕、上锁、幂等函数2、注解使用…

并发幂等性防抖

提交数据,以极快的速度点多次,相同的数据,在并发的情况,如果不做处理那么就会产生多次操作或者记录,或者主键重复报错。

为了解决这个问题,先是做了前端防抖,但是前端并不保险,能绕过或者说是网络不好的情况,

后端也是需要做防抖的处理:

1、做切面环绕、上锁、幂等函数

@Slf4j
@Aspect
@Component
public class NoRepeatSubmitAop {
 

    @Autowired
    private RedisService redisService;

//                         com.hieasy.icrm.project.weixin.controller.wxma.miniapp
    @Synchronized
    @Around("execution(* com.hieasy.icrm.project.weixin.controller.*.*.*Ctrl.*(..)) && @annotation(nrs)")
    public Object arround(ProceedingJoinPoint pjp, NoRepeatSubmit nrs) throws Throwable {
            ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
            HttpServletRequest request = attributes.getRequest();
            String token=request.getHeader("token");
            if(MyStrUtils.isEmpty(token)) return pjp.proceed();
            String key = token+ "-" + request.getServletPath();
//            log.info("开始请求:{}",key);
            if ( !redisService.haskey(key) ) {// 如果缓存中有这个url视为重复提交
                Object o = pjp.proceed();
                redisService.setCacheObject(key, 0, 10, TimeUnit.SECONDS);
//                log.info("正常提交:{},{}",key, MyDateUtil.getNowDateTime());
                return o;
            } else {
                redisService.setCacheObject(key, 0, 10, TimeUnit.SECONDS);//点了同样的URL继续限制,直到2次点击中间间隔超过了限制
                //return R.error(-889,"请勿重复提交或者操作过于频繁!");
//                log.info("限制提交:{},{}",key, MyDateUtil.getNowDateTime());
                throw new BusinessException("请勿重复提交或者操作过于频繁!(间隔10秒,每次点击重新计算)");
            }
    }
 
}

2、注解使用

    @Target(ElementType.METHOD) // 作用到方法上
    @Retention(RetentionPolicy.RUNTIME) // 运行时有效
    public @interface NoRepeatSubmit {
        String name() default "name:";
    }


    @NoRepeatSubmit
    @PostMapping("/goods/save")
    @ApiOperation(value = "商城商品-保存", notes = "此功能新增、修改均可,单处理,多条处理也都可以")
    @ApiOperationSupport(includeParameters = {})
    public JsonResult save(@RequestBody List<CrmWxMallGoods> list) throws Exception {
        Long tenantId=getPresentTenantId();
        int rows=0;
        QueryWrapper wrapper;
        CrmWxMallGoods item;
        for(CrmWxMallGoods goods:list){
            goods.setTenantId(tenantId);
            wrapper=new QueryWrapper();
            wrapper.eq("tenant_id", tenantId);
            wrapper.eq("item_code", goods.getItemCode());
            item= crmWxMallGoodsService.getOne(wrapper);
            if(null!=item){
                goods.setId(item.getId());
                rows+=crmWxMallGoodsService.updateById(goods)?1:0;
            }else{
                rows+=crmWxMallGoodsService.save(goods)?1:0;
            }
        }
        return toJRAjax(rows);
    }

 

今天的文章并发幂等性防抖分享到此就结束了,感谢您的阅读,如果确实帮到您,您可以动动手指转发给其他人。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/24766.html

(0)
编程小号编程小号

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注