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

spring:
 application:
  name: search-service
 data:
  elasticsearch:
   cluster-name: elasticsearch
   cluster-nodes: 192.168.25.129:9300

@Data
@Document(indexName = "goods", type = "_doc", shards = 1, replicas = 0)
public class Goods {
  @Idprivate Long id;
  @Field(type = FieldType.text, analyzer = "ik_max_word")
  private String all;
  @Field(type = FieldType.keyword, index = false)
  private String subTitle;private Long brandId;private Long cid1;private Long cid2;private Long cid3;private Date createTime;private List<Long> price;
  @Field(type = FieldType.keyword, index = false)
  private String skus;private Map<String, Object> specs;
}

@Resource
private ElasticsearchTemplate elasticsearchTemplate;

elasticsearchTemplate.createIndex(Goods.class);

elasticsearchTemplate.putMapping(Goods.class);

//根據(jù)類
elasticsearchTemplate.deleteIndex(Goods.class);
//根據(jù)索引名
elasticsearchTemplate.deleteIndex("goods");

public interface ItemRepository extends ElasticsearchRepository<Item,Long> {
}

@Autowired
private ItemRepository itemRepository;

Item item = new Item(1L, "小米手機7", " 手機",
             "小米", 3499.00, "http://image.leyou.com/13123.jpg");
itemRepository.save(item);

  List<Item> list = new ArrayList<>();
  list.add(new Item(2L, "堅果手機R1", " 手機", "錘子", 3699.00, "http://image.leyou.com/123.jpg"));
  list.add(new Item(3L, "華為META10", " 手機", "華為", 4499.00, "http://image.leyou.com/3.jpg"));
  // 接收對象集合，實現(xiàn)批量新增
  itemRepository.saveAll(list);

  // 查詢?nèi)?，并安裝價格降序排序
  Iterable<Item> items = this.itemRepository.findAll(Sort.by(Sort.Direction.DESC, "price"));
  items.forEach(item-> System.out.println(item));

public interface ItemRepository extends ElasticsearchRepository<Item,Long> {

  /**
   * 根據(jù)價格區(qū)間查詢
   * @param price1
   * @param price2
   * @return
   */
  List<Item> findByPriceBetween(double price1, double price2);
}

    MatchQueryBuilder queryBuilder = QueryBuilders.matchQuery("all", "小米");
    // 執(zhí)行查詢
    Iterable<Goods> goods = this.goodsRepository.search(queryBuilder);

// 構(gòu)建查詢條件
    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
    // 添加基本的分詞查詢
    queryBuilder.withQuery(QueryBuilders.matchQuery("all", "小米"));
    // 執(zhí)行搜索，獲取結(jié)果
    Page<Goods> goods = this.goodsRepository.search(queryBuilder.build());
    // 打印總條數(shù)
    System.out.println(goods.getTotalElements());
    // 打印總頁數(shù)
    System.out.println(goods.getTotalPages());

// 構(gòu)建查詢條件
    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
    // 添加基本的分詞查詢
    queryBuilder.withQuery(QueryBuilders.termQuery("all", "手機"));

    // 初始化分頁參數(shù)
    int page = 0;
    int size = 3;
    // 設(shè)置分頁參數(shù)
    queryBuilder.withPageable(PageRequest.of(page, size));

    // 執(zhí)行搜索，獲取結(jié)果
    Page<Goods> goods = this.goodsRepository.search(queryBuilder.build());
    // 打印總條數(shù)
    System.out.println(goods.getTotalElements());
    // 打印總頁數(shù)
    System.out.println(goods.getTotalPages());
    // 每頁大小
    System.out.println(goods.getSize());
    // 當(dāng)前頁
    System.out.println(goods.getNumber());

// 構(gòu)建查詢條件
    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
    // 添加基本的分詞查詢
    queryBuilder.withQuery(QueryBuilders.termQuery("all", "手機"));

    // 排序
    queryBuilder.withSort(SortBuilders.fieldSort("price").order(SortOrder.DESC));

    // 執(zhí)行搜索，獲取結(jié)果
    Page<Goods> goods = this.goodsRepository.search(queryBuilder.build());
    // 打印總條數(shù)
    System.out.println(goods.getTotalElements());

NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
    // 不查詢?nèi)魏谓Y(jié)果
    queryBuilder.withSourceFilter(new FetchSourceFilter(new String[]{""}, null));
    // 1、添加一個新的聚合，聚合類型為terms，聚合名稱為brands，聚合字段為brand
    queryBuilder.addAggregation(AggregationBuilders.terms("brands").field("brandId"));
    // 2、查詢,需要把結(jié)果強轉(zhuǎn)為AggregatedPage類型
    AggregatedPage<Goods> aggPage = (AggregatedPage<Goods>) this.goodsRepository.search(queryBuilder.build());
    // 3、解析
    // 3.1、從結(jié)果中取出名為brands的那個聚合，
    // 因為是利用String類型字段來進(jìn)行的term聚合，所以結(jié)果要強轉(zhuǎn)為StringTerm類型
    LongTerms agg = (LongTerms) aggPage.getAggregation("brands");
    // 3.2、獲取桶
    List<LongTerms.Bucket> buckets = agg.getBuckets();
    // 3.3、遍歷
    for (LongTerms.Bucket bucket : buckets) {
      // 3.4、獲取桶中的key，即品牌名稱
      System.out.println(bucket.getKeyAsString());
      // 3.5、獲取桶中的文檔數(shù)量
      System.out.println(bucket.getDocCount());
    }

NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
    // 不查詢?nèi)魏谓Y(jié)果
    queryBuilder.withSourceFilter(new FetchSourceFilter(new String[]{""}, null));
    // 1、添加一個新的聚合，聚合類型為terms，聚合名稱為brands，聚合字段為brand
    queryBuilder.addAggregation(AggregationBuilders.terms("brands").field("brandId")
            .subAggregation(AggregationBuilders.avg("priceAvg").field("price"))); // 在品牌聚合桶內(nèi)進(jìn)行嵌套聚合，求平均值
    // 2、查詢,需要把結(jié)果強轉(zhuǎn)為AggregatedPage類型
    AggregatedPage<Goods> aggPage = (AggregatedPage<Goods>) this.goodsRepository.search(queryBuilder.build());
    // 3、解析
    // 3.1、從結(jié)果中取出名為brands的那個聚合，
    // 因為是利用String類型字段來進(jìn)行的term聚合，所以結(jié)果要強轉(zhuǎn)為StringTerm類型
    LongTerms agg = (LongTerms) aggPage.getAggregation("brands");
    // 3.2、獲取桶
    List<LongTerms.Bucket> buckets = agg.getBuckets();
    // 3.3、遍歷
    for (LongTerms.Bucket bucket : buckets) {
      // 3.4、獲取桶中的key，即品牌名稱 3.5、獲取桶中的文檔數(shù)量
      System.out.println(bucket.getKeyAsString() + "，共" + bucket.getDocCount() + "臺");

      // 3.6.獲取子聚合結(jié)果：
      InternalAvg avg = (InternalAvg) bucket.getAggregations().asMap().get("priceAvg");
      System.out.println("平均售價：" + avg.getValue());
    }

spring:
 jackson:
  default-property-inclusion: non_null # 配置json處理時忽略空值