这里的日志主要是记录用户在平台上的操作、以及操作结果。实现思路,则重点记录
用户发送请求中的部分数据,以及执行后返回的结果在写入响应body前拿到controller返回数据。将这两个部分的数据保存到对应的日志表中
-- ----------------------------------------------------------------
-- 用户操作日志表
-- ----------------------------------------------------------------
DROP TABLE IF EXISTS `LOG`;
CREATE TABLE `LOG` (
`ID` INT(12) NOT NULL AUTO_INCREMENT COMMENT '日志编号',
`LOG_MODULE` VARCHAR(50) COMMENT '操作模块',
`REQUEST_IP` VARCHAR(20) COMMENT '请求IP',
`USER_ID` INT(11) NOT NULL COMMENT '用户编号',
`ROLE_NAME` VARCHAR(50) COMMENT '角色名称',
`USER_NAME` VARCHAR(50) COMMENT '用户名称',
`LOG_ACTION` VARCHAR(50) COMMENT '操作行为',
`LOG_RESULT` VARCHAR(20) DEFAULT NULL COMMENT '请求结果',
`LOG_TIME` TIMESTAMP COMMENT '请求时间',
PRIMARY KEY (`ID`)
) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=UTF8;
-- ----------------------------------------------
-- 用户日志记录的请求初始如下
-- ----------------------------------------------
DROP TABLE IF EXISTS `LOG_ACTION`;
CREATE TABLE `LOG_ACTION` (
`ID` INT(11) NOT NULL AUTO_INCREMENT COMMENT '权限ID',
`ACTION_URI` VARCHAR(100) COMMENT 'URI',
`ACTION_MODULE` VARCHAR(100) COMMENT '操作所属的模块',
`ACTION_DESC` VARCHAR(200) COMMENT '动作描述',
UNIQUE INDEX index_action(ACTION_URI),
PRIMARY KEY (`ID`)
) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=UTF8;
-- 可插入如下初始数据
insert into log_action(action_uri,action_Module,action_desc) values ('/abc/bcd.do','用户中心','新建用户');
....等
/**
* Copyright: Copyright (c) 2017 LanRu-Caifu
* @author
* @ClassName: ActionUrlCache.java
* @Description: 缓存初始化需要拦截请求保存到日志
* @version: v1.0.0
*/
public final class ActionUrlCache {
private ActionUrlCache(){}
//缓存地区服务地址
private static final ConcurrentHashMap<String, String> actionCache = new ConcurrentHashMap<>();
//获取缓存
public static ConcurrentHashMap<String, String> getActionCache(){
return actionCache;
}
//添加服务地址
public static void addService(String k ,String v){
//重复覆盖
actionCache.put(k,v);
}
//是否存在指定的key
public static boolean isExist(String k){
return actionCache.containsKey(k);
}
//判读当前缓存是否为空
public static boolean isEmpyt(){
return actionCache.size()<=0;
}
。。。省略
}
/**
* Copyright: Copyright (c) 2017 LanRu-Caifu
* @author
* @ClassName: InitServiceUrl.java
* @Description: 平台启动初始化某些数据
* @version: v1.0.0
*/
@Component
public class InitServiceUrl implements InitializingBean {
private static final Logger LOGGER = Logger.getLogger(InitServiceUrl.class);
@Resource
private LogActionService lAS;
//初始化方法
@Override
public void afterPropertiesSet() throws Exception {
List<LogAction> logActions = lAS.getAllAction();
if(null == logActions){
LOGGER.error("没有配置日志拦截信息");
return ;
}
for(LogAction logAction:logActions){
ActionUrlCache.addService(logAction.getActionUri(), logAction.getActionDesc());
}
}
}
@Repository
public class AccessInterceptor implements HandlerInterceptor {
private static final Logger LOGGER = Logger.getLogger(AccessInterceptor.class);
。。。省略部分
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)
throws Exception {
。。。省略部分
String request_uri = request.getRequestURI();
//该uri存在预设,且为springmvc Controller处理
if (ActionUrlCache.isExist(request_uri) && handler instanceof HandlerMethod) {
RequestModel requestModel = new RequestModel();
requestModel.setRequestIp(getIpAddr(request));//ip
requestModel.setUserName(user.getUserName());
requestModel.setUserId(user.getUserId());;
requestModel.setUri(request_uri);
Role role = (Role)request.getSession().getAttribute("role");
requestModel.setRoleName(role != null?role.getRoleName():null);
requestModel.setLogTime(TimeUtil.getCurrentDate());//日期
RequestModel.setRequestModel(requestModel);
}
return true;
}
。。。省略部分
/**
* Copyright: Copyright (c) 2017 LanRu-Caifu
* @author xzg
* @ClassName: LogResponseBodyAdvice.java
* @Description: 在响应写入body时的提前处理,可以获取Controller中的返回数据
* @version: v1.0.0
*/
@ControllerAdvice
public class LogResponseBodyAdvice implements ResponseBodyAdvice<Object>{
@Resource
private OperateLogService operateLogService;
@Override
public Object beforeBodyWrite(Object result, MethodParameter returnType, MediaType selectedContentType,
Class<? extends HttpMessageConverter<?>> selectedConverterType, ServerHttpRequest request, ServerHttpResponse response) {
//获取在ApiInterceptor对指定请求参数放如到线程局部变量的对象
RequestModel model = RequestModel.getRequestModel();
//移除线程局部变量,释放内存
RequestModel.removeRequestModel();
//保存日志
operateLogService.saveLog(model, result);
return result;
}
。。。省略
日志url服务接口,获取平台初始化的数据
public interface LogActionService {
public List<LogAction> getAllAction();
}
日志操作接口,保存日志信息。RequestModel为日志信息的实体类
public interface LogModuleService {
public Result getLog(Map<String,Object> params);
public void addLog(RequestModel rm);
}
作为处理响应时的操作日志方法
public interface OperateLogService {
public void saveLog(RequestModel model,Object result);
}