快捷導(dǎo)航

SpringBoot 數(shù)據(jù)存儲(chǔ)實(shí)戰(zhàn)指南

更新時(shí)間：2026年03月24日 09:48:00 作者：程序員西西

Elasticsearch是一個(gè)基于Apache Lucene開發(fā)的的搜索服務(wù),提供了一個(gè)分布式多用戶能力的全文搜索引擎,本文介紹如何在SpringBoot項(xiàng)目中整合ElasticSearch來(lái)完成數(shù)據(jù)的存儲(chǔ),感興趣的朋友跟隨小編一起看看吧

Elasticsearch是一個(gè)基于Apache Lucene開發(fā)的的搜索服務(wù)，提供了一個(gè)分布式多用戶能力的全文搜索引擎，并基于RESTful web接口。支持結(jié)構(gòu)化搜索、數(shù)據(jù)分析、復(fù)雜的語(yǔ)言處理、地理位置和對(duì)象間關(guān)聯(lián)關(guān)系等功能。那么如何在SpringBoot項(xiàng)目中整合ElasticSearch來(lái)完成數(shù)據(jù)的存儲(chǔ)呢？下面我們就來(lái)看看。

這里需要特別說(shuō)明在高版本的ElasticSearch對(duì)于數(shù)據(jù)的處理方式與低版本的處理方式是不同的，并且，在Spring Boot中所支持的ElasticSearch客戶端版本也是有所差異的。這里演示的是基于 Spring Boot 2.1.4.RELEASE 版本和ElasticSearch 6.8.0的版本處理方式。

依賴和配置

添加Elasticsearch的依賴到pom.xml文件中。

<parent>
    <artifactId>spring-boot-parent</artifactId>
    <groupId>org.springframework.boot</groupId>
    <version>2.1.4.RELEASE</version>
</parent>
```js
```
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

在配置文件文件中配置ElasticSearch的連接

spring.data.elasticsearch.cluster-name=my-cluster
spring.data.elasticsearch.cluster-nodes=192.168.1.202:9300

這里需要注意，在高版本的SpringBoot配置中已經(jīng)不支持這樣的配置操作，需要注意的實(shí)，在這個(gè)配置中如果是通過(guò)ELK調(diào)用則添加的端口是9200，如果是通過(guò)Java程序調(diào)用則配置的連接端口是9300。

具體實(shí)現(xiàn)

@Document(indexName = "my_index", type = "my_type")
public class MyDocument {
    @Id
    private String id;
    private String name;
    private String description;
    // 省略構(gòu)造函數(shù)、getter和setter
}

繼承ElasticsearchRepository接口實(shí)現(xiàn)數(shù)據(jù)訪問(wèn)層代碼

public interface MyDocumentRepository 
extends ElasticsearchRepository<MyDocument, String> {
}

編寫服務(wù)層代碼

@Service
public class MyDocumentService {
    @Autowired
    private MyDocumentRepository repository;
    public MyDocument save(MyDocument document) {
        return repository.save(document);
    }
    public Iterable<MyDocument> findAll() {
        Iterable<MyDocument> all = repository.findAll();
        return all;
    }
    public MyDocument findById(String id) {
        return repository.findById(id).orElse(null);
    }
    public void deleteById(String id) {
        repository.deleteById(id);
    }
}

編寫Controller類進(jìn)行測(cè)試

@RestController
@RequestMapping("/documents")
public class MyDocumentController {
    @Autowired
    private MyDocumentService service;
    @PostMapping
    public MyDocument create(@RequestBody MyDocument document) {
        return service.save(document);
    }
    @GetMapping
    public Iterable<MyDocument> getAll() {
        Iterable<MyDocument> iterable = service.findAll();
        return iterable;
    }
    @GetMapping("/{id}")
    public MyDocument getById(@PathVariable String id) {
        return service.findById(id);
    }
    @DeleteMapping("/{id}")
    public void deleteById(@PathVariable String id) {
        service.deleteById(id);
    }
}

以上代碼示例演示了如何使用Spring Boot整合Elasticsearch實(shí)現(xiàn)數(shù)據(jù)存儲(chǔ)。

調(diào)用接口進(jìn)行測(cè)試

獲取列表

總結(jié)

在上面的例子中，通過(guò)SpringBoot 2.1.4與ElasticSearch6.8.0完成了整合，如果想要適配更高版本的ElasticSearch或者是Spring Boot ，在過(guò)程中一定注意對(duì)于版本兼容性的選擇。

到此這篇關(guān)于SpringBoot 數(shù)據(jù)存儲(chǔ)實(shí)戰(zhàn)指南的文章就介紹到這了,更多相關(guān)SpringBoot 數(shù)據(jù)存儲(chǔ)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: