首先还是展示目录结构:
本章主要采用队列,定时任务,定时任务插入数据,队列存储每次需要插入的数据,每次插入后就清空队列。
ps:注意加上component注解,将该队列以组件形式注入spring容器,让他来管理。 volatile是Java提供的一种轻量级的同步机制。多个线程访问该变量时,一个线程修改了这个变量的值,其他线程能够立即看得到修改的值。
1、注入刚才创建的队列。2、在after里面,将符合要求的log加入队列。
解读:
ps:poll() 获取并移除此队列的头,如果此队列为空,则返回 null,否则返回头数据。
若获取并移除队列的头为空,则跳出,否则将该数据加入到集合operLogs,再调用insertAll方法批量插入日志的集合,插入完成则清空该集合。
ps:insertAll方法如下:
ps:此处insert方法是mybatis-plus的方法。
在启动类新增EnableScheduling注解
接口请求前
请求多次接口,等待一分钟
已经新增成功。
本期整合到此完毕,接下来会继续更新加强整合,尽情期待。
访问地址:http://localhost:8087/swagger-ui.html或者http://localhost:8087/doc.html