Elasticsearch Java API四种实现方式

叁歲伎倆 2022-05-22 06:48 158阅读 0赞

# 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.3.1 Jest介绍 #####

Jest是Elasticsearch 的Java Http Rest 客户端。

ElasticSearch已经具备应用于Elasticsearch内部的Java API，但是Jest弥补了ES自有API缺少Elasticsearch Http Rest接口客户端的不足。

#  #

####  ####

##### 1.4.3.2、 Jest优势概括如下： #####

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

2）若ES集群使用不同的ES版本，使用原生ES API会有问题，而Jest不会；

3） 更安全（可以在Http层添加安全处理）。

#  #

####  ####

##### 1.4.3.3、pom #####

概括下，Jest使用maven的方式管理项目。支持最新的Elasticsearch。   
pom.xml有相关配置信息。（默认是最新ES版本相关的pom.xml,截止：2017-08-13 16:38, 其默认支持版本5.3.2）。

<dependency>
    
      <groupId>io.searchbox</groupId>
      <artifactId>jest</artifactId>
      <version>2.0.0</version>
    </dependency>

高版本ES也是可以使用的，我实际开发ES5.4.0，用的JEST的做的后端接口开发。

#  #

####  ####

##### 1.4.3.4、Jest使用 #####

![这里写图片描述][SouthEast]

#  #

####  ####

##### 1.4.3.5、实战Jest干货 #####

[https://github.com/ameizi/elasticsearch-jest-example/blob/master/src/main/java/net/aimeizi/client/elasticsearch/TransportClient.java][https_github.com_ameizi_elasticsearch-jest-example_blob_master_src_main_java_net_aimeizi_client_elasticsearch_TransportClient.java]

#  #

####  ####

##### 1.4.3.6、Jest相关下载 #####

Jest github地址：[https://github.com/searchbox-io/Jest][https_github.com_searchbox-io_Jest]

### 1.4.4、Spring Data Elasticsearch ###

可参考[https://blog.csdn.net/qq\_33314107/article/details/80725994][https_blog.csdn.net_qq_33314107_article_details_80725994]

# 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][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][https_www.elastic.co_guide_en_elasticsearch_client_java-api_2.3_index.html]   
3）、Jest地址：[https://github.com/searchbox-io/Jest][https_github.com_searchbox-io_Jest]

4）、代码示例：[https://github.com/ameizi/elasticsearch-jest-example][https_github.com_ameizi_elasticsearch-jest-example]

转载自[https://blog.csdn.net/laoyang360/article/details/72793210][https_blog.csdn.net_laoyang360_article_details_72793210]

[SouthEast]: /images/20220522/7430ef7be65f408ba43865ae13b36f21.png
[https_github.com_ameizi_elasticsearch-jest-example_blob_master_src_main_java_net_aimeizi_client_elasticsearch_TransportClient.java]: https://github.com/ameizi/elasticsearch-jest-example/blob/master/src/main/java/net/aimeizi/client/elasticsearch/TransportClient.java
[https_github.com_searchbox-io_Jest]: https://github.com/searchbox-io/Jest
[https_blog.csdn.net_qq_33314107_article_details_80725994]: https://blog.csdn.net/qq_33314107/article/details/80725994
[http_blog.florian-hopf.de_2016_11_java-clients-elasticsearch.html]: http://blog.florian-hopf.de/2016/11/java-clients-elasticsearch.html
[https_www.elastic.co_guide_en_elasticsearch_client_java-api_2.3_index.html]: https://www.elastic.co/guide/en/elasticsearch/client/java-api/2.3/index.html
[https_github.com_ameizi_elasticsearch-jest-example]: https://github.com/ameizi/elasticsearch-jest-example
[https_blog.csdn.net_laoyang360_article_details_72793210]: https://blog.csdn.net/laoyang360/article/details/72793210