赞
踩
若依前后端分离版手把手教你本地搭建环境并运行项目:
若依前后端分离版手把手教你本地搭建环境并运行项目_本地运行若依前后端分离-CSDN博客
参考上面搭建项目。
Elasticsearch 是java开发的,基于 Lucene 的搜索引擎。它提供了一个分布式多用户能力的全文搜索引擎,基于RESTful Web接口。
Elasticsearch 可以快速有效地存储,搜索和分析大量数据,而且在处理半结构化数据(即自然语言)时特别有用。
ElasticSearch官方文档:
Elastic documentation | Elastic
应用集成ElasticSearch的方式有,REST Client、Jest、Spring Data、Spring Data Elasticsearch Repositories。
下面将介绍Spring Data Elasticsearch的方式。
注:
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请求
则会创建名为user的索引
然后再访问如下GET请求则可以查询索引
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.git
-
- cd elasticsearch-head
-
- npm install
-
- npm run start
电脑需要安装node环境
然后访问
http://localhost:9100/
访问之后需要对ES连接,输入上面es的地址即可,这里是
但是在连接时没有连接成功的提示,此时打开控制台发现。
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
- @Bean
- public 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;
-
- @Test
- public void connecTest() throws IOException {
- CreateIndexRequest request = new CreateIndexRequest("test");
- CreateIndexResponse response = highLevelClient.indices().create(request, RequestOptions.DEFAULT);
- // 查看是否创建成功
- System.out.println(response.isAcknowledged());
- highLevelClient.close();
- }
- }
运行单元测试结果
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。