es 实战 —— spring boot 中使用 Elasticsearch

一、基础配置

依赖

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

客户端配置

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

 基于 Java Config 的配置

@Configuration
public class RestClientConfig extends AbstractElasticsearchConfiguration {

　　 // 完整的配置参考 https://docs.spring.io/spring-data/elasticsearch/docs/current/reference/html/#elasticsearch.clients.configuration
    @Override
    @Bean
    public RestHighLevelClient elasticsearchClient() {

        final ClientConfiguration clientConfiguration = ClientConfiguration.builder()  
            .connectedTo("localhost:9200")
            .build();

        return RestClients.create(clientConfiguration).rest();                         
    }
}

 

 

二、元数据对象映射（objects to documents）

常用注解示例

@Data
@Document(indexName = "article", shards = 5, replicas = 1, indexStoreType = "fs", refreshInterval = "-1")
public class Article implements Serializable {
    private static final long serialVersionUID = 551589397625941750L;

    @Id
    private Long id;

    private String title;

    private String abstracts;

    private String content;

    @Field(format = DateFormat.date_time, index = true, store = true, type = FieldType.Object)
    private Date postTime;

    private Long clickCount;
}

注解说明

@Document

@Persistent
@Inherited
@Retention(RetentionPolicy.RUNTIME)
@Target({ ElementType.TYPE })
public @interface Document {

    // 索引名称（小写）
    String indexName();

    // 映射 type（弃用）
    @Deprecated
    String type() default "";

    // 使用服务端配置？(索引创建)
    boolean useServerConfiguration() default false;

    // 分区数 (索引创建)
    short shards() default 1;

    // 副本数 (索引创建)
    short replicas() default 1;

    // 刷新间隔 (索引创建)
    String refreshInterval() default "1s";

    // 索引存储类型 (索引创建)
    String indexStoreType() default "fs";

    // 是否在启动时创建索引
    boolean createIndex() default true;

    //Configuration of version management.
    VersionType versionType() default VersionType.EXTERNAL;
}

@Field

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.FIELD)
@Documented
@Inherited
public @interface Field {

    // 默认为 Java Field 名称
    String name() default "";

    // 具体参考 https://www.elastic.co/guide/en/elasticsearch/reference/current/mapping-types.html
    FieldType type() default FieldType.Auto;

    boolean index() default true;

    // format 与 pattern 用于定义日期类型
    DateFormat format() default DateFormat.none;

    String pattern() default "";

    // 是否独立存储，不需要从 _source 解析，在需要频繁使用某个字段时使用。
    boolean store() default false;

    // 索引时分析器
    String analyzer() default "";

    // 查询时分析器
    String searchAnalyzer() default "";

    // 跟 analyzer 类似，只对 keyword 类型的字段有效，只有 char_filter和filter，没有tokenizer
    String normalizer() default "";
}

 

 

三、elasticsearchTemplate 操作

默认自动为实体类创建索引，也可以手动创建索引

elasticsearchTemplate.indexOps(Article.class).create();

 

创建

@PostMapping("/article")
public String save(@RequestBody Article article) {
    IndexQuery indexQuery = new IndexQueryBuilder()
            .withId(article.getId().toString())
            .withObject(article)
            .build();
    return elasticsearchTemplate.index(indexQuery, IndexCoordinates.of("article"));
}

 

根据id查询

@GetMapping("/article/{id}")
public Article findById(@PathVariable("id") Long id) {
    return elasticsearchTemplate
            .get(id.toString(), Article.class);
}

 

分页查询

@GetMapping("/article/page")
public void page() {
    QPageRequest p = QPageRequest.of(1, 10);
    Query query = new NativeSearchQueryBuilder()
            .withPageable(p)
            .build();
    SearchHits<Object> search = elasticsearchTemplate.search(query, Object.class);
    List<SearchHit<Object>> searchHits = search.toList();
    SearchHit<Object> objectSearchHit = searchHits.get(0);
    Object content = objectSearchHit.getContent();
}

 

复杂的查询

public void anotherQuery() {
    String articleTitle = "Spring Data Elasticsearch";
    Sort sort = Sort.by("title").descending();
    Query searchQuery = new NativeSearchQueryBuilder()
//                .withQuery(matchAllQuery())
            .withQuery(matchQuery("title", articleTitle).minimumShouldMatch("75%"))
            .withFilter(boolQuery().must(termQuery("id", "documentId")))
            .build();
    searchQuery.addSort(sort);
    SearchHits<Article> articles =
            elasticsearchTemplate.search(searchQuery, Article.class, IndexCoordinates.of("article"));
    Article article = articles.getSearchHit(0).getContent();
}

 

更多介绍

---

 https://docs.spring.io/spring-data/elasticsearch/docs/current/reference/html/#elasticsearch.misc

https://www.cnblogs.com/powerwu/articles/12083998.html