一起来学ElasticSearch之整合SpringBoot(一)

前言

目前正在出一个Es专题系列教程, 篇幅会较多, 喜欢的话，给个重视❤️ ~

本节来给咱们讲一下在Springboot中怎么整合es~

本文偏实战一些，为了便利演示,本节示例沿袭上节索引,好了, 废话不多说直接开整吧~

项目建立

老规矩，先建maven项目,下面是我的pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>org.example</groupId>
    <artifactId>springboot-es-all</artifactId>
    <version>1.0-SNAPSHOT</version>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
    </parent>
    <dependencies>
        <!--test-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <!--ElasticSearch 客户端依靠-->
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
            <version>7.8.0</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>7.8.0</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.8.0</version>
        </dependency>
        <!--Hutool依靠-->
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.8.4</version>
        </dependency>
        <!--fast-json-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.58</version>
        </dependency>
        <dependency>
            <groupId> org.slf4j </groupId>
            <artifactId> slf4j-api </artifactId>
            <version> 1.6.4 </version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-simple</artifactId>
            <version>1.7.25</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.1.3.RELEASE</version>
            </plugin>
        </plugins>
    </build>
</project>

这儿我运用的是elasticsearch-rest-high-level-client官方客户端,主张咱们尽量用官方的，由于随着es的不断升级，许多api都过时了，假如你运用spring-boot-starter-data-elasticsearch这个要依靠社区去维护,许多新特性你没法运用到,也会存在安全性问题。

配置客户端

发动类:

@SpringBootApplication
public class EsStudyApplication {
    public static void main(String[] args) {
        SpringApplication.run(EsStudyApplication.class, args);
    }
}

配置文件 application.yml:

server:
  port: 9000
elasticsearch:
  host: 0.0.0.0
  port: 9200
  username:
  password:

客户端配置 config.EsClientConfig:

@Configuration
public class EsClientConfig {
    @Value("${elasticsearch.host}")
    private String host;
    @Value("${elasticsearch.port}")
    private int port;
    @Value("${elasticsearch.username}")
    private String userName;
    @Value("${elasticsearch.password}")
    private String password;
    @Bean
    public RestHighLevelClient restHighLevelClient() {
        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(userName, password));
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost( host, port, "http")).setHttpClientConfigCallback(httpClientBuilder -> {
                    httpClientBuilder.setMaxConnTotal(500);
                    httpClientBuilder.setMaxConnPerRoute(300);
                    return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
                })
        );
        return restHighLevelClient;
    }
}

然后客户端咱们就配好了，客户端的配置其实还有许多，感兴趣的同学自行查阅。后续运用的时分，直接导入RestHighLevelClient实例就好了

接着发动它，假如操控没有报错，说明配置没啥问题了， 记得要敞开es服务~

索引API初探 & Index API

下面咱们写一点测试用例，来验证咱们是否能够操作es，为了便利演示，这儿直接运用SpringBootTest来测试，咱们平常在写springboot项目，类测试的时分也能够这么做

ping

新建api.IndexApi,调用ping()办法来测试是否链接成功:

@Slf4j
@SpringBootTest
public class IndexApi {
    /**
     * es 索引
     */
    public static final String index = "study";
    @Autowired
    private RestHighLevelClient client;
    @Test
    public void ping() throws IOException {
        if(client.ping(RequestOptions.DEFAULT)) {
            log.info("链接成功");
        }else {
            log.info("链接失败 !");
        }
    }
}    

点击IndexApi左上角的绿色箭头发动测试用例, 假如报错，测验增加以下注解

@RunWith(SpringRunner.class)
@SpringBootTest(classes = { EsStudyApplication.class })
public class IndexApi {....}

回来:

链接成功

说明客户端与es服务端是通的

创立索引 & create

经过前面的学习，有了一定的根底之后，回到代码中其实便是调调办法，由于你知道了这个代码的逻辑做了什么操作。下面来看下怎么创立索引：

/**
     * 创立索引
     */
    @Test
    public void createIndex() throws IOException {
        CreateIndexRequest request = new CreateIndexRequest(index);
        CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
        log.info("创立索引 ===> "+ JSONObject.toJSONString(createIndexResponse)); // 创立索引 ===> {"acknowledged":true,"fragment":false,"shardsAcknowledged":true}
    }

咱们能够回来到kibana中查看索引是否被创立，从而验证代码履行是否成功

增加别名:

// alias
request.alias(new Alias("study_alias"));

索引设置settings:

// index settings
request.settings(
        Settings.builder()
                .put("index.number_of_shards", 3)
                .put("index.number_of_replicas", 2)
);

索引映射mapping:

 // index mappings
//        {
//            "mapping": {
//            "_doc": {
//                "properties": {
//                    "name": {
//                        "type": "text"
//                    }
//                }
//            }
//        }
//        }
XContentBuilder builder = XContentFactory.jsonBuilder();
builder.startObject();
{
    builder.startObject("properties");
    {
        builder.startObject("name");
        {
            builder.field("type", "text");
        }
        builder.endObject();
    }
    builder.endObject();
}
builder.endObject();
request.mapping(builder);

设置恳求超时时间:

// 恳求设置
request.setTimeout(TimeValue.timeValueMinutes(1));

索引是否存在 & exist

 /**
    * 判断索引是否存在
    * @throws IOException
    */
@Test
public void existIndex() throws IOException {
    GetIndexRequest request = new GetIndexRequest(index);
    boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
    log.info("索引{}存在 ===> {}", index, exists);
}

删去索引

 /**
    * 删去索引
    * @throws IOException
    */
@Test
public void delIndex() throws IOException {
    DeleteIndexRequest request = new DeleteIndexRequest(index);
    AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
    log.info("删去索引 ===> {}", JSONObject.toJSONString(delete)); // 删去索引 ===> {"acknowledged":true,"fragment":false}
}

结束语

下节带咱们看下文档操作相关的api，也是咱们事务中运用最多的api~

本着把自己知道的都告知咱们，假如本文对您有所帮助，点赞+重视鼓舞一下呗~

相关文章

• 利用docker建立es集群
• 一起来学ElasticSearch(一)
• 一起来学ElasticSearch(二)
• 一起来学ElasticSearch(三)
• 一起来学ElasticSearch(四)
• 一起来学ElasticSearch(五)
• 一起来学ElasticSearch(六)
• 一起来学ElasticSearch(七)
• 一起来学ElasticSearch(八)
• 一起来学ElasticSearch(九)
• 一起来学ElasticSearch(十)

项目源码(源码已更新 欢迎star⭐️)

• springboot-es-all: https://github.com/qiuChengleiy/springboot-es-all

往期并发编程内容推荐

• Java多线程专题之线程与进程概述
• Java多线程专题之线程类和接口入门
• Java多线程专题之进阶学习Thread(含源码剖析)
• Java多线程专题之Callable、Future与FutureTask(含源码剖析)
• 面试官: 有了解过线程组和线程优先级吗
• 面试官: 说一下线程的生命周期过程
• 面试官: 说一下线程间的通讯
• 面试官: 说一下Java的同享内存模型
• 面试官: 有了解过指令重排吗，什么是happens-before
• 面试官: 有了解过volatile关键字吗 说说看
• 面试官: 有了解过Synchronized吗 说说看
• Java多线程专题之Lock锁的运用
• 面试官: 有了解过ReentrantLock的底层完成吗？说说看
• 面试官: 有了解过CAS和原子操作吗？说说看
• Java多线程专题之线程池的基本运用
• 面试官: 有了解过线程池的作业原理吗？说说看
• 面试官: 线程池是怎么做到线程复用的？有了解过吗，说说看
• 面试官: 堵塞行列有了解过吗?说说看
• 面试官: 堵塞行列的底层完成有了解过吗? 说说看
• 面试官: 同步容器和并发容器有用过吗? 说说看
• 面试官: CopyOnWrite容器有了解过吗? 说说看
• 面试官: Semaphore在项目中有运用过吗？说说看(源码剖析)
• 面试官: Exchanger在项目中有运用过吗？说说看(源码剖析)
• 面试官: CountDownLatch有了解过吗？说说看(源码剖析)
• 面试官: CyclicBarrier有了解过吗？说说看(源码剖析)
• 面试官: Phaser有了解过吗？说说看
• 面试官: Fork/Join 有了解过吗？说说看（含源码剖析）
• 面试官: Stream并行流有了解过吗？说说看

博客(阅览体会较佳)

• 我的博客(阅览体会较佳)

• 地址: github.com/qiuChenglei…

推荐 SpringBoot & SpringCloud (源码已更新 欢迎star⭐️)

• springboot-all

• 地址: github.com/qiuChenglei…

• SpringBoot系列教程合集

• 一起来学SpringCloud合集

项目源码(源码已更新 欢迎star⭐️)

• spring-cloud-all

• SpringCloud整合 Oauth2+Gateway+Jwt+Nacos 完成授权码模式的服务认证(一)

• SpringCloud整合 Oauth2+Gateway+Jwt+Nacos 完成授权码模式的服务认证(二)