springboot篇章整体栏目：

介绍：接下来我会把学习阶段学到的框架等知识点进行整合，每一次整合是在前一章的基础上进行的，所以后面的整合不会重复放前面的代码。每次的demo我放在结尾，本次是接着上一章的内容延续的，只增加新增的或者修改的代码。

上一章进行了AOP的整合，实现了日志的操作（请求接口后新增日志）。本章将对其进行改进，整合定时任务，在某一时间再进行新增操作（会更优化，若每次请求接口时切面都去进行一个新增日志操作会对服务器造成很大压力）。

首先还是展示目录结构：

本章主要采用队列，定时任务，定时任务插入数据，队列存储每次需要插入的数据，每次插入后就清空队列。

第一步：新建一个队列

ps：注意加上component注解，将该队列以组件形式注入spring容器，让他来管理。

volatile是Java提供的一种轻量级的同步机制。多个线程访问该变量时，一个线程修改了这个变量的值，其他线程能够立即看得到修改的值。

第二步：改造切面类

1、注入刚才创建的队列。2、在after里面，将符合要求的log加入队列。

第三步：新建一个任务

@Slf4j
@Component
public class LogTask {

    @Resource
    LogQueue logQueue;

    @Resource
    ISyslogService sysLogService;

    private volatile List<SysLog> operLogs = Collections.synchronizedList(new ArrayList<>());

//    @Scheduled(cron = "0/5 * * * * ?")
    @Scheduled(cron = "0 */1 * * * ?")//每隔一分钟执行一次
    public void logFixDelay(){
        System.out.println("进入");
        //获取日志信息
        while (true){
            SysLog operLog = logQueue.poll();
            if(null==operLog){
                break;
            }
            operLogs.add(operLog);
        }
        if(operLogs.size()>0){
            try{
                log.info("######################批量添加系统日志"+operLogs.size());
                sysLogService.insertAll(operLogs);
            }catch (Exception e){
                log.error("批量添加系统日志异常：",e);
                operLogs.clear();
            }
            operLogs.clear();
        }
    }
}

解读：

ps：poll() 获取并移除此队列的头，如果此队列为空，则返回 null，否则返回头数据。

若获取并移除队列的头为空，则跳出，否则将该数据加入到集合operLogs，再调用insertAll方法批量插入日志的集合，插入完成则清空该集合。
Scheduled的写法有很多，最常用的还是cron写法，自行搜索，此处附在线生成器：在线Cron表达式生成器