ElasticSearch7.3.2-RestHighLevelClient实战

2023-12-03 12:58
文章标签 实战 elasticsearch7.3 resthighlevelclient

本文主要是介绍ElasticSearch7.3.2-RestHighLevelClient实战，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、项目依赖

既然我们server安装7.3.2，那么我们客户端选择同样版本，高版本提供了更高层的api抽象封装。

<!--引入es -->
<dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.3.2</version>
</dependency><dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>7.3.2</version>
</dependency>

二、项目配置

  • application.properties配置
spring.elasticsearch.nodes=10.143.228.25:9200,10.143.228.26:9200,10.143.228.128:9200
spring.elasticsearch.username=elastic
spring.elasticsearch.password=elastic
  • config bean 配置
import com.google.common.collect.Lists;
import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.util.Arrays;
import java.util.List;/*** @description: elasticSearch配置* @Date : 2020/5/14 上午11:37* @Author : 石冬冬-Seig Heil*/
@Configuration
public class ElasticSearchConfig{/*** 使用的协议*/final static String schema = "http";/*** 连接超时时间*/final static int connectTimeOut = 1000;/*** 连接超时时间*/final static int socketTimeOut = 30000;/*** 获取连接的超时时间*/final static int connectionRequestTimeOut = 500;/*** 最大连接数*/final static int maxConnectNum = 100;/*** 最大路由连接数*/final static int maxConnectPerRoute = 100;@Value("${spring.elasticsearch.nodes}")String[] nodes;@Value("${spring.elasticsearch.username}")String username;@Value("${spring.elasticsearch.password}")String password;@Bean(name = "restHighLevelClient")public RestHighLevelClient client() {RestClientBuilder builder = RestClient.builder(hostList().toArray(new HttpHost[0]));final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY,new UsernamePasswordCredentials(username, password));builder.setHttpClientConfigCallback(httpClientBuilder -> {httpClientBuilder.disableAuthCaching();return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);});// 异步httpclient连接延时配置builder.setRequestConfigCallback(requestConfigBuilder -> {requestConfigBuilder.setConnectTimeout(connectTimeOut);requestConfigBuilder.setSocketTimeout(socketTimeOut);requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeOut);return requestConfigBuilder;});// 异步httpclient连接数配置builder.setHttpClientConfigCallback(httpClientBuilder -> {httpClientBuilder.setMaxConnTotal(maxConnectNum);httpClientBuilder.setMaxConnPerRoute(maxConnectPerRoute);return httpClientBuilder;});return new RestHighLevelClient(builder);}List<HttpHost> hostList(){List<HttpHost> nodeList = Lists.newArrayList();Arrays.asList(nodes).stream().forEach(each -> {String[] array = each.split(":");nodeList.add(new HttpHost(array[0],Integer.valueOf(array[1]),schema));});return nodeList;}
}

三、示例介绍

3.1、创建索引

settings是修改分片和副本数的，mappings是修改字段和类型的。

@ApiOperation(value = "createIndex", notes = "createIndex")
@PostMapping("/createIndex/{indexName}")
public Result createIndex(@PathVariable String indexName, @RequestBody Map<String,Map<String,Object>> config) {try {CreateIndexRequest createIndexRequest = new CreateIndexRequest(indexName);createIndexRequest.settings(config.get("settings"));createIndexRequest.mapping(config.get("mapping"));CreateIndexResponse createIndexResponse = client.indices().create(createIndexRequest, RequestOptions.DEFAULT);return Result.suc(JSONObject.toJSON(createIndexResponse));} catch (IOException e) {log.error("[createIndex]",e);return Result.fail(e);}
}

3.2、判断索引是否存在

public boolean exists(String index) {boolean exists;try {GetIndexRequest getIndexRequest = new GetIndexRequest(index);getIndexRequest.humanReadable(true);exists = client.indices().exists(getIndexRequest, DEFAULT);} catch (IOException e) {log.error("[ElasticSearch]exists，index={}",index, e);throw new RuntimeException("[ElasticSearch]exists异常");}return exists;
}

3.3、删除索引

public boolean deleteIndex(String... indices) {boolean acknowledged;try {DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest(indices);AcknowledgedResponse delete = client.indices().delete(deleteIndexRequest,DEFAULT);acknowledged = delete.isAcknowledged();} catch (IOException e) {log.error("[ElasticSearch]deleteIndex，indices={}", JSON.toJSONString(indices), e);throw new RuntimeException("[ElasticSearch]deleteIndex异常");}return acknowledged;
}

3.4、插入文档

@ApiOperation(value = "insertRecord", notes = "insertRecord")
@PostMapping("/insertRecord/{indexName}")
public Result insertRecord(@RequestBody Map<String,Object> param, @PathVariable String indexName) {IndexRequest indexRequest = new IndexRequest(indexName);String userJson = JSONObject.toJSONString(param);indexRequest.source(userJson, XContentType.JSON);try {IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);if (response != null) {ReplicationResponse.ShardInfo shardInfo = response.getShardInfo();if (shardInfo.getTotal() != shardInfo.getSuccessful()) {log.info("shardInfo={}", JSONObject.toJSON(shardInfo));}// 如果有分片副本失败，可以获得失败原因信息if (shardInfo.getFailed() > 0) {for (ReplicationResponse.ShardInfo.Failure failure : shardInfo.getFailures()) {String reason = failure.reason();log.info("副本失败原因,reason={}",reason);}}}return Result.suc(JSONObject.toJSON(response));} catch (IOException e) {log.info("[insertRecord]",e);return Result.fail(e);}
}

3.5、批量插入文档

@ApiOperation(value = "bulkInsertRecord", notes = "bulkInsertRecord")
@PostMapping("/bulkInsertRecord/{indexName}")
public Result bulkInsertRecord(@RequestBody List<Map<String,Object>> batch, @PathVariable String indexName) {BulkRequest bulkRequest = new BulkRequest();batch.forEach(each -> {IndexRequest indexRequest = new IndexRequest(indexName).source(each, XContentType.JSON);bulkRequest.add(indexRequest);});//同步try {BulkResponse response = client.bulk(bulkRequest,RequestOptions.DEFAULT);return Result.suc(JSONObject.toJSON(response));} catch (IOException e) {log.info("[updateRecord]",e);return Result.fail(e);}
}

3.6、更新文档

@ApiOperation(value = "updateRecord", notes = "updateRecord")
@PostMapping("/updateRecord/{indexName}")
public Result updateRecord(@PathVariable String indexName, @RequestParam String id,@RequestBody Map<String,Object> param) {UpdateRequest updateRequest = new UpdateRequest(indexName,id);updateRequest.doc(param);try {UpdateResponse response = client.update(updateRequest, RequestOptions.DEFAULT);return Result.suc(JSONObject.toJSON(response));} catch (IOException e) {log.info("[updateRecord]",e);return Result.fail(e);}
}

3.7、删除文档

@ApiOperation(value = "deleteRecord", notes = "deleteRecord")
@GetMapping("deleteRecord/{indexName}")
public Result deleteRecord(@RequestParam String id, @PathVariable String indexName) {DeleteRequest deleteRequest = new DeleteRequest(indexName);deleteRequest.id(id);try {DeleteResponse response = client.delete(deleteRequest, RequestOptions.DEFAULT);return Result.suc(JSONObject.toJSON(response));} catch (IOException e) {log.info("[updateRecord]",e);return Result.fail(e);}
}

3.8、查询文档

ApiOperation(value = "queryRecord", notes = "queryRecord")
@GetMapping("/queryRecord/{indexName}")
public Result queryRecord(@PathVariable String indexName) {SearchRequest searchRequest = new SearchRequest(indexName);SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();//如果用name直接查询，其实是匹配name分词过后的索引查到的记录(倒排索引)；如果用name.keyword查询则是不分词的查询，正常查询到的记录RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("birthday").from("1991-01-01").to("2010-10-10").format("yyyy-MM-dd");//范围查询
//        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name.keyword", name);//精准查询PrefixQueryBuilder prefixQueryBuilder = QueryBuilders.prefixQuery("name.keyword", "张");//前缀查询
//        WildcardQueryBuilder wildcardQueryBuilder = QueryBuilders.wildcardQuery("name.keyword", "*三");//通配符查询
//        FuzzyQueryBuilder fuzzyQueryBuilder = QueryBuilders.fuzzyQuery("name", "三");//模糊查询FieldSortBuilder fieldSortBuilder = SortBuilders.fieldSort("age");//按照年龄排序fieldSortBuilder.sortMode(SortMode.MIN);//从小到大排序BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();boolQueryBuilder.must(rangeQueryBuilder).should(prefixQueryBuilder);//and or  查询sourceBuilder.query(boolQueryBuilder).sort(fieldSortBuilder);//多条件查询sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));searchRequest.source(sourceBuilder);try {SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);SearchHits hits = response.getHits();JSONArray jsonArray = new JSONArray();for (SearchHit hit : hits) {String sourceAsString = hit.getSourceAsString();JSONObject jsonObject = JSON.parseObject(sourceAsString);jsonArray.add(jsonObject);}return Result.suc();} catch (IOException e) {e.printStackTrace();return Result.suc();}
}

3.9、查询文档

通过封装QueryForm对象实现查询

@ApiOperation(value = "queryCondition", notes = "queryCondition")
@PostMapping("/queryCondition/{indexName}")
public Result queryCondition(@PathVariable String indexName,@RequestBody QueryForm form) {try {SearchRequest searchRequest = new SearchRequest(indexName);searchRequest.source(form.searchSourceBuilder());SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);SearchHits hits = response.getHits();JSONArray jsonArray = new JSONArray();for (SearchHit hit : hits) {String sourceAsString = hit.getSourceAsString();JSONObject jsonObject = JSON.parseObject(sourceAsString);jsonArray.add(jsonObject);}return Result.suc(jsonArray);} catch (IOException e) {return Result.suc();}
}@Data
static class QueryForm {private Integer id;private String age;private String name;private String address;private String birthday;private String birthdayRange;private String ageRange;SearchSourceBuilder searchSourceBuilder(){SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();if(id != null){sourceBuilder.query(QueryBuilders.termQuery("id", id));}if(name != null){sourceBuilder.query(QueryBuilders.termQuery("name", id));}if(age != null){sourceBuilder.query(QueryBuilders.termQuery("age", id));}if(address != null){sourceBuilder.query(QueryBuilders.termQuery("address", id));}if(birthday != null){sourceBuilder.query(QueryBuilders.termQuery("birthday", id));}if(birthdayRange != null){String[] array = birthdayRange.split("-");sourceBuilder.query(QueryBuilders.boolQuery().must(QueryBuilders.rangeQuery("birthday").from(array[0]).to(array[1]).format("yyyy-MM-dd")));}if(ageRange != null){String[] array = ageRange.split("-");sourceBuilder.query(QueryBuilders.boolQuery().must(QueryBuilders.rangeQuery("age").from(array[0]).to(array[1])));}return sourceBuilder;}
}

3.10、源码

源码地址：

https://gitee.com/suze/springBoot/blob/master/src/main/java/org/suze/springboot/elasticsearch/controller/ElasticSearchController.java

源码下载：

git clone https://gitee.com/suze/springBoot

下面的是我的公众号二维码图片，欢迎关注。
秋夜无霜

这篇关于ElasticSearch7.3.2-RestHighLevelClient实战的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/449530。

相关文章

MySQL 多列 IN 查询之语法、性能与实战技巧(最新整理)

MySQL 多列 IN 查询之语法、性能与实战技巧(最新整理)

《MySQL多列IN查询之语法、性能与实战技巧(最新整理)》本文详解MySQL多列IN查询,对比传统OR写法,强调其简洁高效,适合批量匹配复合键,通过联合索引、分批次优化提升性能,兼容多种数据库... 目录一、基础语法：多列 IN 的两种写法1. 直接值列表2. 子查询二、对比传统 OR 的写法三、性能分析
阅读更多...
Python办公自动化实战之打造智能邮件发送工具

Python办公自动化实战之打造智能邮件发送工具

《Python办公自动化实战之打造智能邮件发送工具》在数字化办公场景中,邮件自动化是提升工作效率的关键技能,本文将演示如何使用Python的smtplib和email库构建一个支持图文混排,多附件,多... 目录前言一、基础配置：搭建邮件发送框架1.1 邮箱服务准备1.2 核心库导入1.3 基础发送函数二、
阅读更多...
PowerShell中15个提升运维效率关键命令实战指南

PowerShell中15个提升运维效率关键命令实战指南

《PowerShell中15个提升运维效率关键命令实战指南》作为网络安全专业人员的必备技能,PowerShell在系统管理、日志分析、威胁检测和自动化响应方面展现出强大能力,下面我们就来看看15个提升... 目录一、PowerShell在网络安全中的战略价值二、网络安全关键场景命令实战1. 系统安全基线核查
阅读更多...
从原理到实战深入理解Java 断言assert

从原理到实战深入理解Java 断言assert

《从原理到实战深入理解Java断言assert》本文深入解析Java断言机制,涵盖语法、工作原理、启用方式及与异常的区别,推荐用于开发阶段的条件检查与状态验证,并强调生产环境应使用参数验证工具类替代... 目录深入理解 Java 断言（assert）：从原理到实战引言：为什么需要断言？一、断言基础1.1 语
阅读更多...
Java MQTT实战应用

Java MQTT实战应用

《JavaMQTT实战应用》本文详解MQTT协议,涵盖其发布/订阅机制、低功耗高效特性、三种服务质量等级（QoS0/1/2）,以及客户端、代理、主题的核心概念,最后提供Linux部署教程、Sprin... 目录一、MQTT协议二、MQTT优点三、三种服务质量等级四、客户端、代理、主题1. 客户端（Clien
阅读更多...
在Spring Boot中集成RabbitMQ的实战记录

在Spring Boot中集成RabbitMQ的实战记录

《在SpringBoot中集成RabbitMQ的实战记录》本文介绍SpringBoot集成RabbitMQ的步骤,涵盖配置连接、消息发送与接收,并对比两种定义Exchange与队列的方式:手动声明(... 目录前言准备工作1. 安装 RabbitMQ2. 消息发送者（Producer）配置1. 创建 Spr
阅读更多...
深度解析Spring Boot拦截器Interceptor与过滤器Filter的区别与实战指南

深度解析Spring Boot拦截器Interceptor与过滤器Filter的区别与实战指南

《深度解析SpringBoot拦截器Interceptor与过滤器Filter的区别与实战指南》本文深度解析SpringBoot中拦截器与过滤器的区别,涵盖执行顺序、依赖关系、异常处理等核心差异,并... 目录Spring Boot拦截器（Interceptor）与过滤器（Filter）深度解析：区别、实现
阅读更多...
深度解析Spring AOP @Aspect 原理、实战与最佳实践教程

深度解析Spring AOP @Aspect 原理、实战与最佳实践教程

《深度解析SpringAOP@Aspect原理、实战与最佳实践教程》文章系统讲解了SpringAOP核心概念、实现方式及原理,涵盖横切关注点分离、代理机制（JDK/CGLIB）、切入点类型、性能... 目录1. @ASPect 核心概念1.1 AOP 编程范式1.2 @Aspect 关键特性2. 完整代码实
阅读更多...
MySQL中的索引结构和分类实战案例详解

MySQL中的索引结构和分类实战案例详解

《MySQL中的索引结构和分类实战案例详解》本文详解MySQL索引结构与分类,涵盖B树、B+树、哈希及全文索引,分析其原理与优劣势,并结合实战案例探讨创建、管理及优化技巧,助力提升查询性能,感兴趣的朋... 目录一、索引概述1.1 索引的定义与作用1.2 索引的基本原理二、索引结构详解2.1 B树索引2.2
阅读更多...
从入门到精通MySQL 数据库索引(实战案例)

从入门到精通MySQL 数据库索引(实战案例)

《从入门到精通MySQL数据库索引(实战案例)》索引是数据库的目录,提升查询速度,主要类型包括BTree、Hash、全文、空间索引,需根据场景选择,建议用于高频查询、关联字段、排序等,避免重复率高或... 目录一、索引是什么？能干嘛？核心作用：二、索引的 4 种主要类型（附通俗例子）1. BTree 索引（
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2