Spring Boot中使用log4j实现http请求日志入mongodb
之前在《使用AOP统一处理Web请求日志》一文中介绍了如何使用AOP统一记录web请求日志。基本思路是通过aop去切web层的controller实现,获取每个http的内容并通过log4j将日志内容写到应用服务器的文件系统中。
但是当我们在集群中部署应用之后,应用请求的日志被分散记录在了不同应用服务器的文件系统上,这样分散的存储并不利于我们对日志内容的检索。解决日志分散问题的方案多种多样,本文思路以在《使用AOP统一处理Web请求日志》一文的基础之上,扩展log4j实现将日志写入MongoDB。
准备工作
可以先拿Chapter4-2-4工程为基础,进行后续的实验改造。该工程实现了一个简单的REST接口,一个对web层的切面,并在web层切面前后记录http请求的日志内容。
通过自定义appender实现
思路:log4j提供的输出器实现自Appender接口,要自定义appender输出到MongoDB,只需要继承AppenderSkeleton类,并实现几个方法即可完成。
引入mongodb的驱动
在pom.xml中引入下面依赖
<dependency> <groupId>org.mongodb</groupId> <artifactId>mongodb-driver</artifactId> <version>3.2.2</version></dependency> |
实现MongoAppender
编写MongoAppender类继承AppenderSkeleton,实现如下:
public class MongoAppender extends AppenderSkeleton { private MongoClient mongoClient; private MongoDatabase mongoDatabase; private MongoCollection<BasicDBObject> logsCollection; private String connectionUrl; private String databaseName; private String collectionName; @Override protected void append(LoggingEvent loggingEvent) { if(mongoDatabase == null) { MongoClientURI connectionString = new MongoClientURI(connectionUrl); mongoClient = new MongoClient(connectionString); mongoDatabase = mongoClient.getDatabase(databaseName); logsCollection = mongoDatabase.getCollection(collectionName, BasicDBObject.class); } logsCollection.insertOne((BasicDBObject) loggingEvent.getMessage()); } @Override public void close() { if(mongoClient != null) { mongoClient.close(); } } @Override public boolean requiresLayout() { return false; } // 省略getter和setter } |
定义MongoDB的配置参数,可通过log4j.properties配置:
- connectionUrl:连接mongodb的串
- databaseName:数据库名
- collectionName:集合名
定义MongoDB的连接和操作对象,根据log4j.properties配置的参数初始化:
- mongoClient:mongodb的连接客户端
- mongoDatabase:记录日志的数据库
- logsCollection:记录日志的集合
重写append函数:
- 根据log4j.properties中的配置创建mongodb连接
- LoggingEvent提供getMessage()函数来获取日志消息
- 往配置的记录日志的collection中插入日志消息
重写close函数:关闭mongodb的
配置log4j.properties
设置名为mongodb的logger:
- 记录INFO级别日志
- appender实现为com.didispace.log.MongoAppende
- mongodb连接地址:mongodb://localhost:27017
- mongodb数据库名:logs
- mongodb集合名:logs_request
log4j.logger.mongodb=INFO, mongodb# mongodb输出log4j.appender.mongodb=com.didispace.log.MongoAppenderlog4j.appender.mongodb.connectionUrl=mongodb://localhost:27017log4j.appender.mongodb.databaseName=logslog4j.appender.mongodb.collectionName=logs_request |
切面中使用mongodb logger
修改后的代码如下,主要做了以下几点修改:
- logger取名为mongodb的
- 通过getBasicDBObject函数从HttpServletRequest和JoinPoint对象中获取请求信息,并组装成BasicDBObject
- getHeadersInfo函数从HttpServletRequest中获取header信息
- 通过logger.info(),输出BasicDBObject对象的信息到mongodb
@Aspect@Order(1)@Componentpublic class WebLogAspect { private Logger logger = Logger.getLogger("mongodb"); @Pointcut("execution(public * com.didispace.web..*.*(..))") public void webLog(){} @Before("webLog()") public void doBefore(JoinPoint joinPoint) throws Throwable { // 获取HttpServletRequest ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); HttpServletRequest request = attributes.getRequest(); // 获取要记录的日志内容 BasicDBObject logInfo = getBasicDBObject(request, joinPoint); logger.info(logInfo); } private BasicDBObject getBasicDBObject(HttpServletRequest request, JoinPoint joinPoint) { // 基本信息 BasicDBObject r = new BasicDBObject(); r.append("requestURL", request.getRequestURL().toString()); r.append("requestURI", request.getRequestURI()); r.append("queryString", request.getQueryString()); r.append("remoteAddr", request.getRemoteAddr()); r.append("remoteHost", request.getRemoteHost()); r.append("remotePort", request.getRemotePort()); r.append("localAddr", request.getLocalAddr()); r.append("localName", request.getLocalName()); r.append("method", request.getMethod()); r.append("headers", getHeadersInfo(request)); r.append("parameters", request.getParameterMap()); r.append("classMethod", joinPoint.getSignature().getDeclaringTypeName() + "." + joinPoint.getSignature().getName()); r.append("args", Arrays.toString(joinPoint.getArgs())); return r; } private Map<String, String> getHeadersInfo(HttpServletRequest request) { Map<String, String> map = new HashMap<>(); Enumeration headerNames = request.getHeaderNames(); while (headerNames.hasMoreElements()) { String key = (String) headerNames.nextElement(); String value = request.getHeader(key); map.put(key, value); } return map; } } |
代码示例
本文的相关例子可以查看下面仓库中的chapter4-2-5
目录:
- Github:https://github.com/dyc87112/SpringBoot-Learning
- Gitee:https://gitee.com/didispace/SpringBoot-Learning
如果您觉得本文不错,欢迎Star
支持,您的关注是我坚持的动力!
其他补充
上述内容主要提供一个思路去实现自定义日志的输出和管理。我们可以通过jdbc实现日志记录到mongodb,也可以通过spring-data-mongo来记录到mongodb,当然我们也可以输出到其他数据库,或者输出到消息队列等待其他后续处理等。
对于日志记录到mongodb,也可以直接使用log4mongo实现更为方便快捷。
Spring Boot中使用log4j实现http请求日志入mongodb相关推荐
- Spring boot中使用log4j记录日志
之前在Spring Boot日志管理 一文中主要介绍了Spring Boot中默认日志工具(logback)的基本配置内容.对于很多习惯使用log4j的开发者,Spring Boot依然可以很好的支持 ...
- Spring Boot中对log4j进行多环境不同日志级别的控制
之前介绍了在<Spring boot中使用log4j记录日志>,仅通过log4j.properties对日志级别进行控制,对于需要多环境部署的环境不是很方便,可能我们在开发环境大部分模块需 ...
- log4j记录不同的日志_Spring boot中使用log4j记录日志
之前在Spring Boot日志管理 一文中主要介绍了Spring Boot中默认日志工具(logback)的基本配置内容.对于很多习惯使用log4j的开发者,Spring Boot依然可以很好的支持 ...
- Spring Boot 2.1之后如何在启动日志中打印请求路径列表
点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 作者 | 翟永超 来源 | http://blog.di ...
- Spring Boot中如何扩展XML请求和响应的支持
在之前的所有Spring Boot教程中,我们都只提到和用到了针对HTML和JSON格式的请求与响应处理.那么对于XML格式的请求要如何快速的在Controller中包装成对象,以及如何以XML的格式 ...
- Spring Boot中使用AOP统一处理Web请求日志
AOP为Aspect Oriented Programming的缩写,意为:面向切面编程,通过预编译方式和运行期动态代理实现程序功能的统一维护的一种技术.AOP是Spring框架中的一个重要内容,它通 ...
- Spring Boot中扩展XML请求和响应的支持
在Spring Boot中,我们大多时候都只提到和用到了针对HTML和JSON格式的请求与响应处理.那么对于XML格式的请求要如何快速的在Controller中包装成对象,以及如何以XML的格式返回一 ...
- springboot转发http请求_Spring Boot2 系列教程(八)Spring Boot 中配置 Https
https 现在已经越来越普及了,特别是做一些小程序或者公众号开发的时候,https 基本上都是刚需了. 不过一个 https 证书还是挺费钱的,个人开发者可以在各个云服务提供商那里申请一个免费的证书 ...
- Java笔记-Log4j在Spring Boot中的使用
在Java企业级开发中都需要日志记录相关的操作. Maven相关配置如下,首先要去除Spring Boot自带的日志,然后添加log4j2的日志: <dependency><grou ...
最新文章
- 新智能时代颠覆情报的未来
- [转]搞ACM的你伤不起(转自Roba大神)
- 如何配置DDS以使用多个网络接口?How do I configure DDS to work with multiple network interfaces?
- js json数据传递传递、json数据解析
- spring boot打包问题,访问问题
- idea中artifacts、facets、modules是什么意思?
- Django模板自定义标签和过滤器,模板继承(extend),Django的模型层
- JZ32 从上往下打印二叉树
- Kafka设计解析(一)- Kafka背景及架构介绍
- dnsever 邮件记录
- mac电脑用计算机名共享打印机,从Mac连接Windows共享打印机(2)
- 软件体系结构第三章作业
- SHA256算法原理详解
- 网络工程师职场进化手册
- cisco 链路聚合 (自用)
- android记账app开发报告,【安卓开发】简单记账app功能实现开发-期末大作业个人总结...
- 手机百度浏览器怎么设置繁体字_嫌百度太花哨?来看看如何让百度变得极简
- CSS设置文本、段落样式
- HTML5 案例学习笔记
- 案例拆解:元气森林,这些企业微信裂变经验值得你学习
热门文章
- iSCSI存储设备的udev绑定 以及iscsi重启卡住解决方法
- HtmlAgilityPack/xpath
- 一个整数转换成字符串(C/C++自己写的算法)
- Linux的 i2c 驱动框架分析
- pthread 的坑
- MDK中利用宏定义__DATE__和__TIME__设置产品的代码固件版本
- argv python 提示输入_Python解释器
- linux 查看磁盘分区,文件系统,使用情况的命令和相关工具介绍,Linux 查看磁盘分区、文件系统、使用情况的命令和相关工具介绍...
- 怎么用java实现打字功能_怎么用JAVA编写一个打字游戏
- cad完全卸载教程_CAD室内设计中厨房布置实例