Java异步记录日志-2022新项目--粉丝服务平台-粉丝头条-fensifuwu.com

Java异步记录日志-2022新项目

科技 07-30 来源： Java熬夜党

一、业务场景

web 项目开发中，经常会有的一个操作是记录请求日志，比如记录请求的 IP 地址，记录请求的路径，记录请求的参数等等。

每个系统都会根据自己的需要来记录一些请求相关的日志。一般会将记录的日志信息保存到数据库中，以便于查看，如出现异常

高频率的访问请求，或者是遇到其他一些问题都可以查看记录的日志来进行排查问题。如果系统的请求比较少的话，直接记录日志

则没什么问题，可是如果请求量比较大的时候，如何来优化日志记录的操作呢？

二、需求分析

本篇文章所说的这种方式是使用异步的方式来记录日志。 Java 代码一般都是同步执行，所谓同步执行，简单理解

就是从上往下执行，必须要等待上一行代码执行完之后，才会执行下一行代码。了解前端的同学应该对异步操作并不

陌生，页面中的很多 ajaxx 请求大多都是异步执行的，并不一定要等前面一行的代码执行完，后面一行的代码也可以执

行。可是在 Java 中如何来进行异步操作呢？

三、解决方案

从当前项目中学习到的方式如下:

大致的思路是，在 web 项目中使用拦截器来拦截需要记录日志的请求，在这个拦截器的拦截方法中，获取一个记录日志的任务对象，

对象是多实例的。然后使用这个对象设置一些指定的值，比如请求路径，请求 IP ，请求求时间信息等等。将这些值设置好之后，在使用

一个工具类来调用方法，传入的参数为这个任务处理类。之后就可以使用异步线程的方式来记录请求的日志数据。自己模仿项目中的方

式写的代码如下 :

拦截器中的代码 :

@Slf4jpublic classLogRecordInterceptor **implements** HandlerInterceptor{@AutowiredprivateLogRecordRunnableTask **logRecordRunnableTask** ;@Overridepublic booleanpreHandle(HttpServletRequest request, HttpServletResponse response, Object handler) **throws** Exception {try{String requestURL = request.getRequestURL().toString();logRecordRunnableTask.setUrl(requestURL);logRecordRunnableTask.setRequestTime(CommonUtil. *getCurrentDateTime* ());RecordLogRunnableUtils. *submit* ( **logRecordRunnableTask** );} **catch** (Exception ex) {*log* .error( **"日志记录异常--->{}"** , ex);}return true;}}

注册拦截器bean对象的代码 :

@Configurationpublic classWebMvcConfig **extends** WebMvcConfigurerAdapter {*/****      *  Function:  addInterceptors**      *  Author :  kaye0110,**     *  Version : 1.0**      *  Description : 注册拦截器                            **      *  Param and Description :  **      *   ****@param* *****registry*****/* @Overridepublic voidaddInterceptors(InterceptorRegistry registry) {registry.addInterceptor(logRecordInterceptor()).addPathPatterns( **"/**"** );super.addInterceptors(registry);}@BeanpublicLogRecordInterceptor logRecordInterceptor(){return  newLogRecordInterceptor();}}

日志任务处理类的代码

@Data@Component@Scope( **"prototype"** )public classLogRecordRunnableTask **implements** Runnable{@AutowiredprivateLogRecordService **logRecordService** ;*/***      * 请求地址**      */* **private** String **url** ;*/***      * 请求时间**      */* **private** String **requestTime** ;@Overridepublic voidrun() {logRecordService.createLogRecord( **url** , **requestTime** );}}

注意：这个类是多实例的，类中实现 Runnable 接口，重写 Run 方法，就在这个方法中执行记录日志的操作。

Service 接口实现类的代码 .

@Slf4j@Servicepublic classLogRecordServiceImpl **implements** LogRecordService {@Overridepublic voidcreateLogRecord(String url, String recordTime) {*log* .info( **"url-->{}, recordTime--->{}"** , url, recordTime);}}

日志记录工具类的代码

@Slf4jpublic classRecordLogRunnableUtils {privateRecordLogRunnableUtils(){}private staticExecutorService *executor* = Executors. *newFixedThreadPool* (20);*/* @Description: 执行日志记录操作**       * @author: yilang**       * @date: 2022/7/27 13:03**       * @param: runnable**       * @return: void**       */* **public static void** submit(Runnable runnable) {try{*executor* .submit(runnable);} **catch** (Exception ex) {*log* .error( **"执行日志操作异常:{}"** , ex);}}}

简单测试了一下，使用 postman 一次性发 30 个请求 .