// common/ScrollRequest.java
public record ScrollRequest(
String nextToken, // 다음 페이지 토큰
int size // 요청 크기
) {
public static ScrollRequest of(String nextToken, int size) {
return new ScrollRequest(nextToken, size);
}
}
// common/PageRequest.java
public record PageRequest(
int page, // 페이지 번호
int size, // 페이지 크기
String sortBy, // 정렬 기준
String direction // 정렬 방향
) {
public static PageRequest of(int page, int size, String sortBy, String direction) {
return new PageRequest(page, size, sortBy, direction);
}
public org.springframework.data.domain.PageRequest toPageRequest() {
return org.springframework.data.domain.PageRequest.of(
page,
size,
direction.equalsIgnoreCase("DESC") ?
Sort.by(sortBy).descending() :
Sort.by(sortBy).ascending()
);
}
}
// repository/PostRepository.java
@Repository
public interface PostRepository extends JpaRepository<Post, Long> {
// 페이징용 쿼리
@Query("""
select p
from Post p
join fetch p.writer
where p.deletedAt is null
""")
Page<Post> findAllPosts(Pageable pageable);
// 무한 스크롤용 쿼리
@Query("""
select p
from Post p
join fetch p.writer
where p.id < :lastPostId
and p.deletedAt is null
order by p.id desc
limit :size
""")
List<Post> findPostsForScroll(Long lastPostId, int size);
}
// service/PostService.java
@Service
@Transactional(readOnly = true)
public class PostService {
private final PostRepository postRepository;
// 페이징 방식
public PostListResponse findPostsByPaging(PageRequest request) {
Page<Post> posts = postRepository.findAllPosts(request.toPageRequest());
return PostListResponse.of(
posts.getContent().stream()
.map(PostResponse::from)
.toList(),
posts.getTotalElements(),
posts.getTotalPages(),
posts.hasNext()
);
}
// 무한 스크롤 방식
public ScrollPostResponse findPostsByScroll(ScrollRequest request) {
Long lastPostId = request.nextToken() != null ?
Long.parseLong(request.nextToken()) :
Long.MAX_VALUE;
List<Post> posts = postRepository.findPostsForScroll(lastPostId, request.size());
String nextToken = posts.size() == request.size() ?
String.valueOf(posts.get(posts.size() - 1).getId()) :
null;
return ScrollPostResponse.of(
posts.stream()
.map(PostResponse::from)
.toList(),
nextToken
);
}
}
// dto/PostListResponse.java
public record PostListResponse(
List<PostResponse> posts,
long totalElements,
int totalPages,
boolean hasNext
) {
public static PostListResponse of(
List<PostResponse> posts,
long totalElements,
int totalPages,
boolean hasNext
) {
return new PostListResponse(posts, totalElements, totalPages, hasNext);
}
}
// dto/ScrollPostResponse.java
public record ScrollPostResponse(
List<PostResponse> posts,
String nextToken
) {
public static ScrollPostResponse of(List<PostResponse> posts, String nextToken) {
return new ScrollPostResponse(posts, nextToken);
}
}
##### 구현된 기능 정리
1. 페이징 API
- 전통적인 페이징 방식 구현
- 전체 데이터 개수, 전체 페이지 수 제공
- 정렬 기능 지원
- 페이지 번호 기반 이동
2. 스크롤 API
- 커서 기반 페이징 구현
- nextToken을 사용한 다음 데이터 조회
- 마지막 아이템 ID 기반 조회
- 성능 최적화를 위한 LIMIT 사용
##### 주요 차이점
1. 데이터 접근 방식
- 페이징: offset + limit 사용
- 스크롤: 커서(lastPostId) 기반 조회
2. 반환 정보
- 페이징: 전체 데이터 수, 전체 페이지 수 포함
- 스크롤: 다음 조회를 위한 토큰만 포함
3. 성능 특성
- 페이징: 데이터가 많을 경우 offset으로 인한 성능 저하 가능
- 스크롤: 인덱스 기반 조회로 일관된 성능 보장
