项目重构之数据源配置与优化:log4j 配置数据库连接池Druid,并实现日志存储到数据库-阿里云开发者社区

开发者社区> 程序员泥瓦匠> 正文

项目重构之数据源配置与优化: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

 

四、结论及下载

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

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

相关文章
LC3视角:Kubernetes下日志采集、存储与处理技术实践
在Kubernetes服务化、日志处理实时化以及日志集中式存储趋势下,Kubernetes日志处理上也遇到的新挑战,包括:容器动态采集、大流量性能瓶颈、日志路由管理等问题。本文介绍了“Logtail + 日志服务 + 生态”架构,介绍了:Logtail客户端在Kubernetes日志采集场景下的优势;日志服务作为基础设施一站式解决实时读写、HTAP两大日志强需求;日志服务数据的开放性以及与云产品、开源社区相结合,在实时计算、可视化、采集上为用户提供的丰富选择。
13413 0
基于Tablestore 实现大规模订单系统海量订单/日志数据分类存储的实践
前言:从最早的互联网高速发展、到移动互联网的爆发式增长,再到今天的产业互联网、物联网的快速崛起,各种各样新应用、新系统产生了众多订单类型的需求,比如电商购物订单、银行流水、运营商话费账单、外卖订单、设备信息等,产生的数据种类和数据量越来越多;其中订单系统就是一个非常广泛、通用的系统。而随着数据规模的快速增长、大数据技术的发展、运营水平的不断提高,包括数据消费的能力要求越来越高,这对支撑订单系统的数据库设计、存储系统也提出了更多的要求。在新的需求下,传统的经典架构面临着诸多挑战,需要进一步思考架构优化,以更好支撑业务发展;
188 0
关于React Native项目在android上UI性能调试实践
我们尽最大的努力来争取使UI组件的性能如丝般顺滑,但有的时候这根本不可能做到。要知道,Android有超过一万种不同型号的手机,而在框架底层进行软件渲染的时候是统一处理的,这意味着你没办法像iOS那样自由。不过有些时候,你还是可以想办法提升应用的性能(有的时候问题根本不是出在原生代码上!) 要想解决应用的性能问题,第一步就是搞明白在每个16毫秒的帧中,时间都去哪儿了。为此,我们会使用一个标准的
2668 0
log4j配置单独日志文件输出
log4j.logger.batteryHistory=ERROR,BD log4j.appender.BD=org.apache.log4j.FileAppender log4j.appender.
872 0
c++ 开源日志库选择
liblogger 待选为 glog、log4cplus、log4cpp、log4cxx 目前准备使用glog,使用方便,性能也不错,待进一步试验,如果有不能满足的功能就转用 log4cplus,功能很全面,不过稍复杂些。
1505 0
C++项目参考解答-求最大公约数
【项目-求最大公约数】(1)输入两个数,并求出其最大公约数 #include <iostream> using namespace std; //自定义函数的原型(即函数声明) int main() { int a,b,g; cin>>a>>b; g=gcd(a,b); cout<<"最大公约数是: "<<g; re
880 0
+关注
程序员泥瓦匠
公号:程序员泥瓦匠,关注交个朋友吧
289
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载