本文主要讲解mall整合Elasticsearch的过程，以实现商品信息在Elasticsearch中的导入、查询、修改、删除为例。

项目使用框架介绍

Elasticsearch

Elasticsearch 是一个分布式、可扩展、实时的搜索与数据分析引擎。 它能从项目一开始就赋予你的数据以搜索、分析和探索的能力，可用于实现全文搜索和实时数据统计。

Elasticsearch的安装和使用

1.下载Elasticsearch6.2.2的zip包，并解压到指定目录，下载地址：https://www.elastic.co/cn/downloads/past-releases/elasticsearch-6-2-2

2.安装中文分词插件，在elasticsearch-6.2.2\bin目录下执行以下命令：elasticsearch-plugin install https://github.com/medcl/elasticsearch-analysis-ik/releases/download/v6.2.2/elasticsearch-analysis-ik-6.2.2.zip

3.运行bin目录下的elasticsearch.bat启动Elasticsearch

4.下载Kibana,作为访问Elasticsearch的客户端，请下载6.2.2版本的zip包，并解压到指定目录，下载地址：https://artifacts.elastic.co/downloads/kibana/kibana-6.2.2-windows-x86_64.zip

5.运行bin目录下的kibana.bat，启动Kibana的用户界面

6.访问http://localhost:5601 即可打开Kibana的用户界面

Spring Data Elasticsearch

Spring Data Elasticsearch是Spring提供的一种以Spring Data风格来操作数据存储的方式，它可以避免编写大量的样板代码。

常用注解

@Document

1. //标示映射到Elasticsearch文档上的领域对象

2. public @interface Document {

3.  //索引库名次，mysql中数据库的概念

4.    String indexName();

5.  //文档类型，mysql中表的概念

6.    String type() default "";

7.  //默认分片数

8.    short shards() default 5;

9.  //默认副本数量

10.    short replicas() default 1;

11. 
    

12. }

@Id

//表示是文档的id，文档可以认为是mysql中表行的概念public @interface Id {}

@Field

public @interface Field {  //文档中字段的类型    FieldType type() default FieldType.Auto;  //是否建立倒排索引    boolean index() default true;  //是否进行存储    boolean store() default false;  //分词器名次    String analyzer() default "";}

//为文档自动指定元数据类型public enum FieldType {    Text,//会进行分词并建了索引的字符类型    Integer,    Long,    Date,    Float,    Double,    Boolean,    Object,    Auto,//自动判断字段类型    Nested,//嵌套对象类型    Ip,    Attachment,    Keyword//不会进行分词建立索引的类型}

Sping Data方式的数据操作

继承ElasticsearchRepository接口可以获得常用的数据操作方法

可以使用衍生查询

在接口中直接指定查询方法名称便可查询，无需进行实现，如商品表中有商品名称、标题和关键字，直接定义以下查询，就可以对这三个字段进行全文搜索。

    /**     * 搜索查询     *     * @param name              商品名称     * @param subTitle          商品标题     * @param keywords          商品关键字     * @param page              分页信息     * @return     */    Page<EsProduct> findByNameOrSubTitleOrKeywords(String name, String subTitle, String keywords, Pageable page);

在idea中直接会提示对应字段

使用@Query注解可以用Elasticsearch的DSL语句进行查询

@Query("{"bool" : {"must" : {"field" : {"name" : "?0"}}}}")Page<EsProduct> findByName(String name,Pageable pageable);

项目使用表说明

• pms_product：商品信息表

• pms_product_attribute：商品属性参数表

• pms_product_attribute_value：存储产品参数值的表

整合Elasticsearch实现商品搜索

在pom.xml中添加相关依赖

<!--Elasticsearch相关依赖--><dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-data-elasticsearch<artifactId></dependency>

修改SpringBoot配置文件

修改application.yml文件，在spring节点下添加Elasticsearch相关配置。

data:  elasticsearch:    repositories:      enabled: true    cluster-nodes: 127.0.0.1:9300 # es的连接地址及端口号    cluster-name: elasticsearch # es集群的名称

添加商品文档对象EsProduct

不需要中文分词的字段设置成@Field(type = FieldType.Keyword)类型，需要中文分词的设置成@Field(analyzer = "ikmaxword",type = FieldType.Text)类型。

1. package com.macro.mall.tiny.nosql.elasticsearch.document;

2. 
   

3. import org.springframework.data.annotation.Id;

4. import org.springframework.data.elasticsearch.annotations.Document;

5. import org.springframework.data.elasticsearch.annotations.Field;

6. import org.springframework.data.elasticsearch.annotations.FieldType;

7. 
   

8. import java.io.Serializable;

9. import java.math.BigDecimal;

10. import java.util.List;

11. 
    

12. /**

13. * 搜索中的商品信息

14. * Created by macro on 2018/6/19.

15. */

16. @Document(indexName = "pms", type = "product",shards = 1,replicas = 0)

17. public class EsProduct implements Serializable {

18.    private static final long serialVersionUID = -1L;

19.    @Id

20.    private Long id;

21.    @Field(type = FieldType.Keyword)

22.    private String productSn;

23.    private Long brandId;

24.    @Field(type = FieldType.Keyword)

25.    private String brandName;

26.    private Long productCategoryId;

27.    @Field(type = FieldType.Keyword)

28.    private String productCategoryName;

29.    private String pic;

30.    @Field(analyzer = "ik_max_word",type = FieldType.Text)

31.    private String name;

32.    @Field(analyzer = "ik_max_word",type = FieldType.Text)

33.    private String subTitle;

34.    @Field(analyzer = "ik_max_word",type = FieldType.Text)

35.    private String keywords;

36.    private BigDecimal price;

37.    private Integer sale;

38.    private Integer newStatus;

39.    private Integer recommandStatus;

40.    private Integer stock;

41.    private Integer promotionType;

42.    private Integer sort;

43.    @Field(type =FieldType.Nested)

44.    private List<EsProductAttributeValue> attrValueList;

45. 
    

46.    //省略了所有getter和setter方法

47. }

添加EsProductRepository接口用于操作Elasticsearch

继承ElasticsearchRepository接口，这样就拥有了一些基本的Elasticsearch数据操作方法，同时定义了一个衍生查询方法。

1. package com.macro.mall.tiny.nosql.elasticsearch.repository;

2. 
   

3. import com.macro.mall.tiny.nosql.elasticsearch.document.EsProduct;

4. import org.springframework.data.domain.Page;

5. import org.springframework.data.domain.Pageable;

6. import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

7. 
   

8. /**

9. * 商品ES操作类

10. * Created by macro on 2018/6/19.

11. */

12. public interface EsProductRepository extends ElasticsearchRepository<EsProduct, Long> {

13.    /**

14.     * 搜索查询

15.     *

16.     * @param name              商品名称

17.     * @param subTitle          商品标题

18.     * @param keywords          商品关键字

19.     * @param page              分页信息

20.     * @return

21.     */

22.    Page<EsProduct> findByNameOrSubTitleOrKeywords(String name, String subTitle, String keywords, Pageable page);

23. 
    

24. }

添加EsProductService接口

1. package com.macro.mall.tiny.service;

2. 
   

3. import com.macro.mall.tiny.nosql.elasticsearch.document.EsProduct;

4. import org.springframework.data.domain.Page;

5. 
   

6. import java.util.List;

7. 
   

8. /**

9. * 商品搜索管理Service

10. * Created by macro on 2018/6/19.

11. */

12. public interface EsProductService {

13.    /**

14.     * 从数据库中导入所有商品到ES

15.     */

16.    int importAll();

17. 
    

18.    /**

19.     * 根据id删除商品

20.     */

21.    void delete(Long id);

22. 
    

23.    /**

24.     * 根据id创建商品

25.     */

26.    EsProduct create(Long id);

27. 
    

28.    /**

29.     * 批量删除商品

30.     */

31.    void delete(List<Long> ids);

32. 
    

33.    /**

34.     * 根据关键字搜索名称或者副标题

35.     */

36.    Page<EsProduct> search(String keyword, Integer pageNum, Integer pageSize);

37. 
    

38. }

添加EsProductService接口的实现类EsProductServiceImpl

1. package com.macro.mall.tiny.service.impl;

2. 
   

3. import com.macro.mall.tiny.dao.EsProductDao;

4. import com.macro.mall.tiny.nosql.elasticsearch.document.EsProduct;

5. import com.macro.mall.tiny.nosql.elasticsearch.repository.EsProductRepository;

6. import com.macro.mall.tiny.service.EsProductService;

7. import org.slf4j.Logger;

8. import org.slf4j.LoggerFactory;

9. import org.springframework.beans.factory.annotation.Autowired;

10. import org.springframework.data.domain.Page;

11. import org.springframework.data.domain.PageRequest;

12. import org.springframework.data.domain.Pageable;

13. import org.springframework.stereotype.Service;

14. import org.springframework.util.CollectionUtils;

15. 
    

16. import java.util.ArrayList;

17. import java.util.Iterator;

18. import java.util.List;

19. 
    

20. 
    

21. /**

22. * 商品搜索管理Service实现类

23. * Created by macro on 2018/6/19.

24. */

25. @Service

26. public class EsProductServiceImpl implements EsProductService {

27.    private static final Logger LOGGER = LoggerFactory.getLogger(EsProductServiceImpl.class);

28.    @Autowired

29.    private EsProductDao productDao;

30.    @Autowired

31.    private EsProductRepository productRepository;

32. 
    

33.    @Override

34.    public int importAll() {

35.        List<EsProduct> esProductList = productDao.getAllEsProductList(null);

36.        Iterable<EsProduct> esProductIterable = productRepository.saveAll(esProductList);

37.        Iterator<EsProduct> iterator = esProductIterable.iterator();

38.        int result = 0;

39.        while (iterator.hasNext()) {

40.            result++;

41.            iterator.next();

42.        }

43.        return result;

44.    }

45. 
    

46.    @Override

47.    public void delete(Long id) {

48.        productRepository.deleteById(id);

49.    }

50. 
    

51.    @Override

52.    public EsProduct create(Long id) {

53.        EsProduct result = null;

54.        List<EsProduct> esProductList = productDao.getAllEsProductList(id);

55.        if (esProductList.size() > 0) {

56.            EsProduct esProduct = esProductList.get(0);

57.            result = productRepository.save(esProduct);

58.        }

59.        return result;

60.    }

61. 
    

62.    @Override

63.    public void delete(List<Long> ids) {

64.        if (!CollectionUtils.isEmpty(ids)) {

65.            List<EsProduct> esProductList = new ArrayList<>();

66.            for (Long id : ids) {

67.                EsProduct esProduct = new EsProduct();

68.                esProduct.setId(id);

69.                esProductList.add(esProduct);

70.            }

71.            productRepository.deleteAll(esProductList);

72.        }

73.    }

74. 
    

75.    @Override

76.    public Page<EsProduct> search(String keyword, Integer pageNum, Integer pageSize) {

77.        Pageable pageable = PageRequest.of(pageNum, pageSize);

78.        return productRepository.findByNameOrSubTitleOrKeywords(keyword, keyword, keyword, pageable);

79.    }

80. 
    

81. }

添加EsProductController定义接口

1. package com.macro.mall.tiny.controller;

2. 
   

3. import com.macro.mall.tiny.common.api.CommonPage;

4. import com.macro.mall.tiny.common.api.CommonResult;

5. import com.macro.mall.tiny.nosql.elasticsearch.document.EsProduct;

6. import com.macro.mall.tiny.service.EsProductService;

7. import io.swagger.annotations.Api;

8. import io.swagger.annotations.ApiOperation;

9. import org.springframework.beans.factory.annotation.Autowired;

10. import org.springframework.data.domain.Page;

11. import org.springframework.stereotype.Controller;

12. import org.springframework.web.bind.annotation.*;

13. 
    

14. import java.util.List;

15. 
    

16. /**

17. * 搜索商品管理Controller

18. * Created by macro on 2018/6/19.

19. */

20. @Controller

21. @Api(tags = "EsProductController", description = "搜索商品管理")

22. @RequestMapping("/esProduct")

23. public class EsProductController {

24.    @Autowired

25.    private EsProductService esProductService;

26. 
    

27.    @ApiOperation(value = "导入所有数据库中商品到ES")

28.    @RequestMapping(value = "/importAll", method = RequestMethod.POST)

29.    @ResponseBody

30.    public CommonResult<Integer> importAllList() {

31.        int count = esProductService.importAll();

32.        return CommonResult.success(count);

33.    }

34. 
    

35.    @ApiOperation(value = "根据id删除商品")

36.    @RequestMapping(value = "/delete/{id}", method = RequestMethod.GET)

37.    @ResponseBody

38.    public CommonResult<Object> delete(@PathVariable Long id) {

39.        esProductService.delete(id);

40.        return CommonResult.success(null);

41.    }

42. 
    

43.    @ApiOperation(value = "根据id批量删除商品")

44.    @RequestMapping(value = "/delete/batch", method = RequestMethod.POST)

45.    @ResponseBody

46.    public CommonResult<Object> delete(@RequestParam("ids") List<Long> ids) {

47.        esProductService.delete(ids);

48.        return CommonResult.success(null);

49.    }

50. 
    

51.    @ApiOperation(value = "根据id创建商品")

52.    @RequestMapping(value = "/create/{id}", method = RequestMethod.POST)

53.    @ResponseBody

54.    public CommonResult<EsProduct> create(@PathVariable Long id) {

55.        EsProduct esProduct = esProductService.create(id);

56.        if (esProduct != null) {

57.            return CommonResult.success(esProduct);

58.        } else {

59.            return CommonResult.failed();

60.        }

61.    }

62. 
    

63.    @ApiOperation(value = "简单搜索")

64.    @RequestMapping(value = "/search/simple", method = RequestMethod.GET)

65.    @ResponseBody

66.    public CommonResult<CommonPage<EsProduct>> search(@RequestParam(required = false) String keyword,

67.                                                      @RequestParam(required = false, defaultValue = "0") Integer pageNum,

68.                                                      @RequestParam(required = false, defaultValue = "5") Integer pageSize) {

69.        Page<EsProduct> esProductPage = esProductService.search(keyword, pageNum, pageSize);

70.        return CommonResult.success(CommonPage.restPage(esProductPage));

71.    }

72. 
    

73. }

进行接口测试

将数据库中数据导入到Elasticsearch

进行商品搜索