Mybatis的parameterType造成線程阻塞問(wèn)題分析
一、前言
最近在新發(fā)布某個(gè)項(xiàng)目上線時(shí)，每次重啟都會(huì)收到機(jī)器的 CPU 使用率告警，查看對(duì)應(yīng)監(jiān)控，持續(xù)時(shí)長(zhǎng)達(dá) 5 分鐘，對(duì)于服務(wù)重啟有很大風(fēng)險(xiǎn)。而該項(xiàng)目有非常多 Consumer 消費(fèi)，服務(wù)啟動(dòng)后會(huì)有大量線程去拉取消息處理邏輯，通過(guò)多次 Jstack 輸出線程快照發(fā)現(xiàn)有很多 BLOCKED 狀態(tài)線程，此文主要記錄分析 BLOCKED 原因。
二、分析過(guò)程
2.1、初步分析
"consumer_order_status_jmq1714_1684822992337" #3125 daemon prio=5 os_prio=0 tid=0x00007fd9eca34000 nid=0x1ca4f waiting for monitor entry [0x00007fd1f33b5000]
java.lang.Thread.State: BLOCKED (on object monitor)
at java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1027)
- waiting to lock <0x000000056e822bc8> (a java.util.concurrent.ConcurrentHashMap$Node)
at java.util.concurrent.ConcurrentHashMap.put(ConcurrentHashMap.java:1006)
at org.apache.ibatis.type.TypeHandlerRegistry.getJdbcHandlerMap(TypeHandlerRegistry.java:234)
at org.apache.ibatis.type.TypeHandlerRegistry.getTypeHandler(TypeHandlerRegistry.java:200)
at org.apache.ibatis.type.TypeHandlerRegistry.getTypeHandler(TypeHandlerRegistry.java:191)
at org.apache.ibatis.mapping.ParameterMapping$Builder.resolveTypeHandler(ParameterMapping.java:128)
at org.apache.ibatis.mapping.ParameterMapping$Builder.build(ParameterMapping.java:103)
at org.apache.ibatis.builder.SqlSourceBuilder$ParameterMappingTokenHandler.buildParameterMapping(SqlSourceBuilder.java:123)
at org.apache.ibatis.builder.SqlSourceBuilder$ParameterMappingTokenHandler.handleToken(SqlSourceBuilder.java:67)
at org.apache.ibatis.parsing.GenericTokenParser.parse(GenericTokenParser.java:78)
at org.apache.ibatis.builder.SqlSourceBuilder.parse(SqlSourceBuilder.java:45)
at org.apache.ibatis.scripting.xmltags.DynamicSqlSource.getBoundSql(DynamicSqlSource.java:44)
at org.apache.ibatis.mapping.MappedStatement.getBoundSql(MappedStatement.java:292)
at com.github.pagehelper.PageInterceptor.intercept(PageInterceptor.java:83)
at org.apache.ibatis.plugin.Plugin.invoke(Plugin.java:61)
at com.sun.proxy.$Proxy232.query(Unknown Source)
at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:148)
at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:141)
at org.apache.ibatis.session.defaults.DefaultSqlSession.selectOne(DefaultSqlSession.java:77)
at sun.reflect.GeneratedMethodAccessor160.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:433)
at com.sun.proxy.$Proxy124.selectOne(Unknown Source)
at org.mybatis.spring.SqlSessionTemplate.selectOne(SqlSessionTemplate.java:166)
at org.apache.ibatis.binding.MapperMethod.execute(MapperMethod.java:82)
at org.apache.ibatis.binding.MapperProxy.invoke(MapperProxy.java:59)
......通過(guò)對(duì)服務(wù)連續(xù)間隔 1 分鐘使用 Jstack 抓取線程快照，發(fā)現(xiàn)存在部分線程是 BLOCKED 狀態(tài)，通過(guò)堆棧可以看出，當(dāng)前線程阻塞在 ConcurrentHashMap.putVal，而 putVal 方法內(nèi)部使用了 synchronized 導(dǎo)致當(dāng)前線程被 BLOCKED，而上一級(jí)是 Mybaits 的TypeHandlerRegistry，TypeHandlerRegistry 的作用是記錄 Java 類型與 JDBC 類型的相互映射關(guān)系，例如 java.lang.String 可以映射 JdbcType.CHAR、JdbcType.VARCHAR 等，更上一級(jí)是 Mybaits 的 ParameterMapping，而 ParameterMapping 的作用是記錄請(qǐng)求參數(shù)的信息，包括 Java 類型、JDBC 類型，以及兩種類型轉(zhuǎn)換的操作類 TypeHandler。通過(guò)以上信息可以初步定位為在并發(fā)情況下 Mybaits 解析某些參數(shù)導(dǎo)致大量線程被阻塞，還需繼續(xù)往下分析。
我們可以先回想下 Mybatis 啟動(dòng)加載時(shí)的大致流程，查看下流程中哪些地方會(huì)操作 TypeHandler，會(huì)使用 ConcurrentHashMap.putVal 進(jìn)行緩存操作？
在 Mybatis 啟動(dòng)流程中，大致分為以下幾步：
1、XMLConfigBuilder#parseConfiguration() 讀取本地XML文件
2、XMLMapperBuilder#configurationElement() 解析XML文件中的 select|insert|update|delete 標(biāo)簽
3、XMLMapperBuilder#parseStatementNode() 開(kāi)始解析單條 SQL，包括請(qǐng)求參數(shù)、返回參數(shù)、替換占位符等
4、SqlSourceBuilder 組合單條 SQL 的基本信息
5、SqlSourceBuilder#buildParameterMapping() 解析請(qǐng)求參數(shù)
6、ParameterMapping#getJdbcHandlerMap() 解析 Java 與 JDBC 類型，并把映射結(jié)果放入緩存
而在第 6 步時(shí)候（圖中標(biāo)色），會(huì)去獲取 Java 對(duì)象類型與 JDBC 類型的映射關(guān)系，并把已經(jīng)處理過(guò)的映射關(guān)系 TypeHandler 存入本地緩存中。但是堆棧信息顯示，還是觸發(fā)了 TypeHandler 入緩存的操作，也就是某個(gè) paramType 并沒(méi)有命中緩存，而是在 SQL 查詢的時(shí)候?qū)崟r(shí)解析 paramType，在高并發(fā)情況下造成了線程阻塞情況。下面繼續(xù)分析下 sql xml 的配置：
<select id="listxxxByMap" parameterType="java.util.Map" resultMap="BaseResultMap">
select
<include refid="Base_Column_List"/>
from xxxxx
where business_id = #{businessId,jdbcType=VARCHAR}
and template_id = #{templateId,jdbcType=INTEGER}
</select>代碼請(qǐng)求：
Map<String, Object> params = new HashMap<>();
params.put("businessId", "11111");
params.put("templateId", "11111");
List<TrackingInfo> result = trackingInfoMapper.listxxxByMap(params);初步看沒(méi)發(fā)現(xiàn)問(wèn)題，但是我們?cè)谌?TypeHandler 緩存時(shí) debug 下，分析下哪種類型在緩存中缺失？
從 debug 信息中可以看出，TypeHandler 緩存中存在的是 interface java.util.Map，而 SQL 執(zhí)行時(shí)傳入的是 class java.util.HashMap，導(dǎo)致并沒(méi)有命中緩存。那我們修改下 xml 文件為 parameterType="java.util.HashMap" 是不是就解決了？
很遺憾，部署后仍然存在問(wèn)題。
2.2、進(jìn)一步分析
為了進(jìn)一步分析，引入了對(duì)照組，而對(duì)照組的 paramType 為具體 JavaBean。
<select id="listResultMap" parameterType="com.jdwl.xxx.domain.TrackingInfo" resultMap="BaseResultMap">
select
<include refid="Base_Column_List"/>
from xxxx
where business_id = #{businessId,jdbcType=VARCHAR}
and template_id = #{templateId,jdbcType=INTEGER}
</select>對(duì)照組代碼請(qǐng)求
TrackingInfo record = new TrackingInfo();
record.setBusinessId("11111");
record.setTemplateId(11111);
List<TrackingInfo> result = trackingInfoMapper.listResultMap(record);在裝載參數(shù)的 Handler 類 org.apache.ibatis.scripting.defaults.DefaultParameterHandler#setParameters 處進(jìn)行 debug 分析。
2.2.1、對(duì)照組為 listResultMap（paramType=JavaBean）
兩個(gè)參數(shù)的解析類型分別為 StringTypeHandler（紅框中灰色的字）與 IntegerTypeHandler（紅框中灰色的字），已經(jīng)是 Mybatis 提供的 TypeHandler，并沒(méi)有再進(jìn)行類型的二次解析。說(shuō)明 JavaBean 中的 businessId、templateId 字段已經(jīng)在啟動(dòng)時(shí)候被預(yù)解析了。
2.2.2、實(shí)驗(yàn)組為listxxxByMap（paramType=Map）
兩個(gè)參數(shù)的解析都是 UnknownTypeHandler（紅框中灰色的字），而在 UnknownTypeHandler 中會(huì)再次調(diào)用 resolveTypeHandler() 方法，對(duì)參數(shù)進(jìn)行類型的二次解析?？梢岳斫鉃?Map 里的屬性不是固定類型，只能在執(zhí)行 SQL 時(shí)候再解析一次。
最后修改為 paramType=JavaBean 部署測(cè)試環(huán)境再抓包，并未發(fā)現(xiàn) TypeHandlerRegistry 相關(guān)的線程阻塞。
三、引申思考
既然 paramType 傳值會(huì)出現(xiàn)阻塞問(wèn)題，那 resultType 與 resultMap 是不是有相同問(wèn)題呢？繼續(xù)分為兩個(gè)實(shí)驗(yàn)組：
1、對(duì)照組（resultMap=BaseResultMap）
<resultMap id="BaseResultMap" type="com.jdwl.tracking.domain.TrackingInfo">
<id column="id" property="id" jdbcType="BIGINT"/>
<result column="template_id" property="templateId" jdbcType="INTEGER"/>
<result column="business_id" property="businessId" jdbcType="VARCHAR"/>
<result column="is_delete" property="isDelete" jdbcType="TINYINT"/>
<result column="create_time" property="createTime" jdbcType="TIMESTAMP"/>
<result column="update_time" property="updateTime" jdbcType="TIMESTAMP"/>
<result column="ts" property="ts" jdbcType="TIMESTAMP"/>
</resultMap>
<select id="listResultMap" parameterType="com.jdwl.tracking.domain.TrackingInfo" resultMap="BaseResultMap">
select
<include refid="Base_Column_List"/>
from tracking_info
where business_id = #{businessId,jdbcType=VARCHAR}
and template_id = #{templateId,jdbcType=INTEGER}
</select>對(duì)照組代碼請(qǐng)求：
TrackingInfo record = new TrackingInfo();
record.setBusinessId("11111");
record.setTemplateId(11111);
List<TrackingInfo> result1 = trackingInfoMapper.listResultMap(record);2、實(shí)驗(yàn)組（resultType=JavaBean）
<select id="listResultType" parameterType="com.jdwl.tracking.domain.TrackingInfo" resultType="com.jdwl.tracking.domain.TrackingInfo">
select
<include refid="Base_Column_List"/>
from tracking_info
where business_id = #{businessId,jdbcType=VARCHAR}
and template_id = #{templateId,jdbcType=INTEGER}
</select>實(shí)驗(yàn)組代碼請(qǐng)求：
TrackingInfo record = new TrackingInfo();
record.setBusinessId("11111");
record.setTemplateId(11111);
List<TrackingInfo> result2 = trackingInfoMapper.listResultType(record);在對(duì)返回結(jié)果 Handler 處理類 org.apache.ibatis.executor.resultset.DefaultResultSetHandler#createAutomaticMappings() 進(jìn)行 debug 分析。
1、對(duì)照組（resultMap=BaseResultMap）
List unmappedColumnNames 長(zhǎng)度為 0，表示所有字段都命中了 標(biāo)簽配置，符合預(yù)期。
2、實(shí)驗(yàn)組（resultType=JavaBean）
List unmappedColumnNames 長(zhǎng)度為 11，表示所有字段都在 標(biāo)簽配置中未找到。這是因?yàn)?SQL 執(zhí)行后的 resultMap 對(duì)應(yīng)的 id 并不等于標(biāo)簽的 id，所以這些字段被標(biāo)識(shí)為未解析，又會(huì)執(zhí)行 TypeHandlerRegistry 的類型映射邏輯，引發(fā)并發(fā)時(shí)線程阻塞問(wèn)題。
四、總結(jié)
1、在使用 paramType 時(shí)，xml 配置的類型需要與 Java 代碼中傳入的一致，使用 Mybatis 預(yù)加載時(shí)的類型緩存。
2、在使用 paramType 時(shí)，避免使用 java.util.HashMap 類型，避免 SQL 執(zhí)行時(shí)解析 TypeHandler。
3、在接受返回值時(shí)，使用 resultMap，提前映射返回值，減少 TypeHandler 解析。
五、后續(xù)
在 Mybatis 社區(qū)已經(jīng)優(yōu)化了 TypeHandler 入緩存的邏輯，可以解決重復(fù)計(jì)算 TypeHandler 問(wèn)題，一定程度上緩解以上問(wèn)題。但是 Mybatis 修復(fù)最低版本為 3.5.8，依賴 spring5.x，而我們項(xiàng)目使用的 Mybatis3.4.4，spring4.x，直接升級(jí)會(huì)存在一定風(fēng)險(xiǎn)，所以在不升級(jí)情況下，按照總結(jié)規(guī)范使用也可以降低阻塞風(fēng)險(xiǎn)。
以上就是Mybatis的parameterType造成線程阻塞問(wèn)題分析的詳細(xì)內(nèi)容，更多關(guān)于Mybatis parameterType 線程阻塞的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
C++可以動(dòng)態(tài)的分類內(nèi)存，而java并不能這樣，是不是java就不能操作內(nèi)存呢，其實(shí)是有其他辦法可以操作內(nèi)存的，下面就一起看看Unsafe是如何花式操作內(nèi)存的吧2023-08-08
下面小編就為大家?guī)?lái)一篇Spring根據(jù)XML配置文件注入屬性的方法。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-11-11
Spring實(shí)現(xiàn)動(dòng)態(tài)切換多數(shù)據(jù)源的解決方案
這篇文章主要給大家介紹了Spring實(shí)現(xiàn)動(dòng)態(tài)切換多數(shù)據(jù)源的解決方案,文中給出了詳細(xì)的介紹和示例代碼，相信對(duì)大家的理解和學(xué)習(xí)具有一定的參考借鑒價(jià)值，有需要的朋友可以參考學(xué)習(xí)，下面來(lái)一起看看吧。2017-01-01
java設(shè)計(jì)模式Ctrl?C和Ctrl?V的原型模式詳解
這篇文章主要為大家介紹了java設(shè)計(jì)模式Ctrl?C和Ctrl?V的原型模式詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-02-02
本文主要介紹了idea在plugins中搜不到插件的解決方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-06-06
java動(dòng)態(tài)添加外部jar包到classpath的實(shí)例詳解
這篇文章主要介紹了java動(dòng)態(tài)添加外部jar包到classpath的實(shí)例詳解的相關(guān)資料,希望通過(guò)本文能幫助到大家，需要的朋友可以參考下2017-09-09
詳解Spring Boot 目錄文件結(jié)構(gòu)
這篇文章主要介紹了Spring Boot 目錄文件結(jié)構(gòu)的相關(guān)資料，文中示例代碼非常詳細(xì)，幫助大家更好的理解和學(xué)習(xí)，感興趣的朋友可以了解下2020-07-07
這篇文章主要介紹了在Java中輕松使用工廠設(shè)計(jì)模式介紹，工廠設(shè)計(jì)模式或工廠方法設(shè)計(jì)模式是一種廣泛使用且易于理解的設(shè)計(jì)模式，文章通過(guò)圍繞主題展開(kāi)詳細(xì)的內(nèi)容介紹，感興趣的朋友可以參考一下2022-09-09
在一個(gè)應(yīng)用程序中，我們需要多次使用線程，也就意味著，我們需要多次創(chuàng)建并銷毀線程。而創(chuàng)建并銷毀線程的過(guò)程勢(shì)必會(huì)消耗內(nèi)存。而在Java中，內(nèi)存資源是及其寶貴的，所以，我們就提出了線程池的概念2021-10-10
一篇文章帶你了解SpringMVC數(shù)據(jù)綁定
這篇文章主要給大家介紹了關(guān)于如何通過(guò)一篇文章弄懂Spring MVC的參數(shù)綁定，文中通過(guò)示例代碼以及圖文介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-08-08