高性能必杀技：Java中的池化技术
共 8384字，需浏览 17分钟
·
2024-05-21 10:30
来源：juejin.cn/post/7289344148195835961
👉 欢迎加入小哈的星球 ，你将获得: 专属的项目实战 / Java 学习路线 / 一对一提问 / 学习打卡 / 每月赠书
新项目:仿小红书(微服务架构)正在更新中... , 全栈前后端分离博客项目 2.0 版本完结啦， 演示链接：http://116.62.199.48/ 。全程手摸手，后端 + 前端全栈开发，从 0 到 1 讲解每个功能点开发步骤，1v1 答疑，直到项目上线。目前已更新了261小节，累计41w+字，讲解图：1806张，还在持续爆肝中.. 后续还会上新更多项目，目标是将Java领域典型的项目都整一波，如秒杀系统, 在线商城, IM即时通讯，Spring Cloud Alibaba 等等，戳我加入学习，已有1400+小伙伴加入(早鸟价超低)
一些废话
作为一名Java开发人员，池化技术或多或少在业务代码中使用。常见的包括线程池、连接池等。也是因为Java语言超级丰富的基建，基本上这些池化能力都有着相对成熟的“工具”。
比如，需要使用线程池的时候常常会选择Spring提供的 ThreadPoolTaskExecutor，工具内部替我们维护了线程的生命周期与任务的状态变化。
线程池的运转流程图
正文开始
在笔者的业务场景里，java服务需要通过命令行启动一个特殊进程，并在进程使用完后将其销毁。而业务对启动这个进程的整体耗时较为敏感，打算利用池化技术，将进程池化复用，去除启动进程的消耗，达到优化性能的目标。
认识 GenericObjectPool
池化技术的概念大家可能都比较熟悉了，但真正要从零开始实现池化能力，就会感觉困难很多。好在Java丰富的基建在提供ThreadPoolTaskExecutor的同时，也提供了GenericObjectPool这个辅助我们实现自定义对象池化的工具。
顺带提一句，JedisPool就是使用这个工具实现的。
GenericObjectPool构造方法一共就3个参数，只有PooledObjectFactory必传;
/**
* Creates a new {@code GenericObjectPool} that tracks and destroys
* objects that are checked out, but never returned to the pool.
*
* @param factory The object factory to be used to create object instances
* used by this pool
* @param config The base pool configuration to use for this pool instance.
* The configuration is used by value. Subsequent changes to
* the configuration object will not be reflected in the
* pool.
* @param abandonedConfig Configuration for abandoned object identification
* and removal. The configuration is used by value.
*/
public GenericObjectPool(final PooledObjectFactory<T> factory,
final GenericObjectPoolConfig<T> config, final AbandonedConfig abandonedConfig) {
}
PooledObjectFactory 按照方法注释的描述，它是专门负责给池子创建对象实例的。当然除了创建对象(makeObject)，还包括了检验、激活、销毁对象。基本涵盖了对象生命周期中的各个阶段。
void activateObject(PooledObject<T> p) throws Exception;
void destroyObject(PooledObject<T> p) throws Exception;
PooledObject<T> makeObject() throws Exception;
void passivateObject(PooledObject<T> p) throws Exception;
boolean validateObject(PooledObject<T> p);
更加详细的说明可以浏览 GenericObjectPool's apidocs。源码的注释也很详细值得一看。
使用 GenericObjectPool
先引入依赖
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
<version>${version}</version>
</dependency>
根据自身业务实现PooledObjectFactory接口；作者的业务场景是进程池化，那么对应的创建对象、销毁对象的方法就是创建进程和销毁进程的代码。
public class MyProcessFactory implements PooledObjectFactory<MyProcess> {
@Override
public void destroyObject(PooledObject<MyProcess> p) throws Exception {
final MyProcess process = p.getObject();
if (null != process) {
// 销毁进程
process.stop();
}
}
@Override
public PooledObject<MyProcess> makeObject() throws Exception {
// 这里就是去创建一个进程
MyProcess process = new MyProcess();
process.start();
return new DefaultPooledObject<>(process);
}
// 剩下几个方法也可以按需实现
}
下一步就是构建 GenericObjectPool 实例
PooledObjectFactory<MyProcess> factory = new MyProcessFactory();
GenericObjectPool<MyProcess> pool = new GenericObjectPool(factory);
使用GenericObjectPool
// 获取进程实例
MyProcess process = pool.borrowObject();
// 归还实例
pool.returnObject(process);
进阶使用 GenericObjectPoolConfig
顾名思义，GenericObjectPoolConfig是池化工具的配置类；它包含了池的最大容量、池的最大空闲数、最小空闲数等核心参数。除此之外在它的父类 BaseObjectPoolConfig 中，空闲对象检测规则，对象存放队列进出规则(LIFO)等更加细节的配置。
/**
* The default value for the {@code maxTotal} configuration attribute.
* @see GenericObjectPool#getMaxTotal()
*/
public static final int DEFAULT_MAX_TOTAL = 8;
/**
* The default value for the {@code maxIdle} configuration attribute.
* @see GenericObjectPool#getMaxIdle()
*/
public static final int DEFAULT_MAX_IDLE = 8;
/**
* The default value for the {@code minIdle} configuration attribute.
* @see GenericObjectPool#getMinIdle()
*/
public static final int DEFAULT_MIN_IDLE = 0;
通过调整这些参数值，就能创建符合业务要求的池子。下面就是能常驻4个进程的一套配置参数。
private GenericObjectPoolConfig<MyProcess> genericObjectPoolConfig() {
final GenericObjectPoolConfig<MyProcess> config = new GenericObjectPoolConfig<>();
config.setMaxTotal(20); // 池的最大容量
config.setMaxIdle(4); // 最大空闲连接数
config.setMinIdle(0); // 最小空闲连接数
config.setMaxWait(Duration.ofSeconds(5)); // 获取对象时最大等待时间
config.setTimeBetweenEvictionRuns(Duration.ofMinutes(1)); // 空闲对象检查间隔
config.setMinEvictableIdleTime(Duration.ofMinutes(10)); // 空闲对象被移除的最小空闲时间
config.setTestOnBorrow(true);
config.setLifo(false);
return config;
}
后续
当然真实的业务中还会有很多不相关的逻辑夹杂其中，上文基本涵盖了池化对象搭建与配置的实现方法。最终也实现了性能优化的目标。希望此文能为大家在池化运用多些帮助。
👉 欢迎加入小哈的星球 ，你将获得: 专属的项目实战 / Java 学习路线 / 一对一提问 / 学习打卡 / 每月赠书
新项目:仿小红书(微服务架构)正在更新中... , 全栈前后端分离博客项目 2.0 版本完结啦， 演示链接：http://116.62.199.48/ 。全程手摸手，后端 + 前端全栈开发，从 0 到 1 讲解每个功能点开发步骤，1v1 答疑，直到项目上线。目前已更新了261小节，累计41w+字，讲解图：1806张，还在持续爆肝中.. 后续还会上新更多项目，目标是将Java领域典型的项目都整一波，如秒杀系统, 在线商城, IM即时通讯，Spring Cloud Alibaba 等等，戳我加入学习，已有1400+小伙伴加入(早鸟价超低)
1. 我的私密学习小圈子~
最近面试BAT，整理一份面试资料《Java面试BATJ通关手册》，覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。
获取方式：点“在看”，关注公众号并回复 Java 领取，更多内容陆续奉上。
PS：因公众号平台更改了推送规则，如果不想错过内容，记得读完点一下“在看”，加个“星标”，这样每次新文章推送才会第一时间出现在你的订阅列表里。
点“在看”支持小哈呀，谢谢啦