ElasticSearch8.x和Java API Client

news2024/11/26 16:56:42

建议

建议直接阅读我的博客原文

10.4 Java API Client操作-索引库/文档

客户端更新

ES为不同语言提供了用于操作ES的客户端，截至2023年7月4日，根据官网Java REST Client已经被弃用，取而代之的是Java API Client，黑马的教程里都是环境是es7.12.1和RestClient，版本太旧了，我的笔记用es 8.8.1和Java API Client，但也会提供部分旧版本代码。ES官网也提供了兼容性支持，restclient7.17版本仍然可以操作es8.x版本。

API Client更新说明

image-20230704164100865

image-20230704164642426

为什么要抛弃High Level Rest：

  • 客户端"too heavy"，相关依赖超过 30 MB，且很多都是非必要相关的；api 暴露了很多服务器内部接口

  • 一致性差，仍需要大量的维护工作。

  • 客户端没有集成 json/object 类型映射，仍需要自己借助字节缓存区实现。

Java API Client最明显的特征：

  • 支持lambda表达式操作ES
  • 支持Builder建造者模式操作ES，链式代码具有较强可读性.
  • 应用程序类能够自动映射为Mapping.

可以浅浅感受下两者不同：

RestHighLevelClient：

image-20230705162855862

image-20230705163335206

导入本地项目

1.服务器mysql容器导入数据

# 本地sql文件上传到服务器
scp D:\...\tb_hotel.sql root@my_ip:/root/tmp 
# 复制文件到容器内
docker cp tmp/tb_hotel.sql mysql:/tmp/tb_hotel.sql
# 进入容器
docker exec -it mysql bash
mysql -u root -p
# 容器内执行sql
use my_db;
source /tmp/tb_hotel.sql
# 删除临时文件
docker exec -it mysql rm /tmp/tb_hotel.sql

2.导入hotel-demo

数据结构分析

  • 需要分词：type=text，并设置分词器
  • 不需要索引：index=false
  • 特殊数据类型：geo_point表示具体经纬度，geo_shape表示经纬范围，如1所示
  • 优化搜索，如2所示⭐
    • 多条件索引的效率低于单条件索引
    • "copy_to"属性可将当前字段copy到指定字段
    • 创建条件"all"，将多条件索引的条件都"copy_to"新条件"all"，达成单条件索引

image-20230704162905494

初始化JavaClient

1.导入es的Client依赖，这里要注意jackson-core版本，原因看这篇

<!--旧版本HLRC依赖-->
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <!--es7.17可以操作es8.x-->
    <version>7.17.4</version>
</dependency>

<!--新版本Java API Client依赖-->
 <dependency>
     <groupId>co.elastic.clients</groupId>
     <artifactId>elasticsearch-java</artifactId>
     <version>8.8.1</version>
</dependency>


<!--java api client需要有json对象映射库，springboot-web自带jackson-databind依赖，可以不引入-->
<!--
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.12.7.1</version>
    <exclusions>
        <exclusion>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
        </exclusion>
    </exclusions>
</dependency>
-->
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-core</artifactId>
    <version>2.12.0</version>
</dependency>
<!--如果报错找不到jakarta还需要引入如下依赖-->
<dependency>
     <groupId>jakarta.json</groupId>
     <artifactId>jakarta.json-api</artifactId>
     <version>2.0.1</version>
</dependency>

2.覆盖ES默认版本（Spring Boot默认ES版本7.6.2）

<properties>
    <java.version>1.8</java.version>
    <elasticsearch.version>8.8.1</elasticsearch.version>
</properties>

3.初始化Client

//旧版本RestHighLevelClient
@Bean
public RestHighLevelClient restHighLevelClient(){
    return new RestHighLevelClient(RestClient.builder(
        HttpHost.create("http://xx.xx.xx.xx:9200")
    ));
}
//新版本Java API Client
//新版版还支持创建安全连接，使用SSLContext
@Bean
public ElasticsearchClient elasticsearchClient(){
    //创建低级客户端，负责所有传输级问题：连接池、重试、节点发现等
    RestClient restClient = RestClient.builder(
        new HttpHost(IP,9200)).build();
    //使用Jackson映射器创建传输层，方便ES与应用程序类集成
    ElasticsearchTransport transport = new RestClientTransport(
        restClient,new JacksonJsonpMapper());
    //创建API 客户端
    //阻塞
    return new ElasticsearchClient(transport);
    //异步非阻塞
    //return new ElasticsearchAsyncClient(transport);
}

索引库

创建索引测试

@SpringBootTest
class HotelIndexTest {

    // private RestHighLevelClient client;

    private RestClient restClient;
    private ElasticsearchTransport transport;
    private ElasticsearchClient client;
    
    @Test
    void testCreateIndex() throws IOException {
        //准备Request，并指定index name和请求参数
        CreateIndexRequest request = CreateIndexRequest.of(builder ->
            builder.index("hotel")
                    .withJson(new StringReader(MAPPING_TEMPLATE))
        );
        //发送请求
        client.indices().create(request);
    }
    
    
    //官方还提供了其他方法创建mappings
    //mappings是字符串
    @Test
    void testCreateIndex1() throws IOException {
        JsonpMapper jsonpMapper = client._transport().jsonpMapper();
        //这里的MAPPING_TEST字符串只需要包含{"properties":{}}内容
        JsonParser parser = Json.createParser(new StringReader(MAPPING_TEST));
        client.indices().create(
                new CreateIndexRequest.Builder()
                        .index("hotel")
                     .mappings(TypeMapping._DESERIALIZER.deserialize(parser,jsonpMapper))
                        .build()
        );
    }
    //mappings是json文件
    @Test
    public void testCreateIndex2(){
        String mappingPath = System.getProperty("user.dir") + "/mappings.json";
        JsonpMapper mapper = client._transport().jsonpMapper();
        String mappings_str = new String(Files.readAllBytes(Paths.get(mappingPath)));
        System.out.println("mappings are: " +  mappings_str);
        JsonParser parser = mapper.jsonProvider()
            .createParser(new StringReader( mappings_str ));

        client.indices()
            .create(createIndexRequest -> createIndexRequest.index("test")
                    .mappings(TypeMapping._DESERIALIZER.deserialize(parser, mapper)));
    }
    
    @BeforeEach
    void setUp() {
        restClient = RestClient.builder(new HttpHost(IP,9200)).build();
        transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
        client = new ElasticsearchClient(transport);
    }

    @AfterEach
    void tearDown() throws IOException {
        //关闭连接
        restClient.close();
        transport.close();
    }
}

API Client使用client.indices()操作索引.

image-20230705113225206

判断索引是否存在

 @Test
void testExistsIndex() throws IOException {
    BooleanResponse isExists = client.indices().exists(
        new ExistsRequest.Builder()
        .index("hotel")
        .build()
    );
    System.out.println(isExists.value()?"exist":"not exist");
}

其实代码是什么不重要，完全可以按提示写，例如删除index：

image-20230705154144666

提供了两种方式，上面判断是否存在用的是第二种，也就是XXIndexRequest的方式，删除可以试下第一种：

image-20230705154323920

改写成lambda表达式：

image-20230705154355621

文档

API Client使用client.xx()操作文档.

了解规则之后，根据代码提示直接写，不需要手动转换格式，极度舒适~

image-20230705164204097

image-20230705171150250

image-20230705171411436

bulk批量请求⭐

这个有点难猜，卡了一下

实在不行可以使用最原始的withJson()方法，把批量数据放在json中读取后作为请求参数传上去.但是不够优雅…

image-20230705174157104

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/722450.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Docker（一）之 应用（Application）部署容器化的演进之路

Docker（一）之 应用（Application）部署容器化的演进之路

前言 容器化技术可以帮助企业更大化资源利用&#xff0c;同时帮助项目相关人员&#xff08;开发、运维、测试、安全等&#xff09;以最小的成本实现项目快速上云部署&#xff0c;掌握容器化管理工具Docker&#xff0c;就掌握了云原生最基础、最核心技术之一 应用&#xff08;…
阅读更多...
springboot整合hibernate，gradle，达梦8数据库，实现增删改查的功能

springboot整合hibernate，gradle，达梦8数据库，实现增删改查的功能

1.新建一个springboot项目&#xff0c;选择gradle管理 2.gradle添加以下依赖&#xff0c;gradle版本7.4 dependencies {// https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-webimplementation org.springframework.boot:spring-boot-starter…
阅读更多...
Pytorch深度强化学习1-3：策略评估与贝尔曼期望方程详细推导

Pytorch深度强化学习1-3：策略评估与贝尔曼期望方程详细推导

目录 0 专栏介绍1 从一个例子出发2 回报与奖赏3 策略评估函数4 贝尔曼期望方程5 收敛性证明 0 专栏介绍 本专栏重点介绍强化学习技术的数学原理&#xff0c;并且采用Pytorch框架对常见的强化学习算法、案例进行实现&#xff0c;帮助读者理解并快速上手开发。同时&#xff0c;辅…
阅读更多...
ZUH-ACDM-网络-网闸-根据论坛的案例进行分析

ZUH-ACDM-网络-网闸-根据论坛的案例进行分析

H3C技术论坛&#xff1a;https://zhiliao.h3c.com/Theme/details/64343 文章目录 需求&#xff1a;源地址&#xff1a;172.16.1.33访问目的地址&#xff1a;192.168.4.233确认确定是主机确认外端机连接地址172.16.1.254确认内端机到源地址172.16.1.33是通的确认流量走向/路由第…
阅读更多...
基于matlab使用高斯混合模型检测和计数视频序列中的汽车（附源码）

基于matlab使用高斯混合模型检测和计数视频序列中的汽车（附源码）

一、前言 此示例演示如何使用基于高斯混合模型 &#xff08;GMM&#xff09; 的前景检测器检测和计数视频序列中的汽车。 检测和计数汽车可用于分析交通模式。检测也是执行更复杂的任务&#xff08;例如按类型跟踪或分类车辆&#xff09;之前的第一步。 此示例演示如何使用前…
阅读更多...
prometheus描点原理

prometheus描点原理

大家好&#xff0c;我是蓝胖子&#xff0c;关于prometheus的入门教程有很多&#xff0c;拿我之前学prometheus的经历来讲&#xff0c;看了很多教程&#xff0c;还是会对prometheus的描点以及背后的统计原理感到迷惑&#xff0c;所以今天我们就来分析下这部分&#xff0c;来揭开…
阅读更多...
AIGC - Stable Diffusion 的 墨幽人造人 模型与 Tag 配置

AIGC - Stable Diffusion 的 墨幽人造人 模型与 Tag 配置

欢迎关注我的CSDN&#xff1a;https://spike.blog.csdn.net/ 本文地址&#xff1a;https://spike.blog.csdn.net/article/details/131565068 Stable Diffusion的模型网站 LiblibAI&#xff1a;https://www.liblibai.com 墨幽人造人网址&#xff1a;https://www.liblibai.com/m…
阅读更多...
BUU [vnctf2023]电子木鱼

BUU [vnctf2023]电子木鱼

BUU [vnctf2023]电子木鱼 先看看题目&#xff0c;点不了。 看看源码。Rust整数溢出。 在 Rust 中&#xff0c;整数类型默认是有符号整数类型&#xff0c;意味着这些整数类型可以表示正数和负数。对于有符号整数类型&#xff0c;最高位用来表示符号&#xff0c;0 表示正数&…
阅读更多...
如何在Microsoft Excel中快速创建等比序列

如何在Microsoft Excel中快速创建等比序列

Excel 中的填充句柄允许你通过拖动句柄自动填充行或列中的数据列表&#xff08;数字或文本&#xff09;。这可以在大型工作表中输入顺序数据时节省大量时间&#xff0c;并提高工作效率。 如果数据遵循某个模式或基于其他单元格中的数据&#xff0c;则可以使用“自动填充”功能…
阅读更多...
TiDB（7）：技术内幕之存储

TiDB（7）：技术内幕之存储

1 引言 数据库、操作系统和编译器并称为三大系统&#xff0c;可以说是整个计算机软件的基石。其中数据库更靠近应用层&#xff0c;是很多业务的支撑。这一领域经过了几十年的发展&#xff0c;不断的有新的进展。 很多人用过数据库&#xff0c;但是很少有人实现过一个数据库&a…
阅读更多...
基于FreeRTOS的嵌入式设备管理关键技术研究及实现（学习三）

基于FreeRTOS的嵌入式设备管理关键技术研究及实现（学习三）

设备节点功能模块设计 在本文节点功能设计中&#xff0c;拥有用于检测温度的温度传感器、监测湿度的湿度传感器以及 调节空调温度的IR红外发射器&#xff0c;另留有部分外接扩展串口&#xff0c;因此可能会在实际使用中扩展更多的设备模块与功能。 可见&#xff0c;如何高效地…
阅读更多...
2023年03月份青少年软件编程Python等级考试试卷三级真题(含答案)

2023年03月份青少年软件编程Python等级考试试卷三级真题(含答案)

2023-03 Python三级真题 分数&#xff1a;100 题数&#xff1a;38 测试时长&#xff1a;60min 一、单选题(共25题&#xff0c;共50分) 1.十进制数111转换成二进制数是&#xff1f;&#xff08;　&#xff09;&#xff08;2分&#xff09; A.111 B.1111011 C.101111 D…
阅读更多...
青岛大学_王卓老师【数据结构与算法】Week04_10_线性表的应用3_学习笔记

青岛大学_王卓老师【数据结构与算法】Week04_10_线性表的应用3_学习笔记

本文是个人学习笔记&#xff0c;素材来自青岛大学王卓老师的教学视频。 一方面用于学习记录与分享&#xff0c;另一方面是想让更多的人看到这么好的《数据结构与算法》的学习视频。 如有侵权&#xff0c;请留言作删文处理。 课程视频链接&#xff1a; 数据结构与算法基础–…
阅读更多...
Spring Boot中的度量指标及使用方法

Spring Boot中的度量指标及使用方法

Spring Boot中的度量指标及使用方法 简介 Spring Boot是目前流行的Java后端框架之一&#xff0c;它提供了许多有用的功能&#xff0c;其中包括度量指标。度量指标可以帮助我们监测应用程序的性能、稳定性和可靠性&#xff0c;以便及时发现并解决问题。本文将介绍Spring Boot中…
阅读更多...
使用Jetpack Compose集成WebView

使用Jetpack Compose集成WebView

在Android开发中&#xff0c;WebView是一个非常重要的组件&#xff0c;它可以用来显示网页或加载在线内容。然而&#xff0c;在Jetpack Compose&#xff08;Google推出的新的UI工具包&#xff09;中&#xff0c;目前没有内置的WebView Composable。但不必担心&#xff0c;你可以…
阅读更多...
【数据算法与结构】栈和队列课后习题

【数据算法与结构】栈和队列课后习题

题目&#xff08;共两道&#xff09; 题目1 Qestion: 根据下面代码片段写出运行下列程序段的输出结果(元素类型为char) 题目代码片段 void main() {Stack S; char x,y; InitStack(S); // 初始化栈x ‘e ‘; y ‘c’; Push(S, ‘h‘); Push(S, ‘r‘); Push(S,y);Pop(S,x);…
阅读更多...
了解Java可见性的本质

了解Java可见性的本质

作者&#xff1a;早恒 前一段时间重温了伪共享&#xff08;false sharing&#xff09;问题&#xff0c;了解到深处有几个问题一直想不明白&#xff0c;加上开发过程中遇到volatile时总觉得理解不够透彻&#xff0c;借着这次脑子里这几个问题&#xff0c;探究下Java可见性的本质…
阅读更多...
【C语言】深入学习函数（万字）

【C语言】深入学习函数（万字）

&#x1f466;个人主页&#xff1a;Weraphael ✍&#x1f3fb;作者简介&#xff1a;目前正在回炉重造C语言&#xff08;2023暑假&#xff09; ✈️专栏&#xff1a;【C语言航路】 &#x1f40b; 希望大家多多支持&#xff0c;咱一起进步&#xff01;&#x1f601; 如果文章对你…
阅读更多...
文件上传+文件包含组合式getshell

文件上传+文件包含组合式getshell

实验目的 通过本实验&#xff0c;了解文件包含的特点&#xff0c;掌握图片马的执行方法&#xff0c;文件上传文件包含组合式getshell。 实验环境 操作机&#xff1a;kali 靶机&#xff1a;Windows 2007 用户名/密码&#xff1a;college/360College 实验地址&#xff1a;http…
阅读更多...
jenkins部署springboot项目

jenkins部署springboot项目

jenkins部署springboot项目 1、创建一个项目 上传到gitee 1、创建项目 2、上传到git 2、jenkins创建一个pipeline项目 Pipeline简介 1&#xff09;概念 Pipeline&#xff0c;简单来说&#xff0c;一套运行在 Jenkins 上的工作流框架&#xff0c;将原来独立运行于单个或者…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023