pm-datafileupload-manager: 起个定时器,每1小时执行一次(可以用FixDelay的方式),每次执行做以下动作: *产生本地PVC网元清理任务放进一个队列中,每1000个网元路径包装到一个网元清理任务中(避免任务太小,频繁领取任务) *清理过期空文件夹 *清理本地PVC Load和MidOffice目录 *清理远程FTP文件 提供一个获取清理任务接口pollCleanTask,worker调用该接口时,从队列中取出指定个数的任务;当任务队列为空时,返回0个任务 2)pm-datafileupload-worker: 起个清理线程池,从yml中读取并发度,默认单实例5并发 起一个定时器,每隔1s调用manager的pollCleanTask接口,获取1个清理任务,获取其中待清理的网元路径,提交到清理线程池中,等待线程池中任务全部执行完毕,则返回。 如获取到清理任务数为空,则休眠1min 根据以上逻辑写出todolist
时间: 2024-02-16 18:01:42 浏览: 137
下面是针对题目的todolist:
pm-datafileupload-manager:
- [ ] 实现定时器功能,每1小时执行一次
- [ ] 在定时器回调中,产生本地PVC网元清理任务放进一个队列中,每1000个网元路径包装到一个网元清理任务中
- [ ] 在定时器回调中,清理过期空文件夹
- [ ] 在定时器回调中,清理本地PVC Load和MidOffice目录
- [ ] 在定时器回调中,清理远程FTP文件
- [ ] 提供获取清理任务接口pollCleanTask,从队列中取出指定个数的任务;当任务队列为空时,返回0个任务
pm-datafileupload-worker:
- [ ] 实现清理线程池功能,从yml中读取并发度,默认单实例5并发
- [ ] 实现定时器功能,每隔1s调用manager的pollCleanTask接口,获取1个清理任务,获取其中待清理的网元路径,提交到清理线程池中,等待线程池中任务全部执行完毕,则返回
- [ ] 如果获取到清理任务数为空,则休眠1min
阅读全文