log4j2 mysql_spring boot使用log4j2将日志写入mysql数据库

log4j2官方例子在spring boot中报错而且还是用的是org.apache.commons.dbcp包

我给改了一下使用org.apache.commons.dbcp2包

1.log4j2.xml如下:

method="getDatabaseConnection" />

includeLocation="true">

AsyncLogger 表示是异步插入.需要在pom.xml中插入disruptor引用

com.lmax

disruptor

3.4.1

2.创建LogConnectionFactory类:

package com.malls.common.tool;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.util.concurrent.locks.Lock;

import java.util.concurrent.locks.ReentrantLock;

import javax.sql.DataSource;

import org.apache.commons.dbcp2.ConnectionFactory;

import org.apache.commons.dbcp2.DriverManagerConnectionFactory;

import org.apache.commons.dbcp2.PoolableConnection;

import org.apache.commons.dbcp2.PoolableConnectionFactory;

import org.apache.commons.dbcp2.PoolingDataSource;

import org.apache.commons.pool2.ObjectPool;

import org.apache.commons.pool2.impl.GenericObjectPool;

import com.malls.common.model.DBConfig;

public class LogConnectionFactory {

private static interface Singleton {

final LogConnectionFactory INSTANCE = new LogConnectionFactory();

}

private DataSource dataSource;

private LogConnectionFactory() {

}

private void initDataSource() {

try {

//

// First, we'll create a ConnectionFactory that the

// pool will use to create Connections.

// We'll use the DriverManagerConnectionFactory,

// using the connect string passed in the command line

// arguments.

DBConfig dbConfig = ApplicationConfig.GetDbConfig("dblog");

ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(dbConfig.getUrl(),

dbConfig.getUserName(), dbConfig.getPassword());

//

// Next we'll create the PoolableConnectionFactory, which wraps

// the "real" Connections created by the ConnectionFactory with

// the classes that implement the pooling functionality.

//

PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(connectionFactory,

null);

//

// Now we'll need a ObjectPool that serves as the

// actual pool of connections.

//

// We'll use a GenericObjectPool instance, although

// any ObjectPool implementation will suffice.

//

ObjectPool connectionPool = new GenericObjectPool<>(poolableConnectionFactory);

// Set the factory's pool property to the owning pool

poolableConnectionFactory.setPool(connectionPool);

//

// Finally, we create the PoolingDriver itself,

// passing in the object pool we created.

//

dataSource = new PoolingDataSource<>(connectionPool);

} catch (Exception e) {

// TODO 自动生成的 catch 块

e.printStackTrace();

dataSource = null;

}

}

int i = 0;

private static Lock lock = new ReentrantLock();

public static Connection getDatabaseConnection() throws SQLException {

if (Singleton.INSTANCE.i == 0) {

//这儿如果第一次直接返回连接池的话会报错

//因为PoolableConnectionFactory也使用了log4j记录日志

//这儿是重点

Singleton.INSTANCE.i++;

DBConfig dbConfig = ApplicationConfig.GetDbConfig("dblog");

return DriverManager.getConnection(dbConfig.getUrl(), dbConfig.getUserName(), dbConfig.getPassword());

}

if (Singleton.INSTANCE.dataSource == null) {

lock.lock();

try {

if (Singleton.INSTANCE.dataSource == null) {

Singleton.INSTANCE.initDataSource();

}

} finally {

lock.unlock();

}

}

return Singleton.INSTANCE.dataSource.getConnection();

}

}

要注意注释的地方,第二次才返回连接池

3.创建DBLog类:

package com.malls.common.tool;

import java.time.Duration;

import java.time.LocalDateTime;

import java.util.UUID;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.apache.logging.log4j.message.StructuredDataMessage;

import org.springframework.web.context.request.RequestAttributes;

import org.springframework.web.context.request.RequestContextHolder;

import com.malls.common.model.RequestModel;

public class DBLog {

private static final Logger LOGGER = LogManager.getLogger("AsyncDBLogger");

public static void process(String logType, String content) {

process(logType, content, "");

}

public static void process(String logType, String content, String keyWord) {

StructuredDataMessage msg = getataMessage(logType, content, keyWord);

addMsg(msg, "logLevel", "Process");

LOGGER.info(msg);

}

public static void error(String logType, String content) {

error(logType, content, "");

}

public static void error(String logType, String content, String keyWord) {

StructuredDataMessage msg = getataMessage(logType, content, keyWord);

addMsg(msg, "logLevel", "Error");

LOGGER.error(msg);

}

public static void handle(String logType, String content) {

handle(logType, content, "");

}

public static void handle(String logType, String content, String keyWord) {

StructuredDataMessage msg = getataMessage(logType, content, keyWord);

addMsg(msg, "LogLevel", "Handle");

LOGGER.info(msg);

}

private static StructuredDataMessage getataMessage(String logType, String content, String keyWord) {

String confirm = UUID.randomUUID().toString().replace("-", "");

StructuredDataMessage msg = new StructuredDataMessage(confirm, "", "transfer");

RequestAttributes req = RequestContextHolder.currentRequestAttributes();

RequestModel requestModel = null;

if (req != null) {

requestModel = (RequestModel) req.getAttribute("RequestModel", RequestAttributes.SCOPE_REQUEST);

}

if (requestModel == null) {

requestModel = new RequestModel();

}

addMsg(msg, "RequestKey", requestModel.getRequestKey());

addMsg(msg, "RequestUrl", requestModel.getRequestUrl());

addMsg(msg, "UserName", String.valueOf(requestModel.getCurrentUserId()));

addMsg(msg, "OrderNo", requestModel.getOrderNo());

addMsg(msg, "LogType", logType);

addMsg(msg, "Content", content);

addMsg(msg, "Keyword", keyWord);

addMsg(msg, "ClientIP", requestModel.getClientIP());

long timeLong = Duration.between(requestModel.getBeginRequestTime(), LocalDateTime.now()).toMillis();

addMsg(msg, "TimeLong", String.valueOf(timeLong));

addMsg(msg, "ServerDesc", "777");

addMsg(msg, "RequestServerIP", requestModel.getRequestServerIP());

addMsg(msg, "ServerIP", requestModel.getServerIP());

addMsg(msg, "CurrentApiRequestKey", requestModel.getCurrentApiRequestKey());

addMsg(msg, "LogTime", LocalDateTime.now().toString());

return msg;

}

private static void addMsg(StructuredDataMessage msg, String key, String val) {

if (val == null) {

msg.put(key, "");

} else {

msg.put(key, val);

}

}

}

这样就可以了.

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/554356.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

如何重置IE浏览器?重置IE浏览器的方法

ie浏览器是一款自带的浏览器服务软件&#xff0c;这款软件使用非常的方便&#xff0c;界面使用非常的简洁&#xff0c;浏览器的功能更加的全面&#xff0c;用户可以使用手机快速搜索&#xff0c;那么如何进行IE浏览器的重置呢?如果用户需要使用IE浏览器&#xff0c;想对IE浏览…

Win10系统怎么锁定IE浏览器主页

核心提示&#xff1a;Win10系统怎么锁定IE浏览器主页?一起看看吧! 目前&#xff0c;不少电脑用户都升级了win10系统&#xff0c;不过&#xff0c;关于win10系统的一些使用方法却不是很了解&#xff0c;比如说&#xff1a;当win10系统的IE浏览器被流氓软件窜改的主页网址该怎么…

vs2010 mysql linq to sql 系列_LINQ to SQL 系列 如何使用LINQ to SQL插入、修改、删除数据...

LINQ和 LINQ to SQL 都已经不是一个新事物了&#xff0c;但是我接触的比较晚&#xff0c;本着绝知此事要躬行的态度&#xff0c;决定写这个系列。本文使用的测试环境是VS 2010&#xff0c;和sql server 2005数据库。第一篇 从CUD开始&#xff0c;如何使用LINQ to SQL插入…

如何在IE浏览器中使用和管理RSS订阅源

核心提示&#xff1a;什么是RSS?简单来说&#xff0c;RSS就像微博一样。在你的源有更新的时候把更新推送给你&#xff0c;或者说在网站有更新的时候告诉你更新的内容。而源就好比是那些微博账号。 什么是RSS?简单来说&#xff0c;RSS就像微博一样。在你的源有更新的时候把更…

redis session 超时时间_Shiro性能优化:解决Session频繁读写问题

点击上方蓝色字体&#xff0c;选择“标星公众号”优质文章&#xff0c;第一时间送达作者 | 张永恒来源 | urlify.cn/YjEZNj背景Shiro 提供了强大的 Session 管理功能&#xff0c;基于 Shiro 实现 Session 共享非常方便&#xff0c;只需要定制一个我们自己的SessionDAO&#x…

360浏览器如何拦截和屏蔽网页广告

在浏览网页的时候总会弹出各种烦人的广告&#xff0c;用户可以使用浏览器设置&#xff0c;然后拦截掉网页的广告&#xff0c;操作起来非常的方便&#xff0c;用户可以使用浏览器马上学习起来&#xff0c;感兴趣的用户就一起来学习起来吧!马上就可以为用户提供最便捷的浏览方式&…

如何申请注销腾讯视频账号

今天小编给大家分享“如何申请注销腾讯视频账号”。腾讯视频在电视剧和电影播放过程中无广告&#xff0c;只要点击播放按钮&#xff0c;除了开头的广告外&#xff0c;视频畅快从头看到尾&#xff0c;当然现在有些电视剧直接把广告植入到剧中&#xff0c;哪怕你开了vip一样无法去…

mysql数据库表名大小写敏感_Mysql数据库名和表名的大小写敏感性问题

导读&#xff1a;一直以来&#xff0c;Mysql数据库名和表名的大小写都是个敏感的问题&#xff0c;困扰着Mysql数据库管理员。在 MySQL 中&#xff0c;数据库和表对应于那些目录下的目录和文件。因而&#xff0c;操作系统的敏感性决定数据库和表命名的大小写敏感。这就意味着数据…

手机优酷缓存的视频在哪找

很多人都喜爱在优酷视频上看剧或是影片&#xff0c;有时出门度假旅游或是乘火车等特殊情况&#xff0c;大家必须用手机优酷来下载好一些自身喜爱看的电视连续剧或是影片&#xff0c;便捷那时候没有网络&#xff0c;还可以在手机优酷上看电视剧&#xff0c;进而消磨无趣的時间。…

mysql触发器如果提示_mysql 触发器

1 引言Mysql的触发器和存储过程一样&#xff0c;都是嵌入到mysql的一段程序。触发器是mysql5新增的功能&#xff0c;目前线上凤巢系统、北斗系统以及哥伦布系统使用的数据库均是mysql5.0.45版本&#xff0c;很多程序比如fc-star管理端&#xff0c;sfrd(das)&#xff0c;dorad…

PP视频怎么设置退出程序时清空本地播放记录

本文小编给大家分享PP视频怎么设置退出程序时清空本地播放记录&#xff0c;如果大家在使用PP视频过程当中遇到类似问题&#xff0c;欢迎阅读本文!大家都知道PP视频作为中国最大的视频分享网站&#xff0c;它有非常全面的视频资源。而我们只要通过下载这个客户端&#xff0c;就可…

python中属性是什么意思啊_python中的“对象属性”和一般属性是什么?

假设你有一个类Personclass Person:name "Samuel"age 50country "India"def method1(self):print("Method 1")print(dir(Person))上述程序的输出如下所示&#xff1a;^{pr2}$从上面的输出中可以看到&#xff0c;它返回该对象的有效属性的排序…

PP视频播放视频时如何关闭弹屏

本文小编给大家带来的是PP视频相关的内容。PP视频播放器官方下载电脑版始终以“用户体验”为生命&#xff0c;您可运行PP视频播放器&#xff0c;在线享受奇艺网站内全部免费高清正版视频。不管是哪个视频播放器都会有喜欢和不喜欢的用户&#xff0c;这是正常的情况&#xff0c;…

mysql too many connections_mysql too many connections 解决方法

1、mysql -u root -p 回车输入密码进入mysql2、show processlist;查看连接数&#xff0c;可以发现有很多连接处于sleep状态&#xff0c;这些其实是暂时没有用的&#xff0c;所以可以kill掉3、show variables like "max_connections";查看最大连接数&#xff0c;应该是…

qt更改类名_Qt编写自定义控件属性设计器

以前做.NET开发中&#xff0c;.NET直接就集成了属性设计器&#xff0c;VS不愧是宇宙第一IDE&#xff0c;你能够想到的都给你封装好了&#xff0c;用起来不要太爽&#xff01;因为项目需要自从全面转Qt开发已经6年有余&#xff0c;在工业控制领域&#xff0c;有一些应用场景需要…

搜狐视频怎么开启自动连播

本文播放器家园网给大家整理了搜狐视频怎么开启自动连播方面的内容。搜狐视频支持在线进行加载&#xff0c;离线观看&#xff0c;没有网络一样看高清视频&#xff0c;别说你流量够多用不上&#xff0c;你在电梯里没信号&#xff0c;地铁网速慢。搜狐视频拥有独立的播放界面&…

mysql数据库更改文档_更改MySQL数据库目录位置

更改MySQL数据库目录位置MySQL默认的数据文档存储目录为/var/lib/mysql。假如要把MySQL目录移到/home/data下需要进行下面几步&#xff1a;1、home目录下建立data目录cd /homemkdir data2、把MySQL服务进程停掉&#xff1a;mysqladmin -u root -p shutdown3、把/var/lib/mysql整…

PP视频如何设置默认缓存个数

将来&#xff0c;PP视频将会在多元化的内容储备、个性化的产品体验、定制化营销服务领域继续发力&#xff0c;引领视频体验革命。不断提升连接人与服务的能力&#xff0c;更好的改变人们的生活。PP视频是一款可以电影资源非常丰富的播放器软件&#xff0c;用户可以在这里观看各…

腾讯视频怎么上传自己的视频?

腾讯视频&#xff0c;是定坐落于中国最大视频在线网络媒体&#xff0c;另外也是一款视频播放器。其以丰富多彩的內容、完美的收看感受、方便快捷的登陆方法、二十四小时多服务平台无缝拼接运用感受及其便捷共享的产品特性&#xff0c;满足客户需求在线播放视頻的要求。身旁有精…

sudo mysql压缩备份解压操作_高效管理文件之压缩及解压缩 .bz2 文件

对文件进行压缩&#xff0c;可以通过使用较少的字节对文件中的数据进行编码来显著地减小文件的大小&#xff0c;并且在跨网络的文件的备份和传送时很有用。 另一方面&#xff0c;解压文件意味着将文件中的数据恢复到初始状态。Linux 中有几个文件压缩和解压缩更具&#xff0c;比…