注解式elasticsearch+SpringBoot（附分布式配置）

红太狼 2023-06-21 11:25 3阅读 0赞

前言：以前使用的是Rest High Level Client客户端，使用起来一大堆的类相互嵌套，特别是agg操作，代码十分惨烈。

架构：使用方式与mybatis类似，采用xml的形式，将dsl与代码分离。示例用了swagger2和lombok。

需知：必须学会DSL语法（看半小时差不多就会了吧）。

--------------------

依赖：

<dependency>
                <groupId>com.bbossgroups.plugins</groupId>
                <artifactId>bboss-elasticsearch-spring-boot-starter</artifactId>
                <version>5.9.5</version>
            </dependency>

配置：

server:
      port: 3000
    spring:
      datasource:
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://xxxxxxxxxxxxx/xxxxx?useUnicode=true&characterEncoding=utf-8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=Asia/Shanghai
        username: root
        password: **********
      #      type: com.alibaba.druid.pool.DruidDataSource
      elasticsearch:
        bboss:
          elasticUser: elastic
          elasticPassword: changeme
          elasticsearch:
            rest:
              hostNames: xxx.xxx.xxx.xxx:9200
              ##hostNames: 192.168.8.25:9200,192.168.8.26:9200,192.168.8.27:9200  ##集群地址配置
            dateFormat: yyyy.MM.dd
            timeZone: Asia/Shanghai
            ttl: 2d
            showTemplate: true
            discoverHost: false
          dslfile:
            refreshInterval: -1
          http:
            timeoutConnection: 5000
            timeoutSocket: 5000
            connectionRequestTimeout: 5000
            retryTime: 1
            maxLineLength: -1
            maxHeaderCount: 200
            maxTotal: 400
            defaultMaxPerRoute: 200
            soReuseAddress: false
            soKeepAlive: false
            timeToLive: 3600000
            keepAlive: 3600000
            keystore:
            keyPassword:
            hostnameVerifier:

使用示例：

实体类：

import com.frameworkset.orm.annotation.ESId;
    import lombok.AllArgsConstructor;
    import lombok.Builder;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    /**
     * TODO
     *
     * @author sunziwen
     * @version 1.0
     * @date 2019/12/12 14:53
     **/
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    @Builder
    public class Person{
        @ESId
        private Integer personId;
        private String name;
        private Integer age;
        private String introduction;
    }

测试：

package com.example.layer.controller;
    
    import com.example.layer.entity.Person;
    import io.swagger.annotations.ApiOperation;
    import org.frameworkset.elasticsearch.boot.BBossESStarter;
    import org.frameworkset.elasticsearch.client.ClientInterface;
    import org.frameworkset.elasticsearch.entity.ESDatas;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.ArrayList;
    import java.util.HashMap;
    
    /**
     * TODO
     *
     * @author sunziwen
     * @version 1.0
     * @date 2019/12/12 13:32
     **/
    @RestController
    public class TestController {
        private final BBossESStarter bBossESStarter;
    
        public TestController(BBossESStarter bBossESStarter) {
            this.bBossESStarter = bBossESStarter;
        }
    
        @PostMapping("test_create")
        @ApiOperation("创建索引")
        public Object create() {
            ClientInterface restClient = bBossESStarter.getConfigRestClient("elasticsearch/person.xml");
            return restClient.createIndiceMapping("person", "createPersonIndice");
        }
    
        @PostMapping("test_add")
        @ApiOperation("添加文档")
        public Object add() {
            ClientInterface restClient = bBossESStarter.getRestClient();
            Person person = Person.builder()
                                  .personId(-1)
                                  .name("张三丰")
                                  .age(100)
                                  .introduction("武当创始人")
                                  .build();
            return restClient.addDocument("person", "person", person, "refresh");
        }
    
        @PostMapping("test_adds")
        @ApiOperation("批量添加文档")
        public Object adds() {
            ClientInterface restClient = bBossESStarter.getRestClient();
            ArrayList<Person> people = new ArrayList<>();
            for (int i = 0; i < 1000; i++) {
                Person person = Person.builder()
                                      .personId(i)
                                      .name("张三丰" + i)
                                      .age(100 + i * 2)
                                      .introduction("武当创始人" + i * 3)
                                      .build();
                people.add(person);
            }
            return restClient.addDocuments("person", "person", people, "refresh");
        }
    
        @PostMapping("test_getById")
        @ApiOperation("Id获取文档")
        public Object getById(@RequestParam Integer id) {
            ClientInterface restClient = bBossESStarter.getRestClient();
            return restClient.getDocument("person", "person", id + "", Person.class);
        }
    
        @PostMapping("test_search")
        @ApiOperation("检索")
        public Object search() {
            ClientInterface restClient = bBossESStarter.getConfigRestClient("elasticsearch/person.xml");
            HashMap<String, Object> params = new HashMap<>(2);
            params.put("min", 100);
            params.put("max", 300);
            params.put("size", 100);
            ESDatas<Person> searchRange = restClient.searchList("person/_search", "searchRange", params, Person.class);
            return searchRange;
        }
    }

XML：

分布式配置：

这里为了方便懒得建分布式项目了。在启动时从分布式配置中心拿到相应的配置后...(这里我直接写死了)

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlbnhpbmdjaGVu_size_16_color_FFFFFF_t_70][]

有疑问家sunziwen3366备注csdn

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlbnhpbmdjaGVu_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191212164250711.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlbnhpbmdjaGVu,size_16,color_FFFFFF,t_70