0、題記

之前Elasticsearch的應(yīng)用比較多，但大多集中在關(guān)系型、非關(guān)系型數(shù)據(jù)庫(kù)與Elasticsearch之間的同步。以上內(nèi)容完成了Elasticsearch所需要的基礎(chǔ)數(shù)據(jù)量的供給。但想要在海量的數(shù)據(jù)中找到和自己相關(guān)的業(yè)務(wù)數(shù)據(jù)，實(shí)現(xiàn)對(duì)已有的數(shù)據(jù)實(shí)現(xiàn)全文檢索、分類統(tǒng)計(jì)等功能并應(yīng)用到業(yè)務(wù)系統(tǒng)中，必須借助Java API來實(shí)現(xiàn)。

1、Elasticsearch Java API 概覽

Elasticsearch Java API 相關(guān)使用研究結(jié)果：

1.1 國(guó)內(nèi)的博文講解Elasticsearch Java API 大多偏重于實(shí)現(xiàn)，沒有對(duì)Elasticsearch Java API 整體進(jìn)行講解。這樣的問題是頭疼醫(yī)頭，腳痛醫(yī)腳，始終不得原理。

1.2 Elasticsearch1.X，2.X，5.X隨著版本的迭代，除了系統(tǒng)升級(jí)，Java API也做了相對(duì)較大的調(diào)整。

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

1.3 Elasticsearch官網(wǎng)Java API提供了相對(duì)豐富的解讀。（文末參考給出了官網(wǎng)地址）

1.4 Elasticsearch Java API 大致分如下四類：

1.4.1、TransportClient

步驟1：獲取client；?
步驟2：執(zhí)行對(duì)應(yīng)的增、刪、改、查操作。

查詢使用參考（以下我已經(jīng)驗(yàn)證過，好用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)// 設(shè)置查詢類型 // 1.SearchType.DFS_QUERY_THEN_FETCH = 精確查詢 // 2.SearchType.SCAN = 掃描查詢,無序 // 3.SearchType.COUNT = 不設(shè)置的話,這個(gè)為默認(rèn)值,還有的自己去試試吧.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)// 設(shè)置查詢關(guān)鍵詞.setQuery(QueryBuilders.matchQuery(term, queryString)).addHighlightedField(term).setHighlighterPreTags("<em>").setHighlighterPostTags("</em>")// 設(shè)置查詢數(shù)據(jù)的位置,分頁(yè)用 .setFrom(0) // 設(shè)置查詢結(jié)果集的最大條數(shù) .setSize(60) // 設(shè)置是否按查詢匹配度排序 .setExplain(true) // 最后就是返回搜索響應(yīng)信息.execute().actionGet(); SearchHits searchHits = response.getHits(); System.out.println("-----------------在["+term+"]中搜索關(guān)鍵字["+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高亮部分內(nèi)容:"+highlightField.getFragments()[0].string()); Map<String, Object> sourceAsMap = searchHit.sourceAsMap(); Set<String> keySet = sourceAsMap.keySet(); for (String string : keySet) { //key value 值對(duì)應(yīng)關(guān)系 System.out.println(string+":"+sourceAsMap.get(string)); } System.out.println(); } }

1.4.2、RestClient

elasticsearch 5.0引入了一個(gè)新的客戶端 RestClient ，使用HTTP API elasticsearch代替內(nèi)部協(xié)議。這需要更少依賴關(guān)系。你也不需要關(guān)注那么多版本，當(dāng)前客戶端也可以用于elasticsearch 2.x版本。

使用參考如下（以下我沒有代碼驗(yàn)證）：

HttpEntity entity = new NStringEntity("{ \"query\": { \"match_all\": {}}}",ContentType.APPLICATION_JSON);// alternative: performRequestAsyncResponse response = restClient.performRequest("POST", "/_search", emptyMap(), entity);String json = toString(response.getEntity());// ...

1.4.3、Jest

Jest是ElasticSearch的Java HTTP Rest客戶端。 Jest填補(bǔ)了 ElasticSearch 缺少 Http Rest接口 客戶端的空白。?
通過Maven編譯實(shí)現(xiàn)，需要設(shè)定好不同的版本。現(xiàn)在pom.xml最新的Elasticsearch版本為5.3.3（2017年5月27日），5.3.3的API向ES2.3.4插入索引數(shù)據(jù)，不能保障數(shù)據(jù)正常插入，且沒有報(bào)錯(cuò)。

具體使用參考(以下示例跑通，驗(yàn)證ok）：

/** * @brief：全文檢索入口 * @throws Exception */ private static void fullTextQuery(String queryString) throws Exception { JestClient jestClient = JestExample.getJestClient(); //工廠模式實(shí)現(xiàn) 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

這個(gè)，沒有深入研究。Spring Data Elasticsearch更適合于使用Spring數(shù)據(jù)庫(kù)的開發(fā)人員，并且不想直接與REST API接觸。附參考2有詳細(xì)介紹。

2、小結(jié)

1）以上API的調(diào)用方式各有利弊，具體根據(jù)開發(fā)實(shí)際情況做出選擇。?
2）具體Java API的 TransportClient 方式與Jest方式的增、刪、改、查操作，可以參考(下附4）。?
3）ES的實(shí)踐開發(fā)還有很長(zhǎng)的路要走，尤其分布式部署、原理、出現(xiàn)問題排查、高效檢索 Java API的運(yùn)用等。

3、參考

1）、API對(duì)比：http://blog.florian-hopf.de/2016/11/java-clients-elasticsearch.html?
2）、官網(wǎng)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

總結(jié)

以上是生活随笔為你收集整理的Elasticsearch Java 操作client的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。