ES客户端spring-boot-starter-data-elasticsearch

2023-07-10 287

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

云原生网关 MSE Higress，422元/月

服务治理 MSE Sentinel/OpenSergo，Agent数量不受限

注册配置 MSE Nacos/ZooKeeper，118元/月

简介： SpringDataElasticsearch：ElasticsearchRepositoryElasticsearchRestTemplateElasticsearchOperations

ES客户端分类

Es-Server提供RESTFul-Api，客户端通过发起http请求，调用api实现索引库的管理，数据的交换，server端状态的监控......

官方java客户端：

<dependency>
  <groupId>org.elasticsearch.client</groupId>
  <artifactId>elasticsearch-rest-client</artifactId>
  <version>7.15.2</version>
</dependency>

SpringDataElasticSearch：
~~~
org.springframework.boot
spring-boot-starter-data-elasticsearch

SpringDataElasticSearch继承了官方客户端elasticsearch-rest-client

![](https://img2020.cnblogs.com/blog/718864/202112/718864-20211215153439146-564044069.png)

![](https://img2020.cnblogs.com/blog/718864/202112/718864-20211215153455295-432675008.png)



* Elasticsearch.Net
* devtool：kibana
* HttpClient
* postman
* ......


> 特殊的客户端，节点客户端（NodeClient），将自己作为Es-server集群的节点。

# SpringDataElasticsearch

* ElasticsearchRepository
* ElasticsearchRestTemplate
* ElasticsearchOperations

ElasticsearchRestTemplate继承了ElasticsearchOperations，一般开发中都是基于ElasticsearchRestTemplate来访问ES服务端。

![](https://img2020.cnblogs.com/blog/718864/202112/718864-20211215153503528-1936136269.png)


#  ElasticsearchRestTemplate

## 环境
* ES-Server：7.14.0
* SpringBoot：2.5.3
* spring-boot-starter-data-elasticsearch：2.5.3
* Spring Data Elasticsearch: 4.2.3
* Elasticsearch Client used: 7.12.1
* Elasticsearch cluster: 7.14.0
* 测试索引库名称：vehicle
* 索引库数据结构：

{
"_index": "vehicle",
"_type": "_doc",
"_id": "19771755968",
"_version": 1,
"_score": 1.0,
"_source": {
"id": 19771755968,
"crossing_id": 30474,
"plate_number": "沪D86447",
"plate_color": "黄色",
"is_valid": 1,
"snap_time": "2021-08-29 08:00:00",
"create_time": "2021-08-29 08:07:51",
"lane_number": 1,
"crossing_timestamp": 1630195671.0
}
}


* 索引库映射：

{
"vehicle": {
"mappings": {
"properties": {
"create_time": {
"type": "date",
"format": "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
},
"crossing_id": {
"type": "keyword"
},
"crossing_timestamp": {
"type": "long"
},
"id": {
"type": "keyword"
},
"is_valid": {
"type": "keyword"
},
"lane_number": {
"type": "keyword"
},
"plate_color": {
"type": "keyword"
},
"plate_number": {
"type": "keyword"
},
"snap_time": {
"type": "date",
"format": "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
}
}
}
}
}


## 引入pom依赖

org.springframework.boot
spring-boot-starter-data-elasticsearch

com.alibaba
fastjson
1.2.71

org.springframework.boot
spring-boot-starter-web

org.projectlombok
lombok
true


## 配置ES-Server地址
application.yml

spring:
elasticsearch:
rest:
uris: http://192.168.1.149:19200


## 定义model

import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import lombok.experimental.Accessors;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.DateFormat;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
import java.io.Serializable;
import java.time.LocalDateTime;

@Accessors(chain = true)
@Data
@Document(indexName = "vehicle")
public class Vehicle implements Serializable {
@Id
private String id;
@Field("plate_number")
private String plateNumber;
@Field("plate_color")
private String plateColor;
@Field("is_valid")
private Integer valid;
@Field("lane_number")
private Integer laneNumber;
@Field(name = "create_time", type = FieldType.Date, format = DateFormat.custom, pattern = "uuuu-MM-dd HH:mm:ss")
private LocalDateTime createTime;
@Field("crossing_id")
private Long crossingId;
@Field("crossing_timestamp")
private Long crossingTimestamp;
private Long sum;
}


## 根据id查询