elasticsearch - SpringData Elasticsearch NoNodeAvailableException

Question

我正在使用SpringData将我的应用程序连接到Elastic search本地实例。当我执行常规的curl获取ES信息时，它可以正常工作，但是我无法从Springboot应用程序连接到它。
Elasticsearch本地版本./elasticsearch -V => Version: 7.6.0SpringData Elastic搜索版本3.1.11

> curl -XGET 'http://localhost:9200/_cluster/state?pretty'
{
  "cluster_name" : "elasticsearch",
  "cluster_uuid" : "1_8HMIK5QDug_xH80VZLgQ",
  "version" : 54,
  "state_uuid" : "YEe1FSwfRUuw0uw-T69fJQ",
  "master_node" : "Nbktx7KrREetbyfL7v0Fog",
  "blocks" : { },
  "nodes" : {
    "Nbktx7KrREetbyfL7v0Fog" : {
      "name" : "k***-macOS",
      "ephemeral_id" : "pqMw40oPTUmBoHsyTAz9cg",
      "transport_address" : "127.0.0.1:9301",
      "attributes" : {
        "ml.machine_memory" : "17179869184",
        "xpack.installed" : "true",
        "ml.max_open_jobs" : "20"
      }
    }
  },

    @Value("$ELASTIC_HOST")
    private String EsHost;

    @Value("$ELASTIC_PORT")
    private String EsPort;

    @Bean
    public ElasticsearchOperations elasticsearchTemplate() throws UnknownHostException {
        return new ElasticsearchTemplate(elasticsearchClient());
    }
    @Bean
    public Client elasticsearchClient() throws UnknownHostException {


        Settings settings = Settings.builder()
                .put("client.transport.sniff", true).build();
        TransportClient client = new PreBuiltTransportClient(settings);
        client.addTransportAddress( new TransportAddress(InetAddress.getByName(EsHost), Integer.valueOf(EsPort));
        return client;
    }

尝试了上述所有方法来获取主机和端口 还尝试了9300 ，但仍然没有运气。另外，我的 elasticsearch.yml是默认文件，没有添加任何显式主机或端口。
Docker-compose

version: '3'
services:
  elastic:
    restart: always
    image: docker.elastic.co/elasticsearch/elasticsearch:6.2.2
    environment:
      - cluster.name=elasticsearch
      - node.name=es01
      - discovery.type=single-node
      - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
    ulimits:
      memlock:
        soft: -1
        hard: -1
    ports:
      - "9201:9200"
      - "9301:9300"
  db:
    restart: always
    image: postgres
    ports:
      - "5432:5432"
    environment:
      POSTGRES_PASSWORD: 'xxx'
      POSTGRES_USER: 'xx'
      POSTGRES_DB: 'xx'
  api:
    build:
      context: .
      dockerfile: Dockerfile
    ports:
      - "8080:8080"
    environment:
      ENVIRONMENT_NAME: "dev"
      REGION_NAME: "local"
      POSTGRES_PASSWORD: "xx"
      POSTGRES_USER: "xx"
      POSTGRES_HOST: "db"
      ELASTIC_HOST: "elastic"
      ELASTIC_PORT: "9200"
    depends_on:
      - db
      - elastic

ERROR:

"failed to load elasticsearch nodes : org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: [{#transport#-1}{JjFZc4y-RBCYbdELAsgaAQ}{elastic}{172.20.0.2:9200}]"}

It works if I change this to

environment:
      ENVIRONMENT_NAME: "dev"
      REGION_NAME: "local"
      POSTGRES_PASSWORD: "xxx"
      POSTGRES_USER: "xx"
      POSTGRES_HOST: "db"
      ELASTIC_HOST: "elastic"
      ELASTIC_PORT: "9300" --> this is changed from 9200 

client.addTransportAddress(new TransportAddress(InetAddress.getLocalHost(), 9201));

不，为什么!

Answer 1

Spring Data Elasticsearch 3.1.11是使用版本6.2.2中的Elasticsearch客户端库构建的。因此，即使您设法与集群建立连接，客户端和集群之间也无法正常通信的机会非常高。

至于连接的设置:您应该将要连接的集群的名称添加到设置中:

Settings settings = Settings.builder()
            .put("client.transport.sniff", true)
            .put("cluster.name", "elasticsearch")
            .build();