程序中的多个 Elasticsearch 连接

Question

我正在开发一项服务，在该服务中，我从弹性集群 A 获取 searchHit，然后使用从 A 获得的字段从弹性集群 B 获取详细信息。我创建了一个类 ClientFactory，它根据我发送的值创建 ES 客户端。(A 或 B(但是从 A 获得详细信息后，我无法创建与 B 的连接。我可以一次从 A 或 B 获取详细信息。知道如何解决这个问题吗？

Answer 1

您可以创建两个resthighlevelclient一个与cluster A对话，另一个与cluster B对话，下面是要显示的示例代码：

创建客户端 A

RestHighLevelClient restHighLevelClientA = new RestHighLevelClient(
RestClient.builder(new HttpHost(configuration.getClusteAConfig().getHost(),
configuration.getClusteAConfig().getPort(),
"http")));

创建客户端 B

RestHighLevelClient restHighLevelClientB = new RestHighLevelClient(
RestClient.builder(new HttpHost(configuration.getClusteBConfig().getHost(),
configuration.getClusteBConfig().getPort(),
"http")));

集群 A 和 B 应有 2 个配置，由客户端创建代码读取。

ClusterA:
host: cluste A hosts
port: 9200
ClusterB:
host: cluste B hosts
port: 9200