springboot如何使用mongo做日志存儲
更新時間:2025年06月24日 17:28:01 作者:yololee_
這篇文章主要介紹了springboot如何使用mongo做日志存儲方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
springboot使用mongo做日志存儲
導入依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
實體類
package com.hl.springbootmongodb.pojo;
import lombok.Data;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
//配置MongoDB的表名稱
@Document(collection = "logs")
@Data
public class LogBean {
private String id;
private Integer userId;
private String username;
@DateTimeFormat(pattern="yyyy-MM-dd")
private Date createDate;
private String ip;
private String className;//類名
private String method;//方法名
private String requestURI;//請求
private String responseResults;//響應結果
}
工具類
package com.hl.springbootmongodb.util;
import javax.servlet.http.HttpServletRequest;
public class CommonUtils {
/**
* 默認IP地址
*/
public final static String ERROR_IP = "127.0.0.1";
public static String getUserIP(HttpServletRequest request) {
// 優(yōu)先取 X-Real-IP
String ip = request.getHeader("X-Real-IP");
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("x-forwarded-for");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getRemoteAddr();
if ("0:0:0:0:0:0:0:1".equals(ip)) {
ip = ERROR_IP;
}
}
if ("unknown".equalsIgnoreCase(ip)) {
ip = ERROR_IP;
return ip;
}
int index = ip.indexOf(',');
if (index >= 0) {
ip = ip.substring(0, index);
}
return ip;
}
}
切面類
package com.hl.springbootmongodb.aspect;
import com.hl.springbootmongodb.pojo.LogBean;
import com.hl.springbootmongodb.util.CommonUtils;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
import java.util.Date;
@Component
@Aspect
public class MongoDbLogAspect {
@Autowired
private MongoTemplate mongoTemplate;
//切點的注解 是指那些方法需要被執(zhí)行"AOP"
@Pointcut("execution(* com.hl.springbootmongodb.controller.*.*(..))")
public void logPointCut(){
}
//返回后通知value="logPointCut()"是指通知是在logPointCut()切點返回后通知的
//returning="rtv"是返回值
//@AfterReturning這個注解是返回后通知的注解
@AfterReturning(value="logPointCut()",returning="rtv")
//JoinPoint是連接點的意思我們要獲取到的如類名,方法名,請求參數等都是從連接點中取出來的
public void afterLog(JoinPoint joinpoint, Object rtv) {
System.out.println("進去切點。。。。。");
LogBean logBean = new LogBean();
//獲取類名
String classname = joinpoint.getTarget().getClass().getSimpleName();
//獲取方法名
String method = joinpoint.getSignature().getName();
//獲取請求參數
String requestParam = "";
logBean.setClassName(classname);
logBean.setMethod(method);
logBean.setResponseResults(requestParam);
logBean.setCreateDate(new Date());
//返回值
if (rtv != null) {
logBean.setResponseResults(rtv.toString());
}
//獲取request對象
ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
HttpServletRequest request = requestAttributes.getRequest();
String requestURI = request.getRequestURI();
logBean.setRequestURI(requestURI);
/* UserBean user = (UserBean) request.getSession().getAttribute("user");
if(user!=null){
logBean.setUserId(user.getId());
}*/
//獲取ip地址是封裝好的一個類
String ip = CommonUtils.getUserIP(request);
logBean.setIp(ip);
// User user = (User) SecurityUtils.getSubject().getPrincipal();
// logBean.setUsername(user.getName());
//保存mongodb
mongoTemplate.save(logBean);
System.out.println("日志存儲成功.........");
}
}
controller層
@RestController
public class TestLog {
@PostMapping("/hello")
public String test(){
return "ok";
}
}
配置文件
spring.data.mongodb.uri=mongodb://testuser:password@127.0.0.1:27017/test
測試結果

總結
以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
SpringBoot用JdbcTemplates操作Mysql實例代碼詳解
JdbcTemplate是Spring框架自帶的對JDBC操作的封裝,目的是提供統(tǒng)一的模板方法使對數據庫的操作更加方便、友好,效率也不錯,這篇文章主要介紹了SpringBoot用JdbcTemplates操作Mysql2022-10-10
java.util.NoSuchElementException原因及兩種解決方法
本文主要介紹了java.util.NoSuchElementException原因及兩種解決方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2022-06-06
Mybatis Plus條件構造器ConditionConstructor用法實例解析
這篇文章主要介紹了Mybatis Plus條件構造器ConditionConstructor用法實例解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-08-08

