java - 正确使用 TransportClient 进行 Elasticsearch

Question

我在为 Elasticsearch 创建 TransportClient bean 时遇到问题，编译器说构造函数是私有(private)的，就像那样。我如何才能正确创建 bean？这是我的配置类:

import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.transport.TransportAddress;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;

@Configuration
@EnableElasticsearchRepositories(basePackages = "example.spring.data.es.repository")
@ComponentScan(basePackages = { "example.spring.data.es.service" })
public class Config {

@Bean
public Client client() {
//here compiller says that the TransportClient() is private. How else i cna create the transport client?
    TransportClient client = new TransportClient();

    TransportAddress address = new InetSocketTransportAddress(
            "localhost",9200);
    client.addTransportAddress(address);
    return client;
}

@Bean
public ElasticsearchOperations elasticsearchTemplate() {
    return new ElasticsearchTemplate(client());
}

elasticsearch依赖为:elasticsearch-2.4.2

Answer 1

API 已更改!请注意您使用的版本。

来自 Version 5.5 Transport Client :

TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)

请注意，如果您使用不同于“elasticsearch”的集群名称，则必须设置集群名称:

Settings settings = Settings.builder().put("cluster.name", "myClusterName").build();
TransportClient client = new PreBuiltTransportClient(settings);