Redian新闻
>
池化技术在真实业务中的实践

池化技术在真实业务中的实践

公众号新闻

👉 这是一个或许对你有用的社群

🐱 一对一交流/面试小册/简历优化/求职解惑,欢迎加入芋道快速开发平台知识星球。下面是星球提供的部分资料: 

👉这是一个或许对你有用的开源项目

国产 Star 破 10w+ 的开源项目,前端包括管理后台 + 微信小程序,后端支持单体和微服务架构。

功能涵盖 RBAC 权限、SaaS 多租户、数据权限、商城、支付、工作流、大屏报表、微信公众号等等功能:

  • Boot 地址:https://gitee.com/zhijiantianya/ruoyi-vue-pro
  • Cloud 地址:https://gitee.com/zhijiantianya/yudao-cloud
  • 视频教程:https://doc.iocoder.cn

来源:juejin.cn/post/
7289344148195835961


1 一些废话

作为一名Java开发人员,池化技术或多或少在业务代码中使用。常见的包括线程池、连接池等。也是因为Java语言超级丰富的基建,基本上这些池化能力都有着相对成熟的“工具”。

比如,需要使用线程池的时候常常会选择Spring提供的 ThreadPoolTaskExecutor , 工具内部替我们维护了线程的生命周期与任务的状态变化。

线程池的运转流程图

基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序,支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

  • 项目地址:https://github.com/YunaiV/ruoyi-vue-pro
  • 视频教程:https://doc.iocoder.cn/video/

2 正文开始

在笔者的业务场景里,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 [1]。源码的注释也很详细值得一看。

使用 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;
}

基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序,支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

  • 项目地址:https://github.com/YunaiV/yudao-cloud
  • 视频教程:https://doc.iocoder.cn/video/

3 后续

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


欢迎加入我的知识星球,全面提升技术能力。

👉 加入方式,长按”或“扫描”下方二维码噢

星球的内容包括:项目实战、面试招聘、源码解析、学习路线。

文章有帮助的话,在看,转发吧。

谢谢支持哟 (*^__^*)

微信扫码关注该文公众号作者

戳这里提交新闻线索和高质量文章给我们。
相关阅读
唯老是尊——中国养老现状及探讨(二)重磅白皮书:新时代党的治藏方略的实践及其历史性成就第二届全国工业和信息化技术技能大赛决赛在浙江绍兴举行大模型产业实践专场(二):在市场调查、投资和文献引用预测中的实践 | 第16届中国R会议暨2023X-AGI大会Meta重磅更新,小扎在元宇宙里养了会做家务的狗!人形化身超逼真,AI智能体在真实物理世界和人互动顶尖科学家如何玩转AI?DeepSpeed4Science:利用先进的AI系统优化技术实现科学发现大模型产业实践专场(一):在市场调查、企业数字化、教育培训中的实践 | 第16届中国R会议暨2023X-AGI大会瞭望·治国理政纪事丨“一带一路”发展学——全球共同发展的实践和理论探索专访微知卓丨结合转分化技术打造创新药械产品,我国首个生物人工肝临床结果初现,利用功能肝细胞有效促进受损肝脏恢复深化技术基建优势,智云健康持续升级数字化能力聚焦 | 新加坡南洋理工大学刘宏教授解读“中国与全球南方——跨界治理的视野和知识转移的实践”加国极寒来了!这些车销量暴增,让您自信安心地驾驶!多款技术在冬季驾驶时火出圈​技术在套路面前显得一文不值AI+金融专场:人工智能技术在金融行业的应用 | 第16届中国R会议暨2023X-AGI大会重塑商用车智驾生态,所托瑞安“渐进式”的实践之道音视频技术在手机上的应用与挑战读莎翁剧本的联想实时音视频技术在明星陪看直播中的应用实践什么是优化技术?给算法小白同学的快速讲解和上手文彭凯平:为什么在真正的教育中,“行万里路”如此重要?一百五十二 病休一百五十一 拜年【聚焦】推动全球生物医药前瞻思想、前沿技术在上海汇聚!2023上海国际生物医药产业周今天开幕第十一章第二节 金融资本和货币政策3D打印技术在建筑业的革命:建设更为高效和可持续的未来用来自实践的思考反思指南,进而用真实世界研究行动改变临床实践和指南如何高效部署大模型?CMU最新万字综述纵览LLM推理MLSys优化技术【成都】线下讲座 | 商务谈判在企业管理中的实践对话新生代,“她”力量! | 旅悦集团业务中台总经理许婷婷入选《2023胡润U35中国创业先锋》【荣誉】简米 | Ping++ 荣膺 “产业数字化技术赋能先锋企业”如何评价郭帆被聘为第一届全国电影标准化技术委员会委员?投行业务质量评价,迎来新修订!全业务链覆盖,债券承销、北交所等业务获纳入中大型火箭批产化,发射服务航班化——大生态产业理念的实践Hugging Face 大语言模型优化技术美国知名公立大学关闭校区!读着读着学校没了,正在真实上演……
logo
联系我们隐私协议©2024 redian.news
Redian新闻
Redian.news刊载任何文章,不代表同意其说法或描述,仅为提供更多信息,也不构成任何建议。文章信息的合法性及真实性由其作者负责,与Redian.news及其运营公司无关。欢迎投稿,如发现稿件侵权,或作者不愿在本网发表文章,请版权拥有者通知本网处理。