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(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。