当前位置：首页 > 编程日记 > 正文

Java多线程学习处理高并发问题

编程日记 2024-09-30 14:00:00

在程序的应用程序中，用户或请求的数量达到一定数量，并且无法避免并发请求.由于对接口的每次调用都必须在返回时终止，因此，如果接口的业务相对复杂，则可能会有多个用户.调用接口时，该用户将冻结.

以下内容将介绍解决此问题的巧妙且非常简单的方法.

请求写入内存

我们可以将每个请求封装为一个对象，然后将其写入内存.

@Getter
@Setter
private static class CallVo{//请求对象
private Long param1;//参数1
private Integer param2;//参数2
}
private List<CallVo> callVoList = new ArrayList<>();//请求对象列表
/**
* 接口调用
* @param callVo
* @return
*/
@Transactional
@RequestMapping(value = "/call",method = {RequestMethod.POST})
public void call(@RequestBody CallVo callVo){
synchronized (syncObject) {
callVoList.add(callVo);//将请求对象写入内存
}
}
多线程处理

创建一个线程以继续读取内存中的数据. 如果被请求对象的收集长度为0多线程技术问题解决，则表明没有请求. 如果集合中有数据，请从集合中删除请求的对象并获取时间. 根据相应业务处理请求的参数.

这达到了将同步转变为异步的目的，并简单地解决了高并发性的问题.

private Thread thread;
private final Object syncObject = new Object(); // 同步对象
private volatile boolean runnable;
@Override
public void run() {
while (runnable){
try {
if (callVoList.size() == 0) {//集合长度为0，证明没有请求
Thread.sleep(1000);
continue;
}
CallVo callVo;
synchronized (syncObject) {
callVo = callVoList.remove(0);
}
Long param1 = callVo.getStationId();
Integer param2 = callVo.getCallType();

//业务处理
System.out.println(param1+"---"+param2);

}catch (Exception e){
logger.error("接口调用异常：", e);
}
}
}

完整代码：

@RestController
@Slf4j
@RequestMapping("/erpRemote")
public class ErpRemoteController extends BaseController implements DisposableBean, Runnable{

ErpRemoteController(){
callVoList = new ArrayList<>();
runnable = true;
thread = new Thread(this);
thread.start();
}
/**
* 接口调用
* @param callVo
* @return
*/
@Transactional
@RequestMapping(value = "/call",method = {RequestMethod.POST})
public GeneralResponse call(@RequestBody CallVo callVo){

synchronized (syncObject) {
callVoList.add(callVo);//将请求对象写入内存
}
return GeneralResponse.success(null);
}
@Getter
@Setter
private static class CallVo{//请求对象
private Long param1;//参数1
private Integer param2;//参数2
}
private List<CallVo> callVoList;
private Thread thread;
private final Object syncObject = new Object(); // 同步对象
private volatile boolean runnable;
@Override
public void run() {
while (runnable){
try {
if (callVoList.size() == 0) {//集合长度为0，证明没有请求
Thread.sleep(1000);
continue;
}
CallVo callVo;
synchronized (syncObject) {
callVo = callVoList.remove(0);
}
Long param1 = callVo.getStationId();
Integer param2 = callVo.getCallType();

//业务处理
System.out.println(param1+"---"+param2);

}catch (Exception e){
logger.error("接口调用异常：", e);
}
}
}
@Override
public void destroy() {
runnable = false;
}
}
限制

由于同步是异步的，因此每次请求接口的返回值都是唯一的多线程技术问题解决，因此此方法仅适用于请求者不需要返回的情况.

以上就是小编介绍的“java培训教程：Java多线程学习处理高并发问题”的内容，希望对大家有所帮助，如有疑问，请在线咨询。

https://www.dkcj.cn/info/20997.html

Java多线程学习处理高并发问题

相关文章：

防止表单多次提交

Visual Studio环境变量使用实例：使用环境变量来组织project

股市币市：数据分析与交易所最新公告（20190301）

Python常用6个技术网站汇总分享!

devstack —— 单机部署 OpenStack 体验

使用ultraedit和cl编译器打造简易c/c++开发环境

股市币市：数据分析与交易所最新公告（20190302）

分享五款java学习辅助工具，总有你用的上的~

如何利用 C# 爬取「猫眼电影专业版：票房」数据！

MOSS的CSS样式说明，一个老外总结的

什么是整型?Python整型详细介绍

hibernate.hbm2ddl.auto的value

linux的管道

股市币市：数据分析与交易所最新公告（20190303）

零基础怎么学习web前端开发

【DocFX文档翻译】DocFX 入门 (Getting Started with DocFX)

在Ubuntu上安装Snort入侵检测系统。

一份来自山东院校的考研调剂系统已开放名单！

适合初学者学java技术的书籍推荐!

ref和out的区别

如何利用 C# 爬取「当当 - 计算机与互联网图书销量榜」！

【Java学习笔记之十】Java中循环语句foreach使用总结及foreach写法失效的问题

参加软件测试培训需要学什么技术

程序集和应用程序域

股市币市：数据分析与交易所最新公告

OpenGL学习（hello）

选择python培训机构的关键考核五大因素，让你永不吃亏!

Maven 的classifier的作用

NPOI 导出Excel

如何利用 C# 实现 K 最邻近算法？