Elasticsearch的Java客户端--文档操作--检索文档

官方文档：https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/java-rest-high-document-get.html

public static void main(String[] args) throws IOException {
        // 1.创建客户端
        RestClientBuilder clientBuilder = RestClient.builder(new HttpHost("127.0.0.1", 9200, "http"));
        RestHighLevelClient client = new RestHighLevelClient(clientBuilder);

        // 2.创建检索文档请求，指定文档的索引名称和id
        GetRequest getRequest = new GetRequest("posts", "1");

        // 3.执行请求，返回响应
        GetResponse response = client.get(getRequest, RequestOptions.DEFAULT);

        String id = response.getId();//文档id
        String index = response.getIndex();//索引
        boolean exists = response.isExists();//文档是否存在
        long version = response.getVersion();//版本号
        String source = response.getSourceAsString();//文档内容

        //注意：请求的文档不存在不会抛出错误，但是会返回错误的响应码，请求的索引不存在会抛出
        //索引不存在异常

        // 4.关闭客户端
        client.close();
    }

// 不返回 source 字段
        request.fetchSourceContext(FetchSourceContext.DO_NOT_FETCH_SOURCE);
// 指定要返回的字段和要剔除的字段
String[] includes = new String[]{"message", "*Date"};
String[] excludes = Strings.EMPTY_ARRAY;
FetchSourceContext fetchSourceContext =
        new FetchSourceContext(true, includes, excludes);
request.fetchSourceContext(fetchSourceContext);
request.realtime(false);//设置实时标志
request.versionType(VersionType.EXTERNAL);//版本类型
request.version(2);//版本号
request.refresh(true);//检索文档前执行刷新

在ES的Java客户端中，基本每个请求都有异步和同步操作，且操作方法类似，异步请求的方法名称多了 Async 后缀，多了一个 ActionListener 参数。