Elasticsearch TransportClient 连接 [Java]

Question

我在使用Maven 的Java 项目中使用Elasticsearch：... <elasticsearch.version>6.7.0</elasticsearch.version>...    <!-- Elasticsearch -->    <dependency>        <groupId>org.elasticsearch</groupId>        <artifactId>elasticsearch</artifactId>        <version>${elasticsearch.version}</version>    </dependency>    <dependency>        <groupId>org.elasticsearch.client</groupId>        <artifactId>transport</artifactId>        <version>${elasticsearch.version}</version>    </dependency>    <dependency>        <groupId>org.elasticsearch.plugin</groupId>        <artifactId>transport-netty4-client</artifactId>        <version>${elasticsearch.version}</version>    </dependency>    <dependency>        <groupId>org.apache.logging.log4j</groupId>        <artifactId>log4j-to-slf4j</artifactId>        <version>2.8.2</version>    </dependency>    <!-- Elasticsearch -->        当我尝试初始化 TransportClient 以便为文档编制索引时，出现错误：    NoNodeAvailableException[None of the configured nodes are available:     [{#transport#-1}{BHMBbfcrSUOM_Pyaf1LcnA}{localhost}{127.0.0.1:9300}]]也许需要在 config/elasticsearch.yaml 中添加更多关于传输的信息，或者当前配置是错误的。Java代码：    TransportAddress address;    TransportClient client;    Settings settings;    try {        address = new TransportAddress(InetAddress.getByName("localhost"), 9300);        settings = Settings                    .builder()                    .put("cluster.name", "lib2life")                    .put("client.transport.sniff", true)                    .build();        /* Initiate Transport Client */        client = new PreBuiltTransportClient(settings)                    .addTransportAddress(address);    }

Answer 1

我解决了这个问题。问题是我使用的是带有 TransportClient 的 Elasticsearch 6.7.0 版本，它已被弃用并被 RestHighLevelClient 取代。此外，我必须使用端口 9200 并取消注释 http.port: 9200 和 discovery.seed_hosts: ["host1", "host2"] from elasticsearch.yaml

Answer 2

问题在于您的端口配置，您正在使用端口9300进行 REST 调用，该端口实际上用于 elasticsearch 集群中的节点间通信。请更改下面的 java 代码以使用该端口9200。

address = new TransportAddress(InetAddress.getByName("localhost"), 9200);