1、导入依赖

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.4.2</version>
</dependency>

1.1、解决与SpringBoot自带依赖的冲突

<elasticsearch.version>7.4.2</elasticsearch.version>

2、编写配置、容器中注入RestHighLevelClient

import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.context.annotation.Bean;
@SpringBootConfiguration
public class GulimallElasticSearchConfig {
    @Bean
    public RestHighLevelClient esRestClient() {
        RestClientBuilder builder = null;
        builder = RestClient.builder(new HttpHost("192.168.56.10", 9200, "http"));
        RestHighLevelClient client = new RestHighLevelClient(builder);
        return client;
    }
}

3、请求拦截设置

public static final RequestOptions COMMON_OPTIONS;
static {
    RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder();
    // builder.addHeader("Authorization", "Bearer " + TOKEN);
    // builder.setHttpAsyncResponseConsumerFactory(
    //         new HttpAsyncResponseConsumerFactory
    //                 .HeapBufferedResponseConsumerFactory(30 * 1024 * 1024 * 1024));
    COMMON_OPTIONS = builder.build();
}

<properties>
    <java.version>1.8</java.version>
    <elasticsearch.version>7.12.1</elasticsearch.version>
</properties>
<dependencies>
    <!--elasticsearch依赖包-->
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>7.12.1</version>
    </dependency>
</dependencies>

查询的基本步骤是：

    @Test
    void testMatchAllHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.matchAllQuery());
        // 3.发起请求
        testFindHotelIndex(request);
    }

    @Test
    void tesMatchHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.matchQuery("all","如家"));
        // 3.发起请求
        testFindHotelIndex(request);
    }

    
    /**
     * @description ES通用数据查询
     * @param request:
     */
    public void testFindHotelIndex(SearchRequest request) throws IOException {
        // 3.发起请求
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        //System.out.println(response);

        //4.解析结果
        SearchHits hits = response.getHits();
        //4.1查询总条数
        long value = hits.getTotalHits().value;
        System.out.println("es搜索到:" + value + "条数据");
        //4.2查询的结果数组
        SearchHit[] hitsHits = hits.getHits();

        for (SearchHit e : hitsHits) {
            //4.3 得到source
            String json = e.getSourceAsString();
            //4.4 打印
            System.out.println("json = " + json);

            HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
            System.out.println("hotelDoc = " + hotelDoc.toString());
        }
    }

其它查询变化不大

    private RestHighLevelClient client;

    @BeforeEach
    void setUp() {
        this.client = new RestHighLevelClient(RestClient.builder(
           HttpHost.create("http://192.168.2.199:9200")
        ));
    }

    @AfterEach
    void tearDown() throws IOException {
        this.client.close();
    }

    @Test
    void testClient() {
        System.out.println(client);
    }

    /**
     * @description matchAll 查询所有
     */
    @Test
    void testMatchAllHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.matchAllQuery());
        // 3.发起请求
        testFindHotelIndex(request);
    }
    /**
     * @description  multiMatch多字段查询
     */
    @Test
    void testMultiMatchHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.multiMatchQuery("如家","name","business","brand"));
        // 3.发起请求
        testFindHotelIndex(request);
    }

    /**
     * @description match 单字段查询
     */
    @Test
    void tesMatchHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.matchQuery("all","如家"));
        // 3.发起请求
        testFindHotelIndex(request);
    }


    /**
     * @description 精确查询常见的有term查询和range查询，同样利用QueryBuilders实现
     * term 词条查询
     * range 范围查询
     */
    @Test
    void testTermHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.termQuery("city","上海"));
        // 3.发起请求
        testFindHotelIndex(request);
    }

    /**
     * @description 精确查询常见的有term查询和range查询，同样利用QueryBuilders实现
     * term 词条查询
     * range 范围查询
     */
    @Test
    void testRangeHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.rangeQuery("price").gte(100).lte(500));
        // 3.发起请求
        testFindHotelIndex(request);
    }

    /**
     * @description DSL查询语法-bool查询 复合查询
     */
    @Test
    void testBoolHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        // 2.1创建布尔查询
        BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
        //2.2 添加must条件 2.3添加filter条件
        boolQuery.must(QueryBuilders.termQuery("city", "上海"))
        .filter(QueryBuilders.rangeQuery("price").lte(600));
        //boolQuery.filter(QueryBuilders.rangeQuery("price").lte(250));
        request.source().query(boolQuery);
        // 3.发起请求
        testFindHotelIndex(request);
    }


    /**
     * @description Sort size from分页查询
     */
    @Test
    void testSortHotelIndex() throws IOException {
        int page = 1,size = 5;
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.matchAllQuery())
        .sort("price", SortOrder.ASC).from((page-1)*size).size(size);
        // 3.发起请求
        testFindHotelIndex(request);
    }

    /**
     * @description 高亮显示
     * term 词条查询
     * range 范围查询
     */
    @Test
    void testHighLightHotelIndex() throws IOException {
        // 1.创建Request对象
        SearchRequest request = new SearchRequest("hotel");
        // 2.准备DSL
        request.source().query(QueryBuilders.termQuery("city","上海"));
        //2.2 高亮查询
        request.source().highlighter(new HighlightBuilder().field("name").
        requireFieldMatch(false));
        // 3.发起请求
        testFindHotelIndex(request);
    }


   /**
     * @description ES通用数据查询
     * @param request:
     */
    public void testFindHotelIndex(SearchRequest request) throws IOException {
        // 3.发起请求
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        //System.out.println(response);

        //4.解析结果
        SearchHits hits = response.getHits();
        //4.1查询总条数
        long value = hits.getTotalHits().value;
        System.out.println("es搜索到:" + value + "条数据");
        //4.2查询的结果数组
        SearchHit[] hitsHits = hits.getHits();

        for (SearchHit e : hitsHits) {
            //4.3 得到source
            String json = e.getSourceAsString();
            //4.4 打印
            //System.out.println("json = " + json);
            //反序列化
            HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
            //获取高亮结果
            Map<String, HighlightField> highlightFields = e.getHighlightFields();
            if(!CollectionUtils.isEmpty(highlightFields)){
                //根据字段名获取高亮结果
                HighlightField highlightField = highlightFields.get("name");
                if (highlightField != null) {
                    //获取高亮值
                    String name  = highlightField.getFragments()[0].string();
                    //覆盖高亮结果
                    hotelDoc.setName(name);
                }
            }
            System.out.println("hotelDoc = " + hotelDoc.toString());
        }
    }

算法控制实现（广告排名靠前）

         //2.算法控制
        FunctionScoreQueryBuilder functionScoreQueryBuilder =
                QueryBuilders.functionScoreQuery(
                //原始数据查询，相关性算分的查询
                boolQueryBuilder, new FunctionScoreQueryBuilder.FilterFunctionBuilder[]{
                        //其中一个function score 元素
                        new FunctionScoreQueryBuilder.FilterFunctionBuilder(
                                //过滤条件
                                QueryBuilders.termQuery("isAD", true),
                                //算分函数
                                ScoreFunctionBuilders.weightFactorFunction(10)
                        )
                });
        request.source().query(functionScoreQueryBuilder);

readm-data-elasticsearch(轻量级elasticsearch restClient方式连接框架)
(spring-data团队暂时还没有兼容 本框架提供临时解决方案)

项目地址：https://github.com/readmlll/readm-data-elasticsearch

readm-data-elasticsearch(轻量级elasticsearch restClient方式连接框架)

轻量级elasticsearch restClient方式连接框架/阿里云elasticsearch连接框架

（实测阿里云es 6.7.0没问题，注意开启公网访问，用户名密码，以及设置好白名单）

基于spring,(spring-data-es部分注解)、elasticsearch高低版本client

封装的rest版本es客户端. 仿照spring-data 一贯的使用方式，只需少量代码即可转换transport连接方式到restClient连接

实现全部ElasticsearchRepository接口

优点:

目前最新spring-data-es 是3.1.0 Elasticsearch模板还是不支持restClient连接 （据说3.2.0 会支持）

使用本框架 小项目，轻量级使用es的项目，快速方便的转换transport连接方式到restClient连接，还是使用spring-data-es的习惯，一套代码两种方式连接方式可跑。

我自己的是从自己搭建的es迁移到阿里云es 6.7.0 ，阿里云不支持transport 常用操作的封装，创建文档，查询总数，批量增加修改，批量删除，高亮显示

缺点：

自由度不够，更多属性需要自己修改源码。

于spring-data-es不同点总结： 1.实体对象需要继承EsEntity，必须有id字段且其为string类型 且该字段需要标注@Field注解。 2.仓库对象 不再使用继承接口，需要继承EsRepository类。 3.没有动态生成方法。 但支持ElasticsearchRepository所有接口声明的方法

关于反射的冗余：

本来是想写工具类的，所以EsRestClient有反射代码的冗余 介意的话自己修改。

有点功能洁癖写着写着 还是当demo级别框架写 我自己是使用编译jar包 在别的项目中引入本"demo框架" 当做正常框架使用。 你可以抽离代码放到你的项目中，也可以选择和我一样编译jar，引入依赖。 我会在github上提供一份编译好的jar

本框架主要类目录结构 (详细目录结构在下方)

项目示例和框架源码目录结构:

common_parent为框架父级总管理项目 data为次级管理项目 es-rest为框架项目

paper_site为 使用本框架示例 打开idea编译好common_parent项目 安装jar到本地

​ 再打开paper_site项目(添加好依赖) ​ 填写好yml配置信息 运行readm.paper.PaperApplicationTests.contextLoads 测试方法， ​ 即可自动创建es文档 和相关测试代码 (注意打开相关注释等等)

文档对象声明 和 其字段声明

仓库对象定义

测试仓库方法