SpringBoot接入Elasticsearch完整教程

<!-- Spring Data Elasticsearch 自动引入新版Java API Client -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<!-- lombok 可选，简化实体类 -->
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>

spring:
  elasticsearch:
    uris: http://127.0.0.1:9200 #集群多个节点逗号分隔
    # ES开启认证时配置账号密码
    # username: elastic
    # password: elastic
    connection-timeout: 10s
    socket-timeout: 30s
# 调试：打印ES请求DSL
logging:
  level:
    org.springframework.data.elasticsearch: DEBUG

import lombok.Data;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
@Data
// indexName：索引名（小写，不能大写）createIndex=true项目启动自动创建索引
@Document(indexName = "product", createIndex = true)
public class ProductDoc {
    // @Id 对应ES文档 _id
    @Id
    private Long id;
    // Text：分词，全文检索；ik_max_word 细粒度分词，ik_smart粗粒度
    @Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_smart")
    private String name;
    // Keyword：不分词，精确匹配、筛选、聚合
    @Field(type = FieldType.Keyword)
    private String category;
    @Field(type = FieldType.Double)
    private Double price;
    @Field(type = FieldType.Text, analyzer = "ik_max_word")
    private String desc;
}

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
// 泛型：实体类，主键类型
public interface ProductRepository extends ElasticsearchRepository<ProductDoc, Long> {
    // 【方法名自动推导查询】根据名称分词查询
    List<ProductDoc> findByName(String name);
    // 自定义DSL语句查询
    // @Query("{\"match\": {\"name\": \"?0\"}}")
    // List<ProductDoc> searchName(String keyword);
}

@Service
@RequiredArgsConstructor
public class ProductService {
    private final ProductRepository productRepository;
    // 新增/全量更新（id存在则覆盖，不存在新增）
    public void save(ProductDoc doc) {
        productRepository.save(doc);
    }
    // 根据id查询
    public Optional<ProductDoc> findById(Long id) {
        return productRepository.findById(id);
    }
    // 删除
    public void delete(Long id) {
        productRepository.deleteById(id);
    }
    // 分页
    public Page<ProductDoc> page(String keyword, int page, int size) {
        Pageable pageable = PageRequest.of(page, size);
        return productRepository.findByName(keyword, pageable);
    }
}

@Service
@RequiredArgsConstructor
public class ProductEsService {
    private final ElasticsearchOperations esOperations;
    // 1. 新增文档
    public ProductDoc saveDoc(ProductDoc doc) {
        return esOperations.save(doc);
    }
    // 2. 根据id查询
    public ProductDoc getById(Long id) {
        return esOperations.get(String.valueOf(id), ProductDoc.class);
    }
    // 3. 删除文档
    public void deleteDoc(Long id) {
        esOperations.delete(String.valueOf(id), ProductDoc.class);
    }
    // 4. 复杂组合查询：关键词检索 + 分类筛选 + 价格区间 + 分页 + 高亮
    public SearchHits<ProductDoc> search(String keyword, String category, Double minPrice, int pageNum, int pageSize) {
        // 构建Bool查询
        BoolQuery boolQuery = BoolQuery.builder()
                // must：必须匹配（分词检索商品名）
                .must(m -> m.match(ma -> ma.field("name").query(keyword)))
                // filter：过滤，不计算相关度
                .filter(f -> f.term(t -> t.field("category").value(category)))
                .filter(f -> f.range(r -> r.field("price").gte(JsonData.of(minPrice))))
                .build();
        // 高亮配置
        HighlightOptions highlight = HighlightOptions.builder()
                .field("name", h -> h.preTags("<em>").postTags("</em>"))
                .build();
        NativeSearchQuery searchQuery = NativeSearchQueryBuilder()
                .withQuery(boolQuery)
                .withHighlightOptions(highlight)
                .withPageable(PageRequest.of(pageNum, pageSize)) // page从0开始
                .withSort(Sort.by(Sort.Direction.DESC, "price"))
                .build();
        // 执行查询
        return esOperations.search(searchQuery, ProductDoc.class);
    }
}

@Service
@RequiredArgsConstructor
public class ProductNativeService {
    private final ElasticsearchClient esClient;
    // 新增文档
    public void insert(ProductDoc doc) throws IOException {
        esClient.index(i -> i
                .index("product")
                .id(doc.getId().toString())
                .document(doc)
        );
    }
    // match分词查询
    public SearchResponse<ProductDoc> search(String keyword) throws IOException {
        return esClient.search(s -> s
                .index("product")
                .query(q -> q.match(m -> m.field("name").query(keyword))),
                ProductDoc.class
        );
    }
}

// 注入 ElasticsearchOperations
IndexOperations indexOps = esOperations.indexOps(ProductDoc.class);
// 判断索引是否存在
boolean exist = indexOps.exists();
// 删除索引
if(exist){
    indexOps.delete();
}
// 创建索引+自动映射mapping
indexOps.create();
indexOps.putMapping();

List<ProductDoc> list = new ArrayList<>();
// 封装多条数据
esOperations.save(list);