【八】springboot整合定时任务

小z666

发布于 2024-06-21 18:12:15

840

发布于 2024-06-21 18:12:15

文章被收录于专栏：javajava

介绍：接下来我会把学习阶段学到的框架等知识点进行整合，每一次整合是在前一章的基础上进行的，所以后面的整合不会重复放前面的代码。每次的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表达式生成器

watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

ps：insertAll方法如下：

ps：此处insert方法是mybatis-plus的方法。

第四步：开启定时任务

在启动类新增EnableScheduling注解

第五步：演示

接口请求前

请求多次接口，等待一分钟

已经新增成功。

本期整合到此完毕，接下来会继续更新加强整合，尽情期待。

访问地址：http://localhost:8087/swagger-ui.html或者http://localhost:8087/doc.html

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2024-03-10，如有侵权请联系 cloudcommunity@tencent.com 删除

集合

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度