当前位置：首页 > news >正文

Elasticsearch JavaRestClient版

news 来源：原创 2025/5/16 18:27:35

文章目录

- 初始化RestHighLeveClient（必要条件）
- 索引库操作
- - - 1.创建索引库（4步）
    - 2.删除索引库（3步）
    - 3.判断索引库是否存在（3步）
    - 4.总结：四步走
- 文档操作
- - - 1.创建文档（4步）
    - 2.删除文档（3步）
    - 3.查看文档（4步）
    - 4.增量修改文档(局部更新)（4步）
    - 5.批量创建文档（4步）
    - 6.总结：五步走
- Elasticsearch查询语法
- - - 1.全文检索（5步）
    - - match_all
      - match
      - multi_match
    - 2.精确查找
    - - term
      - range
    - 3.复合查询
    - - Bool Query（5步）
      - function score（广告置顶）
    - 排序（sort）
    - 分页（from/size）
    - 高亮（highlight）
    - 总结

初始化RestHighLeveClient（必要条件）

<!--Maven配置-->
<!--引入es的RestHignLeveClient依赖-->
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId>
</dependency>
<!--因为SpringBoot默认的ES版本是7.6.2，所以我们需要覆盖默认的ES版本:-->
<properties><java.version>1.8</iava.version><elasticsearch,version>7.12.1</elasticsearch.version>
</properties>//1.初始化RestHighLeveClient
RestHighLeveClient client = new RestHighLeveClient(RestClient.builder(//写自己的ES地址HttpHost.create("localhost:9200");
))

索引库操作

1.创建索引库（4步）

//2.相当于 PUT /索引名
CreateIndexRequest request = new CreateIndexRequest("索引库名");
//3.相当于请求体JSON风格
request.source("请求体",XContentType.JSON);
//4.发起请求.indices()包含索引库操作的的所有方法
client.indices().create(request,RequestOptions.DEFAULT);

2.删除索引库（3步）

// 2.相当于 DELETE /索引库名
DeleteIndexRequest request = new DeleteIndexRequest("索引库名");//3.发起请求
client.indices().create(request,RequestOptions.DEFAULT);

3.判断索引库是否存在（3步）

// 2.相当于 GET /索引库名
GetIndexRequest request = new GetIndexRequest("索引库名称");// 3.发起请求
boolean exists = client.indices.exists(request,RequestOptions.DEFAULT);//输出查看是否存在，是为true,不是为false
System.out.println(exists);

4.总结：四步走

从这里可以看出，创建索引有四步，其余只有三步

文档操作

1.创建文档（4步）

// 2.相当于POST /索引库名/_doc/文档id
IndexRequest request = new IndexRequest("索引库名").id("文档id");
// 3.准备json文档，也就是文档的内容，请求体
request.source("请求体",XContentType.JSON);
// 4.发送请求
client.index(request,RequestOptions.DEFAULT);/**注意：
*如果是请求体是实体对象，请序列化成JSON.toJSONString(请求体)
*文档id在ES默认是keyword，在java中也就是String类型,需要toString()转成字符串
*/

2.删除文档（3步）

// 2.相当于 DELETE /索引库名/_doc/文档id
DeleteRequest request = new DeleteRequest("索引库名","文档id");
// 3.发送请求
client.delete(request,RequestOptions.DEFAULT);

3.查看文档（4步）

// 2.相当于 GET /索引库名/_doc/文档id
GetRequest request = new GetRequest("索引库名","文档id");
// 3.发送请求
GetResponse response = client.get(request,RequestOptions.DEFAULT)
// 4.解析结果
String json = response.getSourceAsString();
System.out.println(json)

4.增量修改文档(局部更新)（4步）

// 2.相当于 POST /索引库名/ _update/文档id
UpdateRequest request = new UpdateRequest("indexName","文档id");// 3.准备参数
request.doc("age":18,"name":"Rose"
)
// 4.更新文档
client.update(request,RequestOptions.DEFAULT)

5.批量创建文档（4步）

// 2.创建Bulk请求
BulkRequest request = new BulkRequest();
// 3.准备参数，添加多个IndexRequest(),以实体类为例
for(Student student:students){Student student = new Student();request.add(new IndexRequest("索引库名").id(student.getId()).source(JSON.toJSONString(student),XContentType.JSON);)
}
// 4.发送请求
client.bulk(request,RequestOptions.DEFAULT)

6.总结：五步走

Elasticsearch查询语法

1.全文检索（5步）

match_all

// match_all
// 2.准备request
SearchRequest request = new SearchRequest("索引库名");
// 3.组织DSL参数
request.source.query(QueryBuilders.matchAll());
// 4.发送请求，得到结果
SearchResponse response = client.search(request,RequestOptions.DEFAULT);// 5.解析响应结果
SearchHits searchHits = response.getHits();
// 5.1获取总条数
long total = searchHits.getTotalHits().value;
// 5.2获取文档数组并且遍历
SearHits[] hits = searchHits.getHits();
for(SearchHits hit : hits){//获取文档数据源String json = hit.getSourceAaString();//反序列化HoteDoc hotelDoc = JSON.parseObject(json,HoteDoc.class);
}System.out.println(response);

match

//在match_all第5行修改
QueryBuilders.matchQuery("要查询的字段","查询的内容");

multi_match

//在match_all第5行修改
QueryBuilders.multiMatchQuery("要查询的内容","被查询的字段","被查询的字段");

2.精确查找

term

//在match_all第5行修改
QueryBuilders.termQuery("查询字段","被查询的内容")

range

//在match_all第5行修改
QueryBuilders.rangeQuery("被查询字段").get(100).lte(150)

3.复合查询

Bool Query（5步）

// 2.准备request
SearchRequest request = new SearchRequest("索引库名");
// 3.复合条件
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
boolQuery.must();
boolQuery.filter();
// 3.1组织DSL参数
request.source.query(boolQuery);
// 4.发送请求，得到结果
SearchResponse response = client.search(request,RequestOptions.DEFAULT);// 5.解析结果

function score（广告置顶）

// 2.准备request
SearchRequest request = new SearchRequest("索引库名");// 3.复合条件
FunctionScoreQueryBuilder functionScoreQuery = QueryBuilders.functionScoreQuery(//原始查询QueryBuilders.matchAll();//functionnew FunctionScoreQueryBuilder.FilterFunctionBuilder(//过滤条件QueryBuilders.termQuery("查询字段","被查询的内容")//算分函数ScoreFunctionBuilders.weightFactorFunction(10)))
// 3.1组织DSL参数
request.source.query(functionScoreQuery);// 4.发送请求，得到结果
SearchResponse response = client.search(request,RequestOptions.DEFAULT);

排序（sort）

// 普通字段排序
request.source.sort("要排序的字段",排序方式);// 地理坐标距离排序
request.source.sort(SortBuilders.geoDistanceSort("geo_point类型字段",new GeoPoint("经度,纬度")).order(SortOrder.ASC).unit(DistanceUnit.KILOMETERS)
)

分页（from/size）

request.source.from(0).size(5);

高亮（highlight）

// 2.准备request
SearchRequest request = new SearchRequest("索引库名");
// 3.准备DSL查询出来的字段
request.source.query(QueryBuilders.matchQuery("要查询的字段","查询的内容"))
// 3.1对查询出来的字段高亮显示
request.source.highlighter(new HighlightBuilder().field("要高亮的字段").requireFieldMatch(false)//是否需要与查询字段匹配
)
// 4.发送请求
SearchResponse response = client.search(request,RequestOptions.DEFAULT);//高亮结果的处理
// 5.解析响应结果
SearchHits searchHits = response.getHits();
// 5.1获取总条数
long total = searchHits.getTotalHits().value;
// 5.2获取文档数组并且遍历
SearHits[] hits = searchHits.getHits();
for(SearchHits hit : hits){//获取文档数据源String json = hit.getSourceAaString();//反序列化HoteDoc hotelDoc = JSON.parseObject(json,HoteDoc.class);//获取高亮结果Map<String,HighlightField> highlightFields = hit.getHighlightFields();if(!CollectionUtils.isEmpty(highlightFields)){//根据字段获取高亮结果HighlightFields highlightField = highlightFields.get("name");if(highlightField != null){highlightField.getFragments()[0].string();hotelDoc.setName(name);}}
}

总结

Elasticsearch JavaRestClient版

文章目录初始化RestHighLeveClient（必要条件）索引库操作1.创建索引库（4步）2.删除索引库（3步）3.判断索引库是否存在（3步）4.总结：四步走文档操作1.创建文档（4…...

编程日记 2025/5/16 18:27:35

通过爬虫方式实现视频号助手发布视频

1、将真实的cookie贴到解压后目录中cookie.txt文件里，修改python代码里的user_agent和video_path, cover_path等变量的值，最后运行python脚本即可； 2、运行之前根据import提示安装一些常见依赖，比如requests等； 3、2025年1月份最新版；代码如下： import json import…...

编程日记 2025/5/13 3:07:55

如何在VMware ESXi和Workstation中打开VMDK文件？

VMware 中的 VMDK 是什么？ 在 VMware 中，VMDK 是虚拟磁盘文件的格式，全称是 Virtual Machine Disk。VMDK 文件用于存储虚拟机的硬盘内容，包括操作系统、应用程序、文件等。它相当于虚拟机的硬盘驱动器，可以模拟出各种…...

编程日记 2025/5/16 15:44:33

【计算机视觉技术 - 人脸生成】2.GAN网络的构建和训练

GAN 是一种常用的优秀的图像生成模型。我们使用了支持条件生成的 cGAN。下面介绍简单 cGAN 模型的构建以及训练过程。 2.1 在 model 文件夹中新建 nets.py 文件 import torch import torch.nn as nn# 生成器类 class Generator(nn.Module):def __init__(self, nz100, nc3, n…...

编程日记 2025/5/16 17:58:26

「Mac畅玩鸿蒙与硬件54」UI互动应用篇31 - 滑动解锁屏幕功能

本篇教程将实现滑动解锁屏幕功能，通过 Slider 组件实现滑动操作，学习事件监听、状态更新和交互逻辑的实现方法。关键词滑动解锁UI交互状态管理动态更新事件监听一、功能说明滑动解锁屏幕功能包含以下功能： 滑动解锁区域：用…...

编程日记 2025/5/16 17:19:38

JVM学习指南(9)-JVM运行时数据区

JVM学习指南(9)-JVM运行时数据区引言 Java虚拟机（JVM）是Java程序运行的核心，它为Java程序提供了一个与平台无关的执行环境。JVM的重要性不仅在于它实现了Java的跨平台特性，还在于它对程序执行过程中内存的管理。JVM运行时数据区是程序执行过程中存储数据的关键区域，理解…...

编程日记 2025/5/16 12:54:06

前端实现大文件上传(文件分片、文件hash、并发上传、断点续传、进度监控和错误处理，含nodejs)

大文件分片上传是前端一种常见的技术，用于提高大文件上传的效率和可靠性。主要原理和步骤如下文件分片确定分片大小：确定合适的分片大小。通常分片大小在 1MB 到 5MB 之间使用 Blob.slice 方法：将文件分割成多个分片。每个分片可以使用 Bl…...

编程日记 2025/5/13 7:56:42

什么是 C++ 的序列化？

什么是 C 的序列化？ 序列化（Serialization）是指将对象的状态转换为可以存储或传输的格式的过程。它使得对象能够以二进制或文本的形式被保存到文件中，或者通过网络发送到远程计算机上，稍后可以重新构造出来&#xff0…...

编程日记 2025/5/16 18:05:32

047_小驰私房菜_Qcom 8系列，Jpeg GPU 旋转

【问题背景】横屏模式下，发现有些三方app拍照旋转了90度。【修改策略】 adb shell setprop endor.debug.camera.overrideGPURotationUsecase 1 或者在/vendor/etc/camera/camxoverridesettings.txt 里面添加如下内容 overrideGPURotationUsecase1 【解释】 Ga…...

编程日记 2025/5/14 2:01:38

【C++】2039：【例5.6】冒泡排序

博客主页： [小ᶻ☡꙳ᵃⁱᵍᶜ꙳] 本文专栏: C 文章目录 💯前言💯题目描述💯我的初步实现我的代码实现问题分析 💯老师的实现方式老师代码的特点分析老师代码的执行过程 💯我的代码与老师代码的对比优点…...

编程日记 2025/5/16 18:01:58

【Java回顾】Day4 反射机制

反射机制之前学过一部分，笔记在20250103Java包_网络编程.md里,这里在之前的笔记的基础上做一些补充。反射：得到class对象后反向获取对象的各种信息。包 Field 类或接口中的字段(成员变量)，动态访问和修改类的字段模板获取Class 对象 …...

编程日记 2025/5/12 5:09:09

一、代码 clear; clc; figure(position,[150,100,900,550])%确定图片的位置和大小，[x y width height] %准备数据 Y1[0.53,7.9,8.3;0.52,6.8,9.2;0.52,5.9,8.6;2.8,5.8,7.9;3.9,5.2,7.8;1.8,5.8,8.4]; % withoutNHC X11:6; %画出4组柱状图，宽度1 h1…...

编程日记 2025/5/15 13:23:44

web漏洞之文件包含漏洞

一、文件包含漏洞 1、把DVWA页面改为low级别，然后点击File Inclusion页面原理是File Inclusion页面访问的是low.php和include.php，这两个页面包含了include($_GET[page])这句话，意思是page会把用户输入的参数带进来然后由$_GET读取&#x…...

编程日记 2025/5/12 4:05:28

spring mvc源码学习笔记之六

pom.xml 内容如下 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"http://maven.apache.org/P…...

编程日记 2025/5/12 4:36:04

深入理解 PyTorch 的 Dataset 和 DataLoader：构建高效数据管道

文章目录简介PyTorch 的 DatasetDataset 的基本概念自定义 Dataset实现 __init__ 方法示例：从 CSV 文件加载数据实现 __len__ 方法实现 __getitem__ 方法另一种示例：直接传递列表训练集和验证集的定义 1. 单个 Dataset 类数据分割2. 分别定义两个 Da…...

编程日记 2025/5/16 17:52:22

VSCode设置ctrl或alt+mouse(left)跳转

总结： （1）VSCode初次远程连接服务器时，需要在服务器上下载 python 拓展，然后选择对应的环境 （2）VSCode设置ctrl或altmouse(left)跳转到定义...

编程日记 2025/5/7 17:25:10

在Ubuntu 18.04.6 LTS安装OpenFace流程

一、修改配置:将gcc8，g8作为默认选项 sudo update-alternatives --install /usr/bin/gcc gcc /usr/bin/gcc-8 100 sudo update-alternatives --config gcc 选择版本，再查看gcc --version sudo update-alternatives --install /usr/bin/g g /usr/bin/g-…...

编程日记 2025/5/12 4:35:07

微服务拆分的艺术：构建高效、灵活的系统架构

目录一、微服务拆分的重要性二、微服务拆分的策略 1. 按照业务领域拆分 2. 按照团队结构拆分 3. 按照业务边界拆分 4. 按照数据和数据库拆分 5. 按照用户界面或外部接口拆分 6. 按照功能模块或领域驱动设计拆分 7. 按照性能和可伸缩性需求拆分三、微服务拆分的实践…...

编程日记 2025/5/16 17:34:02

PHP框架+gatewayworker实现在线1对1聊天--发送消息（6）

文章目录发送消息原理说明发送功能实现html部分javascript代码PHP代码发送消息原理说明接下来我们发送聊天的文本信息。点击发送按钮的时候，会自动将文本框里的内容发送出去。过程是我们将信息发送到服务器，服务器再转发给对方。文本框的id为msgcont…...

编程日记 2025/5/16 18:24:24

java项目之读书笔记共享平台（源码+文档）

风定落花生，歌声逐流水，大家好我是风歌，混迹在java圈的辛苦码农。今天要和大家聊的是一款基于springboot的闲一品交易平台。项目源码以及部署相关请联系风歌，文末附上联系信息。项目简介： 读书笔记共享平台的主要使…...

编程日记 2025/5/16 17:32:59

RabbitMq的Java项目实践

在现代软件开发中，消息队列（Message Queue，简称MQ）作为一种重要的组件，承担着上下游消息传递和通信的重任。RabbitMQ作为一款流行的开源消息队列中间件，凭借其高可用性、可扩展性和易用性等特点&#xff0c…...

编程日记 2025/5/16 18:04:27

气膜球幕：引领元宇宙时代的科技与艺术光影盛宴—轻空间

在科技与艺术交织的时代，未来的观影体验将不再受限于传统屏幕的束缚。随着气膜球幕的崭新亮相，突破性的光影效果和沉浸式体验让我们走进了一个全新的视听世界。这不仅仅是一个简单的球形影院，它是连接现实与虚拟、科技与艺术、光与影的桥梁&a…...

编程日记 2025/5/13 23:51:19

行为模式2.命令模式------灯的开关

行为型模式模板方法模式（Template Method Pattern）命令模式（Command Pattern）迭代器模式（Iterator Pattern）观察者模式（Observer Pattern）中介者模式（Mediator Pattern…...

编程日记 2025/5/14 11:20:36

Linux环境下静态库和动态库的实现

Linux 环境下静态库和动态库的实现在软件开发中，库是非常重要的组成部分。它们包含了一组可复用的函数和代码片段，用于提高开发效率和代码质量。在Linux系统中，库分为静态库和动态库两种。本文将介绍它们的实现方式，结合C语言代…...

编程日记 2025/5/15 7:21:49

如何很快将文件转换成另外一种编码格式?编码？按指定编码格式编译?如何检测文件编码格式?Java .class文件编码和JVM运行期内存编码？

如何很快将文件转换成另外一种编码格式? 利用VS Code右下角的"选择编码"功能，选择"通过编码保存"可以很方便将文件转换成另外一种编码格式。尤其，在测试w/ BOM或w/o BOM, 或者ANSI编码和UTF编码转换，特别方便。VS文件另…...

编程日记 2025/5/16 18:09:32

Tortoisegit 安装之后没有Add、ignore解决

在本地的仓库文件夹中点击右键，找到Settings， 从General 找到Contex Menu，我的系统是Win11，所以用Win11 Contex Menu 将所需要的操作打勾即可。...

编程日记 2025/5/15 20:06:47

线性代数考研笔记

行列式背景分子行列式：求哪个未知数，就把b1，b2放在对应的位置分母行列式：系数对应写即可全排列与逆序数 1 3 2：逆序数为1 奇排列 1 2 3：逆序数为0 偶排列将 1 3 2 只需将3 2交换1次就可以还原原…...

编程日记 2025/5/16 17:17:13

C语言带参数的宏定义的相关知识汇总(最常用的形式、带标记分隔符##的形式...)

阅读大型C工程代码时，绕不开带参数的宏定义的阅读，所以有必要强化一下这一块的知识。 01-带参数的宏定义最常用的形式 # define S(a,b) a*b ... ... ... area S(3,2);则在编译预处理时area S(3,2);被展开为： area 3 * 2;02-带标记分隔符…...

编程日记 2025/5/10 23:34:44

cpp编译链接等

一、编译预处理 C程序编译的过程：预处理 -> 编译（优化、汇编）-> 链接预处理指令主要有以下三种： 包含头文件：#include 宏定义：#define（定义宏）、#undef（删除宏…...

编程日记 2025/5/16 17:47:22

openbmc sdk09.03 适配(一)

1.说明本节是根据最新的sdk09.03适配ast2600平台。 sdk下载路径为: https://github.com/AspeedTech-BMC/openbmc可参阅文档: https://blog.csdn.net/wit_yuan/article/details/144613247nfs挂载方法: # mount -o nolock -t nfs serverip:/xx...

编程日记 2025/5/16 16:55:25

JavaScript HTML DOM 实例

JavaScript HTML DOM 实例 JavaScript 的 HTML DOM（文档对象模型）允许您通过脚本来控制 HTML 页面。DOM 是 HTML 文档的编程接口，它将 Web 页面与编程语言连接起来，使得开发者可以改变页面中的内容、结构和样式。在这篇文章中，我们将通过一系列实例来探讨如何使用 JavaSc…...

编程日记 2025/5/14 17:15:10

【Vue】：解决动态更新＜video＞标签 src 属性后视频未刷新的问题

问题描述在 Vue.js 项目，当尝试动态更新 <video> 标签的 <source> 元素 src 属性来切换视频时，遇到了一个问题：即使 src 属性已更改，浏览器仍显示旧视频。具体表现为用户选择新视频后，视频区域继续显示之…...

编程日记 2025/5/6 4:16:55

C语言| 二维数字的定义

【二维数组】二维数组的本质就是一维数组，表现形式上是二维的。定义一般形式为类型说明符数组名[常量表达式][常量表达式]; 举例 int a[2][3]; 定义了一个2行3列的二维数组a，共有6个元素。元素名字依次是：a[0][0],a[0][1],a[0][…...

编程日记 2025/5/16 8:55:29

全国青少年信息学奥林匹克竞赛（信奥赛）备考实战之循环结构（for循环语句）—（十）（求解数学中特殊的数）

实战训练1—完全数问题描述： 数学上的“完全数”是指真因子（除了自身以外的约数）之和等于它本身的自然数。例如，6的因子是1,2,3，而1236，所以6是完全数。如果一个正整数小于它的所有真因数之和&#xff0…...

编程日记 2025/5/16 18:03:22

【大模型】ChatGPT 数据分析与处理使用详解

目录一、前言二、AI 大模型数据分析介绍 2.1 什么是AI数据分析 2.2 AI数据分析与传统数据分析对比 2.2.1 差异分析 2.2.2 优劣势对比 2.3 AI大模型工具数据分析应用场景三、AI大模型工具数据分析操作实践 3.1 ChatGPT 常用数据分析技巧操作演示 3.1.1 快速生成数据…...

编程日记 2025/5/16 17:24:49

[gcc]常见编译开关

GCC 提供了许多编译开关（编译选项），这些开关可以用于控制编译过程的各种方面，如优化级别、调试信息、警告和错误处理等。以下是一些常见的 GCC 编译开关： -o：指定输出文件名。例如，gcc -o myp…...

编程日记 2025/5/13 16:38:42

iOS实现在collectionView顶部插入数据效果

有时候，我们会遇到这种需求，就是下拉刷新的时候，在 collectionView顶部插入数据，这个时候，需要我们注意主要有两点 1 关闭隐式动画由于我们使用insert在collectionView顶部插入数据是有从头部插入的隐式动画的&#…...

编程日记 2025/5/16 17:42:47

GPIO、RCC库函数

void GPIO_DeInit(GPIO_TypeDef* GPIOx); void GPIO_AFIODeInit(void); void GPIO_Init(GPIO_TypeDef* GPIOx, GPIO_InitTypeDef* GPIO_InitStruct); void GPIO_StructInit(GPIO_InitTypeDef* GPIO_InitStruct); //输出读 uint8_t GPIO_ReadInputDataBit(GPIO_TypeDef* GPIOx,…...

编程日记 2025/5/14 22:11:00