Redis应用(4)实现滚动分页

墨蓝 2024-03-30 17:52 51阅读 0赞

思路:

将上次查询的最小值作为下次查询的数据的最大值,同时注意,偏移量.偏移量的求法为,求得上次所有数据中和最小的score相等的数量,同时注意 offset = 0表示和最大值小于等于.包含等于

代码如下:

@Override
        public Result queryBlogOfFollow(Long max, Integer offset) {
            // 1.获取当前用户
            Long userId = UserHolder.getUser().getId();
            // 2.查询收件箱 ZREVRANGEBYSCORE key Max Min LIMIT offset count
            String key = FEED_KEY + userId;
            Set<ZSetOperations.TypedTuple<String>> typedTuples = stringRedisTemplate.opsForZSet()
                    .reverseRangeByScoreWithScores(key, 0, max, offset, 2);
            // 3.非空判断
            if (typedTuples == null || typedTuples.isEmpty()) {
                return Result.ok();
            }
            // 4.解析数据：blogId、minTime（时间戳）、offset
            List<Long> ids = new ArrayList<>(typedTuples.size());
            long minTime = 0; // 2
            int os = 1; // 2
            for (ZSetOperations.TypedTuple<String> tuple : typedTuples) { // 5 4 4 2 2
                // 4.1.获取id
                ids.add(Long.valueOf(tuple.getValue()));
                // 4.2.获取分数(时间戳）
                long time = tuple.getScore().longValue();
                if(time == minTime){
                    os++;
                }else{
                    minTime = time;
                    os = 1;
                }
            }
    
            // 5.根据id查询blog
            String idStr = StrUtil.join(",", ids);
            List<Blog> blogs = query().in("id", ids).last("ORDER BY FIELD(id," + idStr + ")").list();
    
            for (Blog blog : blogs) {
                // 5.1.查询blog有关的用户
                queryBlogUser(blog);
                // 5.2.查询blog是否被点赞
                isLiked(blog);
            }
    
            // 6.封装并返回
            ScrollResult r = new ScrollResult();
            r.setList(blogs);
            r.setOffset(os);
            r.setMinTime(minTime);
    
            return Result.ok(r);
        }