Cat监控Druid数据库连接池
Cat监控Druid数据库连接池
liangxiao 发表于5个月前
Cat监控Druid数据库连接池
  • 发表于 5个月前
  • 阅读 67
  • 收藏 1
  • 点赞 0
  • 评论 0

腾讯云 技术升级10大核心产品年终让利>>>   

#1、原理 Druid提供了SPI机制的filter,通过添加filter拿到数据库连接池的连接的占用情况。

#2、开发 ##2.1 代码


import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

import com.alibaba.druid.filter.FilterAdapter;
import com.alibaba.druid.filter.FilterChain;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidPooledConnection;
import com.alibaba.fastjson.JSONObject;
import com.dianping.cat.Cat;
import com.dianping.cat.message.Event;
import com.niwodai.inf.cat.dubbo.DubboCat;
import com.niwodai.inf.common.serial.ServialContext;

/*
 * @author Michael Feng
 * @date 2017年7月25日
 * @description 监控数据库连接池
 */
public class DataSourceFilter extends FilterAdapter {

    @Override
    public DruidPooledConnection dataSource_getConnection(FilterChain chain, DruidDataSource dataSource,
                                                          long maxWaitMillis) throws SQLException {
        
          
        try{
            Map<String,Object> params = new HashMap<String,Object>();
            params.put("MaxActive", dataSource.getMaxActive());
            params.put("ActiveCount", dataSource.getActiveCount());
            params.put("PoolingCount", dataSource.getPoolingCount());
            params.put("ConnectCount", dataSource.getConnectCount());
            params.put("InitialSize", dataSource.getInitialSize());
            params.put("MaxIdle", dataSource.getMaxIdle());
            params.put("MinIdle", dataSource.getMinIdle());
            params.put("MaxWait", dataSource.getMaxWait());
            String eventName = "connectionId:(" + dataSource.getID() + ")-SerialID:(" + ServialContext.getCurServial()+")";
            Cat.logEvent("DruidDataSource", eventName, Event.SUCCESS, JSONObject.toJSONString(params));
        }catch(Exception e){
            
        }
        
        return chain.dataSource_connect(dataSource, maxWaitMillis);
    }

}

##2.2 配置 在src/main/resources路径下新增文件夹META-INF,文件夹下新建文件druid-filter.properties,文件内容如下:

druid.filters.cat=com.niwodai.inf.cat.datasource.DataSourceFilter

#3、接入

在datasource的配置文件中增加如下属性

<property name="filters" value="cat" />

#4、参数说明 MaxActive:最大活跃线程数

ActiveCount:同时建立连接的连接数

PoolingCount:线程池中连接数,闲置的连接数

ConnectCount:从启动到现在连接过的次数

InitialSize:启动初始化的连接数

MaxIdle:最大可空闲连接数

MinIdle:最小可空闲的连接数

#5、参考文档 5.1 https://github.com/alibaba/druid/wiki/%E9%85%8D%E7%BD%AE_StatFilter 5.2 https://t.hao0.me/db/2016/06/20/druid-filter.html

共有 人打赏支持
粉丝 19
博文 170
码字总数 36332
×
liangxiao
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: