獨孤九劍之Elasticsearch Java API破劍式

0、題記 以前Elasticsearch的應用比較多，但大多集中在關係型、非關係型數據庫與Elasticsearch之間的同步。以上內容完成了Elasticsearch所須要的基礎數據量的供給。但想要在海量的數據中找到和本身相關的業務數據，實現對已有的數據實現全文檢索、分類統計等功能並應用到業務系統中，必須藉助Java API來實現。

一、Elasticsearch Java API 概覽 Elasticsearch Java API 相關使用研究結果：

1.1 國內的博文講解Elasticsearch Java API 大多偏重於實現，沒有對Elasticsearch Java API 總體進行講解。這樣的問題是頭疼醫頭，腳痛醫腳，始終不得原理。

1.2 Elasticsearch1.X，2.X，5.X隨着版本的迭代，除了系統升級，Java API也作了相對較大的調整。

也就是說，1.X的API在2.X以及5.X乃至將來6.X版本都不是通用的。如1.x的fuzzyLikeThisQuery在後續版本都再也不存在。

1.3 Elasticsearch官網Java API提供了相對豐富的解讀。（文末參考給出了官網地址）

1.4 Elasticsearch Java API 大體分以下四類：

1.4.一、TransportClient

步驟1：獲取client；

步驟2：執行對應的增、刪、改、查操做。

查詢使用參考（如下我已經驗證過，好用ok）：

/**

• Query Search
• @param index
• @param type
• @param term
• @param queryString */ private static void querySearch(String index, String type,String term,String queryString){ Client client = createTransportClient(); SearchResponse response = client.prepareSearch(index) .setTypes(type) // 設置查詢類型 // 1.SearchType.DFS_QUERY_THEN_FETCH = 精確查詢 // 2.SearchType.SCAN = 掃描查詢,無序 // 3.SearchType.COUNT = 不設置的話,這個爲默認值,還有的本身去試試吧 .setSearchType(SearchType.DFS_QUERY_THEN_FETCH) // 設置查詢關鍵詞 .setQuery(QueryBuilders.matchQuery(term, queryString)) .addHighlightedField(term) .setHighlighterPreTags("") .setHighlighterPostTags("") // 設置查詢數據的位置,分頁用 .setFrom(0) // 設置查詢結果集的最大條數 .setSize(60) // 設置是否按查詢匹配度排序 .setExplain(true) // 最後就是返回搜索響應信息 .execute() .actionGet(); SearchHits searchHits = response.getHits(); System.out.println("-----------------在["+term+"]中搜索關鍵字["+queryString+"]---------------------"); System.out.println("共匹配到:"+searchHits.getTotalHits()+"條記錄!"); SearchHit[] hits = searchHits.getHits(); for (SearchHit searchHit : hits) { //獲取高亮的字段 Map<String, HighlightField> highlightFields = searchHit.getHighlightFields(); HighlightField highlightField = highlightFields.get(term); System.out.println("高亮字段:"+highlightField.getName()+"\n高亮部份內容:"+highlightField.getFragments()[0].string()); Map<String, Object> sourceAsMap = searchHit.sourceAsMap(); Set keySet = sourceAsMap.keySet(); for (String string : keySet) { //key value 值對應關係 System.out.println(string+":"+sourceAsMap.get(string)); } System.out.println(); } } 1.4.二、RestClient

elasticsearch 5.0引入了一個新的客戶端 RestClient ，使用HTTP API elasticsearch代替內部協議。這須要更少依賴關係。你也不須要關注那麼多版本，當前客戶端也能夠用於elasticsearch 2.x版本。

使用參考以下（如下我沒有代碼驗證）：

HttpEntity entity = new NStringEntity( "{ "query": { "match_all": {}}}", ContentType.APPLICATION_JSON); // alternative: performRequestAsync Response response = restClient.performRequest("POST", "/_search", emptyMap(), entity); String json = toString(response.getEntity()); // ... 1.4.三、Jest

Jest是ElasticSearch的Java HTTP Rest客戶端。 Jest填補了 ElasticSearch 缺乏 Http Rest接口 客戶端的空白。

經過Maven編譯實現，須要設定好不一樣的版本。如今pom.xml最新的Elasticsearch版本爲5.3.3（2017年5月27日），5.3.3的API向ES2.3.4插入索引數據，不能保障數據正常插入，且沒有報錯。

具體使用參考(如下示例跑通，驗證ok）：

/**

• @brief：全文檢索入口
• @throws Exception */ private static void fullTextQuery(String queryString) throws Exception { JestClient jestClient = JestExample.getJestClient(); //工廠模式實現 SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); searchSourceBuilder.query(QueryBuilders.queryStringQuery(queryString));

Search search = new Search.Builder(searchSourceBuilder.toString()) // .addIndex("article") .build(); SearchResult result = jestClient.execute(search); System.out.println(result.getJsonString()); } 1.4.3.1 Jest介紹

Jest是Elasticsearch 的Java Http Rest 客戶端。

ElasticSearch已經具有應用於Elasticsearch內部的Java API，可是Jest彌補了ES自有API缺乏Elasticsearch Http Rest接口客戶端的不足。

1.4.3.二、 Jest優點歸納以下：

1）提供Restful API， 原生ES API不具有；

2）若ES集羣使用不一樣的ES版本，使用原生ES API會有問題，而Jest不會；

3） 更安全（能夠在Http層添加安全處理）。

1.4.3.三、pom

歸納下，Jest使用maven的方式管理項目。支持最新的Elasticsearch。

pom.xml有相關配置信息。（默認是最新ES版本相關的pom.xml,截止：2017-08-13 16:38, 其默認支持版本5.3.2）。

io.searchbox jest 2.0.0 高版本ES也是能夠使用的，我實際開發ES5.4.0，用的JEST的作的後端接口開發。

1.4.3.四、Jest使用

喜歡的點點關注，點點贊。 對Java技術，架構技術感興趣的同窗，歡迎加QQ羣668041364?，一塊兒學習，相互討論。

羣內已經有小夥伴將知識體系整理好（源碼，筆記，PPT，學習視頻），歡迎加羣領取。