三.SpringBoot整合Elasticsearch

谁践踏了优雅 2023-10-13 08:01 59阅读 0赞

### SpringBoot整合Elasticsearch ###

*  前言
 *  一.java调用es的方式和工具
 *  二.java集成Elasticsearch-Rest-Client
 *   *  1.引入pom
     *  2.导入版本不一致问题
     *  3.编写配置类
     *  4.测试类
     *   *  4.1 执行前
         *  4.2 执行后
     *  5.其他篇章

# 前言 #

我们整合es直接给es发请求就可以了，但是现在有很多方式去调用es的接口，那都有那些呢？

# 一.java调用es的方式和工具 #

<table> 
 <thead> 
  <tr> 
   <th>访问es端口</th> 
   <th>访问方式</th> 
   <th>使用工具</th> 
   <th>缺点</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>9300</td> 
   <td>TCP</td> 
   <td>transport-api.jar</td> 
   <td>不适配es版本，es 8.0之后弃用。</td> 
  </tr> 
  <tr> 
   <td>9200</td> 
   <td>HTTP</td> 
   <td>JestClient</td> 
   <td>非官方，对应es版本更新慢。</td> 
  </tr> 
  <tr> 
   <td>9200</td> 
   <td>HTTP</td> 
   <td>RestTemplate</td> 
   <td>模拟发送http请求，但是很多请求需要自己封装。</td> 
  </tr> 
  <tr> 
   <td>9200</td> 
   <td>HTTP</td> 
   <td>HttpClient</td> 
   <td>模拟发送http请求，但是很多请求需要自己封装。</td> 
  </tr> 
  <tr> 
   <td><strong>9200</strong></td> 
   <td><strong>HTTP</strong></td> 
   <td><strong>Elasticsearch-Rest-Client</strong></td> 
   <td><strong>官方RestClient，封装了es的操作，API层次分明，上手简单。</strong></td> 
  </tr> 
 </tbody> 
</table>

# 二.java集成Elasticsearch-Rest-Client #

[Elasticsearch-Rest-Client官方文档][Elasticsearch-Rest-Client]

## 1.引入pom ##

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

## 2.导入版本不一致问题 ##

> 比如你想导入 7.3.1版本的，但是你导入之后发现不是7.3.1版本的。  
> **原因：** 因为springboot默认对Elasticsearch版本进行了引入。

![在这里插入图片描述][2d86a81b9fc6492589453159bbf1e8e7.png]  
![在这里插入图片描述][9792dfa4ea854ff9ad73e42dbd489e8e.png]  
![在这里插入图片描述][3dc152195b7149f183c51f820d999a88.png]  
![在这里插入图片描述][026fe4c9e9aa4e7782131acd9301a146.png]

## 3.编写配置类 ##

@Configuration
    public class EsConfig {
        
    	
    	//发送请求时的请求设置项（全局通用）
        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();
        }
    	
    	//注入
        @Bean
        public RestHighLevelClient config(){
        
            RestClientBuilder builder = null;
            //es的ip、访问的端口号、网络协议
            builder = RestClient.builder(new HttpHost("127.0.0.1",9200,"http"));
            RestHighLevelClient client = new RestHighLevelClient(builder);
            return client;
        }
    }

## 4.测试类 ##

@SpringBootTest
    @RunWith(SpringRunner.class)
    public class test {
        
    
        @Autowired
        RestHighLevelClient restClient;
    
    	//测试从java保存数据到es
        @Test
        public void testEs() throws IOException {
        
           IndexRequest indexRequest = new IndexRequest("ikun");
            indexRequest.id("1");
            Kunkun kunkun = new Kunkun();
            kunkun.setJineng("唱跳rap篮球");
            kunkun.setName("小black子");
            //把对象转为json字符串
            String s = JSON.toJSONString(kunkun);
            //保存的数据
            indexRequest.source(s, XContentType.JSON);
            //执行保存的操作(同步操作,文档里面有写异步请求)
            IndexResponse index = restClient.index(indexRequest, EsConfig.COMMON_OPTIONS);
        }
    
        @Data
        class Kunkun {
        
            private String jineng;
            private String name;
        }
    }

### 4.1 执行前 ###

![在这里插入图片描述][39d14c1cb9624bbab2bbd8a0ae2fcf93.png]

### 4.2 执行后 ###

![在这里插入图片描述][2508d30766244155b100af0c1d241051.png]

## 5.其他篇章 ##

**[一.Elasticsearch快速入门及使用][.Elasticsearch]**

**[二.Elasticsearch进阶][.Elasticsearch 1]**

[Elasticsearch-Rest-Client]: https://www.elastic.co/guide/en/elasticsearch/client/index.html
[2d86a81b9fc6492589453159bbf1e8e7.png]: https://img-blog.csdnimg.cn/2d86a81b9fc6492589453159bbf1e8e7.png
[9792dfa4ea854ff9ad73e42dbd489e8e.png]: https://img-blog.csdnimg.cn/9792dfa4ea854ff9ad73e42dbd489e8e.png
[3dc152195b7149f183c51f820d999a88.png]: https://img-blog.csdnimg.cn/3dc152195b7149f183c51f820d999a88.png
[026fe4c9e9aa4e7782131acd9301a146.png]: https://img-blog.csdnimg.cn/026fe4c9e9aa4e7782131acd9301a146.png
[39d14c1cb9624bbab2bbd8a0ae2fcf93.png]: https://img-blog.csdnimg.cn/39d14c1cb9624bbab2bbd8a0ae2fcf93.png
[2508d30766244155b100af0c1d241051.png]: https://img-blog.csdnimg.cn/2508d30766244155b100af0c1d241051.png
[.Elasticsearch]: https://blog.csdn.net/twotwo22222/article/details/131191351
[.Elasticsearch 1]: https://blog.csdn.net/twotwo22222/article/details/131191411