//集群管理

@Test

public void test() throws IOException, InterruptedException, ExecutionException {

//指定ES集群

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

//创建访问es服务器的客户端

TransportClient client = new PreBuiltTransportClient(settings)

.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.42.160"),9300));

ClusterHealthResponse healths = client.admin().cluster().prepareHealth().get();

String clusterName = healths.getClusterName();

System.out.println("clusterName="+clusterName);

int numberofDataNodes = healths.getNumberOfDataNodes();

System.out.println("numberofDataNodes="+numberofDataNodes);

int numberOfNodes = healths.getNumberOfDataNodes();

System.out.println("numberOfNodes="+numberOfNodes);

for(ClusterIndexHealth health : healths.getIndices().values()) {

String index = health.getIndex();

int numberOfShards = health.getNumberOfShards();

int numberOfReplicas = health.getNumberOfReplicas();

System.out.printf("index=%s,numberOfShareds=%d,numberOfReplicas=%d ",index,numberOfShards,numberOfReplicas);

ClusterHealthStatus status = health.getStatus();

System.out.println(status.toString());

}

}