安装与配置

0、版本问题

版本不一致可能出现莫名奇妙的问题。比如：

• ElasticSearch和IK版本不一致，ElasticSearch启动失败。
• elasticsearch-rest-high-level-client和ElasticSearch版本不一致，创建Index失败。

ElasticSearch Client从7.0开始推荐使用elasticsearch-rest-high-level-client。可以在pom.xml的Dependency Analyzer中查看对应依赖的版本。

1、下载

• ElasticSearch

  • 本次下载的是V7.12.1。
  • 解压

• IK(中文分词插件，不需要则不用下载）

  • 本次下载的是V7.12.1。

  • 在ElasticSearch目录中的plugins目录下，创建IK目录，并将IK包解压到IK目录下。

    

2、配置

• 环境变量配置

  • 环境变量的Path变量中，添加ElasticSearch中bin目录的路径。

    D:\XiangWorkingSpace\elasticsearch-7.12.1\bin
    

• ElasticSearch配置：修改配置文件：config/elasticsearch.yml

    cluster.name: 你的自定义目录
    path.data: 你的自定义目录
    path.logs: 你的自定义目录

• 启动
  • 进入bin目录，双击elasticsearch.bat即可。

SpringBoot整合ElasticSearch

• 引入依赖

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

• 配置ElasticSearch

  @Configuration
  public class ElasticSearchConfig {
      @Value("${elasticsearch.host.one:localhost:9200}")
      private String hostOne;
      @Bean
      RestHighLevelClient client() {
          ClientConfiguration clientConfiguration = ClientConfiguration.builder()
                  .connectedTo(hostOne)
                  .withConnectTimeout(Duration.ofSeconds(5))
                  .withConnectTimeout(Duration.ofSeconds(3))
                  .build();
          return RestClients.create(clientConfiguration).rest();
      }
  }
  

• 配置实体类（Mapping Annotation Overview）

  @Document(indexName = "discussPost")
  public class DiscussPost {
      @Id
      private int id;
      @Field(type = FieldType.Integer)
      private int userId;
      @Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_smart")
      private String title;
      @Transient
      private String content;// 不存入ES
      ...
  }
  

• 配置DAO

  @Repository
  	public interface ElasticSearchRepository extends ElasticsearchRepository<DiscussPost, Integer> {
  }
  

  通过ElasticSearchRepository对ES中的数据进行CURD操作。

• 分页查询ES

@Resource
private ElasticsearchRestTemplate elasticsearchRestTemplate;
...
// 构建查询
NativeSearchQuery searchQuery = new NativeSearchQueryBuilder()
    .withQuery(QueryBuilders.multiMatchQuery(keyWord, "title", "content"))
    .withSort(SortBuilders.fieldSort("type").order(SortOrder.DESC))
    .withSort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC))
    // 页码从0开始
    .withPageable(PageRequest.of(pageNum - 1, pageSize))
    .withHighlightFields(
        new HighlightBuilder.Field("title").preTags("<em>").postTags("</em>"),
        new HighlightBuilder.Field("content").preTags("<em>").postTags("</em>")
    ).build();
// 查询
SearchHits<DiscussPost> searchHits = elasticsearchRestTemplate.search(searchQuery, DiscussPost.class);
// 遍历查询结果做一些自定义处理
for (SearchHit<DiscussPost> searchHit : searchHits.getSearchHits()) {
  DiscussPost discussPost = searchHit.getContent();
  ...
}