国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學(xué)院 > 開發(fā)設(shè)計(jì) > 正文

ElasticSearch 測試連接工具(TestConnection)

2019-11-09 19:54:19
字體:
供稿:網(wǎng)友

截止到0.90.x的版本,Elasticsearch已經(jīng)將connectedNodes從api中去掉,具體代替的方法是什么呢?也沒有找到相關(guān)的說明。

因此決定自己手工寫一個(gè)工具類。其實(shí),我們只有通過API去執(zhí)行一個(gè)方法,就可以測試連接是否正常。測試的方法選定為獲得集群node的信息。測試代碼:

java代碼

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

* 測試服務(wù)器的可用狀態(tài)

*/  

public class TestConnection {  

   /**

    * 測試ES可用連接數(shù)方法

    * 同時(shí)也也可以用以校驗(yàn)ES是否可以連接上

    */  

   public static void main(String[] args) {  

       //通過transport方式連接哦,否則沒有意義了  

       Client client = ESUtils.getClient();  

       try{  

           NodesInfoResponse response = client.admin().cluster()  

                   //超時(shí)時(shí)間設(shè)置為半分鐘  

                   .nodesInfo(new NodesInfoRequest().timeout("30")).actionGet();  

           Map<String,NodeInfo> nodesMap = response.getNodesMap();  

           //打印節(jié)點(diǎn)信息  

           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");  

       }  

   }  

}  


發(fā)表評論 共有條評論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 扎鲁特旗| 广德县| 武义县| 中西区| 莆田市| 东乌| 钟祥市| 安图县| 石棉县| 临颍县| 宁德市| 麟游县| 德昌县| 民乐县| 昭觉县| 越西县| 兴安县| 嘉鱼县| 南郑县| 曲阳县| 肇州县| 庆云县| 迁安市| 高陵县| 分宜县| 郓城县| 屏边| 广丰县| 盐池县| 九江县| 揭阳市| 聂荣县| 深水埗区| 广饶县| 龙州县| 云霄县| 黎平县| 会昌县| 涿鹿县| 东宁县| 普陀区|