问题背景
在我们的微服务系统中,首笔交易响应明显偏慢,经过初步排查发现:
- flowable 流程部署、redis 连接建立、pagehelper 代理生成和 hibernate validator 校验等操作均集中在首笔交易时进行;
- 后续交易响应迅速,说明业务逻辑本身并无性能瓶颈,而主要问题出在各类资源的首次初始化上。
这种“懒加载”机制虽然能够延迟资源加载,但在首笔交易时往往会导致严重延时,影响整体体验。实际项目中需平衡启动速度与首次响应效率,主动预热关键组件。
排查步骤
1. 日志分析
首先,将日志级别调为 debug
,详细观察首笔交易与后续交易之间的差异。
在 flowable 工作流启动时,日志中会出现如下部署信息:
2025-03-31-15:24:25:326 [thread1] debug o.f.e.i.bpmn.deployer.bpmndeployer.deploy.72 -- processing deployment springbootautodeployment 2025-03-31-15:24:25:340 [thread1] debug o.f.e.i.b.d.parseddeploymentbuilder.build.54 -- processing bpmn resource e:\gitprojects\flowableproject\target\classes\processes\eib.bpmn20.xml
同样,redis 连接在首次调用时会看到大量lettuce包日志,如:
2025-03-31-15:24:23:587 [xnio-1 task-1] debug io.lettuce.core.redisclient.initializechannelasync0.304 -- connecting to redis at 10.240.75.250:7379
这些信息表明,在首次调用时,系统才开始部署流程、建立 redis 连接以及加载其它第三方组件,从而导致延迟。
2. 性能工具定位
由于单纯依赖日志排查比较繁琐,我们还使用了 java visualvm(jdk 自带工具,也可选择其它工具)进行采样分析。
在 visualvm 中选择目标进程后通过 cpu 取样,示意图如下(也可配置jmx远程连接)。
观察结果如下:
发现首笔交易相比后续交易多出以下方法的调用(省略的部分二方包慢代码):
com.github.pagehelper.dialect.auto.datasourceautodialect.<init>
org.hibernate.validator.internal.engine.validatorimpl.validate()
这些方法的初始化也成为首笔交易慢的原因之一。
优化方案:提前预热各种资源
针对上述问题,我们的优化思路很简单:提前初始化各项资源,确保首笔交易时不再触发大量懒加载。为此,我们将所有预热操作改写成基于 applicationrunner 的实现,保证在 spring boot 启动后就自动执行。
1. flowable 流程部署预热
在应用启动时,通过扫描 bpmn 文件提前部署流程,避免在交易中首次部署导致延迟。
import org.flowable.engine.repositoryservice; import org.flowable.engine.repository.deploymentbuilder; import org.springframework.boot.applicationarguments; import org.springframework.boot.applicationrunner; import org.springframework.core.io.resource; import org.springframework.core.io.support.pathmatchingresourcepatternresolver; import org.springframework.stereotype.component; @component public class processdeploymentrunner implements applicationrunner { private final repositoryservice repositoryservice; public processdeploymentrunner(repositoryservice repositoryservice) { this.repositoryservice = repositoryservice; } @override public void run(applicationarguments args) throws exception { // 扫描 processes 目录下的所有 bpmn 文件 pathmatchingresourcepatternresolver resolver = new pathmatchingresourcepatternresolver(); resource[] resources = resolver.getresources("classpath:/processes/*.bpmn20.xml"); if (resources.length == 0) { system.out.println("未在 processes 目录下找到 bpmn 文件"); return; } deploymentbuilder deploymentbuilder = repositoryservice.createdeployment() .name("自动部署流程"); for (resource resource : resources) { deploymentbuilder.addinputstream(resource.getfilename(), resource.getinputstream()); } deploymentbuilder.deploy(); system.out.println("流程定义已部署,数量:" + resources.length); } }
2. redis 连接预热
利用 applicationrunner 发送一次 ping 请求,提前建立 redis 连接,避免首笔交易时因连接建立而耗时。
import org.springframework.boot.applicationarguments; import org.springframework.boot.applicationrunner; import org.springframework.data.redis.core.stringredistemplate; import org.springframework.stereotype.component; @component public class rediswarmuprunner implements applicationrunner { private final stringredistemplate redistemplate; public rediswarmuprunner(stringredistemplate redistemplate) { this.redistemplate = redistemplate; } @override public void run(applicationarguments args) { try { string pingresult = redistemplate.getconnectionfactory().getconnection().ping(); system.out.println("✅ redis connection pre-warmed successfully: " + pingresult); } catch (exception e) { system.err.println("❌ redis warm-up failed: " + e.getmessage()); } } }
3. pagehelper 预热
通过执行一条简单的查询语句,触发 pagehelper 及相关 mybatis mapper 的初始化。
import com.baomidou.mybatisplus.extension.toolkit.sqlrunner; import org.springframework.boot.applicationarguments; import org.springframework.boot.applicationrunner; import org.springframework.stereotype.component; @component public class pagehelperwarmuprunner implements applicationrunner { @override public void run(applicationarguments args) { try { boolean result = sqlrunner.db().selectobjs("select 1").size() > 0; system.out.println("✅ pagehelper & sqlrunner pre-warm completed, result: " + result); } catch (exception e) { system.err.println("❌ pagehelper pre-warm failed: " + e.getmessage()); } } }
(请确保配置文件中已开启 sql runner 功能:mybatis-plus.global-config.enable-sql-runner=true
)
4. hibernate validator 预热
通过一次 dummy 校验操作,提前加载 hibernate validator 相关类和反射逻辑
import jakarta.validation.validation; import jakarta.validation.validator; import org.springframework.boot.applicationarguments; import org.springframework.boot.applicationrunner; import org.springframework.stereotype.component; @component public class validatorwarmuprunner implements applicationrunner { @override public void run(applicationarguments args) { try { validator validator = validation.builddefaultvalidatorfactory().getvalidator(); dummyentity dummy = new dummyentity(); validator.validate(dummy); system.out.println("✅ hibernate validator pre-warm completed!"); } catch (exception e) { system.err.println("❌ hibernate validator pre-warm failed: " + e.getmessage()); } } private static class dummyentity { @jakarta.validation.constraints.notnull private string name; } }
5. undertow 预热(可选)
如果使用 undertow 作为内嵌服务器,也可以通过主动发送 http 请求预热相关资源。此外,在配置文件中开启过滤器提前初始化也有助于降低延迟。
在 application.yml
中设置:
server: undertow: eager-init-filters: true
再通过下面的代码发送一次预热请求:
import org.springframework.boot.applicationarguments; import org.springframework.boot.applicationrunner; import org.springframework.stereotype.component; import org.springframework.web.client.resttemplate; @component public class undertowwarmuprunner implements applicationrunner { @override public void run(applicationarguments args) { try { resttemplate resttemplate = new resttemplate(); string response = resttemplate.getforobject("http://localhost:8080/health", string.class); system.out.println("✅ undertow pre-warm completed, response: " + response); } catch (exception e) { system.err.println("❌ undertow pre-warm failed: " + e.getmessage()); } } }
总结
通过上述方案,我们将 flowable 流程部署、redis 连接、pagehelper 初始化、hibernate validator 校验和 undertow 相关组件的预热操作全部迁移到 applicationrunner 中,在应用启动后就自动执行。这样,首笔交易时不再需要进行大量初始化工作,各项资源已预先加载,确保后续请求能达到毫秒级响应,大大提升了用户体验并避免了无效的监控告警。
以上就是springboot首笔交易慢问题排查与优化方案的详细内容,更多关于springboot首笔交易慢问题的资料请关注代码网其它相关文章!
发表评论