独孤九剑之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，学习视频），欢迎加群领取。