欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

ElasticSearch 测试连接工具(TestConnection)

程序员文章站 2022-05-13 16:25:44
...

截止到0.90.x的版本,Elasticsearch已经将connectedNodes从api中去掉,具体代替的方法是什么呢?也没有找到相关的说明。

因此决定自己手工写一个工具类。其实,我们只有通过API去执行一个方法,就可以测试连接是否正常。测试的方法选定为获得集群node的信息。测试代码:

 

import java.util.Map;
import org.elasticsearch.action.admin.cluster.node.info.NodeInfo;
import org.elasticsearch.action.admin.cluster.node.info.NodesInfoRequest;
import org.elasticsearch.action.admin.cluster.node.info.NodesInfoResponse;
import org.elasticsearch.client.Client;

import com.donlianli.es.ESUtils;
/**
 * @author donlianli@126.com
 * 测试服务器的可用状态
 */
public class TestConnection {
	/**
	 * 测试ES可用连接数方法
	 * 同时也也可以用以校验ES是否可以连接上
	 */
	public static void main(String[] args) {
		//通过transport方式连接哦,否则没有意义了
		Client client = ESUtils.getClient();
		try{
			NodesInfoResponse response = client.admin().cluster()
					//超时时间设置为半分钟
					.nodesInfo(new NodesInfoRequest().timeout("30")).actionGet();
	        Map<String,NodeInfo> nodesMap = response.getNodesMap();
	        //打印节点信息
	    	for(Map.Entry<String, NodeInfo> entry : nodesMap.entrySet()){
	    		System.out.println(entry.getKey() + ":" + entry.getValue().getServiceAttributes()) ;
	    	}
		}
		catch(Exception e){
			e.printStackTrace();
			System.out.println("无法连接到Elasticsearch");
		}
	}
}