【总结】实际业务场景中锁、事务、异常如何考虑使用？

文章目录

  • 锁处理
    • 目的：
    • 考虑锁控制思路：
    • 生命周期接口并发控制解决方案：
    • 测试锁是否生效：
      • 模拟多线程并发场景的2种方式：
  • 事务处理
    • 目的：
    • 考虑事务控制思路：
    • 解决方案：
  • 总结

锁处理

目的：

为了避免接口被并发访问，导致业务数据校验（是否正式已存在、是否审批中）被迫通过，导致创建多个流程单据去新增业务数据，造成正式业务数据重复；

*代表采用应用的方案。

应用分布式锁

考虑锁控制思路：

1.分析并发场景（相同应用、不同应用访问）、给出解决方案

如：客户上市接口

并发访问场景：

  1. 同一外部应用系统，同一个用户创建一个客户，连续快速点击2次（2个线程同时访问同一接口，数据已在审批中代码校验被迫通过）
    解决办法：clientID 外部应用标识

  2. 同一外部应用系统，不同用户同时创建同一个客户（2个线程同时访问同一接口，数据已在审批中代码校验被迫通过）

    解决办法：clientID 外部应用标识

  3. 不同外部应用，同时创建相同客户标识的客户（2个线程同时访问同一接口，数据已在审批中代码校验被迫通过）

    解决办法：客户唯一识别标识

2.取用最适配所有场景方案

客户上市最终方案：通过客户唯一识别标识来加锁处理（身份证号+纳税人识别号）

即能控制并发场景1、2，又能控制并发场景3

生命周期接口并发控制解决方案：

1. 客户上市接口并发控制：
方案1：（粗粒度）clientId控制同一外部应用并发访问，缺点：不能控制不同应用并发创建同一个客户时场景
方案2*：（细粒度）不同外部应用，同一个客户不能并发创建（同一个客户识别标识：身份证号 + 纳税人识别号）

2. 客户变更（基础变更、客户调整）接口并发控制：
方案1：（粗粒度）clientId控制同一外部应用并发访问，缺点：不能控制不同应用并发更新同一个客户时场景
方案2*：（细粒度）同一个客户不能并发进行基础信息变更、客户调整，缺点：牺牲了同一个客户实际场景中是可以同时进行基础变更、客户调整操作，造成的结果就是A客户变更、B客户调整，AB同时发起，线程快的会先进入方法，后进入的被锁住，失败访问，需要等待1-2s后进行访问

3. 客户扩充、冻结解冻、地址变更接口并发控制：
方案1*：（粗粒度）clientId控制外部应用并发访问，缺点：不能控制不同应用并发扩充、冻结解冻同一个客户时场景，回调处理新增数据时，先去校验扩充插入条目是否存在，弥补了并发导致重复扩充同一业务范围条目这种场景
方案2：（细粒度）由于是批量客户处理，无法通过客户编码等业务字段来限制并发访问

测试锁是否生效：

// 这里是对外部应用加锁，控制同一应用并发访问改接口方法
@Lock4j(keys = {"#request.clientId"})
@Override
public ServiceResponse testLock(ExtendsCustomerBusinessScopeTaskDto request) {System.out.println("开始处理: " + request.getClientId() + " - " + LocalDateTime.now());try {// 模拟处理时间Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("处理完成: " + request.getClientId() + " - " + LocalDateTime.now());return ServiceResponse.success();
}/**
预期结果1：如果加锁无效，开始处理和结束处理之间间隔2s,但同一clientid调用时间不联系，几乎是同时进行的，类似这样：开始处理: client001 - 2024-07-13T14:31:58.451154700处理完成: client001 - 2024-07-13T14:32:00.4599192002024-07-13 14:32:00.549  INFO 21864 ---[tag 客户端ID：client001-]开始处理: client001 - 2024-07-13T14:32:00.550816300处理完成: client001 - 2024-07-13T14:32:02.5556544002024-07-13 14:32:02.636  INFO 21864 ---[tag 客户端ID：client001-]开始处理: client001 - 2024-07-13T14:32:02.636094400处理完成: client001 - 2024-07-13T14:32:04.6392284002024-07-13 14:32:04.700  INFO 21864 ---[tag 客户端ID：client001-]开始处理: client001 - 2024-07-13T14:32:04.701772900处理完成: client001 - 2024-07-13T14:32:06.7171383002024-07-13 14:32:06.799  INFO 21864 ---[tag 客户端ID：client001-]开始处理: client001 - 2024-07-13T14:32:06.799141500处理完成: client001 - 2024-07-13T14:32:08.803225预期结果2：如果加锁有效，开始处理和结束处理之间间隔2s,且同一clientid调用时间是连续的，类似这样开始处理: client001 - 2024-07-13T14:23:48.889049800处理完成: client001 - 2024-07-13T14:23:50.8946381002024-07-13 14:23:50.984  INFO 16064 --- [tag 客户端ID：client001-]开始处理: client001 - 2024-07-13T14:23:50.992565800处理完成: client001 - 2024-07-13T14:23:52.9942138002024-07-13 14:23:53.088  INFO 16064 --- [tag 客户端ID：client001-]开始处理: client001 - 2024-07-13T14:23:53.095387900处理完成: client001 - 2024-07-13T14:23:55.0962475002024-07-13 14:23:55.170  INFO 16064 --- [tag 客户端ID：client001-]开始处理: client001 - 2024-07-13T14:23:55.178764600处理完成: client001 - 2024-07-13T14:23:57.1841779002024-07-13 14:23:57.269  INFO 16064 --- [tag 客户端ID：client001-]开始处理: client001 - 2024-07-13T14:23:57.335996600处理完成: client001 - 2024-07-13T14:23:59.341987300实际测试结果：预期结果2，加锁有效
*/

模拟多线程并发场景的2种方式：

方式1：postman多线程并发测试

image-20240713143615934

方式2：代码对任务多线程同时调用

// 应用启动main方法
@EnableOpenApi("matrix-mdm")
@EnableMatrixFeignClients
@EnableDiscoveryClient
@EnableMatrixResourceServer
@SpringBootApplication
public class App {public static void main(String[] args) {SpringApplication.run(App.class, args);// lock4j分布式锁控制方法并发有效前提：线程必须通过Spring管理的bean来访问方法，否则加锁无效TnCustomerManagementService tnCustomerManagementServiceImpl = (TnCustomerManagementService) SpringReflectUtils.getBean("tnCustomerManagementServiceImpl");ExtendsCustomerBusinessScopeTaskDto request = new ExtendsCustomerBusinessScopeTaskDto();request.setClientId("client001");Runnable task = () -> tnCustomerManagementServiceImpl.customerBusinessScopeExtendsTask(request);new Thread(task).start();new Thread(task).start();new Thread(task).start();new Thread(task).start();new Thread(task).start();}
}// spring管理的bean的内部方// 请求超时时间设置为30s, 多线程并发时，第一个线程拿到锁，执行中，第二个线程获取不到锁，直接报错，reqire fail, 想要看到完整5个线程并发控制后，串行打印出梳理时间信息，就需要放大点请求超时时间 >= 5个并发线程处理时间总和 @Lock4j(keys = {"#request.clientId"}, acquireTimeout = 30000L)@Overridepublic ServiceResponse customerBusinessScopeExtendsTask(ExtendsCustomerBusinessScopeTaskDto request) {System.out.println("Thread " + Thread.currentThread().getName() + "开始处理: " + request.getClientId() + " - " + LocalDateTime.now());try {// 模拟处理时间Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Thread " + Thread.currentThread().getName() + "处理完成: " + request.getClientId() + " - " + LocalDateTime.now());return ServiceResponse.success();}

事务处理

目的：

为了避免多条数据库SQL操作中间异常时，数据已被插入正式表，但是业务已经执行不下去，再次执行时，就会发生数据已存在的代码校验死锁卡住。

考虑事务控制思路：

  1. 多个SQL操作要么都发生，要么都不发生
  2. 不数据回滚导致业务重复校验死锁、业务不能操作下去

解决方案：

异常回滚处理场景：

  1. 扩充、地址新增：

    插入正式表新条目时，根据数据条目唯一标识校验是否存在（弥补客户扩充是批量扩充接口，导致锁控制粒度只能控制在 相同应用 clientId 中，不同 clientId 并发扩充同一个业务范围数据场景控制不住），

    如果存在，（原因：可能历史数据已存在、锁未并发控制不同ClientId导致审批中数据代码校验失效），直接抛出异常，将之前可能执行的新增、更新操作回滚，

    这时候操作人员看到报错，去检查处理异常已存在数据后（检查记录被创建原因，处理删除数据），再次点击时业务正常进行下去

  2. 扩充、地址新增、变更：

    执行多条SQL操作方法时，中间出现字段过长等导致插入失败时，抛出异常，事务回滚，返回操作人员看到报错，去检查处理异常（放大字段）后，继续执行下去

总结

锁控制、事务控制、异常处理，必须分析场景，再采用最优处理方案

  1. sychronized 同步锁在分布式系统中不生效，需要用到分布式锁

  2. 加锁时，需要考虑锁的粒度。

    判断条件：如果接口访问场景并发量大，考虑细粒度锁控制；如果接口访问场景并发量小，考虑粗粒度锁控制；

    粗粒度锁：如访问接口的外部应用

    细粒度锁：如具体接口业务功能数据判定（客户上市：身份证号、纳税人识别号来锁定唯一客户，控制类似重复点击、同一时刻创建同一客户并发访问接口，导致同一客户被创建审批数据）

  3. 事务控制，需要考虑到多SQL操作异常、业务数据重复异常时等，进行回滚操作；异常信息暴漏到前端，方便开发运维；

若有错误，烦请评论指正！！！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/871962.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

利用AI辅助制作ppt封面

利用AI辅助制作ppt封面

如何利用AI辅助制作一个炫酷的PPT封面 标题使用镂空字背景替换为动态视频 标题使用镂空字 1.首先，新建一个空白的ppt页面，插入一张你认为符合主题的图片，占满整个可视页面。 2.其次，插入一个矩形，右键选择设置形状格式…
阅读更多...
北京交通大学《深度学习》专业课，实验2-前馈神经网络

北京交通大学《深度学习》专业课，实验2-前馈神经网络

1. 源代码 见资源“北京交通大学《深度学习》专业课，实验2-前馈神经网络” 2. 实验内容 （1）手动实现前馈神经网络解决上述回归、二分类、多分类任务 分析实验结果并绘制训练集和测试集的loss曲线 （2）利用to…
阅读更多...
keepalive：

keepalive：

keepalive： 调度器的高可用 vip地址在主备之间的切换，主在工作时，vip地址只在主上，主停止工作，vip漂移到备服务器。 在主备的优先级不变的情况下，主恢复工作，vip会飘回到主服务器。 1、配优…
阅读更多...
企业网络运维-给华为交换机配置sftp，浏览交换机文件并下载上传

企业网络运维-给华为交换机配置sftp，浏览交换机文件并下载上传

文章目录 需求实验开户stelnet权限已完成stelnet账号下的sftp配置使用xshell-sftp访问 需求 浏览交换机文件并下载上传 实验 开户stelnet权限 参考https://blog.csdn.net/xzzteach/article/details/140419150 已完成stelnet账号下的sftp配置 服务类型all包括stelnet和sf…
阅读更多...
强化学习编程实战-5 基于时间差分的方法

强化学习编程实战-5 基于时间差分的方法

第4章中，当模型未知时，由于状态转移概率P未知，动态规划中值函数的评估方法不再适用，用蒙特卡洛的方法聘雇值函数。 在蒙特卡洛方法评估值函数时，需要采样一整条轨迹，即需要从初始状态s0到终止状态的整个序列…
阅读更多...
探索“搭旅万物皆可搭”小程序——构建旅行搭伴平台的创新实践

探索“搭旅万物皆可搭”小程序——构建旅行搭伴平台的创新实践

摘要 随着旅游市场的不断发展和个性化需求的日益增长，旅行搭伴平台逐渐成为连接志同道合旅者的桥梁。本文旨在介绍“搭旅万物皆可搭”小程序的设计理念、核心功能及其背后的技术实现，探讨如何通过算法优化、安全保障、社交互动等手段，打造一…
阅读更多...
GUI界面开发之tkinter(一)

GUI界面开发之tkinter(一)

Tkinter是一个内置的Python库，用于创建图形用户界面（GUI）。它提供了一组工具和小部件，用于创建窗口、对话框、按钮、菜单和其他GUI元素。 在本篇文章中，主要介绍了窗口等知识点。 大家好！我是码银&#x1…
阅读更多...
《昇思25天学习打卡营第22天|onereal》

《昇思25天学习打卡营第22天|onereal》

文本解码原理--以MindNLP为例 回顾：自回归语言模型 根据前文预测下一个单词 一个文本序列的概率分布可以分解为每个词基于其上文的条件概率的乘积 𝑊_0:初始上下文单词序列𝑇: 时间步当生成EOS标签时，停止生成。 MindNLP/huggi…
阅读更多...
MySQL 时区问题：设置了 my.ini 并重启了服务，依旧是 0 时区

MySQL 时区问题：设置了 my.ini 并重启了服务，依旧是 0 时区

1、问题再现 在撰写 飞书 API 2-5 时，需要新建一些数据表，以便实施从数据库到多维表的数据同步。我建了2个测试数据表，连表查询之后，将时间戳转为时间格式返回，结果发现少了 8 小时。 具体逻辑抽象为以下&#xff0c…
阅读更多...
S7-1200PLC 2轴直线插补(详细方案对比)

S7-1200PLC 2轴直线插补(详细方案对比)

1、V90速度轴应用 速度轴V90PN总线伺服梯形加减速速度控制(标准报文1应用)_v90伺服加减速时间怎么调整-CSDN博客文章浏览阅读288次。SMART PLC斜坡函数SMART PLC斜坡函数功能块（梯形图代码）_RXXW_Dor的博客-CSDN博客斜坡函数Ramp的具体应用可以参看下面的文章链接：PID优化系…
阅读更多...
数据库-MySQL 实战项目——书店图书进销存管理系统数据库设计与实现（附源码）

数据库-MySQL 实战项目——书店图书进销存管理系统数据库设计与实现（附源码）

一、前言 该项目非常适合MySQL入门学习的小伙伴，博主提供了源码、数据和一些查询语句，供大家学习和参考，代码和表设计有什么不恰当还请各位大佬多多指点。 所需环境 MySQL可视化工具：navicat； 数据库：MySq…
阅读更多...
[笔记] SEW的振动分析工具DUV40A

[笔记] SEW的振动分析工具DUV40A

1.便携式振动分析仪 DUV40A 文档编号：26871998/EN SEW是一家国际化的大型的机械设备供应商。产品线涵盖电机，减速机，变频器等全系列动力设备。DUV40A是他自己设计的一款振动分析工具。 我们先看一下它的软硬件参数： 内置两路传…
阅读更多...
防火墙综合实验之NAT和智能选路

防火墙综合实验之NAT和智能选路

目录 前言： 一、实验题目 二、实验操作 需求一 需求二 需求三 需求四、需求五 需求六 需求七 ​编辑 需求八 需求九 需求十 需求十一 三、需求测试 前言： 本篇文章是延续上一篇文章，简单来说就是防火墙实验的完善和延续&#…
阅读更多...
CV07_深度学习模块之间的缝合教学(2)--维度转换

CV07_深度学习模块之间的缝合教学(2)--维度转换

教学（1）：链接 1.1 预备知识 问题：假如说我们使用的模型张量是三维的，但是我们要缝合的模块是四维的，应该怎么办？ 方法：pytorch中常用的函数：(1)view函数（2…
阅读更多...
新华三H3CNE网络工程师认证—DHCP使用场景

新华三H3CNE网络工程师认证—DHCP使用场景

网络服务与应用当中的技术有DHCP、Telnet和FTP。DHCP是计算机当中常用来获取地址的。比如日常使用中，计算机并没有接入IP，IP通过DHCP技术从上端服务去获取的。手动配置网络参数会出现多种问题。 文章目录 一、手动配置网络参数的问题1、参数多、理解难2、…
阅读更多...
【零基础】学JS之APIS第四天

【零基础】学JS之APIS第四天

💝💝💝欢迎来到我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。 非常期待和您一起在这个小…
阅读更多...
喰星云·数字化餐饮服务系统 多处 SQL注入漏洞复现

喰星云·数字化餐饮服务系统 多处 SQL注入漏洞复现

0x01 产品简介 喰星云数字化餐饮服务系统是一款专为餐饮企业设计的综合性管理软件，旨在通过信息化手段提升餐饮企业的运营效率、降低运营成本，并实现数据驱动的决策管理。该系统包括供应链管理、财务管理、巡店管理、人力资源管理等多个模块，可全面覆盖餐饮企业的日常运营需…
阅读更多...
Zynq7000系列FPGA中的DDR内存控制器

Zynq7000系列FPGA中的DDR内存控制器

DDR内存控制器是一个高度集成的组件，支持多种DDR内存类型（DDR2、DDR3、DDR3L、LPDDR2），并通过精心设计的架构来优化内存访问效率。 DDR内存控制器架构 AXI内存端口接口（DDRI）：该部分负责处理与…
阅读更多...
雷赛运动控制卡编程（2）限位设定与回原方式、脉冲模式设置

雷赛运动控制卡编程（2）限位设定与回原方式、脉冲模式设置

一、限位开关及急停开关的设置 限位开关的设置 //设置限位开关// dmc_set_el_modeushort _cardNo0;ushort _axisNo 0;ushort _enable 1; // 正负限位使能 ushort _elLogic 0; // 正负限位 低电平 有效ushort _model 0;// 正负限位停止方式为立即停止LTDMC.dmc_set_el_m…
阅读更多...
构建实用的NLP应用程序：重塑人类与计算机的协同工作方式

构建实用的NLP应用程序：重塑人类与计算机的协同工作方式

文章目录 一、NLP技术的核心价值二、构建实用NLP应用程序的关键步骤三、NLP应用程序在协同工作中的创新应用《赠ChatGPT中文范例的自然语言处理入门书》编辑推荐内容简介作者简介精彩书评目录前言/序言获取方式 在数字化时代，自然语言处理（NLP&#xff0…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023