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

大家好，又见面了，我是你们的朋友全栈君。

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

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

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

依赖：

代码语言：javascript复制

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

配置：

代码语言：javascript复制

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:

使用示例：

实体类：

代码语言：javascript复制

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;
}

测试：

代码语言：javascript复制

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：

代码语言：javascript复制

<properties>
<property name="createPersonIndice">
<![CDATA[{
"settings": {
"number_of_shards": 1,
"index.refresh_interval": "5s"
},
"mappings": {
"person": {
"properties": {
"id":{
"type":"long"
},
"name": {
"type": "keyword"
},
"age":{
"type":"long"
},
"introduction": {
"type": "text"
}
}
}
}
}]]>
</property>
<property name="searchRange">
<![CDATA[{
"query": {
"bool": {
"filter": [
{
"range": {
"age": {
"gte": #[min],
"lt": #[max]
}
}
}
]
}
},
"size":#[size]
}]]>
</property>
</properties>

分布式配置：

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

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/215466.html原文链接：https://javaforall.cn

分布式 https 网络安全 xml

0 人点赞