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

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

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

需求背景:

入库单号: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个月会出现一次重复数据,目前没有找到具体原因,所以后来又采用第二种更加细粒度的加锁方式,对请求的具体参数进行加锁,希望能帮到大家解决开发过程中遇到类似的问题提供解决思路

相关推荐

Python自动化脚本应用与示例(python办公自动化脚本)

Python是编写自动化脚本的绝佳选择,因其语法简洁、库丰富且跨平台兼容性强。以下是Python自动化脚本的常见应用场景及示例,帮助你快速上手:一、常见自动化场景文件与目录操作...

Python文件操作常用库高级应用教程

本文是在前面《Python文件操作常用库使用教程》的基础上,进一步学习Python文件操作库的高级应用。一、高级文件系统监控1.1watchdog库-实时文件系统监控安装与基本使用:...

Python办公自动化系列篇之六:文件系统与操作系统任务

作为高效办公自动化领域的主流编程语言,Python凭借其优雅的语法结构、完善的技术生态及成熟的第三方工具库集合,已成为企业数字化转型过程中提升运营效率的理想选择。该语言在结构化数据处理、自动化文档生成...

14《Python 办公自动化教程》os 模块操作文件与文件夹

在日常工作中,我们经常会和文件、文件夹打交道,比如将服务器上指定目录下文件进行归档,或将爬虫爬取的数据根据时间创建对应的文件夹/文件,如果这些还依靠手动来进行操作,无疑是费时费力的,这时候Pyt...

python中os模块详解(python os.path模块)

os模块是Python标准库中的一个模块,它提供了与操作系统交互的方法。使用os模块可以方便地执行许多常见的系统任务,如文件和目录操作、进程管理、环境变量管理等。下面是os模块中一些常用的函数和方法:...

21-Python-文件操作(python文件的操作步骤)

在Python中,文件操作是非常重要的一部分,它允许我们读取、写入和修改文件。下面将详细讲解Python文件操作的各个方面,并给出相应的示例。1-打开文件...

轻松玩转Python文件操作:移动、删除

哈喽,大家好,我是木头左!Python文件操作基础在处理计算机文件时,经常需要执行如移动和删除等基本操作。Python提供了一些内置的库来帮助完成这些任务,其中最常用的就是os模块和shutil模块。...

Python 初学者练习:删除文件和文件夹

在本教程中,你将学习如何在Python中删除文件和文件夹。使用os.remove()函数删除文件...

引人遐想,用 Python 获取你想要的“某个人”摄像头照片

仅用来学习,希望给你们有提供到学习上的作用。1.安装库需要安装python3.5以上版本,在官网下载即可。然后安装库opencv-python,安装方式为打开终端输入命令行。...

Python如何使用临时文件和目录(python目录下文件)

在某些项目中,有时候会有大量的临时数据,比如各种日志,这时候我们要做数据分析,并把最后的结果储存起来,这些大量的临时数据如果常驻内存,将消耗大量内存资源,我们可以使用临时文件,存储这些临时数据。使用标...

Linux 下海量文件删除方法效率对比,最慢的竟然是 rm

Linux下海量文件删除方法效率对比,本次参赛选手一共6位,分别是:rm、find、findwithdelete、rsync、Python、Perl.首先建立50万个文件$testfor...

Python 开发工程师必会的 5 个系统命令操作库

当我们需要编写自动化脚本、部署工具、监控程序时,熟练操作系统命令几乎是必备技能。今天就来聊聊我在实际项目中高频使用的5个系统命令操作库,这些可都是能让你效率翻倍的"瑞士军刀"。一...

Python常用文件操作库使用详解(python文件操作选项)

Python生态系统提供了丰富的文件操作库,可以处理各种复杂的文件操作需求。本教程将介绍Python中最常用的文件操作库及其实际应用。一、标准库核心模块1.1os模块-操作系统接口主要功能...

11. 文件与IO操作(文件io和网络io)

本章深入探讨Go语言文件处理与IO操作的核心技术,结合高性能实践与安全规范,提供企业级解决方案。11.1文件读写11.1.1基础操作...

Python os模块的20个应用实例(python中 import os模块用法)

在Python中,...