百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

在B端业务中由于重复点或并发造成的重复数据处理思路

wptr33 2025-04-09 21:25 15 浏览

需求背景:

入库单号:L-ASN2025022xxxxx

入库批次号:100025022800151

数量:500

理货后,生成了一个500的已理货数据,上架后,生成了两个500已上架数据,重复了



后台查看数据创建时间也一样,仓库操作人员由于网络或者其他问题出现重复点击或者在多人操作同一单据情况下出现的并发问题

这种情况下仅仅针对接口加分布式锁解决不了实际问题,需要针对请求url,参数进行加锁才可以完全解决

以php项目为例 php-laravel框架

1,通过url+请求参数进行加锁处理 可以组织90%以上的重复点击带来的重复数据的问题

PreventDupSubmit.php

all();
        $requestParams["adminId"] = getAdminUserId();
        $requestParams["uri"] = $request->getUri();
        if(isset($requestParams["file"])){
            unset($requestParams["file"]);
        }
        \Log::info(sprintf("并发请求url:%s,请求参数:%s",$request->getUri(),json_encode($requestParams)));
        ksort($requestParams);
        $key = md5(serialize($requestParams));

        $getLock = WmsLockService::getLock($key,8);
//        $request->offsetSet("request_md5_key",$key);


        if(!$getLock){
            return response()->json(json_decode(Response::setError("请勿重复请求,请5秒后再发起请求"), true));
        }

//        $result = Redis::Connection("wms")->set('wms_' . $key, 1,"EX",5,"NX");
//        if(!$result){
//            throw new InvalidRequestException("请勿重复请求,请5秒后再发起请求");
//        }
        $response = $next($request);
        WmsLockService::delLock($key);
//        Redis::Connection("wms")->del('wms_' . $key);
        return $response;
    }
}
WmsLockService.php
<?php

namespace App\Http\Services;

use Illuminate\Support\Facades\Redis;

class WmsLockService
{
    const LOCK_KEY = "wms_lock_";

    public static function getLock($Key="",$time=15){
        $requestId = uniqid(); // 生成一个唯一的请求ID
        $expireTime = 1000 * intval($time); // 锁的过期时间,单位毫秒

        // Lua脚本
        $luaScript = <<eval($luaScript, 1, $lockKey, $requestId, $expireTime);
        return $result;
    }



    public static function delLock($lockKey=""){
        Redis::Connection("wms")->del(self::LOCK_KEY.$lockKey);
    }

}

路由

 Route::match(['get', 'post'], '/stockIn/stockShelf/oneKeyPutawayAction', 'StockShelfController@oneKeyPutawayAction')->middleware('prevent_dup_submit')

中间件


2,假如业务中出现非重复点击,或者由于事务中处理比较慢(请求上架或者理货 请求参数类似于[1,3,5] [1,3,8,9]),两次请求中都有请求参数id:1,3 会造成1和3的并发问题。

处理方法就是针对具体请求的函数对单个参数进行加锁 当上架id:[1,3,5]请求的时候可以让1,3,5分别进行加锁,下一个1,3,8,9来请求的时候就会因为拿不到锁而报错


RedisLock
systemName = $systemName;
        $this->functionName = $functionName;
    }

    public static function initInstance($systemName, $functionName)
    {
        return new self($systemName, $functionName);
    }

    public function lock($key, $ttl = null)
    {
        $redis = Redis::connection();
        $randNum = mt_rand(10000000, 99999999);
        $ttl = $ttl ?? self::TTL;
        $redisKey = self::KEY_PREFIX . ":{$this->systemName}:{$this->functionName}:{$key}";
        $result = $redis->setNx($redisKey, $randNum);
        if ($result) {
            $redis->expire($redisKey, $ttl);
            $this->randNumMap[$key] = $randNum;
            return $randNum;
        } else {
            return null;
        }
    }

    public function unlock($key, $randNum)
    {
        $redis = Redis::connection();
        $redisKey = self::KEY_PREFIX . ":{$this->systemName}:{$this->functionName}:{$key}";
        $lua = <<eval($lua, 1, $redisKey, $randNum);
        return $result;
    }

    public function lockFunction($key, callable $callback,callable $failCallback = null)
    {
        $random = $this->lock($key);
        if ($random !== null) {
            $result = call_user_func($callback);
            $delResult = $this->unlock($key, $random);
            if ($delResult==0){
                if ($failCallback){
                    call_user_func($failCallback);
                }
            }
            return $result;
        } else {
            return false;
        }
    }

    public function lockBatchKey($keyArr, $ttl = null)
    {
        $lockResult = [];
        foreach ($keyArr as $key) {
            $result = $this->lock($key, $ttl);
            if ($result) {
                $lockResult[$key] = $result;
            } else {
                $lockResult[$key] = 0;
            }
        }
        return $lockResult;
    }

    public function unlockBatchKey($resultArr)
    {
        $unlockResult = [];
        foreach ($resultArr as $key => $random) {
            $random = $this->randNumMap[$key] ?? $random;
            $result = $this->unlock($key, $random);
            if ($result) {
                $unlockResult[$key] = true;
            } else {
                $unlockResult[$key] = false;
            }
        }
        return $unlockResult;
    }
}

在开发过程中刚开始使用的是上述第一种方法,但是偶尔3-6个月会出现一次重复数据,目前没有找到具体原因,所以后来又采用第二种更加细粒度的加锁方式,对请求的具体参数进行加锁,希望能帮到大家解决开发过程中遇到类似的问题提供解决思路

相关推荐

SpringBoot 3 + Flutter3 实战低代码运营管理-10章

获课》aixuetang.xyz/5075/三天构建运营管理系统:SpringBoot3+Flutter3高效开发方法论...

SpringBoot探针实现:从零构建应用健康监控利器

SpringBoot探针实现:从零构建应用健康监控利器声明本文中的所有案例代码、配置仅供参考,如需使用请严格做好相关测试及评估,对于因参照本文内容进行操作而导致的任何直接或间接损失,作者概不负责。本文...

Spring Batch中的JobRepository:批处理的“记忆大师”是如何工作

一、JobRepository是谁?——批处理的“档案馆”JobRepository是SpringBatch的“记忆中枢”,负责记录所有Job和Step的执行状态。它像一位严谨的档案管理员,把任务执...

Github霸榜的SpringBoot全套学习教程,从入门到实战,内容超详细

前言...

还在为 Spring Boot3 技术整合发愁?一文解锁大厂都在用的实用方案

你在使用SpringBoot3开发后端项目时,是不是常常陷入这样的困境?想提升项目性能和功能,却不知道该整合哪些技术;好不容易选定技术,又在配置和使用上频频踩坑。其实,这是很多互联网大厂后端开发...

一文吃透!Spring Boot 项目请求日志记录,这几招你绝对不能错过!

在互联网应用开发的高速赛道上,系统的稳定性、可维护性以及安全性是每一位开发者都必须关注的核心要素。而请求日志记录,就如同系统的“黑匣子”,能够为我们提供排查故障、分析用户行为、优化系统性能等关键信息...

spring-boot-starter-actuator简单介绍

SpringBootActuator是SpringBoot的一个功能强大的子项目,它提供了一些有用的监控和管理SpringBoot应用程序的端点。SpringBootActuat...

使用SpringBoot钩子或Actuator实现优雅停机

服务如何响应停机信号在java中我们可以直接利用通过Runtime...

28-自定义Spring Boot Actuator指标

上篇我们学习了《27-自定义SpringBootActuator健康指示器》,本篇我们学习自定义SpringBootActuator指标(Metric)。...

如何在Spring Boot中整合Spring Boot Actuator进行服务应用监控?

监控是确保系统稳定性和性能的关键组成部分,而在SpringBoot中就提供了默认的应用监控方案SpringBootActuator,通过SpringBootActuator提供了开箱即用的应...

「Spring Boot」 Actuator Endpoint

Actuator官网地址:https://docs.spring.io/spring-boot/docs/2.5.6/reference/html/actuator.html目的监控并管理应用程序...

Spring Boot Actuator监控功能全面剖析

SpringBootActuator监控功能全面剖析在现代企业级Java开发中,SpringBoot以其轻量化、高效率的特性深受开发者青睐。而作为SpringBoot生态系统的重要组成部分,S...

1000字彻底搞懂SpringBootActuator组件!

SpringBootActuator组件SpringBootActuator通过HTTPendpoints或者JMX来管理和监控SpringBoot应用,如服务的审计、健康检查、指标统计和...

JavaScript数据类型(javascript数据类型介绍)

基本数据类型BooleanNullNumberStringSymbolUndefined对象数据类型ObjectArray定义:JavaScript数组是内置的对象之一,它可以用一个变量来存储多个同种...

能运行,不代表它是对的:5 个潜伏在正常功能下的 JavaScript 错误

JavaScript的动态性和复杂性意味着,代码虽然表面上正常运行,但一些深层次、隐蔽的陷阱往往让人意想不到,梳理了几个JavaScript开发中难以发现的隐蔽错误,旨在帮助我们写出更健壮、更可...