Spring Boot 结合 ES搜索引擎 实现数据库与 ES 索引同步

在现代应用中，使用 Elasticsearch（ES）作为搜索引擎已经成为了一种流行的选择，它能够提供快速的全文搜索和强大的数据分析功能。但在实际应用中，确保数据库中的数据与 ES 中的索引同步是一个重要的任务。本文将介绍如何使用 Spring Boot 实现数据库与 Elasticsearch 的索引同步，重点讲解相关代码示例。

环境准备

在开始之前，请确保已安装以下软件： - JDK 8 或以上版本 - Maven - Elasticsearch 实例

创建 Spring Boot 项目

首先，我们需要创建一个新的 Spring Boot 项目。在 pom.xml 中，添加依赖如下：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
</dependency>

配置数据库和 Elasticsearch

在 application.yml 文件中，配置数据库和 Elasticsearch 的连接信息。

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/your_db
    username: your_username
    password: your_password
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true

elasticsearch:
  rest:
    uris: http://localhost:9200

创建实体类

接下来，我们需要定义一个实体类来映射数据库表和 Elasticsearch 索引。假设我们的数据库表是 Product。

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import org.springframework.data.elasticsearch.annotations.Document;

@Entity
@Document(indexName = "product")
public class Product {
    @Id
    @GeneratedValue
    private Long id;
    private String name;
    private String description;
    private Double price;

    // getters and setters
}

创建 JPA 仓库接口

我们需要创建一个 JPA 仓库接口来进行数据库操作。

import org.springframework.data.jpa.repository.JpaRepository;

public interface ProductRepository extends JpaRepository<Product, Long> {
}

创建 Elasticsearch 仓库接口

同时，我们也需要创建一个 Elasticsearch 的仓库接口。

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

public interface ProductEsRepository extends ElasticsearchRepository<Product, Long> {
}

实现同步逻辑

为了确保数据库与 Elasticsearch 的数据同步，我们可以创建一个服务，该服务在每次新增、更新或删除数据时同步这些操作。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.transaction.Transactional;

@Service
public class ProductService {

    @Autowired
    private ProductRepository productRepository;

    @Autowired
    private ProductEsRepository productEsRepository;

    @Transactional
    public Product saveProduct(Product product) {
        Product savedProduct = productRepository.save(product);
        productEsRepository.save(savedProduct);
        return savedProduct;
    }

    public void deleteProduct(Long id) {
        productRepository.deleteById(id);
        productEsRepository.deleteById(id);
    }
}

更新和删除操作的同步

在 ProductService 中，当我们调用保存或删除方法时，会同时在数据库和 Elasticsearch 中进行相应的操作。

控制器层

最后，我们可以通过一个控制器暴露 RESTful API 来进行数据的增删改查。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController
@RequestMapping("/products")
public class ProductController {

    @Autowired
    private ProductService productService;

    @PostMapping
    public Product createProduct(@RequestBody Product product) {
        return productService.saveProduct(product);
    }

    @DeleteMapping("/{id}")
    public void deleteProduct(@PathVariable Long id) {
        productService.deleteProduct(id);
    }

    @GetMapping
    public List<Product> getAllProducts() {
        return productService.getAllProducts();
    }
}

总结

通过以上步骤，我们成功实现了使用 Spring Boot 结合 Elasticsearch 实现数据库与 ES 索引同步的功能。在实际应用中，根据具体需求，可能需要进一步优化和扩展。例如，增加定时任务进行同步，或使用消息队列处理异步操作等。通过以上的实现，您可以快速构建一个高效的搜索功能，为用户提供更好的体验。