ElasticSearch Java REST客户端创建-蒲公英云

ElasticSearch Java REST客户端创建

1.低级客户端创建

2.高级客户端创建

3.安全验证高级客户端创建（带用户名和密码）

4.Java REST高级客户端 maven配置

对人工智能感兴趣点下面链接

现在人工智能非常火爆，很多朋友都想学，但是一般的教程都是为博硕生准备的，太难看懂了。最近发现了一个非常适合小白入门的教程，不仅通俗易懂而且还很风趣幽默。所以忍不住分享一下给大家。点这里可以跳转到教程。

https://www.cbedai.net/u014646662

1.低级客户端创建

/**
     * 获取低级客户端
     * 
     * @return
     */
    private static RestClient getLowClient() {
        RestClient client = RestClient.builder(new HttpHost("elk-node01", 9200, "http"),
                new HttpHost("elk-node02", 9200, "http"), new HttpHost("elk-node03", 9200, "http")).build();
        return client;
    }

2.高级客户端创建

/**
     * 获取客户端
     * 
     * @return
     */
    private static RestHighLevelClient getClient() {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("elk-node01", 9200, "http"), new HttpHost("elk-node02", 9200, "http"),
                        new HttpHost("elk-node03", 9200, "http")));
        return client;
    }

3.安全验证高级客户端创建（带用户名和密码）

最简获取

public static RestHighLevelClient createClient(String user,String passwd) throws Exception {
        RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost("192.168.68.101", 9200, "http"),new HttpHost("192.168.68.102", 9200, "http"),new HttpHost("192.168.68.103", 9200, "http"));
        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(user, passwd));
        // 认证
        restClientBuilder.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClientBuilder);
        return restHighLevelClient;
    }

增加部分参数

public static RestHighLevelClient createClient1(String user,String passwd) throws Exception {
        RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost("192.168.68.102", 9200, "http"),
                new HttpHost("192.168.68.103", 9200, "http"));
        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(user, passwd));
        // 认证和线程数
        restClientBuilder.setHttpClientConfigCallback(httpClientBuilder -> {
            httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
            int threadCount = 10;
            httpClientBuilder.setDefaultIOReactorConfig(IOReactorConfig.custom().setIoThreadCount(threadCount).build());
            return httpClientBuilder;
        });
        // 超时超时设置
        restClientBuilder.setRequestConfigCallback(requestConfigCallback -> {
            requestConfigCallback.setConnectTimeout(10);
            requestConfigCallback.setSocketTimeout(10);
            return requestConfigCallback;
        });
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClientBuilder);
        return restHighLevelClient;
    }