Elasticsearch Java API深入詳解


 

0、題記

 

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

 

1、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.1、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("<em>") .setHighlighterPostTags("</em>") // 設置查詢數據的位置,分頁用 .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<String> keySet = sourceAsMap.keySet(); for (String string : keySet) { //key value 值對應關系 System.out.println(string+":"+sourceAsMap.get(string)); } System.out.println(); } }

 

1.4.2、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.3、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.4、Spring Data Elasticsearch

 

這個,沒有深入研究。Spring Data Elasticsearch更適合於使用Spring數據庫的開發人員,並且不想直接與REST API接觸。附參考2有詳細介紹。

 

2、小結

 

1)以上API的調用方式各有利弊,具體根據開發實際情況做出選擇。 
2)具體Java API的 TransportClient 方式與Jest方式的增、刪、改、查操作,可以參考(下附4)。 
3)ES的實踐開發還有很長的路要走,尤其分布式部署、原理、出現問題排查、高效檢索 Java API的運用等。

 

3、參考

 

1)、API對比:http://blog.florian-hopf.de/2016/11/java-clients-elasticsearch.html 
2)、官網API地址:https://www.elastic.co/guide/en/elasticsearch/client/java-api/2.3/index.html 
3)、Jest地址:https://github.com/searchbox-io/Jest 
4)、代碼示例:https://github.com/ameizi/elasticsearch-jest-example

 

—————————————————————————————————— 
更多ES相關實戰干貨經驗分享,請掃描下方【銘毅天下】微信公眾號二維碼關注。 
(每周至少更新一篇!)

 

這里寫圖片描述 
和你一起,死磕Elasticsearch! 
——————————————————————————————————

 

2017-05-28 15:20 思於家中床前

 

作者:銘毅天下 
轉載請標明出處,原文地址: 
http://blog.csdn.net/laoyang360/article/details/72793210 
如果感覺本文對您有幫助,請點擊‘頂’支持一下,您的支持是我堅持寫作最大的動力,謝謝!

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM