Elasticsearch Java 操作client
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: performRequestAsyncResponse 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
Elasticsearch Java 操作client相关推荐
- Elasticsearch RestHighLevelClient 已标记为被弃用 它的替代方案 Elasticsearch Java API Client 的基础教程及迁移方案
在Elasticsearch7.15版本之后,Elasticsearch官方将它的高级客户端RestHighLevelClient标记为弃用状态.同时推出了全新的Java API客户端Elastics ...
- SpringBoot整合最新Elasticsearch Java API Client 7.16教程
文章目录 前言 一.Elasticsearch和Kibana 7.16版本安装 二.pom.xml文件引入依赖 三.代码实例 总结 前言 最新在学习SpringBoot整合es的一些知识,浏览了网上的 ...
- Elasticsearch8.0版本中Elasticsearch Java API Client客户端的基本使用方法
关于Elasticsearch Java API Client客户端如何连接以及如何对索引和文档进行基本的增删改查操作请查看我的上一篇博文:Elasticsearch RestHighLevelCli ...
- es (Elasticsearch)--Java REST Client解析
扫一扫加入大数据公众号和技术交流群,了解更多大数据技术,还有免费资料等你哦 简介 ES提供了两种java的API对数据进行ES集群操作:TransportClient,Java REST Client ...
- Springboot整合ES8(Java API Client)
在 Elasticsearch7.15版本之后,Elasticsearch官方将它的高级客户端 RestHighLevelClient标记为弃用状态.同时推出了全新的 Java API客户端 Elas ...
- 干货 | Elasticsearch Java 客户端演进历史和选型指南
1.Elasticsearch java 客户端为什么要选型? Elasticsearch 官方提供了很多版本的 Java 客户端,包含但不限于: Transport 客户端 Java REST 客户 ...
- Elasticsearch java api操作(一)(Java Low Level Rest Client)
一.说明: 一.Elasticsearch提供了两个JAVA REST Client版本: 1.java low level rest client: 低级别的rest客户端,通过http与集群交互, ...
- Elasticsearch Java API 6.2(java client)
前言 本节描述了Elasticsearch提供的Java API,所有的Elasticsearch操作都使用客户端对象执行,所有操作本质上都是完全异步的(要么接收监听器,要么未来返回). 此外,客户端 ...
- java操作elasticsearch实现query String
1.CommonTersQuery: 指定字段进行模糊查询 //commonTermsQuery @Test public void test35() throws UnknownHostExcept ...
最新文章
- php yaml扩展,php的扩展 - yaml
- 无法创建 SSIS 运行时对象。请验证 DTS.dll 是否可用及是否已注册。此向导无法继续而将终止。 (SQL
- springmvc ztree 实现权限菜单的展示
- c语言程序运行结果怎么看,帮忙看看我这个C语言程序有什么错误,运行结果不正确...
- DB2临时表空间的作用
- JMS学习六(ActiveMQ消息传送模型)
- 4.2 算法之数论 1486 A Funny Game python
- 我的《一种前端代码质量检测方法及装置》专利申请
- 【JAVA】接口中的default和static方法
- java 数组对象属性数组_Java中数组的特性
- 原生android字体,安卓原生字体
- css 背景渐变详解
- 高电平和低电平 到底是啥?
- 二次开发手册——百家CMS微商城说明文档(5)
- 骑行318、 2016.7.13
- Dynamics CRM IFD部署之后遇到的登录问题
- HTML基础--标签VSCode常用快捷方式和插件
- Python3 根据m3u8下载视频,批量下载ts文件并且合并
- More than one file was found with OS independent path 'META-INF/proguard/androidx-annotations.pro'
- VII html+css
热门文章
- websocket binary 数据解析_WebSocket实现原理相关知识点
- solaris系统关闭服务器,solaris系统中关闭和开启系统服务ftp,telnet,ssh,sendmail...
- 酷派手机android版本,酷派大神的手机系统是什么?酷派大神能升级安卓4.3吗?...
- post postman 传递数组对象_PostMan Post方式传递数组数据参数 OK_go
- c语言输入三个数判断等边三角形,随便输入三个数,看能否组成一个三角形
- qpython numpy_Python-Numpy全面精简教程
- 笔记本电脑有蓝牙连接功能吗_百元蓝牙无线键盘推荐——罗技K380
- android透明activity,Android 简单实现透明Activity
- 计算机 游戏 排名2015年,2015十大高性能游戏笔记本电脑排行 最强游戏本推荐
- oracle where in优化,【求助】为什么在where过滤条件中使用in这样子查询后速度变的非常慢?!...