SpringBoot整合Elasticsearch实现全文检索功能

<!-- Elasticsearch -->
<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://localhost:9200
    # 8.x 需要开启账号密码
    # username: elastic
    # password: 123456

package com.demo.entity;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
import java.time.LocalDateTime;
@Data
@Document(
        indexName = "article",
        shards = 1,
        replicas = 0
)
public class ArticleES {
    @Id
    private Long id;
    // 标题：分词检索
    @Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_max_word")
    private String title;
    // 内容：全文检索
    @Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_max_word")
    private String content;
    // 作者：精确匹配，不分词
    @Field(type = FieldType.Keyword)
    private String author;
    // 浏览量
    @Field(type = FieldType.Integer)
    private Integer viewCount;
    // 分类
    @Field(type = FieldType.Keyword)
    private String category;
    @Field(type = FieldType.Date)
    private LocalDateTime createTime;
}

package com.demo.repository;
import com.demo.entity.ArticleES;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface ArticleESRepository extends ElasticsearchRepository<ArticleES, Long> {
    // 根据标题检索
    List<ArticleES> findByTitle(String title);
}

@Service
@RequiredArgsConstructor
public class ArticleESService {
    private final ArticleESRepository repository;
    // 新增/更新文档
    public ArticleES save(ArticleES articleES) {
        return repository.save(articleES);
    }
    // 根据ID查询
    public ArticleES findById(Long id) {
        return repository.findById(id).orElse(null);
    }
    // 查询全部
    public Iterable<ArticleES> findAll() {
        return repository.findAll();
    }
    // 删除
    public void deleteById(Long id) {
        repository.deleteById(id);
    }
}

@Autowired
private ElasticsearchRestTemplate restTemplate;
public List<ArticleES> search(String keyword) {
    // 1. 构建查询条件：标题 or 内容匹配关键词
    NativeSearchQuery query = new NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.multiMatchQuery(keyword, "title", "content"))
            // 高亮配置
            .withHighlightFields(
                    new HighlightBuilder.Field("title").preTags("<span style='color:red'>").postTags("</span>"),
                    new HighlightBuilder.Field("content").preTags("<span style='color:red'>").postTags("</span>")
            )
            // 分页
            .withPageable(PageRequest.of(0, 10))
            // 排序
            .withSort(SortBuilders.fieldSort("viewCount").order(SortOrder.DESC))
            .build();
    // 2. 执行查询
    SearchHits<ArticleES> searchHits = restTemplate.search(query, ArticleES.class);
    // 3. 处理高亮结果
    List<ArticleES> resultList = new ArrayList<>();
    for (SearchHit<ArticleES> hit : searchHits.getSearchHits()) {
        ArticleES article = hit.getContent();
        // 替换高亮标题
        Map<String, List<String>> highlightFields = hit.getHighlightFields();
        if (highlightFields.containsKey("title")) {
            article.setTitle(highlightFields.get("title").get(0));
        }
        if (highlightFields.containsKey("content")) {
            article.setContent(highlightFields.get("content").get(0));
        }
        resultList.add(article);
    }
    return resultList;
}

.withQuery(QueryBuilders.boolQuery()
        .must(QueryBuilders.termQuery("category", "Java"))
        .must(QueryBuilders.rangeQuery("viewCount").gte(100))
)

.withQuery(QueryBuilders.boolQuery()
        .should(QueryBuilders.matchQuery("title", "SpringBoot"))
        .should(QueryBuilders.matchQuery("content", "Redis"))
)

QueryBuilders.rangeQuery("viewCount").gte(100).lte(10000)

QueryBuilders.fuzzyQuery("title", "SpringBoot")

.withAggregation(AggregationBuilders.terms("group_category").field("category"))