1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

spring:
  # 数据源
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/example?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false
    username: root
    password: 123456
  # elasticsearch
  elasticsearch:
    rest:
      uris: 192.168.10.10:9200,192.168.10.11:9200,192.168.10.12:9200

mybatis:
  configuration:
    map-underscore-to-camel-case: true # 开启驼峰映射

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

package com.example;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@MapperScan("com.example.mapper") // Mapper 接口扫描
@SpringBootApplication
public class SearchDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(SearchDemoApplication.class, args);
    }

}

1
2

<script src="https://cdn.jsdelivr.net/npm/vue@2.6.12/dist/vue.min.js"></script>
<script src="https://cdn.jsdelivr.net/npm/axios@0.21.1/dist/axios.min.js"></script>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

package com.example.pojo;

import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;

import java.io.Serializable;
import java.math.BigDecimal;

@Data
@NoArgsConstructor
/**
 * @Document 映射 Elasticsearch 索引库所需要的注解
 *  indexName：索引库名称
 *  shards：分片数
 *  replicas：副本数
 *  createIndex：是否创建索引库
 */
@Document(indexName = "goods", shards = 5, replicas = 1, createIndex = true)
public class Goods implements Serializable {

    private static final long serialVersionUID = -1989082640160920658L;
    @Id
    private Integer goodsId; // 商品ID
    @Field(type = FieldType.Text, analyzer = "ik_max_word") // 分词
    private String goodsName; // 商品名称
    @Field(type = FieldType.Text, analyzer = "ik_max_word") // 分词
    private String keywords; // 商品关键词
    @Field(type = FieldType.Double)
    private BigDecimal marketPrice; // 市场价
    @Field(type = FieldType.Short)
    private Short commentCount; // 商品评论数
    @Field(type = FieldType.Keyword)
    private String originalImg; // 商品原始图地址
    private String goodsRemark; // 商品简单描述
    private String goodsContent; // 商品详细描述，存储商品详情图地址
    private Integer catId; // 分类ID
    private Integer extendCatId; // 扩展分类ID
    private String goodsNo; // 商品编号
    private Integer clickCount; // 点击数
    private Short brandId; // 品牌ID
    private Short storeCount; // 库存数量
    private Integer weight; // 商品重量，单位：克
    private BigDecimal shopPrice; // 本店价
    private BigDecimal costPrice; // 商品成本价
    private Byte isReal; // 是否为实物
    private Byte isOnSale; // 是否上架
    private Byte isFreeShipping; // 是否包邮 0 否， 1 是
    private Integer onTime; // 商品上架时间
    private Short sort; // 商品排序
    private Byte isRecommend; // 是否推荐
    private Byte isNew; // 是否新品
    private Byte isHot; // 是否热卖
    private Integer lastUpdate; // 最后更新时间
    private Short goodsType; // 商品所属类型ID
    private Short specType; // 商品规格类型
    private Integer giveIntegral; // 购买商品赠送积分
    private Integer exchangeIntegral; // 积分兑换：0 不参与积分兑换
    private Short suppliersId; // 供货商ID
    private Integer salesSum; // 商品销量
    private Byte promType; // 0 普通订单，1 限时抢购， 2 团购， 3 促销优惠
    private Integer promId; // 优惠活动ID
    private BigDecimal commission; // 佣金用于分销分成
    private String spu; // SPU
    private String sku; // SKU

}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

package com.example.mapper;

import com.example.pojo.Goods;
import org.apache.ibatis.annotations.Select;

import java.util.List;

/**
 * @author 哈喽沃德先生
 * @微信公众号 哈喽沃德先生
 * @website https://mrhelloworld.com
 * @wechat 124059770
 */
public interface GoodsMapper {

    /**
     * 查询商品ID、商品名称、商品关键词、市场价、商品评论数、商品原始图地址
     *
     * @return 商品列表
     */
    @Select("SELECT goods_id, goods_name, keywords, market_price, comment_count, original_img FROM goods")
    List<Goods> selectGoodsList();

}

1
2
3
4

# 自定义配置
search:
  index:
    enabled: true # 是否需要创建索引和设置映射。默认为 false

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

package com.example.repository;

import com.example.pojo.Goods;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.IndexOperations;
import org.springframework.data.elasticsearch.core.document.Document;
import org.springframework.stereotype.Repository;

import javax.annotation.Resource;
import java.util.Arrays;
import java.util.List;

/**
 * @author 哈喽沃德先生
 * @微信公众号 哈喽沃德先生
 * @website https://mrhelloworld.com
 * @wechat 124059770
 */
@Repository
public class GoodsRepository {

    @Resource
    private ElasticsearchRestTemplate elasticsearchRestTemplate;

    // 是否需要创建索引和设置映射。默认为 false
    @Value("${search.index.enabled}")
    private boolean indexEnabled;

    /**
     * 批量新增商品信息至 Elasticsearch
     *
     * @param goodsList
     */
    public void save(List<Goods> goodsList) {
        // 是否需要创建索引和设置映射
        if (indexEnabled) {
            createIndexAndPutMapping();
        }
        // 批量新增
        elasticsearchRestTemplate.save(goodsList);
    }

    /**
     * 新增单个商品信息至 Elasticsearch
     *
     * @param goods
     */
    public void save(Goods goods) {
        save(Arrays.asList(goods));
    }

    /**
     * 创建索引和设置映射
     */
    private void createIndexAndPutMapping() {
        // 设置索引信息（实体类）
        IndexOperations indexOperations = elasticsearchRestTemplate.indexOps(Goods.class);
        // 创建索引
        indexOperations.create();
        // 创建映射
        Document mapping = indexOperations.createMapping();
        // 将映射写入索引
        indexOperations.putMapping(mapping);
    }

}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

package com.example.service;

import com.example.mapper.GoodsMapper;
import com.example.repository.GoodsRepository;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * @author 哈喽沃德先生
 * @微信公众号 哈喽沃德先生
 * @website https://mrhelloworld.com
 * @wechat 124059770
 */
@Service
public class SearchService {

    @Resource
    private GoodsMapper goodsMapper;
    @Resource
    private GoodsRepository goodsRepository;

    /**
     * 将 MySQL 商品信息导入 Elasticsearch
     */
    public void importGoods() {
        goodsRepository.save(goodsMapper.selectGoodsList());
    }

}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

package com.example.service;

import com.example.SearchDemoApplication;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

import javax.annotation.Resource;

@SpringBootTest(classes = SearchDemoApplication.class)
public class SearchServiceTest {

    @Resource
    private SearchService searchService;

    @Test
    public void testImportGoods() {
        searchService.importGoods();
    }

}

1
2
3
4
5
6
7
8
9

/**
 * 分页、高亮查询
 *
 * @param query
 * @return
 */
public SearchHits<Goods> selectGoodsListForPage(NativeSearchQuery query) {
    return elasticsearchRestTemplate.search(query, Goods.class);
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

package com.example.result;

import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.List;

/**
 * @author 哈喽沃德先生
 * @微信公众号 哈喽沃德先生
 * @website https://mrhelloworld.com
 * @wechat 124059770
 */
@Data
@NoArgsConstructor
public class PageInfo<T> implements Serializable {

    private static final long serialVersionUID = 6260163970867016563L;
    private int currentPage; // 当前页
    private int pageSize; // 每页显示条数
    private int total; // 总记录数
    private int totalPage; // 总页数
    private int prePage; // 上一页
    private int nextPage; // 下一页
    private boolean hasPre; // 是否有上一页
    private boolean hasNext; // 是否有下一页
    private List<T> result; // 返回结果集

    public PageInfo(int currentPage, int pageSize) {
        // 当前页
        this.currentPage = currentPage < 1 ? 1 : currentPage;
        // 每页显示条数
        this.pageSize = pageSize;
        // 是否有上一页
        this.hasPre = currentPage == 1 ? false : true;
        // 是否有下一页
        this.hasNext = currentPage == totalPage ? false : true;
        // 上一页
        if (hasPre) {
            this.prePage = currentPage - 1;
        }
        // 下一页
        if (hasNext) {
            this.nextPage = currentPage + 1;
        }
    }

    public PageInfo(int currentPage, int pageSize, int total) {
        // 当前页
        this.currentPage = currentPage < 1 ? 1 : currentPage;
        // 每页显示条数
        this.pageSize = pageSize;
        // 总记录数
        this.total = total;
        // 计算总页数
        if (total == 0) {
            this.totalPage = 0;
        } else {
            this.totalPage = (total - 1) / pageSize + 1;
        }
        // 是否有上一页
        this.hasPre = currentPage == 1 ? false : true;
        // 是否有下一页
        this.hasNext = currentPage == totalPage ? false : true;
        // 上一页
        if (hasPre) {
            this.prePage = currentPage - 1;
        }
        // 下一页
        if (hasNext) {
            this.nextPage = currentPage + 1;
        }
    }

}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

/**
 * 搜索
 *
 * @param searchStr 搜索条件
 * @param pageNum   第几页
 * @param pageSize  每页显示条数
 * @return
 */
public PageInfo<GoodsVo> doSearch(String searchStr, Integer pageNum, Integer pageSize) {
    // 设置高亮格式 <span style='color:red;'></span>
    HighlightBuilder.Field field = new HighlightBuilder.Field("goodsName");
    field.preTags("<span style='color:red;'>");
    field.postTags("</span>");
    // 构建搜索条件对象
    BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
    // 设置搜索条件 goodsName 和 keywords
    boolQueryBuilder.must(QueryBuilders.multiMatchQuery(searchStr, "goodsName", "keywords"));
    // 构建搜索对象
    NativeSearchQuery query = new NativeSearchQueryBuilder()
            .withQuery(boolQueryBuilder) // 搜索条件
            .withHighlightFields(field) // 高亮
            .withPageable(PageRequest.of(pageNum - 1, pageSize)) // 分页，当前页从 0 开始
            .build();
    // 搜索
    SearchHits<Goods> searchHits = goodsRepository.selectGoodsListForPage(query);
    // 总条数
    Long total = searchHits.getTotalHits();
    if (0 > total) {
        return new PageInfo<>(pageNum, pageSize, 0);
    }
    // 初始化返回结果集
    List<GoodsVo> goodsVoList = new ArrayList<>();
    // 处理搜索结果集
    for (SearchHit<Goods> searchHit : searchHits) {
        // 初始化返回结果对象
        GoodsVo goodsVo = new GoodsVo();
        // 获取结果对象
        Goods goods = searchHit.getContent();
        // 拷贝属性
        BeanUtils.copyProperties(goods, goodsVo);
        // 处理高亮信息
        Map<String, List<String>> highlightFields = searchHit.getHighlightFields();
        // 是否有高亮信息
        if (highlightFields.containsKey("goodsName")) {
            String goodsNameHl = highlightFields.get("goodsName").get(0);
            goodsVo.setGoodsNameHl(goodsNameHl);
        } else {
            goodsVo.setGoodsNameHl(goods.getGoodsName());
        }
        goodsVoList.add(goodsVo);
    }
    // 初始化分页对象
    PageInfo<GoodsVo> pageInfo = new PageInfo<GoodsVo>(pageNum, pageSize, total.intValue());
    pageInfo.setResult(goodsVoList);
    return pageInfo;
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

package com.example.controller;

import com.example.result.PageInfo;
import com.example.service.SearchService;
import com.example.vo.GoodsVo;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @author 哈喽沃德先生
 * @微信公众号 哈喽沃德先生
 * @website https://mrhelloworld.com
 * @wechat 124059770
 */
@RestController
@RequestMapping("search")
public class SearchController {

    @Resource
    private SearchService searchService;

    /**
     * 搜索
     *
     * @param searchStr 搜索条件
     * @param pageNum   第几页
     * @param pageSize  每页显示条数
     * @return
     */
    @GetMapping
    public PageInfo<GoodsVo> doSearch(String searchStr, Integer pageNum, Integer pageSize) {
        return searchService.doSearch(searchStr, pageNum, pageSize);
    }

}

1
2

<script src="https://cdn.jsdelivr.net/npm/vue@2.6.12/dist/vue.min.js"></script>
<script src="https://cdn.jsdelivr.net/npm/axios@0.21.1/dist/axios.min.js"></script>

1
2
3
4
5
6

<form action="" name="search" method="get" class="fl" onsubmit="return false;">
    <input id="searchStr" type="text" class="txt" value="请输入商品关键字"/>
    <input type="submit" class="btn" value="搜索"/>
    <input id="pageNum" type="hidden" value="1"/>
    <input id="pageSize" type="hidden" value="12"/>
</form>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

<!-- 商品列表 start-->
<div id="goodsList" class="goodslist mt10">
    <ul>
        <li>
            <dl>
                <dt><a href=""><img src="images/goods1.jpg" alt=""/></a></dt>
                <dd><a href=""><p class="beyondHidden">清华同方精锐X2 台式电脑（双核E3500 2G 500G DVD 键鼠）带20英寸显示器</p></a></dd>
                <dd><strong>￥2399.00</strong></dd>
                <dd><a href=""><em>已有10人评价</em></a></dd>
            </dl>
        </li>
    </ul>
</div>
<!-- 商品列表 end-->

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

<!-- 分页信息 start -->
<div id="page" class="page mt20">
    <a href="">首页</a>
    <a href="">上一页</a>
    <a href="" class="cur">3</a>
    <a href="">下一页</a>
    <a href="">尾页</a>&nbsp;&nbsp;
    <span>
        <em>共8页&nbsp;&nbsp;到第<input type="text" id="num" class="page_num"/>页</em>
        <a href="" class="skipsearch">确定</a>
    </span>
</div>
<!-- 分页信息 end -->

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

<script>
  var app = new Vue({
    // element 的简写，挂载元素，绑定 id 为 app 的 html 代码片段
    el: '#app',
    // 定义组件数据
    data: {
      goodsList: [],
      page: []
    },
    // 定义组件方法
    methods: {
      // 搜索
      doSearch() {
        axios({
          url: "/search",
          method: "GET",
          params: {
            searchStr: $("#searchStr").val(),
            pageNum: $("#pageNum").val(),
            pageSize: $("#pageSize").val()
          }
        }).then(response => { // 返回结果
          $("#pageNum").val(1);// 重置当前页
          if (response.data.total <= 0) {
            $('#goodsList').append('<strong>对不起，没有找到与“' + $("#searchStr").val() + '”相关的商品，请确认搜索关键词是否正确。</strong>');
          }
          this.goodsList = response.data.result;
          this.page = response.data;
        }).catch(error => {// 异常捕获
          alert('系统正在升级中，请稍后再试！');
        });
      },
      // 上一页
      prePage() {
        // 获取当前页的值并减一，然后重新赋值给当前页
        let page = parseInt($("#pageNum").val()) - 1;
        $("#pageNum").val(page);
        // 调用搜索函数
        this.doSearch();
      },
      // 下一页
      nextPage() {
        // 获取当前页的值并加一，然后重新赋值给当前页
        let page = parseInt($("#pageNum").val()) + 1;
        $("#pageNum").val(page);
        // 调用搜索函数
        this.doSearch();
      },
      // 第几页
      whichPage(num) {
        // 获取点击的按钮（首页、1、2...尾页）值，然后重新赋值给当前页
        $("#pageNum").val(num);
        // 调用搜索函数
        this.doSearch();
      },
      // 到第几页
      goToPage() {
        // 获取输入的页码值，然后重新赋值给当前页
        $("#pageNum").val($("#num").val());
        // 调用搜索函数
        this.doSearch();
      }
    }
  });
</script>

1
2
3
4
5
6

<form action="" name="search" method="get" class="fl" onsubmit="return false;">
    <input id="searchStr" type="text" class="txt" value="请输入商品关键字"/>
    <input v-on:click="doSearch" type="submit" class="btn" value="搜索"/>
    <input id="pageNum" type="hidden" value="1"/>
    <input id="pageSize" type="hidden" value="12"/>
</form>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

<!-- 商品列表 start-->
<div id="goodsList" class="goodslist mt10">
    <ul>
        <li v-for="(goods, index) in goodsList">
            <dl>
                <dt><a href=""><img v-bind:src="goods.originalImg" alt=""/></a></dt>
                <dd><a href=""><p class="beyondHidden" v-html="goods.goodsNameHl"></p></a></dd>
                <dd><strong>￥{{ goods.marketPrice }}</strong></dd>
                <dd><a href=""><em>已有{{ goods.commentCount }}人评价</em></a></dd>
            </dl>
        </li>
    </ul>
</div>
<!-- 商品列表 end-->

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

<!-- 分页信息 start -->
<div id="page" class="page mt20">
    <a v-on:click="whichPage(1)" href="javascript:void(0);">首页</a>
    <a v-if="page.hasPre" v-on:click="prePage" href="javascript:void(0);">上一页</a>
    <a v-for="i in page.totalPage"
       v-on:click="whichPage(i)"
       v-bind:class="{ cur:i == page.currentPage }"
       href="javascript:void(0);">{{ i }}</a>
    <a v-if="page.hasNext" v-on:click="nextPage" href="javascript:void(0);">下一页</a>
    <a v-on:click="whichPage(page.totalPage)" href="javascript:void(0);">尾页</a>&nbsp;&nbsp;
    <span>
        <em>共{{ page.totalPage }}页&nbsp;&nbsp;到第<input type="text" id="num" class="page_num"/>页</em>
        <a v-on:click="goToPage" href="javascript:void(0);" class="skipsearch">确定</a>
    </span>
</div>
<!-- 分页信息 end -->