SpringBoot中整合ElasticSearch快速入门以及踩坑记录

场景

若依前后端分离版手把手教你本地搭建环境并运行项目：

若依前后端分离版手把手教你本地搭建环境并运行项目_本地运行若依前后端分离-CSDN博客

参考上面搭建项目。

ElaticSearch

Elasticsearch 是java开发的，基于 Lucene 的搜索引擎。它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful Web接口。

Elasticsearch 可以快速有效地存储，搜索和分析大量数据，而且在处理半结构化数据（即自然语言）时特别有用。

ElasticSearch官方文档：

Elastic documentation | Elastic

应用集成ElasticSearch的方式有，REST Client、Jest、Spring Data、Spring Data Elasticsearch Repositories。

下面将介绍Spring Data Elasticsearch的方式。

注：

博客：
霸道流氓气质-CSDN博客

实现

1、在Windows上实现ElaticSearch下载安装和配置

下载地址：

Download Elasticsearch | Elastic

这里是Windows，下载对应的包，下载之后解压

进入bin下，双击elasticsearch.bat可以启动

2、踩坑一，这里不要随意下载官网最新的ES的安装包，需要与springboot版本以及spring-boot-data-elasticsearch的版本

使用指定的对应关系。

否则在运行时会提示：

Elasticsearch exception [type=illeagal_argument_exception,reason = request [/test] contains unrecognized parameter: [include_type_name]]

以及其他不可预知的问题。

如何查看SpringBoot版本、SpringBoot-data-elasticsearch版本、ElasticSearch版本的对应关系

Versions :: Spring Data Elasticsearch

这里的SpringBoot版本为2.2.13，所以上面下载ES时选择对应的6.8.2的版本

双击上面bat启动后，访问默认端口9200，出现如下提示则es启动成功

3、为了验证以上ES搭建成功，可使用调用接口的方式测试索引的创建与查询

创建索引

使用接口调用工具，发送如下PUT请求

http://localhost:9200/user

则会创建名为user的索引

然后再访问如下GET请求则可以查询索引

http://localhost:9200/user

ES还支持更多其他的api调用的方式和功能，这里不做介绍。

4、 ElasticSearch可视化工具elasticsearch-head的下载与使用

可以借助可视化工具进行对索引等的可视化操作。

GitHub - mobz/elasticsearch-head: A web front end for an elastic search cluster

访问以上地址

按照官网提示步骤运行

git clone git://github.com/mobz/elasticsearch-head.gitcd elasticsearch-headnpm installnpm run start

电脑需要安装node环境

然后访问

http://localhost:9100/

访问之后需要对ES连接，输入上面es的地址即可，这里是

http://localhost:9200/

但是在连接时没有连接成功的提示，此时打开控制台发现。

elasticsearch-head在连接Elasticsearch时提示:

GET http://localhost:9200/_nodes net::ERR_FAILED

Access to XMLHttpRequest at ... from origin ...has been blocked....

这是因为跨域了。

找到es的配置文件，config目录下的elasticsearch.yml

添加如下跨域配置

http.cors.enabled: true
http.cors.allow-origin: "*"
http.cors.allow-credentials: true
http.cors.allow-headers: Content-Type,Accept,Authorization,x-requested-with

然后重启es服务，则再连接显示成功

5、SpringBoot中集成ES

按照上面版本对应关系，添加pom依赖

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId><version>3.2.2</version></dependency>

然后新建配置类，用来配置es连接地址等

import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.elasticsearch.client.ClientConfiguration;
import org.springframework.data.elasticsearch.client.RestClients;
import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;@Configuration
public class ElasticConfig extends AbstractElasticsearchConfiguration {@Override@Beanpublic RestHighLevelClient elasticsearchClient() {final ClientConfiguration clientConfiguration = ClientConfiguration.builder().connectedTo("127.0.0.1:9200") //这里注意不要加http://.build();return RestClients.create(clientConfiguration).rest();}
}

这里注意使用的是官网推荐使用的RestHighLevelClient方式，详情见官方文档：

Spring Data Elasticsearch - Reference Documentation

注意这里避免踩坑，在配置类中配置es的地址时，使用ip和端口号的方式127.0.0.1:9200

不要带http://

编写单元测试，测试连接与创建索引。

import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.io.IOException;@RunWith(SpringRunner.class)
@SpringBootTest(classes = RuoYiApplication.class,webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class ElasticSearchTest {@Autowired@Qualifier("elasticsearchClient")public RestHighLevelClient highLevelClient;@Testpublic void connecTest() throws IOException {CreateIndexRequest request = new CreateIndexRequest("test");CreateIndexResponse response = highLevelClient.indices().create(request, RequestOptions.DEFAULT);// 查看是否创建成功System.out.println(response.isAcknowledged());highLevelClient.close();}
}

运行单元测试结果