log-record
注意:本仓库最初灵感来源于美团技术博客 ,若您需要寻找的是原文中作者的代码仓库,可以跳转这里 。本仓库从零实现了原文中描述的大部分特性,并吸取大量生产环境实践和内外网用户反馈,随着持续稳定的维护和更新,期望给用户提供更多差异化的功能。
通过Java
注解优雅的记录操作日志,并支持SpEL
表达式,自定义上下文,自定义函数,实体类DIFF
等功能,最终日志可由用户自行采集并处理,或推送至预配置的消息队列,支持SpringBoot1&2&3(JDK8~JDK21)。
采用SpringBoot Starter
的方式,只需一个依赖,一句注解,日志轻松记录,不侵入业务逻辑:
@OperationLog(bizType = "'followerChange'", bizId = "#request.orderId", msg = "'用户' + #queryUserName(#request.userId) + '修改了订单的跟进人:从' + #queryOldFollower(#request.orderId) + '修改到' + #request.newFollower")
public Response<T> function(Request request) {
// 业务执行逻辑
}
SpringBoot1&SpringBoot2(JDK8+)请引用:
<dependency>
<groupId>cn.monitor4all</groupId>
<artifactId>log-record-starter</artifactId>
<version>{最新版本号}</version>
</dependency>
SpringBoot3(JDK17+)请引用:
<dependency>
<groupId>cn.monitor4all</groupId>
<artifactId>log-record-springboot3-starter</artifactId>
<version>{最新版本号}</version>
</dependency>
最新版本号请查阅
Maven
公共仓库
项目背景
大家一定见过下图的操作日志:
在代码层面,如何优雅的记录上面的日志呢?
能想到最粗暴的方式,封装一个操作日志记录类,如下:
String template = "用户%s修改了订单的跟进人:从“%s”修改到“%s”"
LogUtil.log(orderNo, String.format(tempalte, "张三", "李四", "王五"), "张三")
这种方式会导致业务代码被记录日志的代码侵入,对于代码的可读性和可维护性来说是一个灾难。
这个方式显然不够优雅,让我们试试使用注解:
@OperationLog(bizType = "'followerChange'", bizId = "'20211102001'", msg = "'用户 张三 修改了订单的跟进人:从 李四 修改到 王五'")
public Response<T> function(Request request) {
// 业务执行逻辑
}
日志的记录被放到了注解,对业务代码没有侵入。
但是新的问题来了,我们该如何把订单ID、用户信息、数据库里的旧地址、函数入参的新地址传递给注解呢?
Spring
的 SpEL
表达式(Spring Expression Language
) 可以帮助我们,通过引入SpEL
表达式,我们可以获取函数的入参。这样我们就可以对上面的注解进行修改:
- 订单ID:
#request.orderId
- 新地址"王五":
#request.newFollower
@OperationLog(bizType = "'followerChange'", bizId = "#request.orderId", msg = "'用户 张三 修改了订单的跟进人:从 李四 修改到' + #request.newFollower")
public Response<T> function(Request request) {
// 业务执行逻辑
}
如此一来,订单ID和地址的新值就可以通过解析入参动态获取了。
问题还没有结束,通常我们的用户信息(user
),以及老的跟进人(oldFollower
),是需要在方法中查询后才能获取,入参里一般不会包含这些数据。
解决方案也不是没有,我们创建一个可以保存上下文的LogRecordContext
变量,让用户手动传递代码中计算出来的值,再交给SpEL
解析 ,代码如下
@OperationLog(bizType = "'followerChange'", bizId = "#request.orderId", msg = "'用户' + #userName + '修改了订单的跟进人:从' + #oldFollower + '修改到' + #request.newFollower")
public Response<T> function(Request request) {
// 业务执行逻辑
...
// 手动传递日志上下文:用户信息 地址旧值
LogRecordContext.putVariable("userName", queryUserName(request.getUserId()));
LogRecordContext.putVariable("oldFollower", queryOldFollower(request.getOrderId()));
}
什么?你说这不就又侵入了业务逻辑了么?
确实是的,不过这种方法足够便捷易懂,并不会有什么理解的困难。
但是对于有“强迫症”的同学,这样的实现还是不够优雅,我们可以用SpEL
支持的自定义函数,解决这个问题。
SpEL
支持在表达式中传入用户自定义函数,我们将queryUserName
和queryOldFollower
这两个函数提前放入SpEL
的解析器中,SpEL
在解析表达式时,会执行对应函数。
最终,我们的注解变成了这样,并且最终记录了日志:
@OperationLog(bizType = "'followerChange'", bizId = "#request.orderId", msg = "'用户' + #queryUserName(#request.userId) + '修改了订单的跟进人:从' + #queryOldFollower(#request.orderId) + '修改到' + #request.newFollower")
public Response<T> function(Request request) {
// 业务执行逻辑
}
用户 张三 修改了订单的跟进人:从 李四 修改到 王五
以上便是本库的大致实现原理。
项目介绍
本库帮助你通过注解优雅地记录项目中的操作日志,对业务代码无侵入。
本项目特点:
- 快速接入:使用
Spring Boot Starter
实现,用户直接在pom.xml
引入依赖即可使用 - 业务无侵入:无需侵入业务代码,日志切面发生任何异常不会影响原方法执行
SpEL
解析:支持SpEL
表达式- 实体类
Diff
:支持相同甚至不同类对象的Diff
- 条件注解:满足
Condition
条件后才记录日志,通过SpEL
进行解析 - 自定义上下文:支持手动传递键值对,通过
SpEL
进行解析 - 自定义函数:支持注册自定义函数,通过
SpEL
进行解析 - 全局操作人ID:自定义操作人ID获取逻辑
- 指定日志数据管道:自定义操作日志处理逻辑(写数据库,
TLog
等..) - 支持重复注解:同一个方法上可以写多个操作日志注解
- 支持自动重试和兜底处理:支持配置重试次数和处理失败兜底逻辑
SPI
- 支持控制切面执行时机(方法执行前后)
- 支持自定义执行成功判断
- 支持非注解方式手动记录日志
- 自定义消息线程池
- 更多特性等你来发掘...
日志实体(LogDTO)内包含:
logId:生成的UUID
bizId:业务唯一ID
bizType:业务类型
exception:函数执行失败时写入异常信息
operateDate:操作执行时间
success:函数是否执行成功
msg:日志内容
tag:自定义标签
returnStr: 方法执行成功后的返回值(字符串或JSON化实体)
executionTime:方法执行耗时(单位:毫秒)
extra:额外信息
operatorId:操作人ID
List<diffDTO>: 实体类对象Diff数据,包括变更的字段名,字段值,类名等
日志实体复杂示例:
{
"bizId":"1",
"bizType":"testObjectDiff",
"executionTime":0,
"extra":"【用户工号】从【1】变成了【2】 【name】从【张三】变成了【李四】",
"logId":"38f7f417-2cc3-40ed-8c98-2fe3ee057518",
"msg":"【用户工号】从【1】变成了【2】 【name】从【张三】变成了【李四】",
"operateDate":1651116932299,
"operatorId":"操作人",
"returnStr":"{\"id\":1,\"name\":\"张三\"}",
"success":true,
"exception":null,
"tag":"operation",
"diffDTOList":[
{
"diffFieldDTOList":[
{
"fieldName":"id",
"newFieldAlias":"用户工号",
"newValue":2,
"oldFieldAlias":"用户工号",
"oldValue":1
},
{
"fieldName":"name",
"newValue":"李四",
"oldValue":"张三"
}],
"newClassAlias":"用户信息实体",
"newClassName":"cn.monitor4all.logRecord.test.bean.TestUser",
"oldClassAlias":"用户信息实体",
"oldClassName":"cn.monitor4all.logRecord.test.bean.TestUser"
},
{
"diffFieldDTOList":[
{
"fieldName":"id",
"newFieldAlias":"用户工号",
"newValue":2,
"oldFieldAlias":"用户工号",
"oldValue":1
},
{
"fieldName":"name",
"newValue":"李四",
"oldValue":"张三"
}],
"newClassAlias":"用户信息实体",
"newClassName":"cn.monitor4all.logRecord.test.bean.TestUser",
"oldClassAlias":"用户信息实体",
"oldClassName":"cn.monitor4all.logRecord.test.bean.TestUser"
}]
}
使用方法
只需要简单的三步:
第一步: SpringBoot
项目中引入依赖
SpringBoot1&SpringBoot2(JDK8+)请引用:
<dependency>
<groupId>cn.monitor4all</groupId>
<artifactId>log-record-starter</artifactId>
<version>{最新版本号}</version>
</dependency>
SpringBoot3(JDK17+)请引用:
<dependency>
<groupId>cn.monitor4all</groupId>
<artifactId>log-record-springboot3-starter</artifactId>
<version>{最新版本号}</version>
</dependency>
最新版本号请查阅
Maven
公共仓库推荐使用 >= 1.6.x版本
第二步: 配置日志处理方式
支持处理方式:
- 自定义采集处理
- 直接发送至
RabbitMQ
- 直接发送至
RocketMQ
- 直接发送至
SpringCloud Stream
1. 自定义采集处理
若只需要在同一应用内处理日志信息,只需要实现接口IOperationLogGetService
,便可对日志进行处理。
@Component
public class CustomFuncTestOperationLogGetService implements IOperationLogGetService {
@Override
public boolean createLog(LogDTO logDTO) {
log.info("logDTO: [{}]", JSON.toJSONString(logDTO));
return true;
}
}
2. 直接发送至RabbitMQ
配置RabbitMQ
参数
log-record.data-pipeline=rabbitMq
log-record.rabbit-mq-properties.host=localhost
log-record.rabbit-mq-properties.port=5672
log-record.rabbit-mq-properties.username=admin
log-record.rabbit-mq-properties.password=xxxxxx
log-record.rabbit-mq-properties.queue-name=logRecord
log-record.rabbit-mq-properties.routing-key=
log-record.rabbit-mq-properties.exchange-name=logRecord
3. 直接发送至RocketMQ
配置RocketMQ
参数
log-record.data-pipeline=rocketMq
log-record.rocket-mq-properties.topic=logRecord
log-record.rocket-mq-properties.tag=
log-record.rocket-mq-properties.group-name=logRecord
log-record.rocket-mq-properties.namesrv-addr=localhost:9876
4. 直接发送至SpringCloud Stream
配置SpringCloud Stream
参数
log-record.data-pipeline=stream
log-record.stream.destination=logRecord
log-record.stream.group=logRecord
# 为空时 默认为spring.cloud.stream.default-binder指定的Binder
log-record.stream.binder=
# rocketmq binder例子
spring.cloud.stream.rocketmq.binder.name-server=127.0.0.1:9876
spring.cloud.stream.rocketmq.binder.enable-msg-trace=false
第三步: 在需要记录系统操作的方法上,添加注解
@OperationLog(bizType = "'followerChange'", bizId = "#request.orderId", msg = "'用户 张三 修改了订单的跟进人:从 李四 修改到' + #request.newFollower")
public Response<T> function(Request request) {
// 业务执行逻辑
}