elasticsearch我已经装了ik，中文分词器。已经使用容器搭建了集群。之前在我的博客-elasticsearch入门中，已经介绍了http请求操纵es的基本功能，java API功能和他一样，只是从http请求换成了javaApi操作。

springBoot里继承了elasticsearch，他是spring-data的一个子模块，里面的主要核心就是ElasticsearchRepository。只要你写一个interface继承他，就可以用基本的CRUD操作es。

如果你想要http那样灵活的操作es，他提供了elasticsearchRestTemplate，你可以把他看成一个小型的http，你要通过代码的形式将http中的内容表示出来，在通过这个template发送。

导入依赖

org.springframework.boot
spring-boot-starter-web



org.springframework.boot
spring-boot-starter-test
test


org.springframework.boot
spring-boot-starter-data-elasticsearch


org.springframework.data
spring-data-elasticsearch



org.projectlombok
lombok
1.18.12

填写es地址

在你的springBoot项目里，我的是application.properties，加一个自己的地址，这样启动springBoot的时候就会自动识别了。

spring.elasticsearch.uris=http://192.168.9.102:9200

做一个数据类来测试

最好创建一个与es数据相对应的实体类

我的es:

我的实体类:

package com.example.elaticsearchtest2.entity;import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.DateFormat;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
//lombok自动加get,set以及构造
@Data
//指定索引
@Document(indexName = "game")
public class GameEntity  {
@Idprivate String id;/*** 游戏名*/@Field(type = FieldType.Text, analyzer = "ik_max_word")
private String name;/*** 创建日期*/@Field(type = FieldType.Date, format = DateFormat.date, pattern = "yyyy-MM-dd HH:mm:ss")
private String date;/*** 游戏介绍*/@Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_smart")
private String introduction;/*** 主页面地址*/@Field(type = FieldType.Text)
private String url;
}

其中analyzer代表的是分词方式，ik_max_word是ik中文分词器的细粒度模式，关于ik具体请看我的博客 elatiscsearch入门教程中有写到

最基本的ElasticsearchRepository

他的标准用法是用【数据实体类的interface-repository】去继承它

首先写一个，关于game索引的数据实体类的interface

package com.example.elaticsearchtest2.controller;import com.example.elaticsearchtest2.entity.GameEntity;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;@Repository
public interface GameRepository extends ElasticsearchRepository {}

其中，继承参数的那里GameEntity就是我之前写的数据实体，Long代表的是行数类型

一定要加一个repository注解，这样才能被springBoot识别

测试类，一定要用@SpringBootTest注解，这样才能模拟springBoot的运行

然后，自动注入刚刚的接口gameRepository，然后在写一个test方法，调用查询做测试

package com.example.elaticsearchtest2;import com.example.elaticsearchtest2.controller.GameRepository;import com.example.elaticsearchtest2.entity.GameEntity;import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;@SpringBootTest
public class ConnectTest {
@AutowiredGameRepository gameRepository ;@Testpublic void test1(){Iterable all = gameRepository.findAll();for(GameEntity one:all){System.out.println(one);}}
}

右键运行,成功显示出es的数据

这种方法最好用，而且他还支持自定义方法，比下面的那个好用多了。

灵活的elasticsearchRestTemplate

这个写起来很复杂，但是笔记灵活，可以说和http一样，什么功能都有。

有了这个东西就很灵活了，能通过它做各种查询，但是这个东西怎么构建？

他是基于RestHighLevelClient的，也就是说你要先构建这个client，而springBoot-data已经能自动识别这个了，所以你只用在springBoot工程下的任何一个地方，创建一个es的配置类，他就能识别了。

es配置类（用于生成RestHighLevelClient）

package com.example.elaticsearchtest2.tools;
import lombok.Data;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;@Configuration
@Data
public class ElasticsearchConfig extends AbstractElasticsearchConfiguration {private String host="192.168.9.102";private Integer port=9200;@Overridepublic RestHighLevelClient elasticsearchClient() {RestClientBuilder builder = RestClient.builder(new HttpHost(host,port));RestHighLevelClient restHighLevelClient = new RestHighLevelClient(builder);return restHighLevelClient;}
}

回到代码测试类

编写matchTest方法做temp的测试

package com.example.elaticsearchtest2;
import com.example.elaticsearchtest2.controller.GameRepository;
import com.example.elaticsearchtest2.tools.ElasticsearchConfig;
import org.elasticsearch.index.query.MatchQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;


import com.example.elaticsearchtest2.entity.GameEntity;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;



import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;

import org.springframework.data.elasticsearch.core.SearchHit;
import org.springframework.data.elasticsearch.core.SearchHits;

import org.springframework.data.elasticsearch.core.query.*;





@SpringBootTest
public class ConnectTest {
@Autowired
GameRepository gameRepository ;




@Test
public void test1(){
Iterable all = gameRepository.findAll();
for(GameEntity one:all){
System.out.println(one);
}

}

@Test
public void test2(){
ElasticsearchRestTemplate elasticsearchRestTemplate
=new ElasticsearchRestTemplate(new ElasticsearchConfig().elasticsearchClient());

//构建查询条件
MatchQueryBuilder matchQueryBuilder =
QueryBuilders.matchQuery("_all", "小刺字")
.analyzer("ik_max_word");





}
@Test
void matchTest() {
ElasticsearchRestTemplate elasticsearchRestTemplate
=new ElasticsearchRestTemplate(new ElasticsearchConfig().elasticsearchClient());


MatchQueryBuilder matchQueryBuilder =
new MatchQueryBuilder("name", "小池子")
.analyzer("ik_smart");

NativeSearchQuery nativeSearchQuery = new NativeSearchQuery(matchQueryBuilder);

SearchHits searchHits = elasticsearchRestTemplate.search(nativeSearchQuery, GameEntity.class);


for (SearchHit searchHit : searchHits) {
GameEntity game = searchHit.getContent();
System.out.println(game);
}
}


}

结果

虽然我们用的是过时版本的，但是刚好能满足客户版本的需求，我们用的版本是7.9.3，但是es官方8.1已经不用resthighlevelclient了，而是用elasticsearch-java。

参考文章:

下面这个地址对javaApi操作es（含分页，等其他功能的介绍非常详细）

https://www.cnblogs.com/tanghaorong/p/16365684.html#_label0