摘要:问题复现假设线上是一个典型的项目,某一块业务的处理逻辑为接受一个字符串参数,然后将该值赋予给一个注入的对象,修改对象的属性后再返回,期间我们用了来模拟线上的高耗时业务代码如下上述的也非常简单,一个普通的对象具体代码如下所示相信使用过的伙伴们
问题复现
假设线上是一个典型的Spring Boot Web项目,某一块业务的处理逻辑为:
接受一个name字符串参数,然后将该值赋予给一个注入的bean对象,修改bean对象的name属性后再返回,期间我们用了 Thread.sleep(300) 来模拟线上的高耗时业务
代码如下:
@RestController @RequestMapping("name") public class NameController { @Autowired private NameService nameService; @RequestMapping("") public String changeAndReadName (@RequestParam String name) throws InterruptedException { System.out.println("get new request: " + name); nameService.setName(name); Thread.sleep(300); return nameService.getName(); } }
上述的nameService也非常简单,一个普通的Spring Service对象
具体代码如下所示:
@Service public class NameService { private String name; public NameService() { } public NameService(String name) { this.name = name; } public String getName() { return name; } public NameService setName(String name) { this.name = name; return this; } }
相信使用过Spring Boot的伙伴们对这段代码不会有什么疑问,实际运行也没有问题,测试也能跑通,但真的上线后,里面却会产生一个线程安全问题
不相信的话,我们通过线程池,开200个线程来测试NameController就可以复现出来
测试代码如下
@Test public void changeAndReadName() throws Exception { ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(200, 300 , 2000, TimeUnit.SECONDS, new ArrayBlockingQueue(200)); for (int i = 0; i < 200; i++) { poolExecutor.execute(new Runnable() { @Override public void run() { try { System.out.println(Thread.currentThread().getName() + " begin"); Map headers = new HashMap (); Map querys = new HashMap (); querys.put("name", Thread.currentThread().getName()); headers.put("Content-Type", "text/plain;charset=UTF-8"); HttpResponse response = HttpTool.doGet("http://localhost:8080", "/name", "GET", headers, querys); String res = EntityUtils.toString(response.getEntity()); if (!Thread.currentThread().getName().equals(res)) { System.out.println("WE FIND BUG !!!"); Assert.assertEquals(true, false); } else { System.out.println(Thread.currentThread().getName() + " get received " + res); } }catch (Exception e) { e.printStackTrace(); } } }); } while(true) { Thread.sleep(100); } }
这段测试代码,启动200个线程,对NameController进行测试,每一个线程将自己的线程名作为参数提交,并对返回结果进行断言,如果返回的值与提交的值不匹配,那么抛出AssertNotEquals异常
实际测试后,我们可以发现200个线程近乎一半以上都会抛出异常
问题产生原因首先我们来分析一下,当一个线程,向 http://localhost:8080/name 发出请求时,线上的Spring Boot服务,会通过其内置的Tomcat 8.5来接收这个请求
而在Tomcat 8.5中,默认采用的是NIO的实现方式,及每次请求对应一个服务端线程,然后这个服务端的线程,再分配到对应的servlet来处理请求
所以我们可以认为,这并发的200次客户端请求,进入NameController执行请求的,也是分为200个不同的服务端线程来处理
但是Spring提供的Bean对象,并没有默认实现它的线程安全性,即默认状态下,我们的NameController跟NameService都属于单例对象
这下应该很好解释了,200个线程同时操作2个单例对象(一个NameController对象,一个NameService对象),在没有采用任何锁机制的情况下,不产生线程安全问题是不可能的(除非是状态无关性操作)
问题解决办法按照标题说明的,我这里提供三种解决办法,分别是
synchronized修饰方法
synchronized代码块
改变bean对象的作用域
接下来对每个解决办法进行说明,包括他们各自的优缺点
synchronized修饰方法使用synchronized来是修饰可能会产生线程安全问题的方法,应该是我们最容易想到的,同时也是最简单的解决办法,我们仅仅需要在 public String changeAndReadName (@RequestParam String name) 这个方法上,增加一个synchronized进行修饰即可
实际测试,这样确实能解决问题,但是各位是否可以再思考一个问题
我们再来运行测试代码的时候,发现程序运行效率大大降低,因为每一个线程必须等待前一个线程完成changeAndReadName()方法的所有逻辑后才可以运行,而这段逻辑中,就包含了我们用来模拟高耗时业务的 Thread.sleep(300) ,但它跟我们的线程安全没有什么关系
这种情况下,我们就可以使用第二种方法来解决问题
synchronized代码块实际的线上逻辑,经常会遇到这样的情况:我们需要确保线程安全的代码,跟高耗时的代码(比如说调用第三方api),很不凑巧的写在同一个方法中
那么这种情况下,使用synchronized代码块,而不是直接修饰方法会来得高效的多
具体解决代码如下:
@RequestMapping("") public String changeAndReadName (@RequestParam String name) throws InterruptedException { System.out.println(Thread.currentThread().getName() + " get new request: " + name); String result = ""; synchronized (this) { nameService.setName(name); result = nameService.getName(); } Thread.sleep(300); return result; }
再次运行测试代码,我们可以发现效率问题基本解决,但是缺点是需要我们自己把握好哪一块是可能出现线程安全问题的代码(而实际的线上逻辑可能非常复杂,这一块不好把握)
改变bean对象的作用域现在非常不幸的事情发生了,我们连高耗时代码也是状态相关性的,而同时也需要保证效率问题,那么这种情况下就只能通过牺牲少量的内存来解决问题了
大概思路就是通过改变bean对象的作用域,让每一个服务端线程对应一个新的bean对象来处理逻辑,通过彼此之间互不相关来回避线程安全问题
首先我们需要知道bean对象的作用域有哪些,请见下表
作用域 | 说明 |
---|---|
singleton | 默认的作用域,这种情况下的bean都会被定义为一个单例对象,该对象的生命周期是与Spring IOC容器一致的(但出于Spring懒加载机制,只有在第一次被使用时才会创建) |
prototype | bean被定义为在每次注入时都会创建一个新的对象 |
request | bean被定义为在每个HTTP请求中创建一个单例对象,也就是说在单个请求中都会复用这一个单例对象 |
session | bean被定义为在一个session的生命周期内创建一个单例对象 |
application | bean被定义为在ServletContext的生命周期中复用一个单例对象 |
websocket | bean被定义为在websocket的生命周期中复用一个单例对象 |
清楚bean对象的作用域后,接下来我们就只需要考虑一个问题:修改哪些bean的作用域?
前面我已经解释过,这个案例中,200个服务端线程,在默认情况下是操作2个单例bean对象,分别是NameController和NameService(没错,在Spring Boot下,Controller默认也是单例对象)
那么是不是直接将NameController和NameServie设置为prototype就可以了呢?
如果您的项目是用的Struts2,那么这样做没有任何问题,但是在Spring MVC下会严重影响性能,因为Struts2对请求的拦截是基于类,而Spring MVC则是基于方法
所以我们应该将NameController的作用域设置为request,将NameService设置为prototype来解决
具体操作代码如下
@RestController @RequestMapping("name") @Scope("request") public class NameController { }
@Service @Scope("prototype") public class NameService { }参考文献
https://dzone.com/articles/un...
https://dzone.com/articles/un...
https://medium.com/sipios/how...
原创不易,转载请申明出处
案例项目代码: github/liumapp/booklet
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/75824.html
摘要:一直以来,前端的线上问题很难定位,因为它发生于用户的一系列操作之后。当然,这些问题并非不能克服,让我们来一起看看如何去定位线上的问题吧。地址参考一步一步搭建前端监控系统错误监控篇一步一步搭建前端监控系统接口请求异常监控篇 摘要: 记录用户行为,排查线上BUG。 作者:一步一个脚印一个坑 原文:如何定位前端线上问题(如何排查前端生产问题) Fundebug经授权转载,版权归原作者所...
摘要:如问到是否使用某框架,实际是是问该框架的使用场景,有什么特点,和同类可框架对比一系列的问题。这两个方向的区分点在于工作方向的侧重点不同。 [TOC] 这是一份来自哔哩哔哩的Java面试Java面试 32个核心必考点完全解析(完) 课程预习 1.1 课程内容分为三个模块 基础模块: 技术岗位与面试 计算机基础 JVM原理 多线程 设计模式 数据结构与算法 应用模块: 常用工具集 ...
摘要:是框架对的默认集成,我们在实际项目中,也经常使用它的去操作,一般来说没什么问题,但是细心一点的同学会发现,经过这种方法写入的数据会出现乱码问题问题复现项目依赖配置文件配置配置类注入设置数据存入的序列化方式实例化对象可以 org.springframework.data.redis是Spring框架对Redis的默认集成,我们在实际项目中,也经常使用它的RedisTemplate去操作R...
摘要:使用的好处知乎的回答不用自己组装,拿来就用。统一配置,便于修改。 前言 只有光头才能变强 回顾前面: 给女朋友讲解什么是代理模式 包装模式就是这么简单啦 单例模式你会几种写法? 工厂模式理解了没有? 在刷Spring书籍的时候花了点时间去学习了单例模式和工厂模式,总的来说还是非常值得的! 本来想的是刷完《Spring 实战 (第4版)》和《精通Spring4.x 企业应用开发实战》...
摘要:前言一些问题的整理,平时实际工作中可能会忽视的一些原理性问题,后续会选取一些有意思的点进行详述。 前言 一些问题的整理,平时实际工作中可能会忽视的一些原理性问题,后续会选取一些有意思的点进行详述。 JAVA多线程、并发相关 多个线程同时读写,读线程的数量远远⼤于写线程,你认为应该如何解决 并发的问题?你会选择加什么样的锁? JAVA的AQS是否了解,它是⼲嘛的? 除了synchron...
阅读 3058·2021-11-16 11:45
阅读 3578·2021-09-29 09:34
阅读 702·2021-08-16 10:50
阅读 1569·2019-08-30 15:52
阅读 1962·2019-08-30 15:45
阅读 859·2019-08-29 15:23
阅读 1923·2019-08-26 13:51
阅读 3299·2019-08-26 12:23