Java业务功能并发问题处理

业务场景：

笔者负责的功能需要调用其他系统的进行审批，而接口的调用过程耗时有点长（可能长达10秒），一个订单能被多个人提交审批，当订单已提交后会更改为审批中，不能再次审批（下游系统每调用一次会产生一次笔新数据）。前端在点击编辑前会进行一次查询，处于审批中的订单无法点击提交审批。问题代码如下所示

// 在数据加载时, 用户点击编辑详情时会请求当前方法, 方法会校验订单状态决定是否允许用户获取订单详情
public AjaxResult selectOrderDetailToEdit(Long orderId) {OrderDetail orderDetail =  OrderMapper.selectOrderId(orderId);if ("PROCESS".equals(orderDetail.getDealStatus()) {return AjaxResult.error("审批中的订单不能编辑");}return AjaxResult.success(orderDetail);
}/*** 提交审批的逻辑*/
@Transactional
public AjaxResult submitOrderApprove(OrderDetail orderDetail, boolean isProcess) {// 省略其他处理逻辑...// 调用审批接口if (isProcess) {OrderDetail toApproveOrder =  OrderMapper.selectOrderId(orderId);AjaxResult approvedRs = approveOrderProcess(toApproveOrder);// 接口调用成功, 将接口返回的编码和处理中状态写入数据库if (approvedRs.isSuccess()) {toApproveOrder.setProcessCode(approvedRs.getProcessCode());toApproveOrder.setDealStatus("PROCESS");updateOrderDealStatus(toApproveOrder);}}return AjaxResult.success(orderDetail);
}

原因分析：

出现的问题就是当A和B两个用户同时在订单未审批状态时进入了订单的编辑状态，然后A用户进行了提交，订单状态实际已经是审批中，B用户由于页面上订单状态未更新，也显示的是未审批，也可以提交审批，B用户点击提交后，就导致接口调用了两次。上面的描述可能不太直观，可以看下面的时序图。

在这里插入图片描述

解决方案：

多个用户处理一个单据的情况在业务中时常见的，针对这种问题，单机服务和分布式服务的应用采用的解决方案也不相同，下面也记录下不同部署方式的解决方案以供参考。

单机应用处理方式

synchronize代码块

锁粒度比较大，不能控制到按订单加锁，当不同人操作不同的订单也需要等待其他订单处理完成后才能继续处理下一个订单。

public AjaxResult submitOrderApprove(OrderDetail orderDetail, boolean isProcess) {synchronize(当前类名.class) {if ("PROCESS".equals(orderDetail.getDealStatus())) {return AjaxResult("订单已处理");}}
}
ConcurrentHashMap

使用ConcurrentHashMap时需要注意使用完后要remove掉，避免出现其他线程获取不到锁甚至内存溢出的问题
其中使用了putIfAbsent方法保证原子操作，下面直接给出代码示例

// 全局静态的ConcurrentHashMap
private static ConcurrentHashMap<Long, String> orderLockMap = new ConcurrentHashMap<>();public void submitOrderApprove(OrderDetail orderDetail) {long orderId = orderDetail.getOrderId();// map中的值是当前线程名称，remove时需要判断等于当前线程时才移除，避免移除了其他线程的锁值String threadName = Thread.currentThread().getName();try {/* map中的值是当前线程名称，用于在remove时判断当前线程，避免移除其他线程的锁值使用ConcurrentHashMap的putIfAbsent方法, 如果put成功返回null, 键已存在则返回已存在键的值*/if (OrderLock.orderLockMap.putIfAbsent(orderId, threadName) != null) {System.out.println(orderId + "订单正在处理中，请稍后");} else {System.out.println("加锁成功, 当前订单ID:" + orderId);}// 模拟其他业务处理逻辑Thread.sleep(5000L);} finally {if (threadName.equals(orderLockMap.get(orderId))) {orderLockMap.remove(orderId);}}
}

分布式服务处理方式

通过数据库锁限制

在提交逻辑中查询单据状态并增加查询行锁进行判断，这样另外一个线程查询时也会等待锁执行完成后才查询返回，for update是关键

-- 假设是写在mybatis的mapper中的queryOrderProcessStatus()方法的查询sql
select order_id, deal_status from order_detail where order_id = #{orderId} for update;

@Transaction
public void submitOrderApprove(OrderDetail orderDetail) {OrderDetail orderDetail = orderMapper.queryOrderProcessStatus(orderId);if ("PROCESS".equals(orderDetail.getDealStatus())) {return AjaxResult("订单已处理");}// 业务处理逻辑
}

当然在数据库中建立一张表作为事务处理表亦可，因篇幅所限，此处不展示这种处理方法。

通过Redis分布式锁限制

现有的Redis在java方面的api很多，我们实现起来也很方便快捷了，下面使用RedisTemplate实现Redis加锁逻辑。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Component;import java.util.ArrayList;
import java.util.Collections;
import java.util.concurrent.TimeUnit;@Component
public class LockUtil {/*** lua脚本 释放锁，因为有多步操作，需要保证原子性使用lua脚本*/private static final String REDIS_DEL_LOCK_SCRIPT = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";/*** redis锁分类目录*/private static final String LOCK_PREFIX = "LOCK:";/*** redis操作服务*/protected RedisTemplate<String, String> redisTemplate;@Autowiredpublic LockUtil(RedisTemplate redisTemplate) {this.redisTemplate = redisTemplate;}/*** @param lockKey         锁的唯一key* @param lockTime        锁超时时间（毫秒）* @param reqNum          请求锁的次数* @param reqWaitLockTime 每次请求锁的间隔时间（毫秒）* @return* @throws InterruptedException*/public Boolean tryLock(String lockKey, Long lockTime, Integer reqNum, Long reqWaitLockTime) {Boolean isSuccessLock = false;String redisKey = LOCK_PREFIX + lockKey;for (int count = 1; count <= reqNum; count++) {isSuccessLock = redisTemplate.opsForValue().setIfAbsent(redisKey, Thread.currentThread().getName(), lockTime, TimeUnit.MILLISECONDS);if (Boolean.TRUE.equals(isSuccessLock)) {return true;}try {Thread.sleep(reqWaitLockTime);} catch (InterruptedException e) {unLock(lockKey);throw new RuntimeException("加锁失败，锁ID【" + lockKey + "】");}}return isSuccessLock;}/*** 释放锁** @param lockKey 锁的唯一key*/public void unLock(String lockKey) {DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>(REDIS_DEL_LOCK_SCRIPT, Long.class);redisTemplate.execute(redisScript, new ArrayList<>(Collections.singleton(LOCK_PREFIX + lockKey)), Thread.currentThread().getName());}
}
使用示例

@Autowired
private LockUtil lockUtil;public void submitOrderApprove(OrderDetail orderDetail) {// 如果加锁成功, tryLock方法会返回trueif (!lockUtil.tryLock("ORDER_APPROVE:" + orderDetail.getOrderId, 3L, 5, 1L)) {return AjaxResult.error("点击过于频繁，请稍后再操作");}try {// 处理业务逻辑} finally {lockUtil.unlock();}
}

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

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

相关文章

05-微服务-RabbitMQ-概述

05-微服务-RabbitMQ-概述

RabbitMQ 1.初识MQ 1.1.同步和异步通讯 微服务间通讯有同步和异步两种方式&#xff1a; 同步通讯&#xff1a;就像打电话&#xff0c;需要实时响应。 异步通讯&#xff1a;就像发邮件&#xff0c;不需要马上回复。 两种方式各有优劣&#xff0c;打电话可以立即得到响应&am…
阅读更多...
canvas设置文字阴影

canvas设置文字阴影

查看专栏目录 canvas示例教程100专栏&#xff0c;提供canvas的基础知识&#xff0c;高级动画&#xff0c;相关应用扩展等信息。canvas作为html的一部分&#xff0c;是图像图标地图可视化的一个重要的基础&#xff0c;学好了canvas&#xff0c;在其他的一些应用上将会起到非常重…
阅读更多...
实现JavaScript中的数组排序功能

实现JavaScript中的数组排序功能

一、引言 在JavaScript中&#xff0c;数组是一种常用的数据结构&#xff0c;而排序是处理数组的常见任务。对于JavaScript中的数组排序&#xff0c;我们可以通过多种方式来实现。本篇博客将详细介绍如何使用JavaScript实现数组排序功能&#xff0c;并分享一些感悟。 二、实现…
阅读更多...
SQL的一些基本语句

SQL的一些基本语句

SQL&#xff08;Structured Query Language&#xff09;是一种用于管理关系型数据库的语言。下面是一些常用的SQL基本语句&#xff1a; 创建表格&#xff1a; CREATE TABLE table_name (column1 datatype,column2 datatype,column3 datatype,... );插入数据&#xff1a; INSERT…
阅读更多...
详解C语言入门程序：HelloWorld.c

详解C语言入门程序：HelloWorld.c

#include <stdio.h> // 头文件&#xff0c;使用<>编译系统会在系统头文件目录搜索在C语言中&#xff0c;#include 是预处理指令&#xff0c;用于将指定的头文件内容插入到当前源文件中。这里的 <stdio.h> 是一个标准库头文件&#xff0c;其中包含了与输入输出…
阅读更多...
MySQL之CRUD、常见函数及union查询

MySQL之CRUD、常见函数及union查询

目录 一. CRUD 1.1 什么是crud 1.2 SELECT(查询) 1.3 INSERT(新增) 1.4 UPDATE(修改) 1.5 DELETE(删除) 二. 函数 2.1 常见函数 2.2 流程控制函数 2.3 聚合函数 三. union与union all 3.1 union 3.2 union all 3.3 具体不同 3.4 结论 四. 思维导图 一. CRUD 1.1 什么是crud…
阅读更多...
解析：Eureka的工作原理

解析：Eureka的工作原理

Eureka是Netflix开源的一个基于REST的的服务发现注册框架&#xff0c;它遵循了REST协议&#xff0c;提供了一套简单的API来完成服务的注册和发现。Eureka能够帮助分布式系统中的服务提供者自动将自身注册到注册中心&#xff0c;同时也能够让服务消费者从注册中心发现服务提供者…
阅读更多...
【愚公系列】2023年12月 HarmonyOS应用开发者高级认证（完美答案）

【愚公系列】2023年12月 HarmonyOS应用开发者高级认证（完美答案）

&#x1f3c6; 作者简介&#xff0c;愚公搬代码 &#x1f3c6;《头衔》&#xff1a;华为云特约编辑&#xff0c;华为云云享专家&#xff0c;华为开发者专家&#xff0c;华为产品云测专家&#xff0c;CSDN博客专家&#xff0c;CSDN商业化专家&#xff0c;阿里云专家博主&#xf…
阅读更多...
express框架搭建后台服务

express框架搭建后台服务

express 1. 使用express创建web服务器&#xff1a;2. 中间件中间件分类&#xff1a; 3.解决跨域问题&#xff1a;1. CORS2.JSONP 1. 使用express创建web服务器&#xff1a; 1. 导入express2. 创建web服务器3. 启动web服务器// 1. 导入express const express require(express)/…
阅读更多...
6. Mybatis 缓存

6. Mybatis 缓存

6. Mybatis 缓存 MyBatis 包含一个非常强大的查询缓存特性,它可以非常方便地配置和定制。缓存可以极大的提升查询效率MyBatis系统中默认定义了两级缓存 一级缓存二级缓存 默认情况下&#xff0c;只有一级缓存&#xff08;SqlSession级别的缓存&#xff0c;也称为本地缓存&…
阅读更多...
Transforer逐模块讲解

Transforer逐模块讲解

本文将按照transformer的结构图依次对各个模块进行讲解&#xff1a; 可以看一下模型的大致结构&#xff1a;主要有encode和decode两大部分组成&#xff0c;数据经过词embedding以及位置embedding得到encode的时输入数据 输入部分 embedding就是从原始数据中提取出单词或位置&…
阅读更多...
ubuntu22.04配置双网卡绑定提升带宽

ubuntu22.04配置双网卡绑定提升带宽

这里写自定义目录标题 Bonding简介配置验证参考链接 Bonding简介 bonding(绑定)是一种linux系统下的网卡绑定技术&#xff0c;可以把服务器上n个物理网卡在系统内部抽象(绑定)成一个逻辑上的网卡&#xff0c;能够提升网络吞吐量、实现网络冗余、负载均衡等功能&#xff0c;有很…
阅读更多...
软件设计师考试的知识点

软件设计师考试的知识点

这里先总结一下考试的知识点。 上午的考试考题中只有单选题&#xff0c;涉及范围很广&#xff0c;但是考查不深。 上午的考试知识点以及分数比重&#xff1a; 知识点 分数 说明 比例 软件工程基础知识 13 开发方法与开发模型、数据流图与数据字典、结构化设计、测试方法…
阅读更多...
2023年工作初体验

2023年工作初体验

23年终于正式入职&#xff0c;参与了正式上线的电商平台、crm平台等项目的研发&#xff0c;公司规模较小&#xff0c;气氛融洽&#xff0c;没有任何勾心斗角、末位淘汰&#xff0c;几乎没什么压力。虽然是我的第一家公司&#xff0c;但实际是个适合养老的公司&#xff08;笑 总…
阅读更多...
双击shutdown.bat关闭Tomcat报错：未设置关闭端口~

双击shutdown.bat关闭Tomcat报错：未设置关闭端口~

你们好&#xff0c;我是金金金。 场景 当我startup.bat启动tomcat之后&#xff0c;然后双击shutdown.bat关闭&#xff0c;结果报错了~ 排查 看报错信息很明显了&#xff0c;未配置关闭端口&#xff0c;突然想起来了我在安装的时候都选的是默认的配置&#xff0c;我还记得有这…
阅读更多...
快速批量运行命令

快速批量运行命令

Ansible 是 redhat 提供的自动化运维工具&#xff0c;它是 Python编写&#xff0c;可以通过 pip 安装。 pip install ansible 它通过任务(task)、角色(role)、剧本(playbook) 组织工作项目&#xff0c;适用于批量化系统配置、软件部署等需要复杂操作的工作。 但对于批量运行命…
阅读更多...
简单罗列一下jdk常见的垃圾收集器

简单罗列一下jdk常见的垃圾收集器

1. Serial Collector 类型&#xff1a;单线程收集器。工作模式&#xff1a;使用标记-压缩算法进行老年代的垃圾收集&#xff0c;标记-复制算法进行年轻代的垃圾收集。特点&#xff1a;简单高效&#xff0c;适用于单核处理器或小型堆内存。在进行垃圾收集时&#xff0c;会暂停所…
阅读更多...
nginx日志目录详解

nginx日志目录详解

Nginx 默认会打印访问日志&#xff08;access log&#xff09;和错误日志&#xff08;error log&#xff09;。这些日志对于监控和调试网站非常有用。以下是关于如何配置和查看 Nginx 日志的一些基本信息&#xff1a; 配置 Nginx 日志 访问日志&#xff08;Access Log&#xf…
阅读更多...
宝塔部署nuxt3项目问题解决

宝塔部署nuxt3项目问题解决

使用宝塔部署nuxt3项目一直没成功&#xff0c;网站502&#xff0c;要不就是资源加载不出来 测试使用宝塔版本8.0.4 添加node项目方式失败&#xff0c;项目更目录设置到server,无法设置运行目录为public, 导致网站资源加载不出来&#xff0c;设置到.output目录&#xff0c;会提…
阅读更多...
继电器组开发控制

继电器组开发控制

也是通过树莓派IO口的控制来实现继电器组的开发 继电器组有四根信号线&#xff0c;2根电源线。 通过gpio readall 查看树莓派各个端口的信息选择26 27 28 29 作为信号端口 编程可能会遇到的一些问题 1、通过键盘输入指令的时候&#xff0c;如果用scanf 会有bug&#xff0c;导…
阅读更多...
最新文章

Copyright @ 2022~2023