如何在Spring Boot中为Apache Cassandra 3.11.14实现双向高效分页

问题背景 #

使用Apache Cassandra 3.11.14管理存储数百万条记录的交易表，当前基于Slice<T> findAll(Pageable pageable)实现的分页仅支持向前翻页，需改造为支持双向翻页（上/下一页），同时返回包含List<T> transactions、boolean hasMore、String nextCursor的分页响应，优先支持快速跳转页码，至少支持上下页按钮。

当前接口实现：

@GetMapping("/pagination")
Pagination<T> getPageOfTransactions(@RequestParam("size") int size) {

}

解决方案 #

Cassandra作为分布式NoSQL数据库，传统OFFSET分页会导致全表扫描，性能极差，因此优先采用基于游标的双向分页，这是Cassandra原生支持的高效分页方式；页码跳转需采用折中方案（仅在必须时使用）。

一、基于游标的双向分页（推荐，高性能） #

利用Cassandra的PagingState保存分页上下文，结合Spring Data Cassandra的CassandraPageRequest实现双向翻页：

1. 定义分页响应DTO

public class PaginationResponse<T> {
    private List<T> transactions;
    private boolean hasNext;
    private boolean hasPrevious;
    private String nextCursor;
    private String previousCursor;

    // 构造函数、Getter/Setter
}

2. 改造分页接口

@GetMapping("/transactions/pagination")
public PaginationResponse<Transaction> getPage(
        @RequestParam(value = "size", defaultValue = "10") int size,
        @RequestParam(value = "nextCursor", required = false) String nextCursor,
        @RequestParam(value = "previousCursor", required = false) String previousCursor) {

    // 处理分页游标，优先下一页游标，其次上一页游标
    PagingState pagingState = null;
    boolean isForward = true;
    if (nextCursor != null) {
        pagingState = PagingState.fromString(nextCursor);
    } else if (previousCursor != null) {
        pagingState = PagingState.fromString(previousCursor);
        isForward = false;
    }

    // 构建Cassandra分页请求
    CassandraPageRequest pageRequest;
    if (pagingState == null) {
        // 首次查询，按稳定字段排序（比如交易时间降序）
        pageRequest = CassandraPageRequest.of(PageRequest.of(0, size), Sort.by("transaction_time").descending());
    } else {
        // 基于游标分页，指定查询方向
        pageRequest = CassandraPageRequest.of(pagingState, size, isForward);
    }

    // 执行查询
    Slice<Transaction> slice = transactionRepository.findAll(pageRequest);

    // 转换为响应DTO
    PaginationResponse<Transaction> response = new PaginationResponse<>();
    response.setTransactions(slice.getContent());
    response.setHasNext(slice.hasNext());
    response.setHasPrevious(slice.hasPrevious());
    
    // 序列化游标返回前端
    if (slice.hasNext()) {
        response.setNextCursor(((CassandraPageRequest) slice.nextPageable()).getPagingState().toString());
    }
    if (slice.hasPrevious()) {
        response.setPreviousCursor(((CassandraPageRequest) slice.previousPageable()).getPagingState().toString());
    }

    return response;
}

3. Repository层适配

确保Repository继承CassandraRepository，并支持Pageable参数：

public interface TransactionRepository extends CassandraRepository<Transaction, UUID> {
    Slice<Transaction> findAll(Pageable pageable);
}

核心说明

• 依赖Cassandra原生PagingState保存分页位置，避免全表扫描，百万级数据下性能稳定
• 通过isForward参数控制查询方向，实现上下页翻页
• 响应中返回hasNext/hasPrevious标识是否存在前后页，nextCursor/previousCursor作为翻页凭证

二、页码跳转的折中方案（不推荐，仅在必须时使用） #

Cassandra分布式存储的特性决定了它无法快速定位到指定页码，若必须支持页码跳转，可采用以下方式：

• 按固定维度（比如交易日期）将数据分片，每个分片对应一个逻辑页码范围
• 维护一个索引表，记录每个分片的起始/结束游标，前端点击页码时，先查询索引表获取对应游标，再执行分页查询
• 此方案需额外维护索引表，仅适合数据更新频率极低的场景

关键注意事项 #

• 禁止使用OFFSET分页：Cassandra的OFFSET关键字会扫描前面所有数据，百万级数据下会导致超时
• 固定排序字段：分页必须基于稳定的排序（比如主键+时间戳），否则会出现数据重复或遗漏
• 游标安全：若需防止用户篡改游标，可对PagingState进行加密后返回前端

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