【八】springboot整合定时任务-阿里云开发者社区

【八】springboot整合定时任务

2024-03-12 24

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 【八】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();
        }
    }
}