为什么推荐你用Elasticsearch做搜索系统？

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 # 开启驼峰映射

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);
    }

}

<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>

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

}

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 selectGoodsList();

}

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

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 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);
    }

}

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());
    }

}

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();
    }

}

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

    
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 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;
        }
    }

}

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 doSearch(String searchStr, Integer pageNum, Integer pageSize) {
        return searchService.doSearch(searchStr, pageNum, pageSize);
    }

}

<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>

<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.00strong>dd>
                <dd><a href=""><em>已有10人评价em>a>dd>
            dl>
        li>
    ul>
div>

<div id="page" class="page mt20">
    <a href="">首页a>
    <a href="">上一页a>
    <a href="" class="cur">3a>
    <a href="">


    
下一页a>
    <a href="">尾页a>  
    <span>
        <em>共8页  到第<input type="text" id="num" class="page_num"/>页em>
        <a href="" class="skipsearch">确定a>
    span>
div>

<script>
  var app = new Vue({
    // element 的简写，挂载元素，绑定 id 为 app 的 html 代码片段
    el: '#app',
    // 定义组件数据
    data: {
      goodsList: [],
      page: []
    },
    // 定义组件方法
    methods: {
      // 搜索
      doSearch() {
        axios({
          url: "http://localhost:8080/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('对不起，没有找到与“' + $("#searchStr").val() + '”相关的商品，请确认搜索关键词是否正确。');
          }
          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>

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

    
链接：https://pan.baidu.com/s/1VfRjcHCtTFo1-y-nwhmLvQ
提取码：abcd