Elasticsearch7.10搜索引擎RestHighLevelClient高级客户端整合Springboot基础教程

2024-09-06 08:32
文章标签 java springboot spring 整合 客户端 高级 搜索引擎 基础教程 resthighlevelclient elasticsearch7.10

本文主要是介绍Elasticsearch7.10搜索引擎RestHighLevelClient高级客户端整合Springboot基础教程，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目录

一. 基本概念介绍

二. Elasticsearch服务端安装

三. Http rest api简单使用介绍

四. 整合到Springboot及使用RestHighLevelClient高级客户端

五. 后续

网络上关于Elasticsearch搜索引擎的教程不少, 但大多数都是比较老旧的, 甚至包括Elasticsearch官网的教程也是很久没有更新, 再加上Elasticsearch本身升级过程中不断的抛弃老旧概念, 新版本完全不兼容旧版本, 所以老旧教程给新入门的童鞋带来很多困惑.

这里使用当前Elasticsearch最新版本7.10.2结合Springboot2.X版本, 使用http rest api接口和RestHighLevelClient高级客户端封装的一些常用接口给新到的童鞋一些参考.

一. 基本概念介绍

本文侧重于讲述Elasticsearch的基本使用, 关于它的特性和基本概念, 您可以通过官网或其他网络文章了解. 这里只指出与本文有关的一些重要概念.

  • index:索引
    在7.0以前的版本中类似于数据库中的database概念, 由于在7.0版本后移除了type(或者或type只能为_doc这一种类型), 现在的index类似于数据库中的表(table).
  • document:文档
    类似于数据库中的一条记录
  • mapping:映射
    类似于数据库中的表结构, es中mapping可以支持动态映射, dynamic属性有true, false, strict 3种类型的值
  • field:字段
    类似于数据库中的column字段, 字段类型后面会介绍

二. Elasticsearch服务端安装

Elasticsearch官网下载相应操作系统最新版本压缩包, 解压即可, 无需任何额外配置. Elasticsearch运行环境依赖java, 必须先配置好java环境.

以Windows为例: 解压至D:\Apps\elasticsearch-7.10.2

启动: 执行bin目录下的.\elasticsearch.bat 即可启动. 默认http端口为9200, tcp端口为9300

启动成功后在浏览器地址栏输入 localhost:9200, 出现以下信息:

从GitHub上下载相同版本号的ik分词器插件: https://github.com/medcl/elasticsearch-analysis-ik, 解压后复制到elasticsearch/plugins目录下, 重启elasticsearch即可生效.

三. Http rest api简单使用介绍

elasticsearch.rest

### 查看索引 ${index}
GET {{esClusterNode}}/index_user
Accept: application/json### 创建索引 ${index} 指定设置和映射 address字段使用IK分词器分词
### analyzer和search_analyzer的区别:
### 在创建索引，指定analyzer，ES在创建时会先检查是否设置了analyzer字段，如果没定义就用ES预设的
### 在查询时，指定search_analyzer，ES查询时会先检查是否设置了search_analyzer字段，
### 如果没有设置，还会去检查创建索引时是否指定了analyzer，还是没有还设置才会去使用ES预设的
### ES分析器主要有两种情况会被使用:
### 1. 插入文档时，将text类型的字段做分词然后插入倒排索引，此时就可能用到analyzer指定的分词器
### 2. 在查询时，先对要查询的text类型的输入做分词，再去倒排索引搜索，此时就可能用到search_analyzer指定的分词器
PUT {{esClusterNode}}/index_user
Content-Type: application/json{"settings": {"number_of_shards": 3,"number_of_replicas": 2},"mappings": {"properties": {"id": {"type": "keyword"},"name": {"type": "keyword"},"age": {"type": "integer"},"sex": {"type": "keyword"},"email": {"type": "keyword"},"address": {"type": "text","analyzer": "ik_max_word","search_analyzer": "ik_max_word"}}}
}### 删除索引 ${index}
DELETE {{esClusterNode}}/index_user
Content-Type: application/x-www-form-urlencoded### 查看映射 ${index}/_mapping
GET {{esClusterNode}}/index_user/_mapping
Content-Type: application/x-www-form-urlencoded### 新增映射 ${index}/_mapping
PUT {{esClusterNode}}/index_user/_mapping
Content-Type: application/json{"properties": {"score": {"type": "float"}}
}### 新增文档 ${index}/_doc 自动生成ID(不推荐) 这里的ID是指es注解_id, 不是自定义的id字段
POST {{esClusterNode}}/index_user/_doc
Content-Type: application/json{"id": "100001","name": "张三","age": 23,"sex": "男","email": "zhangsan@163.com","address": "广东省深圳市龙华新区民治工业园29号"
}### 搜索文档 ${index}/_search 查询全部文档
GET {{esClusterNode}}/index_user/_search
Content-Type: application/json{"query": {"match_all": {}}
}### 查看文档 ${index}/_doc/${_id}
GET {{esClusterNode}}/index_user/_doc/-MVMlXcBnpDI88FS39oA
Accept: application/json### 新增文档 ${index}/_doc/${_id} 指定ID 推荐
POST {{esClusterNode}}/index_user/_doc/100002
Content-Type: application/json{"id": "100002","name": "李四","age": 45,"sex": "男","email": "lisi@163.com","address": "广东省深圳市龙华新区民治工业园27号"
}### 查看文档 ${index}/_doc/${_id}
GET {{esClusterNode}}/index_user/_doc/100002
Accept: application/json### 更新文档 ${index}/_doc/${_id} ID不存在则新增
PUT {{esClusterNode}}/index_user/_doc/100002
Content-Type: application/json{"id": "100002","name": "李四","age": 35,"sex": "男","email": "lisi666@163.com","address": "广东省广州市越秀区中心工业园81号"
}### 删除文档 ${index}/_doc/${_id}
DELETE {{esClusterNode}}/index_user/_doc/6WoDdncBA_HwaxaTfHFC
Content-Type: application/json### 搜索文档 ${index}/_search 查询全部文档
GET {{esClusterNode}}/index_user/_search
Content-Type: application/json{"query": {"match_all": {}}
}### 搜索文档 ${index}/_search 查询关键字
GET {{esClusterNode}}/index_user/_search
Content-Type: application/json{"query": {"match": {"address": "广东省"}}
}### 搜索文档 ${index}/_search 查询关键字
GET {{esClusterNode}}/index_user/_search
Content-Type: application/json{"query": {"match": {"age": "23"}}
}### 搜索文档 ${index}/_search 查询关键字 关键字也会被分词 例如, 输入深圳市, 匹配市会按 深圳市 深圳 市 进行搜索
GET {{esClusterNode}}/index_user/_search
Content-Type: application/json{"query": {"match": {"address": "深圳市"}}
}### 搜索文档 ${index}/_search 查询关键字 模糊查找 query match 高亮显示
GET {{esClusterNode}}/index_user/_search
Content-Type: application/json{"query": {"match": {"address": "广东省深圳市龙华新区民治工业园"}},"highlight": {"fields": {"address": {}}}
}### 搜索文档 ${index}/_search 查询关键字 精确查找 query term 高亮显示
GET {{esClusterNode}}/index_user/_search
Content-Type: application/json{"query": {"term": {"address": "广州"}},"highlight": {"fields": {"address": {}}}
}### 查看分词结果GET /${index}/_doc/${id}/_termvectors?fields=${fields_name}
GET {{esClusterNode}}/index_user/_doc/100002/_termvectors?fields=address
Accept: application/json

四. 整合到Springboot及使用RestHighLevelClient高级客户端

1. 为Springboot项目pom.xml添加elasticsearch及RestHighLevelClient高级客户端依赖

        <dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>${elasticsearch.version}</version></dependency><dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-client</artifactId><version>${elasticsearch.version}</version></dependency><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>${elasticsearch.version}</version></dependency>

版本均选择7.10.2 这里不推荐使用spring-boot-starter-data-elasticsearch, starter难以控制elasticsearch及其依赖项的版本号.

elasticsearch-rest-high-level-client高级客户端依赖于elasticsearch-rest-client低级客户端, 由于elasticsearch版本间的兼容性非常差, 所以为避免出现一些意向不到的问题, 请保证elasticsearch, elasticsearch-rest-high-level-client, elasticsearch-rest-client, 如果后续需要使用ik分词器, kibana, logstash 使用同一个版本号.

2. 配置RestHighLevelClient高级客户端

  • 添加集群配置文件
    多个集群节点之间以英文逗号 , 分隔, 如 cluster-nodes: localhost:9200,localhost:9201
# es搜索引擎
elasticsearch:cluster-nodes: localhost:9200
  • RestHighLevelClient实例配置
    elasticsearch已经实现了负载均衡功能, 具体如何实现的, 资料很少.
    ElasticSearchConfig.java
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
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;/*** Elasticsearch配置** @author Aylvn* @date 2021-02-03*/
@Slf4j
@Configuration
public class ElasticSearchConfig {@Value("${elasticsearch.cluster-nodes}")private String clusterNodes;@Beanpublic RestHighLevelClient restHighLevelClient() {String[] nodes = clusterNodes.split(",");return new RestHighLevelClient(RestClient.builder(Arrays.stream(nodes).map(this::buildHttpHost).toArray(HttpHost[]::new)));}private HttpHost buildHttpHost(String node) {String[] nodeInfo = node.split(":");return new HttpHost(nodeInfo[0].trim(), Integer.parseInt(nodeInfo[1].trim()), "http");}
}

3. 常用的接口类

索引有关的操作
elasticsearch数据存取使用json格式进行交互的, 由于字段的不确定性, 这里使用Map<String, Object>的key-value键值对作为与elasticsearch交互的参数类型.
常量定义: EsConstant.java


import org.elasticsearch.client.RequestOptions;public class EsConstant {public static final RequestOptions DEFAULT_OPTIONS = RequestOptions.DEFAULT;public static final String ID = "id";public static final String INDEX_MAPPING_PROPERTIES = "properties";public static final String INDEX_MAPPING_DYNAMIC = "dynamic";public static final String INDEX_MAPPING_DYNAMIC_STRICT = "strict";public static final String INDEX_COMPANY = "index_company";public static final String DATE_FORMAT = "format&#

这篇关于Elasticsearch7.10搜索引擎RestHighLevelClient高级客户端整合Springboot基础教程的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


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

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
Java进阶13讲__第12讲_1/2

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory
阅读更多...
JAVA智听未来一站式有声阅读平台听书系统小程序源码

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来，一站式有声阅读平台听书系统 🌟&nbsp;开篇：遇见未来，从“智听”开始 在这个快节奏的时代，你是否渴望在忙碌的间隙，找到一片属于自己的宁静角落？是否梦想着能随时随地，沉浸在知识的海洋，或是故事的奇幻世界里？今天，就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统，它正悄悄改变着我们的阅读方式，让未来触手可及！ 📚&nbsp;第一站：海量资源，应有尽有 走进“智听
阅读更多...
在cscode中通过maven创建java项目

在cscode中通过maven创建java项目

在cscode中创建java项目 可以通过博客完成maven的导入 建立maven项目 使用快捷键 Ctrl + Shift + P 建立一个 Maven 项目 1 Ctrl + Shift + P 打开输入框2 输入 "> java create"3 选择 maven4 选择 No Archetype5 输入 域名6 输入项目名称7 建立一个文件目录存放项目，文件名一般为项目名8 确定
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2