如何配置elasticsearch 5 TransportClient。如何配置elasticsearch 5
现在TransportClient是抽象类。我发现只有PreBuiltTransportClient,这是配置elasticsearch Client的新方法吗?
如何配置elasticsearch 5 TransportClient。如何配置elasticsearch 5
现在TransportClient是抽象类。我发现只有PreBuiltTransportClient,这是配置elasticsearch Client的新方法吗?
是的,你可以发现,在official documentation for 5.0以及
Settings settings = Settings.builder()
.put("cluster.name", "ElasticSearchClusterName");
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host1"), 9300))
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host2"), 9300));
这是一文不值的PreBuiltTransportClient
是pre-configured具有以下模块:
另外,还要确保你对transport
神器的依赖:
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
<version>5.0.0-beta1</version>
</dependency>
首先下载相应的jar文件,并保持在lib文件夹中,并将它们添加到构建路径。 您可以按照下面的代码进行配置:
Settings settings = Settings.builder()
.put("cluster.name", "ElasticSearchClusterName")
//.put("client.transport.sniff", true)
//.put("shield.user", elasticUserName+":"+elasticPassword)
.build();
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new InetSocketTransportAddress(elasticHostOne, elasticTransportPort))
.addTransportAddress(new InetSocketTransportAddress(elasticHostTwo, elasticTransportPort))
.addTransportAddress(new InetSocketTransportAddress(elasticHostThree, elasticTransportPort));
这是什么运气? – Val
你在哪里指定集群? – tgkprog
@tgkprog我已更新我的回答 – Val