{"id":1385,"date":"2023-03-19T11:05:34","date_gmt":"2023-03-19T03:05:34","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1385"},"modified":"2023-04-28T21:11:50","modified_gmt":"2023-04-28T13:11:50","slug":"elasticsearch-7-x-integrate-resthighlevelclient","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/03\/19\/elasticsearch-7-x-integrate-resthighlevelclient\/","title":{"rendered":"ElasticSearch 7.x \u96c6\u6210RestHighLevelClient"},"content":{"rendered":"

Java High Level REST Client<\/code>\u662f\u76ee\u524d\u5b98\u65b9\u63a8\u8350\u4f7f\u7528\u7684\u5ba2\u6237\u7aef\uff0cElasticsearch \u57287.0\u4e2d\u5bf9TransportClient\u8fdb\u884c\u5f03\u7528\uff0c\u5e76\u57288.0\u4e2d\u5b8c\u5168\u5220\u9664\uff0c\u66ff\u800c\u4ee3\u4e4b\u7684\u662fJava High Level REST Client<\/code>\u3002High Level REST Client<\/code>\u4e0e Elasticsearch \u5177\u6709\u76f8\u540c\u7684\u53d1\u5e03\u5468\u671f\u3002\u6545\u6211\u4eec\u80fd\u591f\u4f7f\u7528\u6700\u65b0\u7248\u7684 Elasticsearch<\/p>\n

\u53c2\u8003\uff1ahttps:\/\/www.elastic.co\/guide\/en\/elasticsearch\/client\/java-rest\/7.x\/java-rest-high-getting-started-maven.html<\/a><\/p>\n

<\/p>\n

Maven\u4f9d\u8d56<\/h2>\n
<dependency>\n    <groupId>org.elasticsearch.client<\/groupId>\n    <artifactId>elasticsearch-rest-high-level-client<\/artifactId>\n    <version>7.1.0<\/version>\n    <exclusions>\n        <exclusion>\n            <groupId>org.elasticsearch<\/groupId>\n            <artifactId>elasticsearch<\/artifactId>\n        <\/exclusion>\n        <exclusion>\n            <groupId>org.elasticsearch.client<\/groupId>\n            <artifactId>elasticsearch-rest-client<\/artifactId>\n        <\/exclusion>\n    <\/exclusions>\n<\/dependency>\n<dependency>\n    <groupId>org.elasticsearch<\/groupId>\n    <artifactId>elasticsearch<\/artifactId>\n    <version>7.1.0<\/version>\n<\/dependency>\n<dependency>\n    <groupId>org.elasticsearch.client<\/groupId>\n    <artifactId>elasticsearch-rest-client<\/artifactId>\n    <version>7.1.0<\/version>\n<\/dependency><\/code><\/pre>\n
elasticsearch\u5fc5\u987b\u8981\u5355\u72ec\u4f9d\u8d56\uff0c\u5426\u5219\u4f1a\u51fa\u73b0\u5982\u4e0b\u9519\u8bef:<\/p>\n
An attempt was made to call the method org.elasticsearch.action.search.SearchRequest.isCcsMinimizeRoundtrips()Z but it does not exist.<\/code><\/pre>\n
\u53c2\u8003\uff1ahttps:\/\/github.com\/elastic\/elasticsearch\/issues\/41189<\/a><\/p>\n
\u96c6\u6210RestHighLevelClient<\/h2>\n
\u4e3a\u4e86\u7b80\u5316EsClient\u7684\u521b\u5efa\u6d41\u7a0b\u548c\u591aes\u96c6\u7fa4\u7684\u652f\u6301\uff0c\u7f16\u5199\u4e00\u4e2a\u6784\u9020\u5668<\/p>\n
import org.apache.http.HttpHost;\nimport org.elasticsearch.client.RestClient;\nimport org.elasticsearch.client.RestClientBuilder;\nimport org.elasticsearch.client.RestHighLevelClient;\nimport org.springframework.stereotype.Component;\n\nimport java.util.List;\n\n\/**\n * @Author: yezhou\n * @Date: 2019\/5\/24 21:04\n * @Version 1.0\n *\/\n\n@Component\npublic class EsClientBuilder {\n    private int connectTimeoutMillis = 1000;\n    private int socketTimeoutMillis = 30000;\n    private int connectionRequestTimeoutMillis = 500;\n    private int maxConnectPerRoute = 10;\n    private int maxConnectTotal = 30;\n\n    private final List<HttpHost> httpHosts;\n\n    private EsClientBuilder(List<HttpHost> httpHosts) {\n        this.httpHosts = httpHosts;\n    }\n\n    public EsClientBuilder setConnectTimeoutMillis(int connectTimeoutMillis) {\n        this.connectTimeoutMillis = connectTimeoutMillis;\n        return this;\n    }\n\n    public EsClientBuilder setSocketTimeoutMillis(int socketTimeoutMillis) {\n        this.socketTimeoutMillis = socketTimeoutMillis;\n        return this;\n    }\n\n    public EsClientBuilder setConnectionRequestTimeoutMillis(int connectionRequestTimeoutMillis) {\n        this.connectionRequestTimeoutMillis = connectionRequestTimeoutMillis;\n        return this;\n    }\n\n    public EsClientBuilder setMaxConnectPerRoute(int maxConnectPerRoute) {\n        this.maxConnectPerRoute = maxConnectPerRoute;\n        return this;\n    }\n\n    public EsClientBuilder setMaxConnectTotal(int maxConnectTotal) {\n        this.maxConnectTotal = maxConnectTotal;\n        return this;\n    }\n\n    public static EsClientBuilder build(List<HttpHost> httpHosts) {\n        return new EsClientBuilder(httpHosts);\n    }\n\n    public RestHighLevelClient create() {\n\n        HttpHost[] httpHostArr = httpHosts.toArray(new HttpHost[0]);\n        RestClientBuilder builder = RestClient.builder(httpHostArr);\n\n        builder.setRequestConfigCallback(requestConfigBuilder -> {\n            requestConfigBuilder.setConnectTimeout(connectTimeoutMillis);\n            requestConfigBuilder.setSocketTimeout(socketTimeoutMillis);\n            requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeoutMillis);\n            return requestConfigBuilder;\n        });\n\n        builder.setHttpClientConfigCallback(httpClientBuilder -> {\n            httpClientBuilder.setMaxConnTotal(maxConnectTotal);\n            httpClientBuilder.setMaxConnPerRoute(maxConnectPerRoute);\n            return httpClientBuilder;\n        });\n\n        return new RestHighLevelClient(builder);\n    }\n}<\/code><\/pre>\n
\u914d\u7f6e\u6587\u4ef6application.yml<\/p>\n
elasticsearch:\n  nodes: 192.168.1.10:9200\n  schema: http\n  max-connect-total: 50\n  max-connect-per-route: 10\n  connection-request-timeout-millis: 500\n  socket-timeout-millis: 30000\n  connect-timeout-millis: 1000<\/code><\/pre>\n
\u914d\u7f6e\u7c7bConfiguration<\/p>\n
import org.apache.http.HttpHost;\nimport org.elasticsearch.client.RestHighLevelClient;\nimport org.springframework.beans.factory.annotation.Value;\nimport org.springframework.context.annotation.Bean;\nimport org.springframework.context.annotation.Configuration;\nimport org.springframework.util.Assert;\nimport org.springframework.util.StringUtils;\n\nimport java.util.ArrayList;\nimport java.util.List;\n\n\/**\n * @Author: yezhou\n * @Date: 2019\/5\/24 21:06\n * @Version 1.0\n *\/\n\n@Configuration\npublic class ESConfig {\n    @Value("${elasticsearch.nodes}")\n    private List<String> nodes;\n\n    @Value("${elasticsearch.schema}")\n    private String schema;\n\n    @Value("${elasticsearch.max-connect-total}")\n    private Integer maxConnectTotal;\n\n    @Value("${elasticsearch.max-connect-per-route}")\n    private Integer maxConnectPerRoute;\n\n    @Value("${elasticsearch.connection-request-timeout-millis}")\n    private Integer connectionRequestTimeoutMillis;\n\n    @Value("${elasticsearch.socket-timeout-millis}")\n    private Integer socketTimeoutMillis;\n\n    @Value("${elasticsearch.connect-timeout-millis}")\n    private Integer connectTimeoutMillis;\n\n    @Bean\n    public RestHighLevelClient getRestHighLevelClient() {\n        List<HttpHost> httpHosts = new ArrayList<>();\n        for (String node : nodes) {\n            try {\n                String[] parts = StringUtils.split(node, ":");\n                Assert.notNull(parts,"Must defined");\n                Assert.state(parts.length == 2, "Must be defined as 'host:port'");\n                httpHosts.add(new HttpHost(parts[0], Integer.parseInt(parts[1]), schema));\n            } catch (RuntimeException ex) {\n                throw new IllegalStateException(\n                        "Invalid ES nodes " + "property '" + node + "'", ex);\n            }\n        }\n\n        return EsClientBuilder.build(httpHosts)\n                .setConnectionRequestTimeoutMillis(connectionRequestTimeoutMillis)\n                .setConnectTimeoutMillis(connectTimeoutMillis)\n                .setSocketTimeoutMillis(socketTimeoutMillis)\n                .setMaxConnectTotal(maxConnectTotal)\n                .setMaxConnectPerRoute(maxConnectPerRoute)\n                .create();\n    }\n}<\/code><\/pre>\n
\u63a7\u5236\u5668Controller<\/p>\n
import com.alibaba.fastjson.JSON;\nimport lombok.extern.slf4j.Slf4j;\nimport org.apache.http.HttpHost;\nimport org.elasticsearch.action.search.SearchRequest;\nimport org.elasticsearch.action.search.SearchResponse;\nimport org.elasticsearch.action.search.SearchType;\nimport org.elasticsearch.client.RequestOptions;\nimport org.elasticsearch.client.RestClient;\nimport org.elasticsearch.client.RestHighLevelClient;\nimport org.elasticsearch.index.query.BoolQueryBuilder;\nimport org.elasticsearch.index.query.QueryBuilders;\nimport org.elasticsearch.search.builder.SearchSourceBuilder;\nimport org.elasticsearch.search.sort.SortOrder;\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.web.bind.annotation.GetMapping;\nimport org.springframework.web.bind.annotation.ResponseBody;\nimport org.springframework.web.bind.annotation.RestController;\n\nimport javax.annotation.Resource;\nimport java.io.IOException;\n\n\/**\n * @Author: yezhou\n * @Date: 2019\/5\/24 20:13\n * @Version 1.0\n *\/\n\n@Slf4j\n@RestController\npublic class ElasticSearchController {\n\n    @Resource\n    private RestHighLevelClient client;\n\n    @GetMapping("\/search")\n    @ResponseBody\n    public String search() throws IOException {\n\/\/        RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("192.168.165.239", 9200, "http")));\n\n        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();\n\n        boolQueryBuilder.must(QueryBuilders.termQuery("loglvl.keyword", "ERROR"));\n\/\/        boolQueryBuilder.must(QueryBuilders.wildcardQuery("loglvl.keyword", "INFO"));\n\/\/        boolQueryBuilder.must(QueryBuilders.rangeQuery("field").gt("value"));\n\/\/        boolQueryBuilder.must(QueryBuilders.termsQuery("loglvl.keyword", "INFO"));\n\n\/\/        boolQueryBuilder.must(QueryBuilders.matchQuery("loglvl", "ERROR"));\n\n        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();\n        sourceBuilder.query(boolQueryBuilder);\n        sourceBuilder.sort("@timestamp", SortOrder.DESC);\n        sourceBuilder.from(0);\n        sourceBuilder.size(10);\n\n        RequestOptions requestOptions = RequestOptions.DEFAULT;\n\n        SearchRequest searchRequest = new SearchRequest("thaipay");\n        \/\/searchRequest.searchType(SearchType.QUERY_THEN_FETCH);\n        searchRequest.source(sourceBuilder);\n        log.info(searchRequest.toString());\n        SearchResponse searchResponse = client.search(searchRequest, requestOptions);\n        return JSON.toJSONString(searchResponse);\n    }\n\n}<\/code><\/pre>\n
\u5982\u679c\u662fcluster<\/code>\uff0capplication.yml<\/code>\u7684nodes<\/code>\u8bbe\u7f6e\u591a\u4e2aip:host<\/code>\u9017\u53f7\u9694\u5f00\u5373\u53ef\u3002<\/p>\n
ps: \u591a\u4e2a\u96c6\u7fa4\uff0c\u5728application.yml<\/code>\u518d\u5b9a\u4e49\u4e00\u7ec4\u914d\u7f6e\uff0c\u5728ESConfig\u4e2d\u521b\u5efa\u4e24\u4e2aname\uff0c\u4e0d\u540c\u7684RestHighLevelClient Bean<\/code><\/p>\n","protected":false},"excerpt":{"rendered":"
Java High Level REST Client\u662f\u76ee\u524d\u5b98\u65b9\u63a8\u8350\u4f7f\u7528\u7684\u5ba2\u6237\u7aef\uff0cElasticsearch  […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[301],"tags":[],"class_list":["post-1385","post","type-post","status-publish","format-standard","hentry","category-elasticsearch"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1385","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1385"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1385\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1385"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1385"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1385"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}