项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库

2021-08-30 15:37:32

一、 前言

  泥瓦匠又和大家见面了，最近两天我在Code Review ， 顺便代码小小的Refactoring（重构）下。先了解这个项目吧，这次解决的是数据源配置优化。因为这web项目中配置数据源的地方很多。例如 JDBC要配置数据源，Mybatis要配置数据源，Quartz定时任务要配置数据源，还有Log4j存记录到数据库也要配置…

  如题目，兴许大家的疑惑看了前面的说明会明白。这次给大家带来的 数据源配置与优化：log4j 配置数据库连接池Druid。

  提纲：

  • 二、准备知识
  • 三、正文 开始动手吧
  •      、配置文件
  •      、建数据表
  •      、核心代码讲解
  • 四、结论及下载

二、准备知识

  泥瓦匠也是怕自己说不清楚，又不想把Log4j 和 Durid介绍个遍。那样会太麻烦。这次主要是项目实战。所以泥瓦匠也不罗嗦知识准备这块也就是点到为止。

  Log4j 简介
  在应用程序中添加日志记录总的来说基于三个目的：
    监视代码中变量的变化情况，周期性的记录到文件*其他应用进行统计分析工作；
    跟踪代码运行时轨迹，作为日后审计的依据；
    担当集成开发环境中的调试器的作用，向文件或控制台打印代码的调试信息。
  它支持将日志信息输入到数据库，这次我们一Mysql为例说明。我们需要Log4j来将调试信息、操作信息等记录下来，以便后面的审计，这些日志信息包括用户ID、用户姓名、操作类、路径、方法、操作时间、日志信息。

  Druid 简介

  Druid是Java语言中最好的数据库连接池。Druid能够提供强大的监控和扩展功能。不多多介绍了，阿里牛人作品必须精品。详细介绍在：https://github.com/alibaba/druid/wiki/%E5%B8%B8%E8%A7%81%E9%97%AE%E9%A2%98

 

  泥瓦匠的任务很简单，目的是为了数据源配置优化，实现数据源配置的唯一性。泥瓦匠也画了草图，曾经被人说成画图画出鬼画符的我告诉大家：没事，越做越好。如图，设计简单草图就是这样的。

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库

结论：一个项目的配置文件要保持唯一性，就是数据源配置的唯一性。

 

三、正文 开始动手吧

  开始弄吧，为了写这个东西。我就也搞了个demo项目。泥瓦匠很辛苦的，哈哈送钱的上面支付宝哦。哈哈，泡了杯水，准备说这个项目了。下面，泥瓦匠先给出这个项目的结构图，这样我待会讲起来不怎么累。逻辑性比较强吧。如图：

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库

  上面很清楚的写着我需要完成的功能模块。最后那个test，是一个测试的servlet类。大家一看就明白。我先从配置文件说起吧。

配置文件 ：

  dbConfig.properties 记录的是最基础的db配置：url name psd 等，代码如下：

1
2
3
4
5
6
7
8
database.vendor = mysql
db_url = jdbc:mysql://localhost:3307/test
driverClassName= com.mysql.jdbc.Driver
db_user = root
db_password = 123456
showsql= false
devMode = true
validationQuery=SELECT 1

  log4j.properties则是日志的配置，但日志的配置中有一点注意的是如下：

1
2
3
4
5
6
7
8
9
10
log4j.rootLogger=debug,appender1
log4j.appender.appender1=org.apache.log4j.ConsoleAppender
log4j.appender.appender1.layout=org.apache.log4j.TTCCLayout
log4j.logger.test=INFO, db
 
# log db setting
log4j.appender.db=org.nsg.dbsetting.MyJDBCAppender
log4j.appender.db.BufferSize=1
log4j.appender.db.sql=insert into operate_log(handclass,method,createtime,loglevel,logmsg) values ('%C','%M','%d{yyyy-MM-dd HH\:mm\:ss}','%p','%m')
log4j.appender.db.layout=org.apache.log4j.PatternLayout

  在这里，我们要注意两点：

一、设置我们包的下的logger权限，并给予存数据库的权限。

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库

二、db的实现的应用要为你写的引用类。

1
2
# log db setting
log4j.appender.db=org.nsg.dbsetting.MyJDBCAppender

建数据表 ：

然后我们要根据上面配置文件中写的数据库和表格我们要对应的建一个名为test的数据库和一张名为operate_log的表。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
/*
Navicat MySQL Data Transfer
 
Source Server         : Mysql
Source Server Version : 50617
Source Host           : localhost:3307
Source Database       : test
 
Target Server Type    : MYSQL
Target Server Version : 50617
File Encoding         : 65001
 
Date: 2014-12-08 18:46:21
*/
 
SET FOREIGN_KEY_CHECKS=0;
 
-- ----------------------------
-- Table structure for operate_log
-- ----------------------------
DROP TABLE IF EXISTS `operate_log`;
CREATE TABLE `operate_log` (
  `log_id` int(11) NOT NULL AUTO_INCREMENT,
  `handclass` varchar(100) DEFAULT NULL,
  `method` varchar(100) DEFAULT NULL,
  `createtime` varchar(100) DEFAULT NULL,
  `loglevel` varchar(20) DEFAULT NULL,
  `logmsg` text,
  PRIMARY KEY (`log_id`)
) ENGINE=InnoDB AUTO_INCREMENT=23 DEFAULT CHARSET=utf8;

这样我们就可以开始写代码了，泥瓦匠是一个很细节的人。这次博客，我主要是讲下代码中的核心点。因为后面我会把项目提供给你们下载。所以，这里点到为止。

泥瓦匠说：点到为止，所谓师父领进门，修行在个人啊。

核心代码讲解：

  MyJDBCAppender.java 用于Log4j的数据库Session管理[连接池用Druid]。这个肯定是我们得核心思想。这里我就继承了log4j提供的 org.apache.log4j.jdbc.JDBCAppender;然后只要简单的重写了closeConnection和 getConnection方法。如果获取Druid数据库源对象异常的话，我还写了个 取消初始化 的方法uninitialize。代码这边也贴出下，方便大家观看：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
package org.nsg.dbsetting;
 
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
 
import org.apache.log4j.jdbc.JDBCAppender;
import org.apache.log4j.spi.ErrorCode;
import org.nsg.constant.PropertiesConst;
import org.nsg.exception.JdbcException;
import org.nsg.util.MyProperties;
import org.nsg.util.PropertiesUtil;
 
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
 
/**
 * @Description  MyJDBCAppender.java
 * 用于Log4j的数据库Session管理[连接池用Druid]
 * @author 泥沙砖瓦浆木匠
 * @date 2014年12月7日下午1:50:56
 * @version 1.0
 */
public class MyJDBCAppender extends JDBCAppender
{
    /* Druid数据源 */
    private DruidDataSource dataSource;
     
    public MyJDBCAppender()
    {
        super();
    }
     
    @Override
    protected void closeConnection(Connection con)
    {
        try
        {
            /* 如果数据库连接对象不为空和没有被关闭的话，关闭数据库连接 */
            if ( con != null && !con.isClosed())
                con.close();
             
        }
        catch (SQLException e)
        {
            errorHandler.error("Error closing MyJDBCAppender.closeConnection() 's connection",e,ErrorCode.GENERIC_FAILURE);
        }
    }
 
    @Override
    protected Connection getConnection() throws SQLException
    {
        /* 获取数据库配置property */
        MyProperties properties = PropertiesUtil.loadPropertyFile(PropertiesConst.DB_CONFIG);
        String className = String.valueOf(properties.getProperty("driverClassName",""));
        String connUrl = String.valueOf(properties.getProperty("db_url",""));
        String uname = String.valueOf(properties.getProperty("db_user",""));
        String psw = String.valueOf(properties.getProperty("db_password",""));
 
        System.out.println(className);
        System.out.println(connUrl);
        System.out.println(uname);
        System.out.println(psw);
         
        Properties result = new Properties();
        result.put("driverClassName",className);
        result.put("url",connUrl);
        result.put("username",uname);
        result.put("password",psw);
         
        /* 其他配置 自然你也可以自己写property 然后获取set */
        result.put("maxActive","30");
        result.put("minIdle","3");
 
        try
        {
            dataSource = (DruidDataSource) DruidDataSourceFactory.createDataSource(result);
        }
        catch (Exception e)
        {
            /* Druid数据库源对象产生失败后，取消初始化 */
            try {uninitialize();} catch(Exception e2) {}
            throw new JdbcException(e);
        }
         
        return dataSource.getConnection();
    }
 
    /* 取消初始化 */
    public void uninitialize()
    {
        try
        {
            if (dataSource != null)
                dataSource.close();
        }
        catch (Exception e)
        {
            throw new JdbcException(String.format("MyJDBCAppender uninitialize fail (%s)",e));
        }
        finally
        {
            super.close();
        }
    }
     
}

  值得注意的一点是，泥瓦匠为了方便，所以在其中的地方没有获取druid连接池的配置。而是直接写了下面：

1
2
3
/* 其他配置 自然你也可以自己写property 然后获取set */
        result.put("maxActive","30");
        result.put("minIdle","3");

  其实这样写是不好了，我们可以写一个druid.properties然后将连接池的配置放入其中。获取set，for循环set即可。这边我就不实现了。很简单哦，泥瓦匠相信你们。

 

最后我演示下，示例代码：放到tomcat7上，然后运行访问

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库

看到控制台刷出来两条信息，因为我门设置的是log4j.logger.test=INFO, db。

然后我们去查看数据库，这边我用Navicat：

项目重构之数据源配置与优化：log4j 配置数据库连接池Druid，并实现日志存储到数据库

 

四、结论及下载

结论：重构很有意思，慢慢来，一点一点来，就行了。细节成就未来。

上一篇：apache的rewrite规则无法加载问题


下一篇：初入项目，JS可能遇到的问题优化以及处理方法