SpingBoot：整合Elasticsearch7.2.0

spring boot 2.1.x整合elasticsearch最新版的一处问题
新版本的spring boot 2的spring-boot-starter-data-elasticsearch中支持的elasticsearch版本是2.x，但elasticsearch实际上已经发展到7.2.x版本了，为了更好的使用elasticsearch的新特性，所以弃用了spring-boot-starter-data-elasticsearch依赖，而改为直接使用spring-data-elasticsearch，以便启用对新版本支持，目前的版本对应关系如下

elasticsearch(es)有两种连接方式：transport、rest。transport通过tcp方式访问es(只支持java),rest方式通过http api 访问es(没有语言限制)。
es官方建议使用rest方式, transport 在7.0版本中不建议使用，在8.x的版本中废弃。

引入依赖：

        <dependency>
            <groupid>org.elasticsearch</groupid>
            <artifactid>elasticsearch</artifactid>
            <version>${elasticsearch.version}</version>
        </dependency>
        <dependency>
            <groupid>org.elasticsearch.client</groupid>
            <artifactid>elasticsearch-rest-client</artifactid>
            <version>${elasticsearch.version}</version>
        </dependency>
        <dependency>
            <groupid>org.elasticsearch.client</groupid>
            <artifactid>elasticsearch-rest-high-level-client</artifactid>
            <version>${elasticsearch.version}</version>
        </dependency>

application.yml配置：

elasticsearch:
  ip: 192.168.52.132:9200

客户端连接配置类

package com.dc.elastic.configuration;

import org.apache.commons.lang3.stringutils;
import org.apache.http.httphost;
import org.apache.http.client.config.requestconfig;
import org.elasticsearch.client.restclient;
import org.elasticsearch.client.restclientbuilder;
import org.elasticsearch.client.resthighlevelclient;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.beans.factory.annotation.value;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;

import java.util.arrays;
import java.util.objects;

/**
 * 描述: 连接客户端
 *
 * @author leo
 * @create 2019-08-25 13:22
 */
@configuration
public class elasticsearchrestclient
{
    /**
     * 超时时间设为5分钟
     */
    private static final int time_out = 5 * 60 * 1000;
    private static final int address_length = 2;
    private static final string http_scheme = "http";

    @value("${elasticsearch.ip}")
    string[] ipaddress;

    @bean
    public restclientbuilder restclientbuilder() {
        system.err.println(ipaddress);
        httphost[] hosts = arrays.stream(ipaddress)
                .map(this::makehttphost)
                .filter(objects::nonnull)
                .toarray(httphost[]::new);
        return restclient.builder(hosts);
    }

    @bean(name = "highlevelclient")
    public resthighlevelclient highlevelclient(@autowired restclientbuilder restclientbuilder) {
        restclientbuilder.setrequestconfigcallback(
                new restclientbuilder.requestconfigcallback() {
                    @override
                    public requestconfig.builder customizerequestconfig(
                            requestconfig.builder requestconfigbuilder) {
                        return requestconfigbuilder.setsockettimeout(time_out);
                    }
                });
        //todo 此处可以进行其它操作
        return new resthighlevelclient(restclientbuilder);
    }


    private httphost makehttphost(string s) {
        assert stringutils.isnotempty(s);
        string[] address = s.split(":");
        if (address.length == address_length) {
            string ip = address[0];
            int port = integer.parseint(address[1]);
            system.err.println(ip+"+"+port);
            return new httphost(ip, port, http_scheme);
        } else {
            return null;
        }
    }
}

测试controller

 @requestmapping("/test")
    public void test(@requestparam string keyword) {
        integer pageindex = 1;
        integer pagesize = 5;
        string indexname = "vw_ods";
        map<string, object> data = new hashmap<>();
        data.put("clearacctname", keyword);

        list<map<string, object>> result = new arraylist<map<string, object>>();
        searchrequest searchrequest = new searchrequest(indexname);
        // searchrequest.types(indexname);
        querybuilder(pageindex, pagesize, data, indexname, searchrequest);
        try {
            searchresponse response = highlevelclient.search(searchrequest, requestoptions.default);
            for (searchhit hit : response.gethits().gethits()) {
                map<string, object> map = hit.getsourceasmap();
                map.put("id", hit.getid());
                result.add(map);

                // 取高亮结果
                map<string, highlightfield> highlightfields = hit.gethighlightfields();
                highlightfield highlight = highlightfields.get("clearacctname");
                text[] fragments = highlight.fragments(); // 多值的字段会有多个值
                string fragmentstring = fragments[0].string();
                system.out.println("高亮：" + fragmentstring);
            }
            system.out.println("pageindex:" + pageindex);
            system.out.println("pagesize:" + pagesize);
            system.out.println(response.gethits().gettotalhits());
            system.out.println(result.size());
            for (map<string, object> map : result) {
                system.out.println(map.get("clearacctname"));
            }
        } catch (ioexception e) {
            e.printstacktrace();
        }
    }

    private void querybuilder(integer pageindex, integer pagesize, map<string, object> query, string indexname,
                              searchrequest searchrequest) {
        if (query != null && !query.keyset().isempty()) {
            searchsourcebuilder searchsourcebuilder = new searchsourcebuilder();
            if (pageindex != null && pagesize != null) {
                searchsourcebuilder.size(pagesize);
                if (pageindex <= 0) {
                    pageindex = 0;
                }
                searchsourcebuilder.from((pageindex - 1) * pagesize);
            }
            boolquerybuilder boolbuilder = querybuilders.boolquery();
            query.keyset().foreach(key -> {
                boolbuilder.must(querybuilders.matchquery(key, query.get(key)));

            });
            searchsourcebuilder.query(boolbuilder);

            highlightbuilder highlightbuilder = new highlightbuilder();
            highlightbuilder.field highlighttitle =
                    new highlightbuilder.field("title").pretags("<strong>").posttags("</strong>");
            highlighttitle.highlightertype("unified");
            highlightbuilder.field(highlighttitle);
            searchsourcebuilder.highlighter(highlightbuilder);

            searchrequest source = searchrequest.source(searchsourcebuilder);
        }
    }

官方文档：https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.2/java-rest-overview.html

作者：onlooker
来源：三无青年博客
原文：https://www.35youth.cn/712.html
版权声明：本文为博主原创文章，转载请附上博文链接！