欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

对RAM做简单的池化实现

程序员文章站 2022-07-12 20:38:04
...
首先由于项目的关系需要使用IBM的Rational Assert Manager做ROA的资源存储。所以需要编写一个队RAM进行池化的东西。大致实现类似JDBC下DBCP的功能。当然这里记录下的只是利用pool进行简单池化,并没有添加其他额外的功能。后期在使用中可能会增强该方法的功能。

首先列出该池化实现的需要jar:
junit-4.8.2.jar
log4j-1.2.16.jar
commons-pool-1.6.jar
com.ibm.ram.common_7.5.1.v20110224.jar
ramclient-ant.jar
ramclient.jar

首先pool中主要有三个接口:ObjectPool,ObjectPoolFactory和PoolableObjectFactory。这一组接口是基于Object的,而相对的还有一组也是三个接口就是基于KeyObject,底层使用Map实现。这里我们不需要使用Map的这种数据结构,所以只选择了Object讲解。

而ObjectPool接口implement后,主要就是用于实现池存储的功能。
ObjectPoolFactory这个接口主要是用于池的创建。当需要批量创建配置相同的池时,可以实现该工厂接口去批量穿件ObjectPool。
PoolableObjectFactory这个接口主要就是对我们需要池化的对象的创建,销毁,挂起,和激活等操作的管理工厂。

而pool包中,已经implement了以上接口实现了部分类。我们只需要通过继承那些类,稍作添加一些功能和重写一些方法即可。这种方式也是最简单实用的方式。不用自己去实现一些存储的实现。

而这里对于Object的,有genericObject和stackObject。两者只是存储的方式不同而已。前者使用arraylist实现,后者使用stack实现。本人选择arraylist实现的genericObject系列。作为池子的父类。

public class RAMObjectPool extends GenericObjectPool<RAMSession> {

	public RAMObjectPool() {
		super();
	}
	
	public RAMObjectPool(PoolableRAMObjectFactory factory) {
		super(factory);
	}
	
	public RAMObjectPool(PoolableRAMObjectFactory factory,Config config) {
		super(factory, config);
	}
	
	@Override
	public RAMSession borrowObject() throws Exception {
		return borrowObject();
	}

	
	@Override
	public void invalidateObject(RAMSession obj) throws Exception {
		invalidateObject(obj);	
	}

	
	@Override
	public void returnObject(RAMSession obj) throws Exception {
		returnObject(obj);
	}

简简单单就可以对对象进行池化了。

由于这里我们只使用一个池子,所以不使用池子创建的工厂。就再实现一个对象的创建销毁工厂即可。因为这里我们需要使用的功能很简单,所以只是继承了BasePoolableObjectFactory类就可以了。

public class PoolableRAMObjectFactory extends BasePoolableObjectFactory<RAMSession> {

	private static Logger logger = Logger.getLogger(PoolableRAMObjectFactory.class);
	
	private String url = null;
	
	private String userId = null;
	
	private String userPwd = null;
	
	public PoolableRAMObjectFactory(String ramURL, String ramUserID, String ramPassword) {
		url = ramURL;
		userId = ramUserID;
		userPwd = ramPassword;
	}
	/**
	 * create a RAMSession
	 * @return 
	 * @throws Exception
	 */
	@Override
	public RAMSession makeObject() throws Exception {
		// Create a connection to Rational Asset Manager
        RAMSession session = new RAMSession(url,userId, userPwd);
        if(logger.isDebugEnabled())logger.debug("obj is created");
		return session;
	}
	/**
	 * 
	 * @param obj
	 * @return
	 */
	@Override
	public boolean validateObject(RAMSession obj) {
		return true;
	}
	
	@Override
	public void destroyObject(RAMSession obj) throws Exception {
		if(obj!=null) {
			if(logger.isDebugEnabled())logger.debug("obj is destroyed");
			obj.release();
			obj = null;
		}
	}
	
	@Override
	public void activateObject(RAMSession obj) throws Exception {
		
	}
	
	@Override
	public void passivateObject(RAMSession obj) throws Exception {
		if (obj!=null) {
			if(logger.isDebugEnabled())logger.debug("obj is cleared");
			obj.clear();
			obj = null;
		}
	}

}


而对象工厂如果每次都去创建的话,会比较麻烦,而如果写成单例的话,创建出来的RAMSession会不大好管理,所以创建了一个专门用于从池中获取RAMSession进行管理的对象。并用单例模式进行创建。单例模式使用的是bob lee的单例模式。

public class RAMSessionManager {
	
	private static Logger logger = Logger.getLogger(RAMSessionManager.class);
	
	private RAMObjectPool objectPool = null;
	
	private ThreadLocal<RAMSession> localSession = new ThreadLocal<RAMSession>();
	
	private RAMSessionManager() {
		GenericObjectPool.Config config = null;
		Properties properties = BaseConfig.load();
		String ramURL = properties.getProperty("ramURL");
		String ramUserID = properties.getProperty("ramUserID");
		String ramPassword = properties.getProperty("ramPassword");
		try {
			config = LoadObjectPoolConfig.load(properties.getProperty("poolConfigURL"));
		} catch (Exception e) {
			config = null;
		}
		if(config==null) {
			objectPool = new RAMObjectPool(new PoolableRAMObjectFactory(ramURL, ramUserID, ramPassword));
		} else {
			objectPool = new RAMObjectPool(new PoolableRAMObjectFactory(ramURL, ramUserID, ramPassword),config);
		}
		printDebugInfo();
	}
	
	static class RAMSessionHolder {
		public static RAMSessionManager instance = new RAMSessionManager();
	}
	
	public static RAMSessionManager getInstance() {
		return RAMSessionHolder.instance;
	}
	/**
	 * create session
	 * @return
	 * @throws Exception
	 */
	public RAMSession createSession() throws Exception {
		RAMSession obj = objectPool.borrowObject();
		if(obj!=null) {
			printDebugInfo();
			localSession.set(obj);
		} else {
			throw new NullPointerException("RAMSession is null from pool!");
		}
		return obj;
	}
	/**
	 * if created Session get it, else create Session
	 * @return
	 * @throws Exception
	 */
	public RAMSession openSession() throws Exception {
		RAMSession obj = localSession.get();
		if(obj==null) {
			obj = createSession();
		}
		return obj;
	}
	/**
	 * close Session 
	 * @param obj
	 * @throws Exception
	 */
	public void closeSession(RAMSession obj) throws Exception {
		if(obj!=null) {
			objectPool.returnObject(obj);
			printDebugInfo();
		}
	}
	
	private void printDebugInfo() {
		if (logger.isDebugEnabled()) {
			logger.debug("Active number : "+objectPool.getNumActive()+"\t Idle number : "+objectPool.getNumIdle());
		}
	}
}


最后就是BaseConfig和LoadObjectPoolConfig两个配置进行读取类的编写就可以了。这里就不附上代码了。详情请参考附件。
相关标签: java pool RAM