Java基于elasticsearch实现集群管理
这篇文章主要介绍了java基于elasticsearch实现集群管理,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
本篇文章主要是查看集群中的相关信息，具体请看代码和注释
@Test
publicvoidtest45()throwsUnknownHostException{
//1、指定es集群cluster.name是固定的key值，my-application是ES集群的名称
Settingssettings=Settings.builder().put("cluster.name","my-application").build();
//2.创建访问ES服务器的客户端
TransportClientclient=newPreBuiltTransportClient(settings)
.addTransportAddress(newTransportAddress(InetAddress.getByName("192.168.1.94"),9300));
//获取集群信息
ClusterHealthResponsehealthResponse=client.admin().cluster().prepareHealth().get();
//获取集群名称
StringclusterName=healthResponse.getClusterName();
System.out.println(clusterName);
//获取存放数据的那些节点
intnumberOfDataNodes=healthResponse.getNumberOfDataNodes();
System.out.println(numberOfDataNodes);
//获取节点的总数量
intnumberOfNodes=healthResponse.getNumberOfNodes();
System.out.println(numberOfNodes);
//获取集群中一共有多少索引
for(ClusterIndexHealthhealth:healthResponse.getIndices().values()){
Stringindex=health.getIndex();//当前索引名称
intnumberOfShards=health.getNumberOfShards();//主分片
intnumberOfReplicas=health.getNumberOfReplicas();//副本
ClusterHealthStatusstatus=health.getStatus();//得到当前的健康状况
System.out.println(status);//健康-绿色一般-黄色不健康-红色
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。