SpringAop實現(xiàn)操作日志記錄
更新時間：2020年12月29日 17:34:58 作者：經(jīng)典雞翅
這篇文章主要介紹了SpringAop實現(xiàn)操作日志記錄的方法，幫助大家更好的理解和使用SpringAop，感興趣的朋友可以了解下
前言
大家好，這里是經(jīng)典雞翅，今天給大家?guī)硪黄赟pringAop實現(xiàn)的操作日志記錄的解決的方案。大家可能會說，切，操作日志記錄這么簡單的東西，老生常談了。不！
網(wǎng)上的操作日志一般就是記錄操作人，操作的描述，ip等。好一點的增加了修改的數(shù)據(jù)和執(zhí)行時間。那么！我這篇有什么不同呢！今天這種不僅可以記錄上方所說的一切，還增加記錄了操作前的數(shù)據(jù)，錯誤的信息，堆棧信息等。正文開始~~~~~
思路介紹
記錄操作日志的操作前數(shù)據(jù)是需要思考的重點。我們以修改場景來作為探討。當我們要完全記錄數(shù)據(jù)的流向的時候，我們必然要記錄修改前的數(shù)據(jù)，而前臺進行提交的時候，只有修改的數(shù)據(jù)，那么如何找到修改前的數(shù)據(jù)呢。有三個大的要素，我們需要知道修改前數(shù)據(jù)的表名，表的字段主鍵，表主鍵的值。這樣通過這三個屬性，我們可以很容易的拼出 select * from 表名 where 主鍵字段 = 主鍵值。我們就獲得了修改前的數(shù)據(jù)，轉(zhuǎn)換為json之后就可以存入到數(shù)據(jù)庫中了。如何獲取三個屬性就是重中之重了。我們采取的方案是通過提交的映射實體，在實體上打上注解，根據(jù) Java 的反射取到值。再進一步拼裝獲得對象數(shù)據(jù)。那么AOP是在哪里用的呢，我們需要在記錄操作日志的方法上，打上注解，再通過切面獲取到切點，一切的數(shù)據(jù)都通過反射來進行獲得。
定義操作日志注解
既然是基于spinrg的aop實現(xiàn)切面。那么必然是需要一個自定義注解的。用來作為切點。我們定義的注解，可以帶一些必要的屬性，例如操作的描述，操作的類型。操作的類型需要說一下，我們分為新增、修改、刪除、查詢。那么只有修改和刪除的時候，我們需要查詢一下修改前的數(shù)據(jù)。其他兩種是不需要的，這個也可以用來作為判斷。
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface OperateLog {
String operation() default "";
String operateType() default "";
}
定義用于找到表和表主鍵的注解
表和表主鍵的注解打在實體上，內(nèi)部有兩個屬性 tableName 和 idName。這兩個屬性的值獲得后，可以進行拼接 select * from 表名 where 主鍵字段。
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface SelectTable {
String tableName() default "";
String idName() default "";
}
定義獲取主鍵值的注解
根據(jù)上面所說的三個元素，我們還缺最后一個元素主鍵值的獲取，用于告訴我們，我們應該從提交的請求的那個字段，拿到其中的值。
@Target({ElementType.FIELD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface SelectPrimaryKey {
}
注解的總結(jié)
有了上面的三個注解，注解的準備工作已經(jīng)進行完畢。我們通過反射取到數(shù)據(jù)，可以獲得一切。接下來開始實現(xiàn)切面，對于注解的值進行拼接處理，最終存入到我們的數(shù)據(jù)庫操作日志表中。
切面的實現(xiàn)
對于切面來說，我們需要實現(xiàn)切點、數(shù)據(jù)庫的插入、反射的數(shù)據(jù)獲取。我們先分開進行解釋，最后給出全面的實現(xiàn)代碼。方便大家的理解和學習。
切面的定義
基于spring的aspect進行聲明這是一個切面。
@Aspect
@Component
public class OperateLogAspect {
}
切點的定義
切點就是對所有的打上OperateLog的注解的請求進行攔截和加強。我們使用annotation進行攔截。
@Pointcut("@annotation(com.jichi.aop.operateLog.OperateLog)")
private void operateLogPointCut(){
}
獲取請求ip的共用方法
private String getIp(HttpServletRequest request){
String ip = request.getHeader("X-forwarded-for");
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("Proxy-Client-IP");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("WL-Proxy-Client-IP");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("HTTP_CLIENT_IP");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("HTTP_X_FORWARDED_FOR");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getRemoteAddr();
}
return ip;
}
數(shù)據(jù)庫的日志插入操作
我們將插入數(shù)據(jù)庫的日志操作進行單獨的抽取。
private void insertIntoLogTable(OperateLogInfo operateLogInfo){
operateLogInfo.setId(UUID.randomUUID().toString().replace("-",""));
String sql="insert into log values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
jdbcTemplate.update(sql,operateLogInfo.getId(),operateLogInfo.getUserId(),
operateLogInfo.getUserName(),operateLogInfo.getOperation(),operateLogInfo.getMethod(),
operateLogInfo.getModifiedData(),operateLogInfo.getPreModifiedData(),
operateLogInfo.getResult(),operateLogInfo.getErrorMessage(),operateLogInfo.getErrorStackTrace(),
operateLogInfo.getExecuteTime(),operateLogInfo.getDuration(),operateLogInfo.getIp(),
operateLogInfo.getModule(),operateLogInfo.getOperateType());
}
環(huán)繞通知的實現(xiàn)
日志的實體類實現(xiàn)
@TableName("operate_log")
@Data
public class OperateLogInfo {
//主鍵id
@TableId
private String id;
//操作人id
private String userId;
//操作人名稱
private String userName;
//操作內(nèi)容
private String operation;
//操作方法名稱
private String method;
//操作后的數(shù)據(jù)
private String modifiedData;
//操作前數(shù)據(jù)
private String preModifiedData;
//操作是否成功
private String result;
//報錯信息
private String errorMessage;
//報錯堆棧信息
private String errorStackTrace;
//開始執(zhí)行時間
private Date executeTime;
//執(zhí)行持續(xù)時間
private Long duration;
//ip
private String ip;
//操作類型
private String operateType;
}
準備工作全部完成。接下來的重點是對環(huán)繞通知的實現(xiàn)。思路分為數(shù)據(jù)處理、異常捕獲、finally執(zhí)行數(shù)據(jù)庫插入操作。環(huán)繞通知的重點類就是ProceedingJoinPoint ，我們通過它的getSignature方法可以獲取到打在方法上注解的值。例如下方。
MethodSignature signature = (MethodSignature) pjp.getSignature(); OperateLog declaredAnnotation = signature.getMethod().getDeclaredAnnotation(OperateLog.class); operateLogInfo.setOperation(declaredAnnotation.operation()); operateLogInfo.setModule(declaredAnnotation.module()); operateLogInfo.setOperateType(declaredAnnotation.operateType()); //獲取執(zhí)行的方法 String method = signature.getDeclaringType().getName() + "." + signature.getName(); operateLogInfo.setMethod(method); String operateType = declaredAnnotation.operateType();
獲取請求的數(shù)據(jù)，也是通過這個類來實現(xiàn)，這里有一點是需要注意的，就是我們要約定參數(shù)的傳遞必須是第一個參數(shù)。這樣才能保證我們?nèi)〉降臄?shù)據(jù)是提交的數(shù)據(jù)。
if(pjp.getArgs().length>0){
Object args = pjp.getArgs()[0];
operateLogInfo.setModifiedData(new Gson().toJson(args));
}
接下來的一步就是對修改前的數(shù)據(jù)進行拼接。之前我們提到過如果是修改和刪除，我們才會進行數(shù)據(jù)的拼接獲取，主要是通過類來判斷書否存在注解，如果存在注解，那么就要判斷注解上的值是否是控制或者，非空才能正確的進行拼接。取field的值的時候，要注意私有的變量需要通過setAccessible(true)才可以進行訪問。
if(GlobalStaticParas.OPERATE_MOD.equals(operateType) ||
GlobalStaticParas.OPERATE_DELETE.equals(operateType)){
String tableName = "";
String idName = "";
String selectPrimaryKey = "";
if(pjp.getArgs().length>0){
Object args = pjp.getArgs()[0];
//獲取操作前的數(shù)據(jù)
boolean selectTableFlag = args.getClass().isAnnotationPresent(SelectTable.class);
if(selectTableFlag){
tableName = args.getClass().getAnnotation(SelectTable.class).tableName();
idName = args.getClass().getAnnotation(SelectTable.class).idName();
}else {
throw new RuntimeException("操作日志類型為修改或刪除，實體類必須指定表面和主鍵注解！");
}
Field[] fields = args.getClass().getDeclaredFields();
Field[] fieldsCopy = fields;
boolean isFindField = false;
int fieldLength = fields.length;
for(int i = 0; i < fieldLength; ++i) {
Field field = fieldsCopy[i];
boolean hasPrimaryField = field.isAnnotationPresent(SelectPrimaryKey.class);
if (hasPrimaryField) {
isFindField = true;
field.setAccessible(true);
selectPrimaryKey = (String)field.get(args);
}
}
if(!isFindField){
throw new RuntimeException("實體類必須指定主鍵屬性！");
}
}
if(StringUtils.isNotEmpty(tableName) &&
StringUtils.isNotEmpty(idName)&&
StringUtils.isNotEmpty(selectPrimaryKey)){
StringBuffer sb = new StringBuffer();
sb.append(" select * from ");
sb.append(tableName);
sb.append(" where ");
sb.append(idName);
sb.append(" = ? ");
String sql = sb.toString();
try{
List<Map<String, Object>> maps = jdbcTemplate.queryForList(sql, selectPrimaryKey);
if(maps!=null){
operateLogInfo.setPreModifiedData(new Gson().toJson(maps));
}
}catch (Exception e){
e.printStackTrace();
throw new RuntimeException("查詢操作前數(shù)據(jù)出錯！");
}
}else {
throw new RuntimeException("表名、主鍵名或主鍵值 存在空值情況，請核實！");
}
}else{
operateLogInfo.setPreModifiedData("");
}
切面的完整實現(xiàn)代碼
@Aspect
@Component
public class OperateLogAspect {
@Autowired
private JdbcTemplate jdbcTemplate;
@Pointcut("@annotation(com.jichi.aop.operateLog.OperateLog)")
private void operateLogPointCut(){
}
@Around("operateLogPointCut()")
public Object around(ProceedingJoinPoint pjp) throws Throwable {
Object responseObj = null;
OperateLogInfo operateLogInfo = new OperateLogInfo();
String flag = "success";
try{
HttpServletRequest request = SpringContextUtil.getHttpServletRequest();
DomainUserDetails currentUser = SecurityUtils.getCurrentUser();
if(currentUser!=null){
operateLogInfo.setUserId(currentUser.getId());
operateLogInfo.setUserName(currentUser.getUsername());
}
MethodSignature signature = (MethodSignature) pjp.getSignature();
OperateLog declaredAnnotation = signature.getMethod().getDeclaredAnnotation(OperateLog.class);
operateLogInfo.setOperation(declaredAnnotation.operation());
operateLogInfo.setModule(declaredAnnotation.module());
operateLogInfo.setOperateType(declaredAnnotation.operateType());
//獲取執(zhí)行的方法
String method = signature.getDeclaringType().getName() + "." + signature.getName();
operateLogInfo.setMethod(method);
String operateType = declaredAnnotation.operateType();
if(pjp.getArgs().length>0){
Object args = pjp.getArgs()[0];
operateLogInfo.setModifiedData(new Gson().toJson(args));
}
if(GlobalStaticParas.OPERATE_MOD.equals(operateType) ||
GlobalStaticParas.OPERATE_DELETE.equals(operateType)){
String tableName = "";
String idName = "";
String selectPrimaryKey = "";
if(pjp.getArgs().length>0){
Object args = pjp.getArgs()[0];
//獲取操作前的數(shù)據(jù)
boolean selectTableFlag = args.getClass().isAnnotationPresent(SelectTable.class);
if(selectTableFlag){
tableName = args.getClass().getAnnotation(SelectTable.class).tableName();
idName = args.getClass().getAnnotation(SelectTable.class).idName();
}else {
throw new RuntimeException("操作日志類型為修改或刪除，實體類必須指定表面和主鍵注解！");
}
Field[] fields = args.getClass().getDeclaredFields();
Field[] fieldsCopy = fields;
boolean isFindField = false;
int fieldLength = fields.length;
for(int i = 0; i < fieldLength; ++i) {
Field field = fieldsCopy[i];
boolean hasPrimaryField = field.isAnnotationPresent(SelectPrimaryKey.class);
if (hasPrimaryField) {
isFindField = true;
field.setAccessible(true);
selectPrimaryKey = (String)field.get(args);
}
}
if(!isFindField){
throw new RuntimeException("實體類必須指定主鍵屬性！");
}
}
if(StringUtils.isNotEmpty(tableName) &&
StringUtils.isNotEmpty(idName)&&
StringUtils.isNotEmpty(selectPrimaryKey)){
StringBuffer sb = new StringBuffer();
sb.append(" select * from ");
sb.append(tableName);
sb.append(" where ");
sb.append(idName);
sb.append(" = ? ");
String sql = sb.toString();
try{
List<Map<String, Object>> maps = jdbcTemplate.queryForList(sql, selectPrimaryKey);
if(maps!=null){
operateLogInfo.setPreModifiedData(new Gson().toJson(maps));
}
}catch (Exception e){
e.printStackTrace();
throw new RuntimeException("查詢操作前數(shù)據(jù)出錯！");
}
}else {
throw new RuntimeException("表名、主鍵名或主鍵值 存在空值情況，請核實！");
}
}else{
operateLogInfo.setPreModifiedData("");
}
//操作時間
Date beforeDate = new Date();
Long startTime = beforeDate.getTime();
operateLogInfo.setExecuteTime(beforeDate);
responseObj = pjp.proceed();
Date afterDate = new Date();
Long endTime = afterDate.getTime();
Long duration = endTime - startTime;
operateLogInfo.setDuration(duration);
operateLogInfo.setIp(getIp(request));
operateLogInfo.setResult(flag);
}catch (RuntimeException e){
throw new RuntimeException(e);
}catch (Exception e){
flag = "fail";
operateLogInfo.setResult(flag);
operateLogInfo.setErrorMessage(e.getMessage());
operateLogInfo.setErrorStackTrace(e.getStackTrace().toString());
e.printStackTrace();
}finally {
insertIntoLogTable(operateLogInfo);
}
return responseObj;
}
private void insertIntoLogTable(OperateLogInfo operateLogInfo){
operateLogInfo.setId(UUID.randomUUID().toString().replace("-",""));
String sql="insert into energy_log values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
jdbcTemplate.update(sql,operateLogInfo.getId(),operateLogInfo.getUserId(),
operateLogInfo.getUserName(),operateLogInfo.getOperation(),operateLogInfo.getMethod(),
operateLogInfo.getModifiedData(),operateLogInfo.getPreModifiedData(),
operateLogInfo.getResult(),operateLogInfo.getErrorMessage(),operateLogInfo.getErrorStackTrace(),
operateLogInfo.getExecuteTime(),operateLogInfo.getDuration(),operateLogInfo.getIp(),
operateLogInfo.getModule(),operateLogInfo.getOperateType());
}
private String getIp(HttpServletRequest request){
String ip = request.getHeader("X-forwarded-for");
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("Proxy-Client-IP");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("WL-Proxy-Client-IP");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("HTTP_CLIENT_IP");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("HTTP_X_FORWARDED_FOR");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getRemoteAddr();
}
return ip;
}
}
示例的使用方式
針對于示例來說我們要在controller上面打上操作日志的注解。
@PostMapping("/updateInfo")
@OperateLog(operation = "修改信息",operateType = GlobalStaticParas.OPERATE_MOD)
public void updateInfo(@RequestBody Info info) {
service.updateInfo(info);
}
針對于Info的實體類，我們則要對其中的字段和表名進行標識。
@Data
@SelectTable(tableName = "info",idName = "id")
public class Info {
@SelectPrimaryKey
private String id;
private String name;
}
總結(jié)
文章寫到這，也就結(jié)束了，文中難免有不足，歡迎大家批評指正
以上就是SpringAop實現(xiàn)操作日志記錄的詳細內(nèi)容，更多關(guān)于SpringAop 操作日志記錄的資料請關(guān)注腳本之家其它相關(guān)文章！
您可能感興趣的文章:
- SpringBoot使用AOP實現(xiàn)統(tǒng)一角色權(quán)限校驗
- Spring AOP實現(xiàn)功能權(quán)限校驗功能的示例代碼
- SpringBoot中使用AOP實現(xiàn)日志記錄功能
- SpringBoot使用AOP實現(xiàn)日志記錄功能詳解
- Spring AOP如何自定義注解實現(xiàn)審計或日志記錄(完整代碼)
- 在springboot中使用AOP進行全局日志記錄
- Spring AOP實現(xiàn)復雜的日志記錄操作(自定義注解)
- springMVC自定義注解,用AOP來實現(xiàn)日志記錄的方法
- 使用Spring AOP做接口權(quán)限校驗和日志記錄
相關(guān)文章
這篇文章主要介紹了String轉(zhuǎn)JSONObject，本文通過實例代碼給大家介紹兩種方式轉(zhuǎn)換，結(jié)合實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-07-07
一般情況下,在SpringBoot項目開發(fā)完成進行服務器部署時,都是打成JAR包進行部署運行的,但是在有些情況下也需要將其打成War包使用Tomcat進行部署,本篇文章就簡單介紹一下SpringBoot如何打成War包,需要的朋友可以參考下2024-10-10
DeferredResult是Spring中處理異步請求的強大工具,可以幫助改善應用程序的性能和用戶體驗,本文就來介紹一下Spring中DeferredResult異步處理,感興趣的可以了解一下2023-12-12
RabbitMQ是開源的消息隊列服務器,實現(xiàn)了AMQP高級消息隊列協(xié)議標準,AMQP?是一種應用層協(xié)議,為面向消息的中間件設計,基于此協(xié)議的客戶端與消息中間件可傳遞消息,并不受產(chǎn)品、開發(fā)語言等條件的限制,這篇文章主要介紹了Springboot集成RabbitMQ的過程,需要的朋友可以參考下2024-04-04
這篇文章主要介紹了使用Feign調(diào)用第三方http接口，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
java執(zhí)行SQL語句實現(xiàn)查詢的通用方法詳解
這篇文章主要介紹了java執(zhí)行SQL語句實現(xiàn)查詢的通用方法詳解，具有一定借鑒價值，需要的朋友可以參考下。2017-12-12
Java中的String類默認是Unicode編碼,大家平常所說的UTF-8就是使用最廣的一種unicode的實現(xiàn)方式,以下我們還是來看一下Java中的字符編碼問題處理心得總結(jié):2016-06-06
這篇文章主要介紹了Spring中依賴注入(DI)幾種方式解讀,構(gòu)造器依賴注入通過容器觸發(fā)一個類的構(gòu)造器來實現(xiàn)的,該類有一系列參數(shù),每個參數(shù)代表一個對其他類的依賴,需要的朋友可以參考下2024-01-01
IntelliJ IDEA中ajax開發(fā)實現(xiàn)分頁查詢示例
這篇文章主要介紹了IntelliJ IDEA中ajax開發(fā)實現(xiàn)分頁查詢，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-03-03
淺談Java序列化和反序列化為何要實現(xiàn)Serializable接口
這篇文章主要介紹了淺談Java序列化和反序列化為何要實現(xiàn)Serializable接口,序列化最重要的作用是在傳遞和保存對象時.保證對象的完整性和可傳遞性,對象轉(zhuǎn)換為有序字節(jié)流,以便在網(wǎng)絡上傳輸或者保存在本地文件中,需要的朋友可以參考下2023-12-12