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

---

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

---

一、SpringBoot 整合

创建一个模块。。

只选择 web 即可

导入依赖

将服务加入到注册中心

二、配置

在 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;
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

三、测试

参照官方文档：

@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) {}
	}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

阿里云搭建好的架构：