个人名片：
博主：酒徒ᝰ.
个人简介：沉醉在酒中，借着一股酒劲，去拼搏一个未来。
本篇励志：三人行，必有我师焉。
本项目基于B站黑马程序员Java《SpringCloud微服务技术栈》，SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式
【SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式，系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】 点击观看
目录
- 五、RestClient操作文档
- 1. 新增文档
- 2. 查询文档
- 3. 删除文档
- 4. 修改文档
- 5. 批量导入文档
五、RestClient操作文档
Elasticsearch中的RestClient是一种非Java API，用于与Elasticsearch集群进行交互。RestClient提供了一种简单、直观的方式来操作和管理Elasticsearch中的文档。
RestClient使用HTTP协议来与Elasticsearch集群进行通信。它支持多种请求类型，例如GET、POST、PUT、DELETE等，并且可以发送请求到指定的索引、类型和ID。RestClient是Elasticsearch官方推荐的API之一，它具有以下优点：
简单易用 RestClient API的设计非常简洁，易于学习和使用。通过简单的HTTP请求，开发人员可以轻松地创建、查询、更新和删除Elasticsearch中的文档。
全面的功能支持 RestClient支持Elasticsearch中的大部分功能，包括全文搜索、结构化搜索、聚合查询等。它还提供了监控和管理Elasticsearch集群的功能，可以帮助开发人员了解集群的状态和运行情况，并及时发现和解决问题。
跨平台支持 RestClient是基于HTTP协议的API，它可以在任何支持HTTP协议的平台上使用。无论是Java、Python、Ruby还是其他编程语言，都可以使用RestClient
API与Elasticsearch集群进行交互。灵活的定制 RestClient API是Elasticsearch中的非侵入式API，它可以在不修改原有代码的情况下，轻松地对Elasticsearch进行定制和扩展。
RestClient操作文档的作用主要有以下几点：
文档的CRUD操作 RestClient可以用于创建、读取、更新和删除Elasticsearch中的文档。这些操作可以通过简单的HTTP请求实现，开发人员只需要提供文档的JSON表示形式和相应的请求方法即可。
结构化搜索 RestClient提供了结构化搜索的功能，可以帮助开发人员根据指定的字段进行搜索和过滤操作。这些操作可以通过简单的查询字符串或JSON格式的查询请求实现。
全文搜索 RestClient提供了全文搜索的功能，可以帮助开发人员根据文本内容进行搜索和匹配操作。这些操作可以通过简单的查询字符串或JSON格式的查询请求实现。
聚合查询 RestClient提供了聚合查询的功能，可以帮助开发人员对大量数据进行分组、汇总和统计。这些操作可以通过简单的查询字符串或JSON格式的查询请求实现。
数据分析和监控 RestClient提供了数据分析和监控的功能，可以帮助开发人员了解Elasticsearch集群的状态和运行情况，并及时发现和解决问题。这些操作可以通过监控API实现。
案例：利用JavaRestClient实现文档的CRUD
初始化：
@SpringBootTest
public class HotelDocumentTest {
@Autowired
private IHotelService hotelService;
@Autowired
private RestHighLevelClient client;
@BeforeEach
void setup() {
this.client = new RestHighLevelClient(RestClient.builder(
HttpHost.create("http://192.168.179.128:9200")
));
}
@AfterEach
void tearDown() throws IOException {
this.client.close();
}
}
1. 新增文档
@Test
void testIndexDocument() throws IOException {
Hotel hotel = hotelService.getById(36934L);
HotelDoc hotelDoc = new HotelDoc(hotel);
IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());
request.source(JSON.toJSONString(hotelDoc), XContentType.JSON);
client.index(request, RequestOptions.DEFAULT);
}
2. 查询文档
@Test
void testGetDocumentById() throws IOException {
GetRequest request = new GetRequest("hotel", "36934");
GetResponse response = client.get(request, RequestOptions.DEFAULT);
String json = response.getSourceAsString();
HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
System.out.println(hotelDoc);
}
3. 删除文档
@Test
void testDeleteDocument() throws IOException {
DeleteRequest request = new DeleteRequest("hotel", "36934");
client.delete(request, RequestOptions.DEFAULT);
}
4. 修改文档
- 全量修改 = 插入数据
- 增量修改 存在修改该字段，不存在则自动添加字段
@Test
void testUpdateDocument() throws IOException {
UpdateRequest request = new UpdateRequest("hotel", "36934");
request.doc(
"price", "954",
"startName", "四钻"
);
client.update(request, RequestOptions.DEFAULT);
}
5. 批量导入文档
@Test
void testBulk() throws IOException {
List<Hotel> list = hotelService.list();
BulkRequest request = new BulkRequest();
for (Hotel hotel : list) {
HotelDoc hotelDoc = new HotelDoc(hotel);
request.add(new IndexRequest("hotel")
.id(hotelDoc.getId().toString())
.source(JSON.toJSONString(hotelDoc), XContentType.JSON));
}
client.bulk(request, RequestOptions.DEFAULT);
}
小结：
文档操作的基本步骤：
初始化RestHighLevelClient
创建XxxRequest。XXX是Index、Get、Update、Delete、Bulk
准备参数（Index、Update、Bulk时需要）
发送请求。调用RestHighLevelClient#.xxx()方法，xxx是index、get、update、delete、bulk
解析结果（Get时需要）
