`
ldzyz007
  • 浏览: 715031 次
  • 性别: Icon_minigender_1
  • 来自: 西安
社区版块
存档分类
最新评论

Jakarta Commons Pool

    博客分类:
  • java
阅读更多
使用Jakarta Commons Pool可以根据需要快速的实现自己的对象池,只需要实现PoolableObjectFactory或者KeyedPoolableObjectFactory接口。KeyedPoolableObjectFactory和PoolableObjectFactory的不同之处在于KeyedPoolableObjectFactory的每个方法都比PoolableObjectFactory多了一个Object key的参数,使用这个参数可以使得对象池中的每个对象都有所不同。
      PoolableObjectFactory定义了五个方法(摘至Jakarta Commons Pool API文档):
makeObject is called whenever a new instance is needed.
activateObject is invoked on every instance before it is returned from the pool.
passivateObject is invoked on every instance when it is returned to the pool.
destroyObject is invoked on every instance when it is being "dropped" from the pool (whether due to the response from validateObject, or for reasons specific to the pool implementation.)
validateObject is invoked in an implementation-specific fashion to determine if an instance is still valid to be returned by the pool. It will only be invoked on an "activated" instance.

例子

import java.net.SocketAddress;
import java.nio.channels.SocketChannel;

import org.apache.commons.pool.KeyedPoolableObjectFactory;

/**
* <p>Title: </p>
*
* <p>Description: </p>
*
* <p>Copyright: Copyright (c) 2005</p>
*
* <p>Company: </p>
*
* @author George Hill
* @version 1.0
*/

public class SocketPoolableObjectFactory implements KeyedPoolableObjectFactory {

    /**
     * 创建新的对象
     * @param key Object 创建对象需要用到的参数
     * @return Object SocketChannel实例
     * @throws Exception
     */
    public Object makeObject(Object key) throws Exception {
    SocketAddress address = (SocketAddress) key;

    // 创建SocketChannel
    SocketChannel channel = SocketChannel.open(address);

    return channel;
  }

  /**
   * 销毁对象
   * @param key Object 创建对象时的参数
   * @param obj Object 需要销毁的对象
   * @throws Exception
   */
  public void destroyObject(Object key, Object obj) throws Exception {
    SocketChannel channel = (SocketChannel) obj;

    if (channel != null)
      channel.close();
    channel = null;
  }

  /**
   * 检验对象是否有效
   * @param key Object 创建对象时的参数
   * @param obj Object 需要进行检验的对象
   * @return boolean 有效返回true,无效返回false
   */
  public boolean validateObject(Object key, Object obj) {
    SocketChannel channel = (SocketChannel) obj;

    if (channel != null && channel.isOpen() && channel.isConnected())
      return true;

    return false;
  }

  /**
   * 将对象激活,这里不需要做任何工作
   * @param key Object
   * @param obj Object
   * @throws Exception
   */
  public void activateObject(Object key, Object obj) throws Exception {
  }

  /**
   * 将对象挂起,这里不需要做任何工作
   * @param key Object
   * @param obj Object
   * @throws Exception
   */
  public void passivateObject(Object key, Object obj) throws Exception {
  }

}

测试

import java.io.IOException;
import java.net.*;
import java.nio.ByteBuffer;
import java.nio.channels.*;
import java.util.*;

import org.apache.commons.pool.*;
import org.apache.commons.pool.impl.*;


public class TestThread implements Runnable {

  // 线程名称
  private String name;

  // 对象池
  private KeyedObjectPool pool;

  // 连接的网络地址
  private InetSocketAddress address;

  public TestThread(String name, KeyedObjectPool pool,
                    InetSocketAddress address) {
    this.name = name;
    this.pool = pool;
    this.address = address;
  }

  public void run() {
    System.out.println(name + ": Client Start");
    SocketChannel channel = null;

    try {
      channel = (SocketChannel) pool.borrowObject(address);
    }
    catch (Exception ex) {
      ex.printStackTrace();
    }

    // 从对象池中借出对象成功
    if (channel != null) {
      System.out.println(name + ": Borrow Channel successfully!");

      try {
        channel.configureBlocking(false);

        // 创建Selector
        Selector selector = Selector.open();
        // 向Selector注册我们需要的READ事件
        SelectionKey skey = channel.register(selector, SelectionKey.OP_READ);

        boolean stop = false;
        int n = 0;
        int read = 0;
        ByteBuffer buffer = ByteBuffer.allocate(1024);

        System.out.println("Client Start");

        // 轮询
        while (!stop) {
          // 获取Selector返回的时间值
          n = selector.select();

          // 当传回的值大于0事,读事件发生了
          if (n > 0) {
            Set set = selector.selectedKeys();
            Iterator it = set.iterator();

            while (it.hasNext()) {
              skey = (SelectionKey) it.next();
              it.remove();

              if (skey.isReadable()) {
                SocketChannel sc = (SocketChannel) skey.channel();

                while ( (read = sc.read(buffer)) != -1) {
                  if (read == 0) {
                    break;
                  }

                  buffer.flip();
                  byte[] array = new byte[read];
                  buffer.get(array);
                  String s = new String(array);
                  System.out.print(s);
                  buffer.clear();

                  if (s.indexOf("new") != -1) {
                    stop = true;
                    System.out.println();
                  }
                }
              }
            }
          }
        }
      }
      catch (IOException ioe) {
        ioe.printStackTrace();
      }

      try {
        pool.returnObject(address, channel);
      }
      catch (Exception ex) {
        ex.printStackTrace();
      }
    }

    System.out.println(name + ": Client Stop");
  }

 
  public static void main(String[] args) throws Exception {
    SocketPoolableObjectFactory factory = new SocketPoolableObjectFactory();
    StackKeyedObjectPoolFactory poolFactory = new StackKeyedObjectPoolFactory(factory);
    KeyedObjectPool pool = poolFactory.createPool();

    // 创建连接清华BBS的线程
    Thread t1 = new Thread(new TestThread("清华", pool, new InetSocketAddress("bbs.tsinghua.edu.cn", 23)));
    t1.start();
    // 创建连接华南理工BBS的线程
    Thread t2 = new Thread(new TestThread("华南理工", pool, new InetSocketAddress("bbs.gznet.edu.cn", 23)));
    t2.start();
  }

}


参考
1. Jakarta Commons Pool网站:http://jakarta.apache.org/commons/pool/
2. IBM开发者的一篇很好的文章《使用Jakarta Commons Pool处理对象池化》       https://www.ibm.com/developerworks/cn/java/l-common-pool/
分享到:
评论

相关推荐

    commons-pool

    Jakarta Commons Pool是一个用于在Java程序中实现对象池化的组件。它的基本情况是: 主要作者:Morgan Delagrange、Geir Magnusson、Craig McClanahan、Rodney Waldhoff、David Weinrich和Dirk Verbeeck 最新版本:...

    jakarta commons cookbook 电子版

    《Jakarta Commons Cookbook》是Java开发领域中一本非常实用的指南,主要涵盖了Apache Jakarta Commons组件的使用技巧和最佳实践。这本书旨在帮助开发者更好地理解和利用Jakarta Commons库中的各种工具类和模块,...

    Apache Jakarta Commons 使用手册

    ### Apache Jakarta Commons 使用手册知识点详解 #### 一、概述 《Apache Jakarta Commons 使用手册》是一部详细介绍Apache Jakarta Commons项目下的各种Java组件的专业书籍。该书由Will Iverson编写,旨在为...

    jakarta-commons 相关依赖包

    jakarta-commons 相关依赖包,文件列表: commons-attributes-api.jar commons-attributes-compiler.jar commons-beanutils.jar commons-codec.jar commons-collections.jar commons-dbcp.jar commons-digester.jar ...

    commons-pool2-2.11.1-bin.zip

    DBCP(DataBase Connection Pool)是 apache common上的一个 java 连接池项目,也是 tomcat 使用的连接池组件,依赖 于Jakarta commons-pool 对象池机制,DBCP可以直接的在应用程序中使用。 使用DBCP会用到commons-...

    java对象池化技术[参照].pdf

    Jakarta Commons Pool 包含了两个包:`org.apache.commons.pool` 和 `org.apache.commons.pool.impl`,总共有21个类,包括4个抽象类和6个接口。这个组件由多位作者共同开发,如Morgan Delagrange、Geir Magnusson等...

    JAKARTA COMMONS

    27. **Commons Pool**: 提供对象池接口和实现,有助于高效利用资源。 28. **Commons Primitives**: 为基本类型提供了 XML 验证框架,支持国际化验证规则和错误消息。 29. **Commons Resources**: 提供了一个框架来...

    介绍Jakarta Commons的烹饪书

    9. **DBCP和POOL**:数据库连接池组件,如Commons-DBCP和Commons-POOL,它们提高了数据库连接的管理和性能,降低了资源消耗。 10. **Email组件**:发送电子邮件的工具,支持多种邮件协议,如SMTP、SMTPS等,可以...

    Jakarta commons docs API CHM 格式

    commons-pool 提供了通用对象池接口,一个用于创建模块化对象池的工具包,以及通常的对象池实 commons-primitives java 简单类型使用的扩展 commons-proxy 创建动态代理的库 commons-scxml commons-transaction ...

    Iverson book Apache Jakarta Commons[E文版]

    Apache Jakarta Commons是Apache软件基金会的一个项目集合,它提供了一系列实用工具类库,旨在简化Java开发。这个项目的主要目标是创建可重用的Java组件,这些组件涵盖了从数据处理到网络通信的各种领域。Iverson的...

    commons-dbcp和commons-pool

    Apache Commons DBCP是Apache软件基金会的Jakarta项目下的一个子项目,主要功能是提供数据库连接池服务。数据库连接池是一种在应用服务器启动时预创建一定数量的数据库连接,并将这些连接存储在一个池中,当多个用户...

    commons-pool 等jar包

    DBCP(Database Connection Pool)是Apache Jakarta项目中的一个子项目,它利用了commons-pool对象池机制来实现数据库连接的复用,从而减少创建和释放数据库连接时的开销。Tomcat,一个广泛使用的Java应用服务器,...

    Jakarta Commons Online Bookshelf

    《Jakarta Commons在线书架》一书深入探讨了Apache Jakarta Commons库的重要性和使用方法,为读者提供了一套全面的学习资源,旨在帮助Java开发者理解和掌握Jakarta Commons提供的各种工具和组件。以下是对书中提及的...

    Java对象池实现源码

    本篇文章将深入探讨Java对象池的实现原理,以及如何借鉴"Jakarta Commons Pool"组件来设计一个轻量级的对象池。 一、对象池的基本概念 对象池的基本工作流程包括以下几个步骤: 1. 初始化:预创建一定数量的对象并...

    commons-pool-1.5.2-bin.zip

    4. `jakarta-pool-1.5.2.jar`: 这是Apache Commons Pool的核心库文件,包含了所有必需的类和接口,用于实现对象池。 5. `jakarta-pool-1.5.2-sources.jar`: 源代码jar文件,可以用于查看和理解Pool库的内部工作原理...

    jakarta-commons.zip

    以上只是Jakarta Commons项目的一部分,还有其他许多模块,如DBCP(数据库连接池)、Pool(对象池)和BCEL(Byte Code Engineering Library)等。这些组件极大地丰富了Java开发者的工具箱,使得他们能够更加高效地...

    c3p0和dbcp数据源jar包

    它基于Apache的Jakarta Commons Pool对象池机制,同时结合了Jakarta Commons Pool和Jakarta Commons DBCP的优点。C3P0提供了连接池的高级特性,如自动检测失效的连接并进行回收,支持多线程环境下的并发控制,以及...

    Jakarta+Commons+学习

    【Jakarta Commons 学习】 Jakarta Commons 是一个由 Apache 软件基金会维护的 Java 开源项目集合,它提供了大量的实用工具类和组件,极大地丰富了 Java 的标准库功能。这个项目旨在解决常见的编程问题,提高开发...

    dbcp连接池所需jar(commons-collections-3.1.jar,commons-dbcp-1.2.jar,commons-pool-1.6.)

    DBCP(Database Connection Pool)是Apache组织提供的一个开源数据库连接池组件,它的全称为"Jakarta Commons DBCP"。这个连接池库被设计用来管理数据库连接,提高应用程序的性能和效率。在Java应用程序中,频繁地...

Global site tag (gtag.js) - Google Analytics