---

前言

被逼無(wú)奈，各行各業(yè)都在卷，給自己充電學(xué)習(xí)了Elasticsearch，在學(xué)完基礎(chǔ)知識(shí)后（其實(shí)就是CRUD😂），就去Springboot中嘗試整合ES。終于抽出時(shí)間，將學(xué)習(xí)的東西整理分享在此，歡迎大家批評(píng)指正哈~

---

一、ElasticSearch本地環(huán)境搭建

詳細(xì)安裝步驟參考此資料windows 安裝 Elasticsearch

二、SpringBoot整合ElasticSearch

我這里Spring Boot版本2.7.5，ElasticSearch版本7.17.3。版本一定要對(duì)應(yīng)上，否則會(huì)報(bào)一堆錯(cuò)誤問(wèn)題。
SpringBoot官方推薦對(duì)應(yīng)Elasticsearch版本。

先啟動(dòng)ES本地服務(wù)（雙擊elasticsearch.bat啟動(dòng)服務(wù)），然后在elasticsearch-head可視化插件目錄中執(zhí)行npm start run啟動(dòng)可視化插件。

1.pom中引入ES依賴

<!-- ElasticSearch --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId><exclusions><exclusion><artifactId>elasticsearch-java</artifactId><groupId>co.elastic.clients</groupId></exclusion></exclusions></dependency><dependency><groupId>co.elastic.clients</groupId><artifactId>elasticsearch-java</artifactId><version>8.0.1</version><exclusions><exclusion><artifactId>jakarta.json-api</artifactId><groupId>jakarta.json</groupId></exclusion></exclusions></dependency><dependency><groupId>jakarta.json</groupId><artifactId>jakarta.json-api</artifactId><version>2.0.1</version></dependency>

2.application.yaml配置elasticsearch

elasticsearch:port: 9200ip: 127.0.0.1username: elasticpassword: 123456

3.ElasticSearchClientConnect連接ES客戶端工具類

@Configuration
public class ElasticSearchClientConnect {@Value("${elasticsearch.port}")private int port;@Value("${elasticsearch.ip}")private String ip;@Value("${elasticsearch.username}")private String username;@Value("${elasticsearch.password}")private String password;/*** 創(chuàng)建rest客戶端*/@Beanpublic ElasticSearchResult restClient(){RestClient restClient = RestClient.builder(new HttpHost(ip, port,"http")).build();ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());ElasticsearchClient client = new ElasticsearchClient(transport);return new ElasticSearchResult(restClient,transport,client);}
}

4.ElasticSearchResult封裝響應(yīng)結(jié)果

@Data
public class ElasticSearchResult {private RestClient restClient;private ElasticsearchTransport elasticsearchTransport;private ElasticsearchClient elasticsearchClient;public ElasticSearchResult(RestClient restClient, ElasticsearchTransport elasticsearchTransport, ElasticsearchClient elasticsearchClient) {this.restClient = restClient;this.elasticsearchTransport = elasticsearchTransport;this.elasticsearchClient = elasticsearchClient;}
}

5.Person實(shí)體類

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Person {private String name;private String sex;private Integer age;
}

6.Person實(shí)體類

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Person {private String name;private String sex;private Integer age;
}

7.ElasticsearchController增刪改查控制層

/*** ES增刪改查*/
@RestController
public class ElasticsearchController {@Autowiredprivate ElasticSearchClientConnect elasticSearchClientConfig;/*** 新建my_index索引* @return* @throws IOException*/@GetMapping("/createIndex")public Boolean createIndex() throws IOException {CreateIndexResponse createIndexResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().indices().create(c -> c.index("my_index"));// 打印結(jié)果System.out.println(createIndexResponse.acknowledged());// 關(guān)閉連接elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();return createIndexResponse.acknowledged();}/*** 查詢索引* @throws IOException*/@GetMapping("/selectIndex")public void selectIndex() throws IOException {GetIndexResponse getIndexResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().indices().get(e -> e.index("jing_index"));// 打印結(jié)果System.out.println("getIndexResponse.result() = " + getIndexResponse.result());System.out.println("getIndexResponse.result().keySet() = " + getIndexResponse.result().keySet());// 關(guān)閉連接elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 刪除索引* @return* @throws IOException*/@GetMapping("/deleteIndex")public Boolean deleteIndex() throws IOException {// 刪除索引DeleteIndexResponse deleteIndexResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().indices().delete(e -> e.index("jing_index"));System.out.println("刪除操作 = " + deleteIndexResponse.acknowledged());// 關(guān)閉連接elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();return deleteIndexResponse.acknowledged();}}

8.ElasticsearchDocumentController文檔操作控制層

/*** ES文檔操作*/
@RestController
public class ElasticsearchDocumentController {@Autowiredprivate ElasticSearchClientConnect elasticSearchClientConfig;/*** 添加document* @throws IOException*/@GetMapping("/addDocument")public void addDocument() throws IOException {// 向Person對(duì)象中添加數(shù)據(jù)Person Person = new Person("java客戶端", "男", 18);// 向索引中添加數(shù)據(jù)CreateResponse createResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().create(e -> e.index("jing_index").id("1001").document(Person));System.out.println("createResponse.result() = " + createResponse.result());elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 查詢document* @throws IOException*/@GetMapping("/queryDocument")public void queryDocument() throws IOException {// 構(gòu)建請(qǐng)求GetResponse<Person> getResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().get(e -> e.index("jing_index").id("1001"), Person.class);System.out.println("getResponse.source().toString() = " + getResponse.source().toString());elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 修改document* @throws IOException*/@GetMapping("/modifyDocument")public void modifyDocument() throws IOException {// 使用map集合封裝需要修改的內(nèi)容Map<String, Object> map = new HashMap<>();map.put("name", "java客戶端aaa");// 構(gòu)建請(qǐng)求UpdateResponse<Person> updateResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().update(e -> e.index("jing_index").id("1001").doc(map), Person.class);System.out.println("updateResponse.result() = " + updateResponse.result());elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 刪除document* @throws IOException*/@GetMapping("/removeDocument")public void removeDocument() throws  IOException {// 構(gòu)建請(qǐng)求DeleteResponse deleteResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().delete(e -> e.index("jing_index").id("1001"));System.out.println("deleteResponse.result() = " + deleteResponse.result());elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 批量添加document* @throws IOException*/@GetMapping("/batchAddDocument")public void batchAddDocument() throws IOException {// 構(gòu)建一個(gè)批量數(shù)據(jù)集合List<BulkOperation> list = new ArrayList<>();list.add(new BulkOperation.Builder().create(d -> d.document(new Person("test2", "男", 19)).id("1002").index("Person_test")).build());list.add(new BulkOperation.Builder().create(d -> d.document(new Person("test3", "男", 20)).id("1003").index("Person_test")).build());list.add(new BulkOperation.Builder().create(d -> d.document(new Person("test4", "女", 21)).id("1004").index("Person_test")).build());// 調(diào)用bulk方法執(zhí)行批量插入操作BulkResponse bulkResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().bulk(e -> e.index("Person_test").operations(list));System.out.println("bulkResponse.items() = " + bulkResponse.items());elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 批量刪除document* @throws IOException*/@GetMapping("/batchDeleteDocument")public void batchDeleteDocument() throws IOException {// 構(gòu)建一個(gè)批量數(shù)據(jù)集合List<BulkOperation> list = new ArrayList<>();list.add(new BulkOperation.Builder().delete(d -> d.id("1002").index("Person_test")).build());list.add(new BulkOperation.Builder().delete(d -> d.id("1003").index("Person_test")).build());// 調(diào)用bulk方法執(zhí)行批量插入操作BulkResponse bulkResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().bulk(e -> e.index("Person_test").operations(list));System.out.println("bulkResponse.items() = " + bulkResponse.items());elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 全量查詢document* @throws IOException*/@GetMapping("/queryAllDocument")public void queryAllDocument() throws IOException {// 全量查詢SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(e -> e.index("Person_test").query(q -> q.matchAll(m -> m)), Person.class);HitsMetadata<Person> hits = searchResponse.hits();for (Hit<Person> hit : hits.hits()) {System.out.println("Person = " + hit.source().toString());}System.out.println("searchResponse.hits().total().value() = " + searchResponse.hits().total().value());elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 分頁(yè)查詢document* @throws IOException*/@GetMapping("/pagingQueryDocument")public void pagingQueryDocument() throws IOException {// 分頁(yè)查詢SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").query(q -> q.matchAll(m -> m)).from(0).size(2), Person.class);searchResponse.hits().hits().forEach(h -> System.out.println(h.source().toString()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 排序查詢document* @throws IOException*/@GetMapping("/sortQueryDocument")public void sortQueryDocument() throws IOException {// 排序查詢SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").query(q -> q.matchAll(m -> m)).sort(o -> o.field(f -> f.field("age").order(SortOrder.Asc))), Person.class);searchResponse.hits().hits().forEach(h -> System.out.println(h.source().toString()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 條件查詢document* @throws IOException*/@GetMapping("/conditionQueryDocument")public void conditionQueryDocument() throws IOException {// 條件查詢SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").query(q -> q.matchAll(m -> m)).sort(o -> o.field(f -> f.field("age").order(SortOrder.Asc))).source(r -> r.filter(f -> f.includes("name", "age").excludes(""))), Person.class);searchResponse.hits().hits().forEach(h -> System.out.println(h.source().toString()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 組合查詢  must是必須滿足所有條件，should只要滿足一個(gè)就行* @throws IOException*/@GetMapping("/combinationQueryDocument")public void combinationQueryDocument() throws IOException {// 組合查詢SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").query(q -> q.bool(b -> b.must(m -> m.match(u -> u.field("age").query(21))).must(m -> m.match(u -> u.field("sex").query("男"))).mustNot(m -> m.match(u -> u.field("sex").query("女"))))), Person.class);//SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(//                s -> s.index("Person_test").query(q -> q.bool(b -> b//                        .should(h -> h.match(u -> u.field("age").query(19)))//                        .should(h -> h.match(u -> u.field("sex").query("男")))//                ))//                , Person.class);searchResponse.hits().hits().forEach(h -> System.out.println(h.source().toString()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 范圍查詢* @throws IOException*/@GetMapping("/scopeQueryDocument2")public void scopeQueryDocument2() throws IOException {// 范圍查詢，gte()表示取大于等于，gt()表示大于，lte()表示小于等于SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").query(q -> q.range(r -> r.field("age").gte(JsonData.of(20)).lt(JsonData.of(21)))), Person.class);searchResponse.hits().hits().forEach(h -> System.out.println(h.source().toString()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 模糊查詢* @throws IOException*/@GetMapping("/fuzzyQueryDocument2")public void fuzzyQueryDocument2() throws IOException {// 模糊查詢，fuzziness表示差幾個(gè)可以查詢出來(lái)SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").query(q -> q.fuzzy(f -> f.field("name").value("tst").fuzziness("2"))), Person.class);searchResponse.hits().hits().forEach(h -> System.out.println(h.source().toString()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 高亮查詢* @throws IOException*/@GetMapping("/highlightQueryDocument2")public void highlightQueryDocument2() throws IOException {// 高亮查詢SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").query(q -> q.term(t -> t.field("name").value("test4"))).highlight(h -> h.fields("name", f -> f.preTags("<font color='red'>").postTags("</font>"))), Person.class);searchResponse.hits().hits().forEach(h -> System.out.println(h.source().toString()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 聚合查詢* @throws IOException*/@GetMapping("/aggregateQueryDocument2")public void aggregateQueryDocument2() throws IOException {// 聚合查詢，取最大年齡SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").aggregations("maxAge", a ->a.max(m -> m.field("age"))), Person.class);searchResponse.aggregations().entrySet().forEach(f -> System.out.println(f.getKey() + ":" + f.getValue().max().value()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}/*** 分組查詢* @throws IOException*/@GetMapping("/groupQueryDocument2")public void groupQueryDocument2() throws IOException {// 分組查詢SearchResponse<Person> searchResponse = elasticSearchClientConfig.restClient().getElasticsearchClient().search(s -> s.index("Person_test").aggregations("ageGroup", a ->a.terms(t -> t.field("age"))), Person.class);searchResponse.aggregations().get("ageGroup").lterms().buckets().array().forEach(f -> System.out.println(f.key() + ":" + f.docCount()));elasticSearchClientConfig.restClient().getElasticsearchTransport().close();elasticSearchClientConfig.restClient().getRestClient().close();}
}

---

三、測(cè)試

1.創(chuàng)建索引，名為my_index

查詢結(jié)果顯示創(chuàng)建成功

2.創(chuàng)建文檔，給名為my_index的索引創(chuàng)建文檔

查詢結(jié)果顯示創(chuàng)建文檔成功

四、項(xiàng)目結(jié)構(gòu)及代碼下載

源碼下載地址，歡迎Star哦~~
springboot-cacheable

---

參考資料

SpringBoot官方推薦對(duì)應(yīng)Elasticsearch版本
SpringBoot集成elasticsearch 7.17.3及常規(guī)應(yīng)用
Elasticsearch8.x版本中RestHighLevelClient被棄用
SpringBoot 整合ElasticSearch實(shí)現(xiàn)模糊查詢，批量CRUD，排序，分頁(yè)，高亮
windows 安裝 Elasticsearch