Java中的池化技术

作为一名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;
}

后续

当然真实的业务中还会有很多不相关的逻辑夹杂其中,上文基本涵盖了池化对象搭建与配置的实现方法。最终也实现了性能优化的目标。希望此文能为大家在池化运用多些帮助

原创文章,作者:guozi,如若转载,请注明出处:https://www.sudun.com/ask/79191.html

(0)
guozi's avatarguozi
上一篇 2024年5月30日 下午6:09
下一篇 2024年5月30日 下午6:12

相关推荐

  • 网站被攻击打不开,网站遇到攻击

    8、加强员工安全意识:员工在网站安全中发挥着重要作用,如何加强员工安全意识培训,避免点击恶意链接;如何保护自己的账户密码等。 如果网站受到攻击,不仅会导致网站无法访问,而且用户的个…

    行业资讯 2024年5月18日
    0
  • 服务器托管便宜,服务器托管公司哪家好

    3、高速网络连接:辽宁服务器托管公司配备先进的网络设备和高速的网络连接,可以为企业提供稳定、高速的网络环境。这不仅可以改善用户体验,还可以提高网站在搜索引擎上的排名。 4、数据安全…

    行业资讯 2024年3月19日
    0
  • 在线代理ip网站,“在线代理”

    完成网站构建后,请务必对其进行测试,以确保其正常工作且没有错误。同时,还应注意内容是否准确、排版是否美观。通过测试后,您就可以正式发布您的网站了。 7、持续优化 网站建设不是一次性…

    行业资讯 2024年4月21日
    0
  • 租个服务器

    在当今信息时代,网络安全问题日益突出,各行各业都离不开网络的支持。而随着网络的发展,网络安全加速行业也应运而生。它能够有效提升网络安全性能,保障数据传输的稳定性和可靠性。然而,在众…

    行业资讯 2024年4月12日
    0

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注