Elasticsearch实战篇：索引库、文档与JavaRestClient操作指南

Elasticsearch 实战篇：索引库、文档与 JavaRestClient 操作指南

整理自黑马程序员《SpringCloud微服务开发与实战》Elasticsearch01 课程
对应章节：索引库操作、文档操作、JavaRestClient 客户端

一、索引库操作 (Index Operations)

索引库类似于 MySQL 中的表，Mapping 定义了表结构（字段类型、分词器等）。

1. Mapping 映射属性

在创建索引库前，需定义字段的 Mapping 属性。黑马课程中重点讲解了以下核心属性：

示例：黑马商城商品字段 Mapping 分析

{"mappings":{"properties":{"id":{"type":"keyword"},// 精确匹配，不分词"name":{"type":"text","analyzer":"ik_max_word",// 写入时细粒度分词"search_analyzer":"ik_smart"// 搜索时粗粒度分词},"price":{"type":"integer"},// 用于范围查询"brand":{"type":"keyword"},// 品牌做精确匹配"spec":{"type":"object",// 规格参数对象"properties":{"size":{"type":"keyword"}}}}}}

2. 索引库的 CRUD

创建索引库完整示例：

PUT/heima_goods{"mappings":{"properties":{"info":{"type":"text","analyzer":"ik_smart"},"email":{"type":"keyword","index":false}// 不参与搜索}}}

二、文档操作 (Document Operations)

文档是索引库中的具体数据，以 JSON 格式存储。

1. 文档的 CRUD

增量修改示例：

POST/heima_goods/_update/1{"doc":{"price":2999// 仅修改价格字段}}

2. 批量操作 (Bulk API)

用于高性能地批量新增、修改或删除文档。黑马项目中常用于数据初始化（如导入酒店数据）。

DSL 格式（注意是POST请求，操作类型与数据成对出现）：

POST/_bulk{"index":{"_index":"hotel","_id":"1"}}{"name":"如家酒店","price":300}{"index":{"_index":"hotel","_id":"2"}}{"name":"汉庭酒店","price":400}

三、JavaRestClient 客户端

ES 官方提供的 Java 高级客户端，用于在代码中替代 Kibana 的 DSL 语句。

1. 环境初始化

步骤 1：引入依赖（注意版本对齐）

<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId></dependency><!-- 覆盖 Spring Boot 默认的 ES 版本 --><properties><elasticsearch.version>7.12.1</elasticsearch.version></properties>

步骤 2：配置客户端 Bean

@ConfigurationpublicclassElasticsearchConfig{@BeanpublicRestHighLevelClientrestHighLevelClient(){returnnewRestHighLevelClient(RestClient.builder(HttpHost.create("http://你的IP:9200")));}}

2. 索引库操作 (Java API)

核心对象：IndicesClient（通过client.indices()获取）

创建索引库代码示例：

@TestvoidtestCreateIndex()throwsIOException{// 1. 创建 Request 对象CreateIndexRequestrequest=newCreateIndexRequest("hotel");// 2. 准备 DSL（MAPPING_TEMPLATE 是定义好的 JSON 字符串）request.source(MAPPING_TEMPLATE,XContentType.JSON);// 3. 发送请求CreateIndexResponseresponse=client.indices().create(request,RequestOptions.DEFAULT);System.out.println(response.isAcknowledged());}

3. 文档操作 (Java API)

核心对象：直接使用RestHighLevelClient的方法。

新增文档代码示例：

@TestvoidtestAddDocument()throwsIOException{// 1. 查询数据库数据（黑马案例：Hotel -> HotelDoc）Hotelhotel=hotelService.getById(1L);HotelDochotelDoc=newHotelDoc(hotel);// 转换为文档对象// 2. 创建 Request 对象（指定索引库和ID）IndexRequestrequest=newIndexRequest("hotel").id(hotelDoc.getId().toString());// 3. 准备 JSON 数据（使用 FastJSON 等工具转换）request.source(JSON.toJSONString(hotelDoc),XContentType.JSON);// 4. 发送请求client.index(request,RequestOptions.DEFAULT);}

4. 批量导入 (BulkProcessor)

黑马项目中用于一次性导入大量数据（如全量商品数据）。

代码模板：

@TestvoidtestBulk()throwsIOException{// 1. 查询所有数据List<Hotel>hotels=hotelService.list();// 2. 创建批量请求BulkRequestbulkRequest=newBulkRequest();// 3. 遍历添加子请求for(Hotelhotel:hotels){HotelDocdoc=newHotelDoc(hotel);IndexRequestrequest=newIndexRequest("hotel").id(doc.getId().toString()).source(JSON.toJSONString(doc),XContentType.JSON);bulkRequest.add(request);}// 4. 发送批量请求BulkResponseresponse=client.bulk(bulkRequest,RequestOptions.DEFAULT);}

四、黑马商城业务改造实战

1. 商品搜索改造思路

1. 数据同步：商品上架时，通过 JavaRestClient 将商品数据写入 ES 索引库（item_index）。
2. 字段设计：
   • title（商品名）：type: text, analyzer: ik_max_word
   • category（分类）：type: keyword（用于精确过滤）
   • price（价格）：type: integer（用于范围查询）
   • specs（规格）：type: object（嵌套对象，用于参数搜索）
3. 搜索流程：前端搜索词 -> JavaRestClient 构建 DSL 查询 -> 返回结果。

2. 避坑指南

• 版本一致性：Spring Boot 父工程默认的 ES 客户端版本可能与服务器不一致，必须在pom.xml中显式指定<elasticsearch.version>7.12.1</elasticsearch.version>。
• 字段不可变：Mapping 中的字段一旦创建，只能新增，不能修改类型。设计初期需谨慎。
• 分词器选择：搜索建议用ik_smart（粗粒度，减少噪音），索引建议用ik_max_word（细粒度，召回率高）。