使用 Java 客户端添加 ElasticSearch 文档

松哥原创的 Spring Boot 视频教程已经杀青，感兴趣的小伙伴戳这里--> Spring Boot+Vue+微人事视频教程

今天我们来继续看 ElasticSearch 的 Java 客户端操作～我们来看下如何利用 Java 客户端添加 Es 文档。

以下是视频笔记：

注意，笔记只是视频内容的一个简要记录，因此笔记内容比较简单，完整的内容可以查看视频。

29.1 添加文档

public class DocTest01 {
public static void main(String[] args) throws IOException {
        RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(
new HttpHost("localhost", 9200, "http"),
new HttpHost("localhost", 9201, "http"),
new HttpHost("localhost", 9202, "http")
        ));
//构建一个 IndexRequest 请求，参数就是索引名称
        IndexRequest request = new IndexRequest("book");
//给请求配置一个 id，这个就是文档 id。如果指定了 id，相当于 put book/_doc/id ，也可以不指定 id，相当于 post book/_doc
//        request.id("1");
//构建索引文本，有三种方式：JSON 字符串、Map 对象、XContentBuilder
        request.source("{\"name\": \"三国演义\",\"author\": \"罗贯中\"}", XContentType.JSON);
//执行请求，有同步和异步两种方式
//同步
        IndexResponse indexResponse = client.index(request, RequestOptions.DEFAULT);
//获取文档id
        String id = indexResponse.getId();
        System.out.println("id = " + id);
//获取索引名称
        String index = indexResponse.getIndex();
        System.out.println("index = " + index);
//判断文档是否添加成功
if (indexResponse.getResult() == DocWriteResponse.Result.CREATED) {
            System.out.println("文档添加成功");
        }
//判断文档是否更新成功（如果 id 已经存在）
if (indexResponse.getResult() == DocWriteResponse.Result.UPDATED) {
            System.out.println("文档更新成功");
        }
        ReplicationResponse.ShardInfo shardInfo = indexResponse.getShardInfo();
//判断分片操作是否都成功
if (shardInfo.getTotal() != shardInfo.getSuccessful()) {
            System.out.println("有存在问题的分片");
        }
//有存在失败的分片
if (shardInfo.getFailed() > 0) {
//打印错误信息
for (ReplicationResponse.ShardInfo.Failure failure : shardInfo.getFailures()) {
                System.out.println("failure.reason() = " + failure.reason());
            }
        }

//异步
//        client.indexAsync(request, RequestOptions.DEFAULT, new ActionListener<IndexResponse>() {
//            @Override
//            public void onResponse(IndexResponse indexResponse) {
//
//            }
//
//            @Override
//            public void onFailure(Exception e) {
//
//            }
//        });
        client.close();
    }
}

演示分片存在问题的情况。由于我只有三个节点，但是在创建索引时，设置需要三个副本，此时的节点就不够用：

PUT book
{
"settings": {
"number_of_replicas": 3,
"number_of_shards": 3  
  }
}

创建完成后，再次执行上面的添加代码，此时就会打印出 有存在问题的分片 。

构建索引信息，有三种方式：

//构建索引文本，有三种方式：JSON 字符串、Map 对象、XContentBuilder
//request.source("{\"name\": \"三国演义\",\"author\": \"罗贯中\"}", XContentType.JSON);
//Map<String, String> map = new HashMap<>();
//map.put("name", "水浒传");
//map.put("author", "施耐庵");
//request.source(map).id("99");
XContentBuilder jsonBuilder = XContentFactory.jsonBuilder();
jsonBuilder.startObject();
jsonBuilder.field("name", "西游记");
jsonBuilder.field("author", "吴承恩");
jsonBuilder.endObject();
request.source(jsonBuilder);

默认情况下，如果 request 中包含有 id 属性，则相当于 PUT book/_doc/1 这样的请求，如果 request 中不包含 id 属性，则相当于 POST book/_doc ，此时 id 会自动生成。对于前者，如果 id 已经存在，则会执行一个更新操作。也就是 es 的具体操作，会自动调整。

当然，也可以直接指定操作。例如，指定为添加文档的操作：

//构建一个 IndexRequest 请求，参数就是索引名称
IndexRequest request = new IndexRequest("book");
XContentBuilder jsonBuilder = XContentFactory.jsonBuilder();
jsonBuilder.startObject();
jsonBuilder.field("name", "西游记");
jsonBuilder.field("author", "吴承恩");
jsonBuilder.endObject();
request.source(jsonBuilder).id("99");
//这是一个添加操作，不要自动调整为更新操作
request.opType(DocWriteRequest.OpType.CREATE);
//执行请求，有同步和异步两种方式
//同步
IndexResponse indexResponse = client.index(request, RequestOptions.DEFAULT);

ElasticSearch 基础知识：

1. 打算出一个 ElasticSearch 教程，谁赞成，谁反对？

2. ElasticSearch 从安装开始

3. ElasticSearch 第三弹，核心概念介绍

4. ElasticSearch 中的中文分词器该怎么玩？

5. ElasticSearch 索引基本操作

6. ElasticSearch 文档的添加、获取以及更新

7. ElasticSearch 文档的删除和批量操作

8. ElasticSearch 文档路由，你的数据到底存在哪一个分片上？

9. ElasticSearch 并发的处理方式：锁和版本控制

10. ElasticSearch 中的倒排索引到底是什么？

11. ElasticSearch 动态映射与静态映射

12. ElasticSearch 四种字段类型详解

13. ElasticSearch 中的地理类型和特殊类型

14. ElasticSearch 23 种映射参数详解

15. ElasticSearch 如何配置某个字段的权重？

16. ElasticSearch 23 种映射参数详解【3】

17. ElasticSearch 映射模版

18. ElasticSearch 搜索入门

19. ElasticSearch 全文搜索怎么玩？

20. ElasticSearch 打错字还能搜索到？试试 fuzzy query！

21. ElasticSearch 复合查询，理解 Es 中的文档评分策略！

22. 想搜索附近评分较高的餐厅，ElasticSearch 大显身手！

23. ElasticSearch 如何像 MySQL 一样做多表联合查询？

24. ElasticSearch 地理位置查询与特殊查询

25. ElasticSearch 搜索高亮与排序

26. ElasticSearch 指标聚合

27. ElasticSearch 桶聚合

28. ElasticSearch 管道聚合

29. Java 操作 ElasticSearch，so easy！

30. ElasticSearch Java 高级客户端索引操作～

31. ElasticSearch Java 高级客户端如何操作索引？