Proxool数据库连接池

1、web.xml中配置监听器

<listener>  
  <listener-class>com.richinfo.listener.InitListener</listener-class>  
</listener>
<context-param>
    <param-name>webAppRootKey</param-name>
    <param-value>webApp.root</param-value>
</context-param>

2、监听器InitListener

public class InitListener implements ServletContextListener {
    private  Logger logger = null;
    @Override
    public void contextDestroyed(ServletContextEvent arg0) {
        destoryPool();// 释放memcached连接池
    }
    
    @Override
    public void contextInitialized(ServletContextEvent arg0) {
        String PFSApiFilePath="";
        logger = LogManager.getLogger(InitListener.class.getName());
        logger.info("-----initMemcachePool......-----");
        //增加定时任务
        addJob("cacheCleanJob","cacheCleanGroup",ContentService.cronExpression ,new CacheCleanTask()); 
        addJob("userTaskJob","userTaskGroup",ContentService.cronUserExpression ,new UserTask()); 
        try {
            PFSApiFilePath=arg0.getServletContext().getRealPath("/")+"WEB-INF" +File.separator+"classes" + File.separator +"PFSApiConfig.xml";
            System.out.println("PFSApiFilePath:" +PFSApiFilePath);
            ReadXMLConfig.readXMLFile(PFSApiFilePath);
            logger.info("-----init FPS readXMLFile is success");
        } catch (Exception e) {
            logger.info("-----init FPS readXMLFile is fail:"+"|path:"+ PFSApiFilePath);
            e.printStackTrace();
        }
        
        logger.info("-----init success......-----");
        String img = "http://ww3.sinaimg.cn/crop.0.53.432.324.240/005M94J9jw1ezrqz0z0qxj30c00ewglu.jpg";
    }
    
    //定时器
    public void addJob(String jobName, String groupName, String cronExpression, Job job)  {
        SchedulerFactory sfw = new StdSchedulerFactory();
        try {
            Scheduler sched = sfw.getScheduler();
            JobDetail jobDetail = new JobDetail(jobName, groupName, job.getClass());// 任务名，任务组，任务执行类
            CronTrigger trigger = new CronTrigger(jobName, cronExpression);// 触发器名,触发器组
            trigger.setCronExpression(cronExpression);// 触发器时间设定
            trigger.setTimeZone(TimeZone.getTimeZone("GMT+8"));  
            sched.scheduleJob(jobDetail, trigger);
            // 启动
            if (!sched.isShutdown())
                sched.start();
        } catch (SchedulerException e) 
        {
            
        } catch (ParseException e) {
            
        }
    }
    
    private void destoryPool() {
        //SockIOPool.getInstance("SockIOPool_UPM").shutDown();
        RedisCached.destroy();
        logger.info("释放memcached pool完成!");
    }
    
    
}

3、定时任务CacheCleanTask

public class CacheCleanTask implements Job {
    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        // 清理MemCached缓存前取出部分缓存信息,并重置缓存时间信息
        String strDate = RedisCached.get("UPMMemCachedIsDayRead"); 
        boolean issucc = false;
        long begin = System.currentTimeMillis();

        if (strDate != null && !"".equals(strDate)) {
            Date DayReadDate = new Date();
            long DateDiffTimeSpan = 0;
            DayReadDate = DateTimeTools.stringToDateTime(strDate, "yyyy-MM-dd HH:mm:ss");
            logInfo += "UPMMemCachedIsDayRead  The last time:" + strDate + "|";
            DateDiffTimeSpan = DateTimeTools.DateDiffTimeSpan(DayReadDate, new Date(), 4);
            logInfo += " DateDiffTimeSpan :" + DateDiffTimeSpan + "M|";
            RedisCached.set("UPMMemCachedIsDayRead", strDate, (int) DateDiffTimeSpan);
        }
        log.info("每日清理缓存成功," + issucc);
        // 清理所有Redis缓存
        issucc = RedisCached.flushAll();
        //刷新所有位置缓存(刷新全国/省/市地区信息)
        loadCache2();
        //将已读到用户和内容的对应关系存储到MemCached中，使用户能优先显示未读的内容
        loadMemUserIsReadCache();
        //刷新 数据源缓存
        LoadDATASOURCECache2();
        //刷新所有位置所有地区的静态文件缓存(本地缓存)
        LoadStaticFile();

        // 可以考虑不刷新所有缓存
        ContentService.MAP_CONTENT_SHOW_RULE.clear();
        ContentService.MAP_CONTENT_SHOW_RULE_TAG.clear();

        log.info("[CacheCleanTask]total cost:{} ms.", System.currentTimeMillis() - begin);
    }
}

4、Proxool.xml连接池配置

<?xml version="1.0" encoding="ISO-8859-1"?>
<!-- the proxool configuration can be embedded within your own application's.
Anything outside the "proxool" tag is ignored. -->
<something-else-entirely>
  <proxool>
    <alias>public</alias>
    <driver-url>jdbc:oracle:thin:@192.168.9.73:1521:oss</driver-url>
    <driver-class>oracle.jdbc.driver.OracleDriver</driver-class>
    <driver-properties>
      <property name="user" value="upm"/>
      <property name="password" value="upm"/>
    </driver-properties>
    <maximum-connection-lifetime>600000</maximum-connection-lifetime>
    <maximum-connection-count>5</maximum-connection-count>
    <house-keeping-test-sql>select CURRENT_DATE FROM dual</house-keeping-test-sql>
  </proxool>
</something-else-entirely>

5、连接池管理工具类

package com.richinfo.dao.base;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

public class DBManager {
    private static Logger log = LogManager.getLogger(DBManager.class);

    /**
     * 默认的数据库链接，链接Oss139 统一位置 管理下的对象
     * 
     * @return Connection
     */
    public static Connection getConnection() {

        try {
            Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return null;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
        Connection conn = null;
        try {
            conn = DriverManager.getConnection("proxool.public");
        } catch (SQLException e) {
            e.printStackTrace();
            log.error("DBManager getConnection null.{}", e);
            return null;
        }
        return conn;
    }

    /**
     * 链接指定的 数据库对象
     * 
     * @param dataBaseName
     * 对象名
     * @return Connection
     */
    public static Connection getConnection(String dataBaseName) {

        try {
            Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return null;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
        Connection conn = null;
        try {
            conn = DriverManager.getConnection("proxool." + dataBaseName);
        } catch (SQLException e) {
            e.printStackTrace();
            return null;
        }
        return conn;
    }

    public static void close(Connection conn, Statement st, ResultSet rs) {

        try {
            if (rs != null)
                rs.close();
        } catch (Exception e) {
            log.error("DBManager close fail rs. {}", e);
        }
        ;
        try {
            if (st != null)
                st.close();
        } catch (Exception e) {
            log.error("DBManager close fail st. {}", e);
        }
        ;
        try {
            if (conn != null)
                conn.close();
        } catch (Exception e) {
            log.error("DBManager close fail conn. {}", e);
        }
    }
}