[大数据]Spring Boot + Elasticsearch 初体验

Elasticsearch 怎么说呢，经常会看到相关开源软件在使用，像日志解决方案 ELK 之类的，但是由于之前的工作经历，没有相关的业务需求，所以不需要用到这个框架，这次可能有机会接触到，先熟悉熟悉吧…

安装

1. 因为是本地测试，直接下载 Win 版本的就行了，官网：https://www.elastic.co/downloads/elasticsearch
2. 下载后解压，进入bin目录下，双击执行 elasticsearch.bat
3. 测试：http://localhost:9200
   
4. 修改密码

• /elasticsearch-7.15.2/config/elasticsearch.yml 添加配置
  xpack.security.enabled: true
• /elasticsearch-7.15.2/bin/elasticsearch-setup-passwords interactive 设置密码

5. 可视化：https://github.com/mobz/elasticsearch-head

分词器

顾名思义，就是将一段文字拆成词语，那么搜索的时候，就可以根据这些关键字查找，比如：华为手机，可拆成，<华为>，<手机>
https://github.com/medcl/elasticsearch-analysis-ik/releases

1. 可查看 ES 版本对应 IK 版本，咱这边版本直接拉最新版本，当前是 elasticsearch-analysis-ik-7.15.2.zip
2. 压缩包解压到 ES 安装路径 /plugins/ik 文件夹
   
3. 重启 ES

Spring Boot 使用

Spring Boot 版本：2.6.1
Elasticsearch 版本: 7.15.2
Spring Data Elasticsearch ：4.3.0

这里就不指定版本号了，跟着 Spring Boot Parent 走，2.6.1 对应 Elasticsearch 版本是 4.3.0
参考：官方提供版本对账表

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

首先说一下用这个包的原因：

1. 咱是新手，没有太多骚操作，能实现核心功能即可
2. 这个包封装好了很多通用方法，简化了开发成本
3. Spring Boot 玩家，集成契合度200%

那缺点也是很明显：

1. Elasticsearch 官方更新的版本速度快，而 Spring Boot 对这块的封装，是有相当大的延迟的
2. Elasticsearch 随着版本升级API略有变化，Spring Data Elasticsearch 容易遇到版本不兼容问题

所以有需要跟官方保持同步更新的话，建议使用 Elasticsearch 提供的包，官网 4.0 版本 client 文档：传送门

配置

server:
  port: 9090
spring:
  elasticsearch:
    uris: http://127.0.0.1:9200
    username: elastic
    password: 123456

代码部分

一般情况下，商城搜索商品的需求比较常见，咱就模拟这种情况测试一下搜索功能。

1. 新建商品信息 ES 对象，

/**
 * 搜索商品的信息
 *
 * @author jason
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Document(indexName = "pms")
public class EsProduct implements Serializable {

	private static final long serialVersionUID = -1L;

	private Long id;
	private String productSn;
	private Long productCategoryId;
	private String productCategoryName;
	private String pic;
	@Field(analyzer = "ik_max_word",type = FieldType.Text)
	private String name;
	@Field(analyzer = "ik_max_word",type = FieldType.Text)
	private String subTitle;
	@Field(analyzer = "ik_max_word",type = FieldType.Text)
	private String keywords;
	private BigDecimal price;

}

2. 新建 ES 操作类

/**
 * 商品ES操作类
 * 
 * @author jason
 */
public interface EsProductRepository extends ElasticsearchRepository<EsProduct, Long> {

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

}

3. 接口，先写个数据初始化的接口，然后写一个搜索的接口

public interface EsProductService {

	/**
	 * 初始化数据
	 */
	Iterable<EsProduct> initData();

	/**
	 * 根据关键字或名称或副标题，搜索内容
	 */
	Page<EsProduct> search(String keyword, Integer pageNum, Integer pageSize);

}

测试

1. 测试数据初始化到 ES，共100条数据，50条小米，50条华为
   一般来说，这里的操作都是从 MySql 初始化到 ES，后续增量更新数据
   

2. 搜跟小米有关的商品信息
   

3. 搜跟华为有关的商品信息
   

高端操作

高端的操作往往只需要最朴素的烹饪方式，忙碌了一上午，陈师傅决定，且听下回分解…

源码下载