百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

Apache Commons Pool——优化你的java内存

mhr18 2025-05-28 18:57 9 浏览 0 评论

大家好,我是吉森。我会持续分享一些开发技巧、经验和技术,如果你也热爱各种开发技术,欢迎关注我。

今天我们继续介绍Apache Commons工具包,今天的主角是:Commons Pool。简单地说,它是对象池技术的一套实现。

入门级介绍

开始之前,有必要啰嗦几句什么是对象池。

对象池,顾名思义,是一个存放对象的池子。我们使用对象的时候,可以从池中借出对象,完成任务后把对象归还回池中。对象池可以算做一种设计模式,它是单例模式的变种。单例模式是我们在整个应用中只能创建一个对象,而对象池模式是我们在应用中可以创建有限多个对象。

为什么用对象池?很多用来代表资源的大对象,它们在创建和销毁时的内存消耗都比较大,这种情况下我们垃圾收集器的负担很重。一旦创建了过多的资源对象而没有及时回收,就可能造成内存溢出 (OOM)问题。

下面就让我们关注一下通过Apache Commons Pool工具怎么创建对象池。

示例代码

// 创建一个通用的对象池
ObjectPool<Object> pool = new GenericObjectPool<>(new BasePooledObjectFactory<>() {
    // 创建对象的方法                                              
    @Override
    public Object create() {
        return new Object();
    }

    // 将对象包装成池中的对象 
    @Override
    public PooledObject<Object> wrap(Object obj) {
        return new DefaultPooledObject<>(obj);
    }
});

Object obj;
try {
    // 从对象池中借中对象
    obj = pool.borrowObject();
    try {
        // 使用对象
        doSomething(obj);
    } catch(Exception e) {
        // 让对象失效
        pool.invalidateObject(obj);
        // do not return the object to the pool twice
        obj = null;
    } finally {
        // 返还对象
        if(null != obj) {
            pool.returnObject(obj);
        }
    }
} catch(Exception e) {
    // 借出对象失败的处理
    e.printStackTrace();
}

进一步分析

从上面的示例代码中,我们可以看出,在对象池创建过程中的两个关键接口是ObjectPoolPooledObjectFactory

ObjectPool就是对象池,创建时需要加上泛型表明对象池中存储对象的类型,其中最常用的实现类是GenericObjectPool。我们可以通过在构造器中额外加入一个GenericObjectPoolConfig对象来配置对象池,主要配置项包括最小空闲对象数、最大空闲对象数以及最大总对象数。

创建GenericObjectPool时,我们需要重写两个方法,即createwrap。我们注意到create方法没有任何参数,说明对象池中的对象是完全一样的,即对象之间是equals的关系。wrap方法是告诉程序我们怎么将对象包装为池化对象,通常使用默认方式即可。

PooledObjectFactory是用于定义对象池中对象的生命周期方法的接口。换句话上,对象池创建、激活、销毁对象等过程其实都是调用PooledObjectFactory中的方法来实现的。主要的生命周期方法包括:

// 创建对象
PooledObject<T> makeObject() throws Exception;

// 销毁对象
void destroyObject(PooledObject<T> p) throws Exception;

// 确保对象有效
boolean validateObject(PooledObject<T> p);

// 重新初始化对象
void activateObject(PooledObject<T> p) throws Exception;

// 将对象重置为未初始化的状态
void passivateObject(PooledObject<T> p) throws Exception;

从池中取出对象和归还对象就比较简单了,直接调用borrowObjectreturnObject方法即可,借出对象的时候先检查闲置的对象是否可用,再检查所有对象是否要用,如果都不可用并且池中对象还未达到最大数量,则在池中创建新的对象。

其他对象池

除了GenericObjectPool外,Commons Pool还提供了其他几种对象池的对象。

  1. SoftReferenceObjectPool,即软引用对象池。我们都知道,在JVM中,软引用对象是指GC可以根据内存需要自主决定是否清理的对象。因此这种对象池不存在容量已满的情况,内存不足时,池中的对象会被GC回收。
  2. KeyedObjectPool,即有主键的对象池。前面提到GenericObjectPool中所有的对象都是一样的,KeyedObjectPool则是通过不同的key来标记不同的对象。KeyedObjectPool是一个接口,根据实现类不同,可以是一个key对应一个对象或多个对象。
  3. SynchronizedObjectPool,顾名思义,是线程安全的对象池。它是一个内部类,不能直接创建,需要通过PoolUtils.synchronizedPool方法将现有的对象池转为SynchronizedObjectPool。如果原对象池是KeyedObjectPool,则会包装为SynchronizedKeyedObjectPool。
  4. ErodingObjectPool,指不断衰减的对象池。它也是一个内部类,表示对象池的size将在闲置对象不再需要时不断地减少。不能直接创建,需要通过PoolUtils.erodingPool方法将现有的对象池转为ErodingObjectPool。这种线程池的效率比较高,通常采用FIFO(先进先出)的顺序来移除对象。

应用场景

最后说说什么时候使用对象池,以及对象池的优缺点。

对象池主要减少了创建对象和销毁对象的开销,因此一定是对象创建和销毁内存开销较大的情况下,才需要使用对象池,这些情况主要包括网络连接、数据库连接、图形图像处理等。

数据库连接池、线程池等都属于对象池,但是它们都有更特定的解决方案,通常不会使用Apache Commons Pool。根据maven网站上的统计,应用了Commons Pool的知名第三方库主要包括jedis (redis连接驱动)、Spring data redis (spring连接redis)、lettuce (redis连接驱动)、ActiveMQ Pool (消息队列)、Jmeter components (压力测试)、RabbitMQ backend (消息队列)等。可以看出,这些应用的普遍特点就是内存开销比较大。

因此,我们也应该仅在创建内存开销较大的对象时,主动使用对象池。

敲黑板啦~

引入Commons-Pool

<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-pool2 -->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
    <version>2.9.0</version>
</dependency>

参考资料

Apache Commons官方网站

今天介绍的内容就到这里了,感谢观看。

什么,还没看够?关注我看更多技术干货~

相关推荐

Team IDE 集成管理工具

Team·IDE工具简介TeamIDE工具集成SSH、FTP、MySql、Redis、Zookeeper、Kafka、Elasticsearch等管理工具Team·IDE功能模块目录结...

MySQL大数据表处理策略,原来一直都用错了……

场景当我们业务数据库表中的数据越来越多,如果你也和我遇到了以下类似场景,那让我们一起来解决这个问题。数据的插入,查询时长较长后续业务需求的扩展,在表中新增字段,影响较大表中的数据并不是所有的都为有效数...

Java程序员你真的甘心只做增删改查吗

各位志同道合的朋友们大家好,我是一个一直在一线互联网踩坑十余年的编码爱好者,现在将我们的各种经验以及架构实战分享出来,如果大家喜欢,就关注我,一起将技术学深学透,我会每一篇分享结束都会预告下一专题最近...

Java后端开发除了增删改查还有什么?

后端的追求:接口稳定、架构合理、业务逻辑清晰、模块拆分合理、支持高并发等。软件本身归根到底都是由算法+数据结构构成的,进一步细化之后,其实就是通过一系列的增删改查操作,构成算法,对数据结构进行操作,赋...

基于shiro实现session持久化和分布式共享

前言本文写下session持久化和分布式共享基于shiro框架对session的管理机制来实现必要性一直处于登陆状态:你登陆微信不可能三天两头就让你重新登陆吧?而是一直处于登陆状态除非主动退出...

为啥工作那么多年,你还是只会增删改查?

你以为没有这样的感觉,工作中领导和同事都非常认可你的能力,但是你想更进一步,却不被认可。想出去看看,跳槽面试,却也是屡屡碰壁。面试的过程中,面试官问技术方案,明明心里很清楚,或者说印象还行,可就是说不...

Java程序员除了做增删改查还能干嘛?

就以Java后端开发为例,说说不同级别程序员干的事情。1初级开发,大概是有3年Java开发经验。22年底,上海,这批程序员如果学历是本科,薪资一般是8k到2w,当然如果能进好公司或互联网大厂,薪资能...

Java面试题及答案总结(2025版持续更新)

大家好,我是Java面试分享面对Java后端岗位的激烈竞争,掌握系统化的知识体系至关重要。本文整理了覆盖主流技术栈的高频面试题,助你高效备战,内容包含:Java基础、并发编程、Spring生态、数据库...

微服务架构之API网关——在微服务项目中的技术框架和用法实践

API网关技术实战在介绍了API网关的相关理论之后,大家可以了解到API网关的作用和优缺点,接下来将为大家介绍API网关在微服务项目中的技术框架和用法实践。Zuul网关其实API网关并不是很难的技术,...

带小白黑客入门,你也可以跟我们一起成为黑客大牛

小编这几天一直在做关于ssrf的实验,这篇文章可以带纯小白黑客入门。靶机ip地址:192.168.2.138查看靶机运行的redis服务。攻击机为ip192.168.2.112.用客户端redis-c...

Python最常见的170道面试题全解析答案(二)

60.请写一个Python逻辑,计算一个文件中的大写字母数量答:withopen(‘A.txt’)asfs:count=0foriinfs.read():ifi.isupper...

Spring Boot项目集成Redis,原来这么简单!

在现代软件开发的“快车道”上,SpringBoot无疑是许多开发者手中的“神兵利器”。它以其“约定大于配置”的理念,大大简化了Java应用的开发和部署过程,让开发者能够将更多精力聚焦于业务逻辑本身。...

Apache Commons Pool——优化你的java内存

大家好,我是吉森。我会持续分享一些开发技巧、经验和技术,如果你也热爱各种开发技术,欢迎关注我。今天我们继续介绍ApacheCommons工具包,今天的主角是:CommonsPool。简单地说,它是...

码农成长系列-基于WebSocket的后台消息提醒

场景描述当用户对app有某些业务操作时,需要将该操作友好地提醒给,有接收提醒权限的后台管理者。技术场景分析经分析,要实现上述业务,业务拆解后可能需要解决如下业务①.触发提醒待推送数据的监听②.提醒时接...

百度直播消息系统的实践和演进

导读:直播业务的核心功能有两个,一个是实时音视频推拉流,另一个是直播间消息流的收发。本文主要介绍百度直播服务内的消息服务系统的设计实践和演化。一、背景直播间内用户聊天互动,形式上是常见的IM消息流;...

取消回复欢迎 发表评论: