Elasticsearch中ReactiveSortingRepository的findBy方法能否使用别名查询

1. 是否支持使用别名替代直接访问索引 #

完全支持。
ReactiveCrudRepository 和 ReactiveSortingRepository 底层请求均直接转发给 Elasticsearch 客户端，Elasticsearch 本身会自动处理别名到实际索引的路由映射，使用逻辑和直接填真实索引名完全一致，仅需要在实体类的 @Document 注解的 indexName 属性中直接填写别名即可，原有仓库的正常读写逻辑不需要做任何修改。

2. 实现不同方法使用不同索引/别名的方案 #

可以实现按方法维度指定索引/别名，两种常用方案按需选择即可：

方案1：默认走查询别名，自定义删除操作走实际索引 #

适用场景：大多数查询操作使用别名，仅少量写/删操作使用真实索引
步骤如下：

• 实体类@Document直接配置查询别名，默认所有仓库方法都会走该别名

@Document(indexName = "product_search_alias") // 填你配置的查询别名
public class Product {
    @Id
    private String id;
    private String category;
    // 其他字段、getter、setter省略
}

• 定义自定义方法接口，声明需要走真实索引的方法

public interface CustomProductRepository {
    Mono<Void> deleteById(String id);
}

• 实现自定义接口，调用ReactiveElasticsearchOperations指定真实索引执行删除

@Repository
public class CustomProductRepositoryImpl implements CustomProductRepository {

    private final ReactiveElasticsearchOperations elasticsearchOperations;

    // 构造注入响应式ES操作类
    public CustomProductRepositoryImpl(ReactiveElasticsearchOperations elasticsearchOperations) {
        this.elasticsearchOperations = elasticsearchOperations;
    }

    @Override
    public Mono<Void> deleteById(String id) {
        // 第三个参数指定实际索引名，不走实体类配置的别名
        return elasticsearchOperations.delete(
                Query.query(Criteria.where("id").is(id)),
                Product.class,
                IndexCoordinates.of("product_actual_index")
        ).then();
    }
}

• 主仓库接口同时继承基础仓库和自定义接口

public interface ProductRepository extends ReactiveSortingRepository<Product, String>, CustomProductRepository {
    // 所有默认实现的findBy方法自动走实体类配置的别名
    Flux<Product> findByCategory(String category);
}

方案2：默认走实际索引，给指定查询方法单独配置别名 #

适用场景：大多数操作用真实索引，仅少量查询操作使用别名
不需要自定义实现类，直接在查询方法上通过@Query注解的indices属性指定别名即可：

@Document(indexName = "product_actual_index") // 默认走实际索引
public class Product {
    @Id
    private String id;
    private String category;
    // 其他字段省略
}

public interface ProductRepository extends ReactiveSortingRepository<Product, String> {
    // 该方法指定走查询别名，indices参数填你的别名
    @Query(value = "{\"match\": {\"category\": ?0}}", indices = "product_search_alias")
    Flux<Product> findByCategory(String category);

    // 默认的delete方法自动走实体类配置的实际索引，不需要额外修改
}

注意事项 #

• 提前在Elasticsearch侧完成别名配置，仅需要给查询别名开通对应索引的读权限即可，不需要开通写权限，避免误操作。
• 如果使用写别名，需要确保别名仅映射单个可写索引，避免写入冲突，本需求中删除操作直接走实际索引，不存在该问题。

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