Elasticsearch搜索功能的实现——实战篇

布满荆棘的人生 2023-09-26 21:52 128阅读 0赞

**实战环境**

elastic search 8.5.0 + kibna 8.5.0 + springboot 3.0.2 + spring data elasticsearch 5.0.2 + jdk 17

### 一、集成 spring data elasticsearch ###

#### 1 添加依赖 ####

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>

#### 2 配置es连接 ####

@Configuration
    public class ElasticsearchConfig extends ElasticsearchConfiguration {
    
        @Override
        public ClientConfiguration clientConfiguration() {
    
                return ClientConfiguration.builder()
                        .connectedTo("127.0.0.1:9200")
                        .withBasicAuth("elastic", "********")
                        .build();
    
        }
    }

#### 3 配置打印DSL语句 ####

# 日志配置
    logging:
      level:
        #es日志
        org.springframework.data.elasticsearch.client.WIRE : trace

### 二、index及mapping 文件编写 ###

@Data
    @Document(indexName = "news") //索引名
    @Setting(shards = 1,replicas = 0,refreshInterval = "1s") //shards 分片数 replicas 副本数
    @Schema(name = "News",description = "新闻对象")
    public class News implements Serializable {
    
        @Id  //索引主键
        @NotBlank(message = "新闻ID不能为空")
        @Schema(type = "integer",description = "新闻ID",example = "1")
        private Integer id;
    
        @NotBlank(message = "新闻标题不能为空")
        @Schema(type = "String",description = "新闻标题")
        @MultiField(mainField = @Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_smart"),
                otherFields = {@InnerField(type = FieldType.Keyword, suffix = "keyword") }) //混合类型字段 指定 建立索引时分词器与搜索时入参分词器
        private String title;
    
        @Schema(type = "LocalDate",description = "发布时间")
        @Field(type = FieldType.Date,format = DateFormat.date)
        private LocalDate pubDate;
    
        @Schema(type = "String",description = "来源")
        @Field(type = FieldType.Keyword)
        private String source;
    
        @Schema(type = "String",description = "行业类型代码",example = "1,2,3")
        @Field(type = FieldType.Text,analyzer = "ik_max_word",searchAnalyzer = "ik_smart")
        private String industry;
    
        @Schema(type = "String",description = "预警类型")
        @Field(type = FieldType.Keyword)
        private String type;
    
        @Schema(type = "String",description = "涉及公司")
        @Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik