Redis实现每周热评的项目实践

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>4.0.1</version>
</dependency>

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Tuple;
import java.util.Set;
public class RedisUtil {
    private static final String WEEKLY_HOT_COMMENTS = "weekly_hot_comments";
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost", 6379);
        // 添加评论到有序集合
        addComment("comment_1", 10);
        addComment("comment_2", 5);
        addComment("comment_3", 15);
        // 获取每周热评
        Set<Tuple> weeklyHotComments = getWeeklyHotComments();
        for (Tuple tuple : weeklyHotComments) {
            System.out.println("Comment: " + tuple.getElement() + ", Likes: " + tuple.getScore());
        }
    }
    public static void addComment(String commentId, int likes) {
        Jedis jedis = new Jedis("localhost", 6379);
        jedis.zadd(WEEKLY_HOT_COMMENTS, likes, commentId);
        jedis.close();
    }
    public static Set<Tuple> getWeeklyHotComments() {
        Jedis jedis = new Jedis("localhost", 6379);
        Set<Tuple> weeklyHotComments = jedis.zrevrangeWithScores(WEEKLY_HOT_COMMENTS, 0, 0);
        jedis.close();
        return weeklyHotComments;
    }
}

public static Set<Tuple> getWeeklyHotComments() {
    Jedis jedis = new Jedis("localhost", 6379);
    Set<Tuple> weeklyHotComments = jedis.zrevrangeWithScores(WEEKLY_HOT_COMMENTS, 0, 0);
    // 删除上上周的热评数据
    jedis.zremrangeByScore(WEEKLY_HOT_COMMENTS, "0", getLastWeekMondayTimestamp());
    jedis.close();
    return weeklyHotComments;
}
private static double getLastWeekMondayTimestamp() {
    // 获取本周一的日期
    Calendar calendar = Calendar.getInstance();
    calendar.set(Calendar.DAY_OF_WEEK, Calendar.MONDAY);
    calendar.set(Calendar.HOUR_OF_DAY, 0);
    calendar.set(Calendar.MINUTE, 0);
    calendar.set(Calendar.SECOND, 0);
    calendar.set(Calendar.MILLISECOND, 0);
    // 获取上上周一的日期
    calendar.add(Calendar.WEEK_OF_YEAR, -1);
    // 计算上上周一的 Unix 时间戳
    return calendar.getTimeInMillis() / 1000.0;
}