阿里巴巴druid源码分析之 filter-chain设计模式_JAVA_编程开发_程序员俱乐部

中国优秀的程序员网站程序员频道CXYCLUB技术地图
热搜:
更多>>
 
您所在的位置: 程序员俱乐部 > 编程开发 > JAVA > 阿里巴巴druid源码分析之 filter-chain设计模式

阿里巴巴druid源码分析之 filter-chain设计模式

 2016/9/21 5:32:51  蜗牛天空  程序员俱乐部  我要评论(0)
  • 摘要:druid是号称目前最好的java数据库连接池,温少写点代码中有很多设计模式的思想,其中最重要的一个就是filter-chain设计模式给druid所带来的可扩展性。对此,我很感兴趣,并希望日后借鉴,所以看了看他的源码,以此记录一下。druid中设计到filter-chain设计模式的类或接口主要有一下几个Filter、FilterAdapter、FilterChain、FilterChainImpl、FilterEventAdapter
  • 标签:源码 阿里巴巴 模式 分析 设计 设计模式

druid是号称目前最好的java数据库连接池,温少写点代码中有很多设计模式的思想,其中最重要的一个就是filter-chain设计模式给druid所带来的可扩展性。对此,我很感兴趣,并希望日后借鉴,所以看了看他的源码,以此记录一下。

druid中设计到filter-chain设计模式的类或接口主要有一下几个Filter、FilterAdapter、FilterChain、FilterChainImpl、FilterEventAdapter、FilterManager 以及举例讲讲两个具体的filter:StatFilter、Slf4jLogFilter

?

具体职责划分如下:

Filter接口:定义了过滤器需要关注的事件,以及可以处理的事件

?

FilterChain接口:定义了这个过滤器链可以处理的事件,druid的设计中,这两个接口几乎一样。

?

FilterChainImpl实现类:主要有两个具体作用,其一,具体处理chain中事件的具体事件;其二,将请求分发给下一个filter‘“处理”,注意,这里的处理,并不是去处理这个事件,而是做一些doBefore,doAfter事件。

?

FilterEventAdapter类:将我们关注的具体事件,通过适配器的设计模式,分为doBefore,do,doAfter三种事件

StatFilter、Slf4jLogFilter类:实现了doBefore,doAfter,这样的话,配置了这两个filter的类就可以做一些切面的事情了

?

FilterManager类:工具类,提供了filter的spi方式加载方式,也在于一种解耦,将filter和chain解耦,方便日后扩展。

?

举例数据库的连接过程

其中filter的接口,每个filter只能临时拥有chain,而每个chain拥有filter:

class="java" name="code"> ConnectionProxy connection_connect(FilterChain chain, Properties info) throws SQLException;

?FilterChain接口,druid中,最终执行具体方法的是FilterChainImpl,

ConnectionProxy connection_connect(Properties info) throws SQLException;
 int getFilterSize();

?FilterChainImpl具体如何实现调用和分发请求的呢?请看

 public ConnectionProxy connection_connect(Properties info) throws SQLException {
        if (this.pos < filterSize) {
            return nextFilter().connection_connect(this, info);
        }

        Driver driver = dataSource.getRawDriver();
        String url = dataSource.getRawJdbcUrl();

        Connection nativeConnection = driver.connect(url, info);
        return wrap(nativeConnection, info);
    }

?从这里,我们可以看到,其实具体数据库的连接,没必要每个filter都具体去做,为什么呢,因为具体的数据库连接这一步是固定的,写不出花来的,不需要每一个filter去实现,所以,filterChainImpl帮我们做了,这个也是filter-chain和其他的chain不同的地方,它的filter更关注切面的处理。而这里好像也看不出来怎么分发,

请看下面代码:

  private Filter nextFilter() {
        Filter filter = getFilters().get(pos++);
        return filter;
    }

?其实他就是遍历了list,记住list的偏移量,一个个取出来filter的

ok,到这里我们就可以看看filter具体怎样处理事件的。根据上面说的,每个事件被分成了doBefore,do,doAfter那么这是在哪里被切分的呢?这时候就引出了FilterEventAdapter类了

  public ConnectionProxy connection_connect(FilterChain chain, Properties info) throws SQLException {
        connection_connectBefore(chain, info);

        ConnectionProxy connection = super.connection_connect(chain, info);

        connection_connectAfter(connection);

        return connection;
    }

    public void connection_connectBefore(FilterChain chain, Properties info) {

    }

    public void connection_connectAfter(ConnectionProxy connection) {

    }

?看见了吧,这里就被分成了三个事件了,所以,我们可以肯定,每个filter都是继承的FilterEventAdapter

 public ConnectionProxy connection_connect(FilterChain chain, Properties info) throws SQLException {
        ConnectionProxy connection = null;
        {
            long startNano = System.nanoTime();
            long startTime = System.currentTimeMillis();

            long nanoSpan;
            long nowTime = System.currentTimeMillis();

            JdbcDataSourceStat dataSourceStat = chain.getDataSource().getDataSourceStat();
            dataSourceStat.getConnectionStat().beforeConnect();
            try {
                connection = chain.connection_connect(info);
                nanoSpan = System.nanoTime() - startNano;
            } catch (SQLException ex) {
                dataSourceStat.getConnectionStat().connectError(ex);
                throw ex;
            }
            dataSourceStat.getConnectionStat().afterConnected(nanoSpan);

            if (connection != null) {
                JdbcConnectionStat.Entry statEntry = getConnectionInfo(connection);

                dataSourceStat.getConnections().put(connection.getId(), statEntry);

                statEntry.setConnectTime(new Date(startTime));
                statEntry.setConnectTimespanNano(nanoSpan);
                statEntry.setEstablishNano(System.nanoTime());
                statEntry.setEstablishTime(nowTime);
                statEntry.setConnectStackTrace(new Exception());

                dataSourceStat.getConnectionStat().setActiveCount(dataSourceStat.getConnections().size());
            }
        }
        return connection;
    }

?从标红代码中可以看到,果然如此,druid的filter-chain就是这样设计的。FilterManager工具类就不用过多介绍了。

?

?

?

?

上一篇: java 虚拟机-内存管理 下一篇: 复合控件
发表评论
用户名: 匿名