Elasticsearch增长X-Pack插件后如何使用Java客户端访问

时间 2019-11-11

标签 elasticsearch 增长 pack 插件如何使用 java 客户端访问栏目日志分析繁體版

原文原文链接

Elasticsearch没有安装X-Pack插件时建立TransportClient只须要依赖java

<dependency>
  <groupId>org.elasticsearch.client</groupId>
  <artifactId>transport</artifactId>
  <version>5.3.0</version>
</dependency>

而后使用elasticsearch

Settings settings = Settings.builder()
        .put("cluster.name", "myClusterName").build();

TransportClient client = new PreBuiltTransportClient(settings)
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host1"), 9300))
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host2"), 9300));

// on shutdown
client.close();

就能链接上Elasticsearch了maven

可是在增长了X-Pack插件以后,因为Elasticsearch默认开启了xpack.security.enabled,若是仍是使用原先的链接方式的话会抛权限异常,解决方式有两种ui

1.直接在elasticsearch.yml中增长配置url

xpack.security.enabled=false

这样的话就仍是能够使用原先的方式进行访问插件

2.使用x-pack-transportcode

<dependency>
  <groupId>org.elasticsearch.client</groupId>
  <artifactId>x-pack-transport</artifactId>
  <version>5.3.0</version>
</dependency>

注意这个依赖在maven中央仓库中找不到xml

须要在pom.xml中配置elastic的maven仓库get

<repository>
  <id>elastic</id>
  <url>https://artifacts.elastic.co/maven</url>
  <releases>
     <enabled>true</enabled>
  </releases>
  <snapshots>
     <enabled>false</enabled>
  </snapshots>
</repository>

下载好依赖以后使用如下方式就能访问了it

TransportClient client = new PreBuiltXPackTransportClient(Settings.builder()
        .put("cluster.name", "myClusterName")
        .put("xpack.security.user", "transport_client_user:changeme")
        ...
        .build())
    .addTransportAddress(new InetSocketTransportAddress("localhost", 9300))
    .addTransportAddress(new InetSocketTransportAddress("localhost", 9301));