Spring Boot复刻Twitter：JpaRepository实现登录增量加载帖子

看起来你已经把核心功能搞定了，现在碰到的性能问题确实很常见——一次性加载数万条帖子肯定会拖垮服务器和客户端体验。结合你已经有的lastLoginTime和postTime字段，咱们可以通过自定义JPQL查询精准控制加载的帖子范围，直接解决这个问题。

先理清楚需求逻辑 #

你说的“上次登录时间前24小时内发布的帖子”，结合例子（8点登录加载昨日8点后），其实就是要加载**从「上次登录时间减去24小时」到「当前登录时刻」**之间，你关注的用户发布的所有帖子对吧？咱们就围绕这个逻辑来实现。

1. 确认实体字段的正确性 #

先确保你的实体类里这两个时间字段已经正确配置了注解，能自动维护时间：

// 用户实体示例
@Entity
public class User {
    // 其他字段省略...
    @LastModifiedTime
    private LocalDateTime lastLoginTime; // 登录时会自动更新，首次登录可能为null

    // getter、setter方法
}

// 帖子实体示例
@Entity
public class Post {
    // 其他字段省略...
    @CreatedTime
    private LocalDateTime postTime; // 帖子发布时自动设置
    @ManyToOne
    private User author; // 帖子的发布者，关联到用户实体

    // getter、setter方法
}

2. 编写JpaRepository的自定义JPQL查询 #

在你的PostRepository里添加一个自定义查询方法，通过@Query注解实现时间范围和关注用户的筛选：

public interface PostRepository extends JpaRepository<Post, Long> {

    @Query("SELECT p FROM Post p " +
           "WHERE p.author.id IN :followedUserIds " +
           "AND p.postTime BETWEEN :startTime AND :currentTime " +
           "ORDER BY p.postTime DESC") // 按发布时间倒序，最新的先展示
    List<Post> findRecentPostsForLoggedInUser(@Param("followedUserIds") List<Long> followedUserIds,
                                              @Param("startTime") LocalDateTime startTime,
                                              @Param("currentTime") LocalDateTime currentTime);

    // 进阶：如果帖子数量还是较多，建议用分页查询
    @Query("SELECT p FROM Post p " +
           "WHERE p.author.id IN :followedUserIds " +
           "AND p.postTime BETWEEN :startTime AND :currentTime " +
           "ORDER BY p.postTime DESC")
    Page<Post> findRecentPostsForLoggedInUserWithPage(@Param("followedUserIds") List<Long> followedUserIds,
                                                      @Param("startTime") LocalDateTime startTime,
                                                      @Param("currentTime") LocalDateTime currentTime,
                                                      Pageable pageable);
}

参数说明： #

• followedUserIds：当前用户关注的所有用户ID集合，你需要先从关注关系表中获取这个列表
• startTime：计算方式是用户的lastLoginTime减去24小时，对应例子里的“昨日8点”
• currentTime：当前登录的时间，也就是LocalDateTime.now()
• Pageable：分页参数，用来控制每次加载的帖子数量，比如每页20条，避免一次性加载过多数据

3. 业务层调用的示例代码 #

在登录的业务逻辑里，你需要先计算时间范围，再调用上面的查询方法，最后记得更新用户的lastLoginTime：

@Service
public class LoginService {

    @Autowired
    private UserRepository userRepository;
    @Autowired
    private PostRepository postRepository;
    @Autowired
    private FollowRepository followRepository; // 假设你有维护关注关系的Repository

    public List<Post> loadPostsWhenUserLogin(Long userId) {
        // 获取当前用户信息
        User currentUser = userRepository.findById(userId)
                .orElseThrow(() -> new RuntimeException("用户不存在"));

        // 获取当前用户关注的所有用户ID
        List<Long> followedUserIds = followRepository.findFollowedUserIdsByUserId(userId);

        // 处理首次登录的情况：如果lastLoginTime为null，就取当前时间减24小时作为起始时间
        LocalDateTime startTime = currentUser.getLastLoginTime() != null
                ? currentUser.getLastLoginTime().minusHours(24)
                : LocalDateTime.now().minusHours(24);
        LocalDateTime currentTime = LocalDateTime.now();

        // 查询符合条件的帖子
        List<Post> recentPosts = postRepository.findRecentPostsForLoggedInUser(followedUserIds, startTime, currentTime);

        // 更新用户的上次登录时间为当前时间
        currentUser.setLastLoginTime(currentTime);
        userRepository.save(currentUser);

        return recentPosts;
    }

    // 分页版本的调用示例
    public Page<Post> loadPostsWithPageWhenUserLogin(Long userId, int pageNum, int pageSize) {
        User currentUser = userRepository.findById(userId)
                .orElseThrow(() -> new RuntimeException("用户不存在"));
        List<Long> followedUserIds = followRepository.findFollowedUserIdsByUserId(userId);

        LocalDateTime startTime = currentUser.getLastLoginTime() != null
                ? currentUser.getLastLoginTime().minusHours(24)
                : LocalDateTime.now().minusHours(24);
        LocalDateTime currentTime = LocalDateTime.now();

        // 创建分页参数：按发布时间倒序，每页pageSize条，取第pageNum页
        Pageable pageable = PageRequest.of(pageNum - 1, pageSize, Sort.by(Sort.Direction.DESC, "postTime"));

        return postRepository.findRecentPostsForLoggedInUserWithPage(followedUserIds, startTime, currentTime, pageable);
    }
}

4. 额外的性能优化建议 #

• 加索引：给Post实体的author.id和postTime字段创建联合索引，能大幅提升查询速度：

  @Entity
  public class Post {
      // ...
      @Index(name = "idx_post_author_time", columnList = "author_id, post_time")
      private LocalDateTime postTime;
      // ...
  }
  

• 异步加载：如果还是觉得加载慢，可以考虑用异步查询，让用户先看到页面，后续再加载帖子内容
• 缓存热门帖子：对于一些高人气的帖子，可以缓存起来，减少数据库查询压力

内容的提问来源于stack exchange，提问作者Shelton