Elasticsearch Java API深入详解

2022-11-22 09:09:22

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
如果感觉本文对您有帮助，请点击‘顶’支持一下，您的支持是我坚持写作最大的动力，谢谢！

码农公寓