定时任务:清理账号爬取次数缓存

This commit is contained in:
2025-06-16 14:38:13 +08:00
parent c56e2378a5
commit 45ce929bd4
2 changed files with 41 additions and 0 deletions

View File

@@ -39,6 +39,11 @@
<groupId>cn.iocoder.boot</groupId>
<artifactId>yudao-spring-boot-starter-mybatis</artifactId>
</dependency>
<!-- 多租户相关 -->
<dependency>
<groupId>cn.iocoder.boot</groupId>
<artifactId>yudao-spring-boot-starter-biz-tenant</artifactId>
</dependency>
</dependencies>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

View File

@@ -0,0 +1,36 @@
package cn.iocoder.yudao.module.tkdata.job;
import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler;
import cn.iocoder.yudao.framework.tenant.core.job.TenantJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Set;
/*
* @author: ziin
* @date: 2025/6/13 18:54
*/
@Component
@Slf4j
public class CleanTKAccountCache implements JobHandler {
@Resource
private RedisTemplate redisTemplate;
@Override
public String execute(String param) throws Exception {
// 1. 获取所有匹配的 key注意keys 命令在生产环境可能阻塞 Redis慎用
Set<String> keys = redisTemplate.keys("tkaccount:" + "*");
// 2. 如果找到 key则批量删除
if (keys != null && !keys.isEmpty()) {
redisTemplate.delete(keys);
}
Boolean tkAccount = redisTemplate.delete("tkaccount:*");
return String.format("清除缓存账号数量: %s", keys.size());
}
}