本文整理了Java中org.elasticsearch.client.transport.TransportClient.transportAddresses()方法的一些代码示例，展示了TransportClient.transportAddresses()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TransportClient.transportAddresses()方法的具体详情如下：
包路径：org.elasticsearch.client.transport.TransportClient
类名称：TransportClient
方法名：transportAddresses

TransportClient.transportAddresses介绍

[英]Returns the current registered transport addresses to use (added using #addTransportAddress(org.elasticsearch.common.transport.TransportAddress).
[中]返回要使用的当前注册传输地址（使用#addTransportAddress（org.elasticsearch.common.transport.TransportAddress）添加）。

代码示例

代码示例来源：origin: SonarSource/sonarqube

private static String displayedAddresses(TransportClient nativeClient) {
 return nativeClient.transportAddresses().stream().map(TransportAddress::toString).collect(Collectors.joining(", "));
}

代码示例来源：origin: SonarSource/sonarqube

private static String displayedAddresses(TransportClient nativeClient) {
 return nativeClient.transportAddresses().stream().map(TransportAddress::toString).collect(Collectors.joining(", "));
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void connection_to_remote_es_nodes_when_cluster_mode_is_enabled_and_local_es_is_disabled() {
 settings.setProperty(CLUSTER_ENABLED.getKey(), true);
 settings.setProperty(CLUSTER_NODE_TYPE.getKey(), "application");
 settings.setProperty(CLUSTER_SEARCH_HOSTS.getKey(), format("%s:8080,%s:8081", localhost, localhost));
 EsClient client = underTest.provide(settings.asConfig());
 TransportClient transportClient = (TransportClient) client.nativeClient();
 assertThat(transportClient.transportAddresses()).hasSize(2);
 TransportAddress address = transportClient.transportAddresses().get(0);
 assertThat(address.getAddress()).isEqualTo(localhost);
 assertThat(address.getPort()).isEqualTo(8080);
 address = transportClient.transportAddresses().get(1);
 assertThat(address.getAddress()).isEqualTo(localhost);
 assertThat(address.getPort()).isEqualTo(8081);
 assertThat(logTester.logs(LoggerLevel.INFO)).has(new Condition<>(s -> s.contains("Connected to remote Elasticsearch: [" + localhost + ":8080, " + localhost + ":8081]"), ""));
 // keep in cache
 assertThat(underTest.provide(settings.asConfig())).isSameAs(client);
}

代码示例来源：origin: SonarSource/sonarqube

@Test
 public void es_client_provider_must_add_default_port_when_not_specified() {
  settings.setProperty(CLUSTER_ENABLED.getKey(), true);
  settings.setProperty(CLUSTER_NODE_TYPE.getKey(), "application");
  settings.setProperty(CLUSTER_SEARCH_HOSTS.getKey(), format("%s,%s:8081", localhost, localhost));

  EsClient client = underTest.provide(settings.asConfig());
  TransportClient transportClient = (TransportClient) client.nativeClient();
  assertThat(transportClient.transportAddresses()).hasSize(2);
  TransportAddress address = transportClient.transportAddresses().get(0);
  assertThat(address.getAddress()).isEqualTo(localhost);
  assertThat(address.getPort()).isEqualTo(9001);
  address = transportClient.transportAddresses().get(1);
  assertThat(address.getAddress()).isEqualTo(localhost);
  assertThat(address.getPort()).isEqualTo(8081);
  assertThat(logTester.logs(LoggerLevel.INFO)).has(new Condition<>(s -> s.contains("Connected to remote Elasticsearch: [" + localhost + ":9001, " + localhost + ":8081]"), ""));

  // keep in cache
  assertThat(underTest.provide(settings.asConfig())).isSameAs(client);
 }
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void connection_to_local_es_when_cluster_mode_is_disabled() {
 settings.setProperty(CLUSTER_ENABLED.getKey(), false);
 settings.setProperty(SEARCH_HOST.getKey(), localhost);
 settings.setProperty(SEARCH_PORT.getKey(), 8080);
 EsClient client = underTest.provide(settings.asConfig());
 TransportClient transportClient = (TransportClient) client.nativeClient();
 assertThat(transportClient.transportAddresses()).hasSize(1);
 TransportAddress address = transportClient.transportAddresses().get(0);
 assertThat(address.getAddress()).isEqualTo(localhost);
 assertThat(address.getPort()).isEqualTo(8080);
 assertThat(logTester.logs(LoggerLevel.INFO)).has(new Condition<>(s -> s.contains("Connected to local Elasticsearch: [" + localhost + ":8080]"), ""));
 // keep in cache
 assertThat(underTest.provide(settings.asConfig())).isSameAs(client);
}

代码示例来源：origin: org.sonarsource.sonarqube/sonar-server

private static String displayedAddresses(TransportClient nativeClient) {
 return nativeClient.transportAddresses().stream().map(TransportAddress::toString).collect(Collectors.joining(", "));
}

代码示例来源：origin: org.sonarsource.sonarqube/sonar-main

private static String displayedAddresses(TransportClient nativeClient) {
 return nativeClient.transportAddresses().stream().map(TransportAddress::toString).collect(Collectors.joining(", "));
}

代码示例来源：origin: crate/elasticsearch-inout-plugin

private void closeClient() {
  if (transportClient != null) {
    TransportClient tc = ((TransportClient) transportClient);
    for (TransportAddress address : tc.transportAddresses()) {
      tc.removeTransportAddress(address);
    }
    transportClient.close();
  }
}

代码示例来源：origin: Netflix/metacat

if (client.transportAddresses().isEmpty()) {
  throw new IllegalStateException("No Elasticsearch cluster nodes added. Unable to create client.");