<dependencies>
    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>4.2.3</version>
    </dependency>
</dependencies>

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
 
import java.util.Set;
 
public class RedisUtil {
    private static JedisPool pool;
 
    static {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(50);
        config.setMaxIdle(10);
        config.setMinIdle(5);
        config.setTestOnBorrow(true);
        pool = new JedisPool(config, "localhost", 6379);  // Redis 地址
    }
 
    public static Jedis getJedis() {
        return pool.getResource();
    }
 
    public static void close(Jedis jedis) {
        if (jedis != null) {
            jedis.close();
        }
    }
 
    public static void incrementSearchCount(String key,String topic) {
        Jedis jedis = getJedis();
        try {
            // 使用 Redis 的 ZINCRBY 命令遞增話題的熱度
            jedis.zincrby(key, 1, topic);
        } finally {
            close(jedis);
        }
    }
 
    public static Set<String> getTopSearch(int topN) {
        Jedis jedis = getJedis();
        try {
            // 使用 Redis 的 ZREVRANGE 命令獲取熱搜榜單
            return jedis.zrevrange("hot_search", 0, topN - 1);
        } finally {
            close(jedis);
        }
    }
}

    @Autowired
    private RedisTemplate redisTemplate;
 
    /**
     * 更新天的熱搜數(shù)據(jù)
     */
    public void updateDaySearch(){
        long hour = System.currentTimeMillis()/(1000*60*60);
        //小時(shí)key的前綴
        String hourPrefix = "search:hour";
        //天的key
        String dayPrefix = "search:day";
        //計(jì)算最近24小時(shí)的key的集合
        ArrayList<Object> dayKeys = new ArrayList<>();
        //統(tǒng)計(jì)近24小時(shí)的key的集合
        for (int i = 1; i < 23; i++) {
            String key = hourPrefix+(hour-i);
            dayKeys.add(key);
            //設(shè)置當(dāng)天的key 40天過期，防止資源的浪費(fèi)
            redisTemplate.expire(key,40, TimeUnit.DAYS);
        }
        //將近24小時(shí)的key的值進(jìn)行合并
        //（redisTemplate.opsForZSet()。unionAndStore(a,b,c);把a(bǔ)，b 兩個(gè)zset合并儲存到c集合中）
        redisTemplate.opsForZSet().unionAndStore(hourPrefix+hour,dayKeys,dayPrefix);
        log.info("*********************進(jìn)行天數(shù)據(jù)的更新************************");
    }
 
    public void updateMonthSearch(){
        long hour = System.currentTimeMillis()/(1000*60*60);
        //小時(shí)key的前綴
        String hourPrefix = "search:hour";
        //天的key
        String monthPrefix = "search:day";
        //計(jì)算最近24小時(shí)的key的集合
        ArrayList<Object> monthKeys = new ArrayList<>();
        //統(tǒng)計(jì)近24小時(shí)的key的集合
        for (int i = 1; i < 24*30-1; i++) {
            String key = hourPrefix+(hour-i);
            monthKeys.add(key);
        }
        //將近30天的key的值進(jìn)行合并
        redisTemplate.opsForZSet().unionAndStore(hourPrefix+hour,monthKeys,monthPrefix);
        log.info("***************進(jìn)行月數(shù)據(jù)的更新*********************");
    }
 
    /**
     * 更新最近7天的數(shù)據(jù)
     */
    public void updateWeekSearch(){
        long hour = System.currentTimeMillis()/(1000*60*60);
        //小時(shí)key的前綴
        String hourPrefix = "search:hour";
        //周的key
        String weekPrefix = "search:week";
        //計(jì)算最近24小時(shí)的key的集合
        ArrayList<Object> weekKeys = new ArrayList<>();
        //統(tǒng)計(jì)近24小時(shí)的key的集合
        for (int i = 1; i < 24*7-1; i++) {
            String key = hourPrefix+(hour-i);
            weekKeys.add(key);
        }
        //將近30天的key的值進(jìn)行合并
        redisTemplate.opsForZSet().unionAndStore(hourPrefix+hour,weekKeys,weekPrefix);
        log.info("************進(jìn)行周數(shù)據(jù)的更新******************");
    }
 
    /**
     * 定時(shí)器每小時(shí)調(diào)用一次次方法進(jìn)行，小時(shí)榜，天榜，周榜，月榜的更新
     */
    public void updateAllSearch(){
        //TODO 此方法建議使用定時(shí)框架，quartz ,xxl-job等進(jìn)行定時(shí)調(diào)用
        updateDaySearch();
        updateWeekSearch();
        updateMonthSearch();
    }