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

TransportClient.connectedNodes介绍

[英]Returns the current connected transport nodes that this client will use.

The nodes include all the nodes that are currently alive based on the transport addresses provided.
[中]返回此客户端将使用的当前连接的传输节点。
根据提供的传输地址，这些节点包括当前处于活动状态的所有节点。

代码示例

代码示例来源：origin: apache/flink

@Override
public TransportClient createClient(Map<String, String> clientConfig) {
  Settings settings = Settings.builder().put(clientConfig)
    .put(NetworkModule.HTTP_TYPE_KEY, Netty3Plugin.NETTY_HTTP_TRANSPORT_NAME)
    .put(NetworkModule.TRANSPORT_TYPE_KEY, Netty3Plugin.NETTY_TRANSPORT_NAME)
    .build();
  TransportClient transportClient = new PreBuiltTransportClient(settings);
  for (TransportAddress transport : ElasticsearchUtils.convertInetSocketAddresses(transportAddresses)) {
    transportClient.addTransportAddress(transport);
  }
  // verify that we actually are connected to a cluster
  if (transportClient.connectedNodes().isEmpty()) {
    // close the transportClient here
    IOUtils.closeQuietly(transportClient);
    throw new RuntimeException("Elasticsearch client is not connected to any Elasticsearch nodes!");
  }
  if (LOG.isInfoEnabled()) {
    LOG.info("Created Elasticsearch TransportClient with connected nodes {}", transportClient.connectedNodes());
  }
  return transportClient;
}

代码示例来源：origin: apache/flink

@Override
public TransportClient createClient(Map<String, String> clientConfig) {
  Settings settings = Settings.settingsBuilder().put(clientConfig).build();
  TransportClient transportClient = TransportClient.builder().settings(settings).build();
  for (TransportAddress address : ElasticsearchUtils.convertInetSocketAddresses(transportAddresses)) {
    transportClient.addTransportAddress(address);
  }
  // verify that we actually are connected to a cluster
  if (transportClient.connectedNodes().isEmpty()) {
    // close the transportClient here
    IOUtils.closeQuietly(transportClient);
    throw new RuntimeException("Elasticsearch client is not connected to any Elasticsearch nodes!");
  }
  if (LOG.isInfoEnabled()) {
    LOG.info("Created Elasticsearch TransportClient with connected nodes {}", transportClient.connectedNodes());
  }
  return transportClient;
}

代码示例来源：origin: apache/flink

if (transportClient.connectedNodes().isEmpty()) {
  throw new RuntimeException("Elasticsearch client is not connected to any Elasticsearch nodes!");
  LOG.info("Created Elasticsearch TransportClient with connected nodes {}", transportClient.connectedNodes());

代码示例来源：origin: org.apache.apex/malhar-contrib

@Override
public boolean isConnected()
{
 if (client != null) {
  return client.connectedNodes().size() != 0;
 }
 return false;
}

代码示例来源：origin: stackoverflow.com

private void verifyConnection(TransportClient client) {
  ImmutableList<DiscoveryNode> nodes = client.connectedNodes();
  if (nodes.isEmpty()) {
    throw new ElasticsearchException(
        "No nodes available. Verify ES is running!");
  } else {
    log.info("connected to nodes: " + nodes.toString());
  }
}

代码示例来源：origin: apache/apex-malhar

@Override
public boolean isConnected()
{
 if (client != null) {
  return client.connectedNodes().size() != 0;
 }
 return false;
}

代码示例来源：origin: javanna/elasticshell

public List<String> connectedNodes() {
  ImmutableList<DiscoveryNode> discoveryNodes = client().connectedNodes();
  List<String> nodes = new ArrayList<String>();
  for (DiscoveryNode discoveryNode : discoveryNodes) {
    TransportAddress address = discoveryNode.address();
    if (address != null) {
      nodes.add(address.toString());
    }
  }
  return nodes;
}

代码示例来源：origin: SpringDataElasticsearchDevs/spring-data-elasticsearch

protected void buildClient() throws Exception {
  client =  new TransportClient(settings());
  Assert.notEmpty(clusterNodes,"[Assertion failed] clusterNodes settings missing.");
  for (String clusterNode : clusterNodes) {
    String hostName = substringBefore(clusterNode, COLON);
    String port = substringAfter(clusterNode, COLON);
    Assert.hasText(hostName,"[Assertion failed] missing host name in 'clusterNodes'");
    Assert.hasText(port,"[Assertion failed] missing port in 'clusterNodes'");
    logger.info("adding transport node : " + clusterNode);
    client.addTransportAddress(new InetSocketTransportAddress(hostName, Integer.valueOf(port)));
  }
  client.connectedNodes();
}

代码示例来源：origin: stackoverflow.com

import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;

import java.net.InetAddress;
import java.net.UnknownHostException;

public class App {
  public static void main(String[] args) throws UnknownHostException {
    // The following settings aren't strictly necessary, because the default cluster name is "elasticsearch".
    Settings settings = Settings.builder().put("cluster.name", "elasticsearch").build();
    TransportClient client = new PreBuiltTransportClient(settings);
    client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));
    System.out.println(client.connectedNodes());
  }
}

代码示例来源：origin: SpringForAll/springcloud-thoth

@Bean(destroyMethod = "close")
public Client client() throws Exception {
  //TransportClient client = TransportClient.builder().settings(settings()).build();
  TransportClient client = new PreBuiltTransportClient(settings());
  //TransportClient client = new PreBuiltXPackTransportClient(settings()); //X-pack
  String clusterNodes = elasticsearchProperties.getClusterNodes();
  Assert.hasText(clusterNodes, "[Assertion failed] clusterNodes settings missing.");
  for (String clusterNode : split(clusterNodes, ElasticsearchProperties.COMMA)) {
    String hostName = substringBeforeLast(clusterNode, ElasticsearchProperties.COLON);
    String port = substringAfterLast(clusterNode, ElasticsearchProperties.COLON);
    Assert.hasText(hostName, "[Assertion failed] missing host name in 'clusterNodes'");
    Assert.hasText(port, "[Assertion failed] missing port in 'clusterNodes'");
    logger.info("adding transport node : " + clusterNode);
    client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName
        (hostName), Integer.valueOf(port)));
  }
  client.connectedNodes();
  return client;
}

代码示例来源：origin: org.apache.flink/flink-connector-elasticsearch2_2.11

@Override
public TransportClient createClient(Map<String, String> clientConfig) {
  Settings settings = Settings.settingsBuilder().put(clientConfig).build();
  TransportClient transportClient = TransportClient.builder().settings(settings).build();
  for (TransportAddress address : ElasticsearchUtils.convertInetSocketAddresses(transportAddresses)) {
    transportClient.addTransportAddress(address);
  }
  // verify that we actually are connected to a cluster
  if (transportClient.connectedNodes().isEmpty()) {
    // close the transportClient here
    IOUtils.closeQuietly(transportClient);
    throw new RuntimeException("Elasticsearch client is not connected to any Elasticsearch nodes!");
  }
  if (LOG.isInfoEnabled()) {
    LOG.info("Created Elasticsearch TransportClient with connected nodes {}", transportClient.connectedNodes());
  }
  return transportClient;
}

代码示例来源：origin: Stratio/elasticsearch-benchmark

client.addTransportAddress(new InetSocketTransportAddress(host, 9300));
client.connectedNodes();

代码示例来源：origin: jaibeermalik/searchanalytics-bigdata

protected Client createClient() {
  if (client == null) {
    if (logger.isDebugEnabled()) {
      logger.debug("Creating client for Search!");
    }
    // Try starting search client at context loading
    try {
      final Settings settings = ImmutableSettings
          .settingsBuilder()
          .put(ElasticSearchReservedWords.CLUSTER_NAME.getText(),
              searchServerClusterName).build();
      TransportClient transportClient = new TransportClient(settings);
      transportClient = transportClient
          .addTransportAddress(new InetSocketTransportAddress(
              "localhost", 9300));
      if (transportClient.connectedNodes().size() == 0) {
        logger.error("There are no active nodes available for the transport, it will be automatically added once nodes are live!");
      }
      client = transportClient;
    } catch (final Exception ex) {
      // ignore any exception, dont want to stop context loading
      logger.error("Error occured while creating search client!", ex);
    }
  }
  return client;
}

代码示例来源：origin: jaibeermalik/elasticsearch-tutorial

if(transportClient.connectedNodes().size() == 0)

代码示例来源：origin: fujitsu-pio/io

private void prepareClient(String clusterName, String hostNames) {
  if (esTransportClient != null) {
    return;
  }
  if (clusterName == null || hostNames == null) {
    return;
  }
  Settings st = Settings.settingsBuilder()
      .put("cluster.name", clusterName)
      .put("client.transport.sniff", true)
      .build();
  List<DiscoveryNode> connectedNodes = null;
  esTransportClient = TransportClient.builder().settings(st).addPlugin(DeleteByQueryPlugin.class).build();
  List<EsHost> hostList = parseConfigAndInitializeHostsList(hostNames);
  for (EsHost host : hostList) {
    
    esTransportClient.addTransportAddress(new InetSocketTransportAddress(new InetSocketAddress(host.getName(), host.getPort()) ));
    connectedNodes = esTransportClient.connectedNodes();
  }
  if (connectedNodes.isEmpty()) {
    throw new EsClientException("Datastore Connection Error.");
  }
  loggingConnectedNode(connectedNodes);
}

代码示例来源：origin: Stratio/wikipedia-parser

client.addTransportAddress(new InetSocketTransportAddress(host, 9300));
client.connectedNodes();

代码示例来源：origin: javanna/elasticshell

protected ShellNativeClient newTransportClient(TransportAddress... addresses) {

    Settings settings = ImmutableSettings.settingsBuilder().put("client.transport.ignore_cluster_name", true).build();
    org.elasticsearch.client.transport.TransportClient client = new TransportClient(settings).addTransportAddresses(addresses);

    //if no connected node we can already close the (useless) client
    if (client.connectedNodes().size() == 0) {
      client.close();
      return null;
    }

    AbstractClient<TransportClient, JsonInput, JsonOutput> shellClient = clientWrapper.wrapEsTransportClient(client);
    resourceRegistry.registerResource(shellClient);
    ShellNativeClient shellNativeClient = clientWrapper.wrapShellClient(shellClient);
    clientScopeSynchronizerRunner.startSynchronizer(shellNativeClient);
    return shellNativeClient;
  }
}