Elasticsearch学习篇第三章：Elasticsearch的四种Java api的使用方法

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>transport</artifactId>
    <version>7.9.1</version>
</dependency>
复制

public TransportClient transportClient() {
    TransportClient transportClient = null;
    try {
        // 配置信息
        Settings esSetting = Settings.builder()
                .put("cluster.name", clusterName) //集群名字
                .put("client.transport.sniff", true)//增加嗅探机制，找到ES集群
                .put("thread_pool.search.size", Integer.parseInt(poolSize))//增加线程池个数，暂时设为5
                .build();
        //配置信息Settings自定义
        transportClient = new PreBuiltTransportClient(esSetting);
        TransportAddress transportAddress = new TransportAddress(InetAddress.getByName(hostName), Integer.valueOf(port));
        transportClient.addTransportAddresses(transportAddress);
    } catch (Exception e) {
        log.error("elasticsearch TransportClient create error!!", e);
    }
    return transportClient;
}
复制

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.9.1</version>
</dependency>
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-elasticsearch</artifactId>
</dependency>
复制

@Bean
public RestHighLevelClient elasticsearchClient(){
    //获取es连接（不需要密码可以直接连接）
    //private RestHighLevelClient restHighLevelClient = new RestHighLevelClient(RestClient
    // .builder(new HttpHost(hostname, port, protocol)));


    // 账号密码
    CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(AuthScope.ANY,new UsernamePasswordCredentials(username, password));
    // 初始化
    RestClientBuilder builder = RestClient.builder(hostList.toArray(new HttpHost[0]));
    // 异步httpclient连接延时配置
    builder.setRequestConfigCallback(new RequestConfigCallback() {
        @Override
        public Builder customizeRequestConfig(Builder requestConfigBuilder) {
            requestConfigBuilder.setConnectTimeout(connectTimeOut);
            requestConfigBuilder.setSocketTimeout(socketTimeOut);
            requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeOut);
            return requestConfigBuilder;
        }
    });
    // 异步httpclient连接数配置
    builder.setHttpClientConfigCallback(new HttpClientConfigCallback() {
        @Override
        public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
            httpClientBuilder.setMaxConnTotal(maxConnectNum);
            httpClientBuilder.setMaxConnPerRoute(maxConnectPerRoute);
            httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
            return httpClientBuilder;
        }
    });
    RestHighLevelClient client = new RestHighLevelClient(builder);
    return client;
}
复制

包写错了<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency> -->
复制

@Bean
public JestClient getJestClient(){
    List<String> uris = Arrays.asList(url.split(","));
    JestClientFactory jestClientFactory = new JestClientFactory();
    jestClientFactory.setHttpClientConfig(new HttpClientConfig
            .Builder(uris)
            .connTimeout(10000)
            .readTimeout(10000)
            .maxConnectionIdleTime(1500L, TimeUnit.MILLISECONDS)
            .multiThreaded(true)
            .build());
    return jestClientFactory.getObject();
}
复制

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
复制

public interface ItemRepository extends ElasticsearchRepository<Item,Long> {}
复制

https://gitee.com/hzy100java/springboot-elasticsearch.git
复制