SpringCloud 微服务全栈体系（十五）

news2025/1/11 5:50:34

第十一章 分布式搜索引擎 elasticsearch

五、RestClient 操作文档

  • 为了与索引库操作分离，再次参加一个测试类，做两件事情：

    • 初始化 RestHighLevelClient
    • 酒店数据在数据库，需要利用 IHotelService 去查询，所以注入这个接口
package com.alex.hotel;

import com.alex.hotel.pojo.Hotel;
import com.alex.hotel.service.IHotelService;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;
import java.util.List;

@SpringBootTest
public class HotelDocumentTest {
    @Autowired
    private IHotelService hotelService;

    private RestHighLevelClient client;

    @BeforeEach
    void setUp() {
        this.client = new RestHighLevelClient(RestClient.builder(
                HttpHost.create("http://192.168.150.101:9200")
        ));
    }

    @AfterEach
    void tearDown() throws IOException {
        this.client.close();
    }
}

1. 新增文档

  • 要将数据库的酒店数据查询出来，写入 elasticsearch 中。
1.1 索引库实体类
  • 数据库查询后的结果是一个 Hotel 类型的对象。结构如下：
@Data
@TableName("tb_hotel")
public class Hotel {
    @TableId(type = IdType.INPUT)
    private Long id;
    private String name;
    private String address;
    private Integer price;
    private Integer score;
    private String brand;
    private String city;
    private String starName;
    private String business;
    private String longitude;
    private String latitude;
    private String pic;
}

  • 与索引库结构存在差异：

    • longitude 和 latitude 需要合并为 location

  • 因此，需要定义一个新的类型，与索引库结构吻合：

package com.alex.hotel.pojo;

import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@NoArgsConstructor
public class HotelDoc {
    private Long id;
    private String name;
    private String address;
    private Integer price;
    private Integer score;
    private String brand;
    private String city;
    private String starName;
    private String business;
    private String location;
    private String pic;

    public HotelDoc(Hotel hotel) {
        this.id = hotel.getId();
        this.name = hotel.getName();
        this.address = hotel.getAddress();
        this.price = hotel.getPrice();
        this.score = hotel.getScore();
        this.brand = hotel.getBrand();
        this.city = hotel.getCity();
        this.starName = hotel.getStarName();
        this.business = hotel.getBusiness();
        this.location = hotel.getLatitude() + ", " + hotel.getLongitude();
        this.pic = hotel.getPic();
    }
}
1.2 语法说明
  • 新增文档的 DSL 语句如下：
POST /{索引库名}/_doc/1
{
    "name": "Jack",
    "age": 21
}
  • 对应的 java 代码如图：

在这里插入图片描述

  • 可以看到与创建索引库类似，同样是三步走：

    • 创建 Request 对象
    • 准备请求参数，也就是 DSL 中的 JSON 文档
    • 发送请求

  • 变化的地方在于，这里直接使用 client.xxx()的 API，不再需要 client.indices()了。

1.3 完整代码

  • 导入酒店数据，基本流程一致，但是需要考虑几点变化：

    • 酒店数据来自于数据库，我们需要先查询出来，得到 hotel 对象
    • hotel 对象需要转为 HotelDoc 对象
    • HotelDoc 需要序列化为 json 格式

  • 因此，代码整体步骤如下：

    • 根据 id 查询酒店数据 Hotel
    • 将 Hotel 封装为 HotelDoc
    • 将 HotelDoc 序列化为 JSON
    • 创建 IndexRequest，指定索引库名和 id
    • 准备请求参数，也就是 JSON 文档
    • 发送请求

  • 在 hotel-demo 的 HotelDocumentTest 测试类中，编写单元测试：

@Test
void testAddDocument() throws IOException {
    // 1.根据id查询酒店数据
    Hotel hotel = hotelService.getById(61083L);
    // 2.转换为文档类型
    HotelDoc hotelDoc = new HotelDoc(hotel);
    // 3.将HotelDoc转json
    String json = JSON.toJSONString(hotelDoc);

    // 1.准备Request对象
    IndexRequest request = new IndexRequest("hotel").id(hotelDoc.getId().toString());
    // 2.准备Json文档
    request.source(json, XContentType.JSON);
    // 3.发送请求
    client.index(request, RequestOptions.DEFAULT);
}

2. 查询文档

2.1 语法说明
  • 查询的 DSL 语句如下：
GET /hotel/_doc/{id}

  • 非常简单，因此代码大概分两步：

    • 准备 Request 对象
    • 发送请求

  • 不过查询的目的是得到结果，解析为 HotelDoc，因此难点是结果的解析。完整代码如下：

请添加图片描述

  • 可以看到，结果是一个 JSON，其中文档放在一个_source属性中，因此解析就是拿到_source，反序列化为 Java 对象即可。

  • 与之前类似，也是三步走：

    • 准备 Request 对象。这次是查询，所以是 GetRequest
    • 发送请求，得到结果。因为是查询，这里调用 client.get()方法
    • 解析结果，就是对 JSON 做反序列化
2.2 完整代码

在 hotel-demo 的 HotelDocumentTest 测试类中，编写单元测试：

@Test
void testGetDocumentById() throws IOException {
    // 1.准备Request
    GetRequest request = new GetRequest("hotel", "61082");
    // 2.发送请求，得到响应
    GetResponse response = client.get(request, RequestOptions.DEFAULT);
    // 3.解析响应结果
    String json = response.getSourceAsString();

    HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
    System.out.println(hotelDoc);
}

3. 删除文档

  • 删除的 DSL 为是这样的：
DELETE /hotel/_doc/{id}

  • 与查询相比，仅仅是请求方式从 DELETE 变成 GET，可以想象 Java 代码应该依然是三步走：

    • 准备 Request 对象，因为是删除，这次是 DeleteRequest 对象。要指定索引库名和 id
    • 准备参数，无参
    • 发送请求。因为是删除，所以是 client.delete()方法

  • 在 hotel-demo 的 HotelDocumentTest 测试类中，编写单元测试：

@Test
void testDeleteDocument() throws IOException {
    // 1.准备Request
    DeleteRequest request = new DeleteRequest("hotel", "61083");
    // 2.发送请求
    client.delete(request, RequestOptions.DEFAULT);
}

4. 修改文档

4.1 语法说明

  • 修改讲过两种方式：

    • 全量修改：本质是先根据 id 删除，再新增
    • 增量修改：修改文档中的指定字段值

  • 在 RestClient 的 API 中，全量修改与新增的 API 完全一致，判断依据是 ID：

    • 如果新增时，ID 已经存在，则修改
    • 如果新增时，ID 不存在，则新增

  • 这里不再赘述，主要关注增量修改。

  • 代码示例如图：

在这里插入图片描述

  • 与之前类似，也是三步走：

    • 准备 Request 对象。这次是修改，所以是 UpdateRequest
    • 准备参数。也就是 JSON 文档，里面包含要修改的字段
    • 更新文档。这里调用 client.update()方法
4.2 完整代码
  • 在 hotel-demo 的 HotelDocumentTest 测试类中，编写单元测试：
@Test
void testUpdateDocument() throws IOException {
    // 1.准备Request
    UpdateRequest request = new UpdateRequest("hotel", "61083");
    // 2.准备请求参数
    request.doc(
        "price", "952",
        "starName", "四钻"
    );
    // 3.发送请求
    client.update(request, RequestOptions.DEFAULT);
}

5. 批量导入文档

  • 案例需求：利用 BulkRequest 批量将数据库数据导入到索引库中。

  • 步骤如下：

    • 利用 mybatis-plus 查询酒店数据

    • 将查询到的酒店数据（Hotel）转换为文档类型数据（HotelDoc）

    • 利用 JavaRestClient 中的 BulkRequest 批处理，实现批量新增文档

5.1 语法说明

  • 批量处理 BulkRequest，其本质就是将多个普通的 CRUD 请求组合在一起发送。

  • 其中提供了一个 add 方法，用来添加其他请求：

在这里插入图片描述

  • 能添加的请求包括：

    • IndexRequest，也就是新增
    • UpdateRequest，也就是修改
    • DeleteRequest，也就是删除

  • 因此 Bulk 中添加了多个 IndexRequest，就是批量新增功能了。

  • 其实还是三步走：

    • 创建 Request 对象。这里是 BulkRequest
    • 准备参数。批处理的参数，就是其它 Request 对象，这里就是多个 IndexRequest
    • 发起请求。这里是批处理，调用的方法为 client.bulk()方法

  • 在导入酒店数据时，将上述代码改造成 for 循环处理即可。

5.2 完整代码
  • 在 hotel-demo 的 HotelDocumentTest 测试类中，编写单元测试：
@Test
void testBulkRequest() throws IOException {
    // 批量查询酒店数据
    List<Hotel> hotels = hotelService.list();

    // 1.创建Request
    BulkRequest request = new BulkRequest();
    // 2.准备参数，添加多个新增的Request
    for (Hotel hotel : hotels) {
        // 2.1.转换为文档类型HotelDoc
        HotelDoc hotelDoc = new HotelDoc(hotel);
        // 2.2.创建新增文档的Request对象
        request.add(new IndexRequest("hotel")
                    .id(hotelDoc.getId().toString())
                    .source(JSON.toJSONString(hotelDoc), XContentType.JSON));
    }
    // 3.发送请求
    client.bulk(request, RequestOptions.DEFAULT);
}

6. 小结

  • 文档操作的基本步骤：

    • 初始化 RestHighLevelClient
    • 创建 XxxRequest。XXX 是 Index、Get、Update、Delete、Bulk
    • 准备参数（Index、Update、Bulk 时需要）
    • 发送请求。调用 RestHighLevelClient#.xxx()方法，xxx 是 index、get、update、delete、bulk
    • 解析结果（Get 时需要）

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

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

相关文章

Pandas数据集的合并与连接merge()方法_Python数据分析与可视化

Pandas数据集的合并与连接merge()方法_Python数据分析与可视化

数据集的合并与连接 merge()解析merge()的主要参数 merge()解析 merge()可根据一个或者多个键将不同的DataFrame连接在一起&#xff0c;类似于SQL数据库中的合并操作。 数据连接的类型 一对一的连接&#xff1a; df1 pd.DataFrame({employee: [Bob, Jake, Lisa, Sue], grou…
阅读更多...
HDCTF2023 - Reverse方向全WP

HDCTF2023 - Reverse方向全WP

文章目录 [HDCTF 2023]easy_re[HDCTF 2023]easy_asm[HDCTF 2023]fake_game[HDCTF 2023]enc[HDCTF 2023]double_code[HDCTF 2023]买了些什么呢[HDCTF2023]basketball [HDCTF 2023]easy_re UPX壳&#xff0c;脱壳 一个base64编码。 [HDCTF 2023]easy_asm ida打开后可以看到xor 10…
阅读更多...
深入了解千兆光模块和万兆光模块

深入了解千兆光模块和万兆光模块

光模块是一种光电转换设备&#xff0c;在发射端&#xff0c;光模块能够将设备产生的电信号转换成光信号从而实现在光纤介质中传输&#xff0c;在接收端光模块将接收到的光信号再次转换为设备能够识别的电信号&#xff0c;从而实现高速、精准的数据传输。例如&#xff0c;在线视…
阅读更多...
V100 GPU服务器安装CUDA教程

V100 GPU服务器安装CUDA教程

大家好，我是爱编程的喵喵。双985硕士毕业，现担任全栈工程师一职，热衷于将数据思维应用到工作与生活中。从事机器学习以及相关的前后端开发工作。曾在阿里云、科大讯飞、CCF等比赛获得多次Top名次。现为CSDN博客专家、人工智能领域优质创作者。喜欢通过博客创作的方式对所学的…
阅读更多...
常见树种（贵州省）：009楠木、樟木、桂木种类

常见树种（贵州省）：009楠木、樟木、桂木种类

摘要&#xff1a;本专栏树种介绍图片来源于PPBC中国植物图像库&#xff08;下附网址&#xff09;&#xff0c;本文整理仅做交流学习使用&#xff0c;同时便于查找&#xff0c;如有侵权请联系删除。 图片网址&#xff1a;PPBC中国植物图像库——最大的植物分类图片库 一、楠木 …
阅读更多...
python实现炫酷的屏幕保护程序

python实现炫酷的屏幕保护程序

shigen日更文章的博客写手&#xff0c;擅长Java、python、vue、shell等编程语言和各种应用程序、脚本的开发。记录成长&#xff0c;分享认知&#xff0c;留住感动。 上次的文章如何实现一个下班倒计时程序的阅读量很高&#xff0c;觉得也很实用酷炫&#xff0c;下边是昨天的体验…
阅读更多...
Leetcode刷题详解——删除并获得点数

Leetcode刷题详解——删除并获得点数

1. 题目链接&#xff1a;740. 删除并获得点数 2. 题目描述&#xff1a; 给你一个整数数组 nums &#xff0c;你可以对它进行一些操作。 每次操作中&#xff0c;选择任意一个 nums[i] &#xff0c;删除它并获得 nums[i] 的点数。之后&#xff0c;你必须删除 所有 等于 nums[i] …
阅读更多...
如何使用http来获取thingsbord中的设备数据

如何使用http来获取thingsbord中的设备数据

背景 有个读者问我，他想做tb的二次开发，想要通过一个接口来查询设备的遥测数据。 于是我给他写了这篇文章。 具体实现 由于他使用的是cloud版本，于是我使用cloud来做演示 文档的接口 https://thingsboard.cloud/swagger-ui/#/telemetry-controller/getTimeseriesUsing…
阅读更多...
一道简单的积分题目

一道简单的积分题目

题目如下图&#xff1a; 解法1&#xff1a; 解法2&#xff1a; 解法3&#xff1a; 错误做法&#xff1a; 在 x ∈ ( 0 , ∞ ) 上有 ln ⁡ x < x &#xff0c;令 f ( x ) ln ⁡ x 1 x 2 &#xff0c; g ( x ) &#xff1d; x 1 x 2 ∴ f ( x ) < g ( x ) &#x…
阅读更多...
【汇编】“转移”综述、操作符offset、jmp指令

【汇编】“转移”综述、操作符offset、jmp指令

文章目录 前言一、转移综述1.1 :背景&#xff1a;1.2 转移指令1.3 转移指令的分类按转移行为根据指令对IP修改的范围不同 二、操作符offset2.1 offset操作符是干什么的&#xff1f;标号是什么&#xff1f; 2.2 nop是什么&#xff1f; 三、jmp指令3.1 jmp指令的功能3.2 jmp指令&…
阅读更多...
Vue移动 HTML 元素到指定位置 teleport 标签

Vue移动 HTML 元素到指定位置 teleport 标签

teleport 标签&#xff1a;用于将组件中的 HTML 元素移动到任意的位置。 使用 teleport 标签移动 HTML 元素&#xff1a; <!-- 将 teleport 中的内容移动到 body 标签中 --> <teleport to"body"><div><h3>我是第三层组件的标题</h3>…
阅读更多...
腾讯云轻量数据库1核1G性能测评、租用费用和详细介绍

腾讯云轻量数据库1核1G性能测评、租用费用和详细介绍

腾讯云轻量数据库服务采用腾讯云自研的新一代云原生数据库 TDSQL-C&#xff0c;融合了传统数据库、云计算与新硬件技术的优势&#xff0c;100%兼容 MySQL&#xff0c;实现超百万级 QPS 的高吞吐&#xff0c;128TB 海量分布式智能存储&#xff0c;保障数据安全可靠。腾讯云百科t…
阅读更多...
Android Termux安装MySQL，内网穿透实现公网远程访问

Android Termux安装MySQL，内网穿透实现公网远程访问

文章目录 前言1.安装MariaDB2.安装cpolar内网穿透工具3. 创建安全隧道映射mysql4. 公网远程连接5. 固定远程连接地址 前言 Android作为移动设备&#xff0c;尽管最初并非设计为服务器&#xff0c;但是随着技术的进步我们可以将Android配置为生产力工具&#xff0c;变成一个随身…
阅读更多...
【Linux】：进程间通信和日志模拟

【Linux】：进程间通信和日志模拟

进程间通信 一.基本概念二.简单的通信-管道(匿名管道)1.建立通信信道2.通信接口 三.命名管道三.模拟命名管道通信&#xff08;加上日志&#xff09;1.完整代码2.基本使用 一.基本概念 是什么 两个或多个进程实现数据层面的交互。 因为进程独立性的存在&#xff0c;导致进程间…
阅读更多...
【前段基础入门之】=＞CSS3新特性 BFC

【前段基础入门之】=＞CSS3新特性 BFC

什么是BFC( 概念) W3C 上对 BFC 的定义&#xff1a; MDN 上对 BFC 的定义&#xff1a; 简而言之 开启了BFC能解决什么问题 元素开启 BFC 后&#xff0c;其子元素不会再产生 margin 塌陷问题元素开启 BFC 后&#xff0c;自己不会被其他浮动元素所覆盖元素开启 BFC 后&#xff0…
阅读更多...
【Java】多线程-wait/notify

【Java】多线程-wait/notify

1、wait和notify Java的多线程中&#xff0c;线程的执行顺序和时间都是不定的。为了控制线程的调度顺序&#xff0c;前面我们引入了join()方法。 但是join()只能在线程执行完后&#xff0c;才能执行其他线程&#xff0c;有没有什么方法可以在线程执行顺序中来调度其他线程呢&…
阅读更多...
代码随想录 Day50 单调栈 LeetCodeT503 下一个最大元素II T42接雨水

代码随想录 Day50 单调栈 LeetCodeT503 下一个最大元素II T42接雨水

前言 前面我们说到了单调栈的第一题,下一个最大元素I,其实今天的两道题都是对他的变种,知道第一个单调栈的思想能够想清楚,其实这道题是很简单的 考虑好三个状态,大于等于小于,其实对于前面这些题目只要细心的小伙伴就会发现其实小于和等于的处理是一样的都是直接入栈,只有大于…
阅读更多...
灵魂拷问std::enable_shared_from_this，揭秘实现原理

灵魂拷问std::enable_shared_from_this，揭秘实现原理

灵魂拷问std::enable_shared_from_this&#xff0c;揭秘实现原理 引言 在C编程中&#xff0c;使用智能指针是一种安全管理对象生命周期的方式。std::shared_ptr是一种允许多个指针共享对象所有权的智能指针。然而&#xff0c;当一个对象需要获取对自身的shared_ptr时&#xff0…
阅读更多...
中贝转债上市价格预测

中贝转债上市价格预测

中贝转债-113678 基本信息 转债名称&#xff1a;中贝转债&#xff0c;评级&#xff1a;A&#xff0c;发行规模&#xff1a;5.17亿元。 正股名称&#xff1a;中贝通信&#xff0c;今日收盘价&#xff1a;49.2元&#xff0c;转股价格&#xff1a;32.8元。 当前转股价值 转债面值…
阅读更多...
JavaScript中的random小案例

JavaScript中的random小案例

前言 Math对象是JavaScript的内置对象&#xff0c;而random是Math对象属性 Math.random&#xff08;&#xff09;函数返回一个浮点数&#xff0c;伪随机数在范围从0 到小于1&#xff0c;也就是说&#xff0c;从 0&#xff08;包括 0&#xff09;往上&#xff0c;但是不包括 1&a…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023