Springboot整合es

@Configuration
public class ESConfiguration {
    @Bean
    public RestHighLevelClient elasticsearchClient() {
        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("admin", "admin"));
 
        
        return new RestHighLevelClient(RestClient.builder(
                //使用公网地址 new HttpHost("www.xxx.com", 9200,"https")
                new HttpHost("localhost", 9200)
        ).setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
            public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                httpClientBuilder.disableAuthCaching();
                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
            }
        }));
    }
}

//搜索条件
SearchRequest searchRequest = new SearchRequest(indexName);
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
 
//分页
sourceBuilder.from(pageNo);
sourceBuilder.size(pageSize);//聚合时都默认返回10条数据，我们可以通过指定size值来修改这个默认值
 
//查询条件构造 调用sourceBuilder相关api设置即
 
//指定字段查询
sourceBuilder.fetchSource(include,exclude);//可以是数组
 
//超时设置
sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
 
//查询
searchRequest.source(sourceBuilder);
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
 
//结果
SearchHit[] searchHits =   searchResponse.getHits().getHits();
List<Map<String, Object>> maps = new ArrayList<>();
for (SearchHit hit : searchHits) {
    Map<String, Object> sourceAsMap = hit.getSourceAsMap();
    maps.add(sourceAsMap);
}