如何将多个弹性搜索连接添加到Spring Boot项目？

Question

我有两个弹性搜索服务器，我需要添加到spring boot项目的连接。对于一个连接，下面是我的代码，

@Configuration
@EnableElasticsearchRepositories(basePackages = {"packageName"})
public class ES {

    @Bean
    public RestHighLevelClient client() {
        CredentialsProvider cp = new BasicCredentialsProvider();
        cp.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("username", "password"));

        return new RestHighLevelClient(RestClient.builder(new HttpHost("host", "port", "https"))
                        .setHttpClientConfigCallback(httpAsyncClientBuilder -> httpAsyncClientBuilder.setDefaultCredentialsProvider(cp)
                                        .setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy())));
    }
}

那么如何添加其他服务器连接呢？如果我复制这个类并添加其他服务器连接详细信息，它会起作用吗？而且我还需要分隔索引。例如，我需要索引entity1必须仅在server 1中，并且索引entity2必须仅在server 2中。这可能吗？如果有人能帮助我，真的很感激。

Answer 1

如果两个服务器属于同一个ES集群，请使用RestClient。构建器接受一组要连接的HttpHosts。客户端（在后台是ES低级REST客户端）将循环请求到这些主机。

更多信息

Answer 2

这在Spring Data Elasticsearch中目前是不可能的。存储库使用Spring上下文提供的ElasticsearchOperations bean，该bean使用配置的RestHighLevelClient。无法配置到不同集群的多个连接。

编辑：

您可以使用bean将一个连接配置为默认连接，然后将其作为ElasticsearchOperations注入并由存储库方法使用。

对于第二个连接，您需要创建一个新的RestHighLevelClient，就像您已经做的那样，然后创建一个额外的Elasticsearch chRestTemboard传入第二个客户端；使用注入的Elasticsearch chConverter作为第二个构造html" target="_blank">函数参数。您可以检查org.springframework.data.elasticsearch.config.AbstractElasticsearch chConfiguration中的代码是如何完成的。

使用第二个ElasticsearchOperations实例，您可以针对第二个集群工作，但您必须使用此接口的方法，而不能使用存储库方法。