开发者社区> 二哥聊RPA> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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

简介:
+关注继续查看

一、 前言

  泥瓦匠又和大家见面了,最近两天我在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

 

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

image

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

 

三、正文 开始动手吧

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

image

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

配置文件

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

1
2
3
4
5
6
7
8
database.vendor = mysql
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权限,并给予存数据库的权限。

image

二、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上,然后运行访问

image

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

然后我们去查看数据库,这边我用Navicat:

image

 

四、结论及下载

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

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Zookeeper的服务器的log4j升级为log4j2的升级方案(忽略配置化兼容问题)
Zookeeper的服务器的log4j升级为log4j2的升级方案(忽略配置化兼容问题)
0 0
Log4j 曝核弹级漏洞,一行配置修复,速改
Log4j 曝核弹级漏洞,一行配置修复,速改
0 0
日志输出之log4j配置
整理一下log4j.properties配置文件的相关内容,留备后用。
0 0
log4j日志文件配置
log4j日志文件配置和使用
630 0
这个 Log4j 的报错,会导致系统的 log4j.xml 配置(失效)被覆盖重置。SLF4J: Class path contains multiple SLF4J bindings
这个 Log4j 的报错,会导致系统的 log4j.xml 配置(失效)被覆盖重置。 2018-04-27 17:31:43.248 org.slf4j.
1598 0
Log4j 与 logback对比、及使用配置
    二、参考文档 1.Log4j 与 logback对比、及使用配置
549 0
+关注
二哥聊RPA
公号「二哥聊RPA」。关注我,一起洞察 RPA ◎ RPA创业者 ◎ 现明堂红木商业顾问,为十月结晶、可啦啦、鑫蜂维等多家企业提供 RPA 咨询服务 ◎ 希望帮助大家在 RPA 上做一些力所能及的事情
文章
问答
文章排行榜
最热
最新
相关电子书
更多
分析性数据库2.0深入技术解析
立即下载
阿里云数据库案例集下载
立即下载
PostgresChina2018_权宗亮_基于odyssey连接池实现企业级PostgreSQL数据分布中间件
立即下载