谷粒商城高级篇 (四) --------- Elasticsearch-Rest-Client

Bertha 。 2024-04-05 06:05 89阅读 0赞

#### 目录 ####

*  一、SpringBoot 整合
 *  二、配置
 *  三、测试

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

**1、9300：TCP**  
spring-data-elasticsearch:transport-api.jar；

*  springboot 版本不同， transport-api.jar 不同，不能适配 es 版本
 *  7.x 已经不建议使用，8 以后就要废弃

**2、9200：HTTP**

*  JestClient：非官方，更新慢
 *  RestTemplate：模拟发 HTTP 请求，ES 很多操作需要自己封装，麻烦
 *  HttpClient：同上
 *  Elasticsearch-Rest-Client：官方 RestClient，封装了 ES 操作，API 层次分明，上手简单最终选择

Elasticsearch-Rest-Client（elasticsearch-rest-high-level-client）[https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/java-rest-high.html][https_www.elastic.co_guide_en_elasticsearch_client_java-rest_current_java-rest-high.html]

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

## 一、SpringBoot 整合 ##

创建一个模块。。  
![在这里插入图片描述][e60f7b4f754a4d7a9c9de1c0701085dd.png]  
只选择 web 即可  
![在这里插入图片描述][ba33ff5dd876476f843548bae2534453.png]  
导入依赖

![在这里插入图片描述][d3ce12b7c68f4801b4cb7391c64d49ee.png]  
将服务加入到注册中心

![在这里插入图片描述][129fb059f6644fc384294dc2cd0c79cc.png]  
![在这里插入图片描述][77e41f0b28ae43bda184bc6eb89181b6.png]

## 二、配置 ##

在 config 包下新建 ElasticSearchConfig 配置文件

package com.fancy.gulimall.search.config;
    
    import org.apache.http.HttpHost;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class ElasticSearchConfig {
        
    
        @Bean
        public RestHighLevelClient esRestClient() {
        
            RestHighLevelClient client = new RestHighLevelClient(
                    RestClient.builder(
                            new HttpHost("192.168.38.130", 9200, "http")
                    )
            );
            return client;
        }
    }

## 三、测试 ##

参照官方文档：

@Test
    void test1() throws IOException {
        
    	Product product = new Product();
    	product.setSpuName("华为");
    	product.setId(10L);
    	IndexRequest request = new IndexRequest("product").id("20").source("spuName","华为","id",20L);
    	try {
        
    		IndexResponse response = client.index(request, RequestOptions.DEFAULT);
    		System.out.println(request.toString());
    		IndexResponse response2 = client.index(request, RequestOptions.DEFAULT);
    	} catch (ElasticsearchException e) {
        
    		if (e.status() == RestStatus.CONFLICT) {
        }
    	}
    }

阿里云搭建好的架构：

![在这里插入图片描述][32a3f470dcf9428a9060023819b1fbc9.png]

[https_www.elastic.co_guide_en_elasticsearch_client_java-rest_current_java-rest-high.html]: https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/java-rest-high.html
[e60f7b4f754a4d7a9c9de1c0701085dd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/04/3856e3d24f604cdaa2399a49e8d12722.png
[ba33ff5dd876476f843548bae2534453.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/04/fc78541e0636419c9edf8c7df0206119.png
[d3ce12b7c68f4801b4cb7391c64d49ee.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/04/939c984a3f9040baa0033ad107f70153.png
[129fb059f6644fc384294dc2cd0c79cc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/04/72e3c3c1d5d846adb15d38df6b49633e.png
[77e41f0b28ae43bda184bc6eb89181b6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/04/8dd53091f82a40e4a35a76dc4969d8fb.png
[32a3f470dcf9428a9060023819b1fbc9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/04/6e55cc81b51041e5b70412ad6dc05c9c.png