Spring Boot中如何结合Pageable使用ReactiveCassandraRepository？

错误原因分析 #

你遇到的报错是因为：ReactiveCassandraRepository默认的findAll()方法不带参数，自定义的findAll(Pageable pageable)不符合Spring Data Cassandra的方法命名推导规则——框架会将带参数的findAll识别为要查询某个名为findAll的属性，而你的Match实体显然没有这个属性，因此报错。

另外需要注意：Cassandra作为分布式数据库，不推荐传统的offset/limit分页（即依赖Pageable的pageNumber），这种方式会导致全表扫描，性能极低。Spring Data Cassandra的响应式分页更依赖分页状态（Paging State）或键分页来实现高效的连续分页。

正确实现方式 #

方式一：利用Spring Data查询推导规则实现分页

修改仓库接口，使用findAllBy前缀配合Pageable参数，同时返回Slice类型（而非Page，因为Page需要查询总条数，Cassandra中此操作性能极差）：

import org.springframework.data.cassandra.repository.ReactiveCassandraRepository;
import org.springframework.data.domain.Slice;
import org.springframework.data.domain.Pageable;
import reactor.core.publisher.Flux;
import java.util.UUID;

public interface MatchRepository extends ReactiveCassandraRepository<Match, UUID> {
    // 通过findAllBy前缀让框架识别分页参数，返回Slice包含当前页数据和分页状态
    Slice<Match> findAllBy(Pageable pageable);
}

业务层使用示例：

@Service
public class MatchService {
    private final MatchRepository matchRepository;

    public MatchService(MatchRepository matchRepository) {
        this.matchRepository = matchRepository;
    }

    // 第一页查询
    public Flux<Match> getFirstPageMatches(int pageSize) {
        Pageable pageable = PageRequest.of(0, pageSize);
        return matchRepository.findAllBy(pageable)
                .flatMapMany(slice -> Flux.fromIterable(slice.getContent()));
    }

    // 后续分页查询（利用前一页的Slice获取下一页状态）
    public Flux<Match> getNextPageMatches(Slice<Match> previousSlice) {
        if (previousSlice.hasNext()) {
            return matchRepository.findAllBy(previousSlice.nextPageable())
                    .flatMapMany(slice -> Flux.fromIterable(slice.getContent()));
        }
        return Flux.empty();
    }
}

方式二：自定义查询结合分页

如果需要更灵活的SQL控制，可以用@Query注解实现：

public interface MatchRepository extends ReactiveCassandraRepository<Match, UUID> {
    @Query("SELECT * FROM match")
    Flux<Match> findAllMatches(Pageable pageable);
}

Spring Data Cassandra会自动将Pageable参数转换为Cassandra的分页查询逻辑。

核心注意事项 #

1. 优先使用Slice而非Page：Slice仅返回当前页数据和是否有下一页的标识，无需查询总条数，更适配Cassandra的分布式特性。
2. 避免offset分页：不要依赖Pageable的pageNumber参数，推荐用分页状态（从Slice中获取）或基于实体主键的键分页，保证查询性能。

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