【开发篇】九、SpringBoot整合ES(ElasticSearch)

news2024/11/19 18:24:20

文章目录

  • 1、整合
  • 2、简单示例
  • 3、一点补充
  • 4、增删改查索引与文档

1、整合

整合思路都一样,先起步依赖或普通依赖,再配置,再封装的操作对象。先引入依赖:

<dependency>   
	<groupId>org.springframework.boot</groupId>    
	<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

application.yaml配置:

spring:  
  elasticsearch:    
    rest:      
      uris: http://localhost:9200

在需要的地方注入客户端操作对象:

@Autowired
ElasticsearchRestTemplate template;

注意,与以往不同的是,SpringBoot平台并没有跟随ES的更新速度进行同步更新,ES提供了High Level Client操作ES,导入坐标:

<dependency>    
	<groupId>org.elasticsearch.client</groupId>    
	<artifactId>elasticsearch-rest-high-level-client</artifactId>
</dependency>

不用加配置,上面的starter搭配的那个配置也可以注释掉了,使用es-high-level-client,ES的信息写在代码中,不写在配置文件中,因为没和SpringBoot整合还。

2、简单示例

既然es-high-level-client还没和Spring做整合,那自然不能使用@Autowired自动注入一个客户端操作对象了。RestHighLevelClient对象需要我们自己来手动创建,并初始化。且之前对象做为Bean交给Spring管理时,我们只管用,现在手搓的RestHighLevelClient用完需要关闭资源连接。在UT中看下效果,以创建索引为例:

@Test
void test() throws IOException {

    HttpHost host = HttpHost.create("http://localhost:9200");   
     
    RestClientBuilder builder = RestClient.builder(host);   
     
    RestHighLevelClient client = new RestHighLevelClient(builder); 
       
    //客户端操作    
    CreateIndexRequest request = new CreateIndexRequest("books");   
     
    //获取操作索引的客户端对象,调用创建索引操作    
    client.indices().create(request, RequestOptions.DEFAULT); 
       
    //关闭客户端    
    client.close();
}

创建客户端连接对象和关闭连接是重复操作,使用SetUp和TearDown方法来改进下:

在这里插入图片描述

SetUp和TearDown分别代表每个测试用例@Test执行前和执行后进行的操作。

@SpringBootTest
class Springboot18EsApplicationTests {
    	    	   
	private RestHighLevelClient client; 
	   
	@BeforeEach    
	void setUp() {       
		this.client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://localhost:9200")));    
	}   
	
	@AfterEach    
	void tearDown() throws IOException {        
		this.client.close();    
	}
	
}

此时,直接写CRUD代码就行。

@Test
void test() throws IOException {    
	//客户端操作    
	CreateIndexRequest request = new CreateIndexRequest("books");    
	//获取操作索引的客户端对象,调用创建索引操作    
	client.indices().create(request, RequestOptions.DEFAULT);
}

3、一点补充

高版本的SpringBoot好像已经完成了整合,可以直接注入RestHighLevelClient这个对象(测试版本SpringBoot 2.6.13)

@Autowired
private RestHighLevelClient restHighLevelClient;

在Ioc容器中获取一下,是可以拿到这个Bean的,且其加载了application.yaml中的es配置:

spring:  
  elasticsearch:    
    rest:      
      uris: http://localhost:9200 # 默认就是这个uri,写不写都行

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

不确定,没查文档,实际开发时自己看吧,注入不成功就@Bean自己创建一个。

4、增删改查索引与文档

之前专栏已经整理完了,跳转【ES专栏】

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

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

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

相关文章

电子签章软件怎么安装?选本地私有还是SaaS云?

出于高效便捷、安全防伪&#xff0c;以及跟上数字化转型趋势的考虑&#xff0c;越来越多的企业开始考虑使用电子签章软件。 但是每当企业考虑购买电子签章软件时&#xff0c;往往都会面对本地私有部署和SaaS公有云两种不同的电子签章软件安装部署方式&#xff0c;而不知道到底应…

使用c++实现输出爱心(软件:visual Studio)

#include <iostream> using namespace std;int main() {//爱心曲线方程(x^2y^2-a)^3-x^2*y30double a 0.5;//定义绘图边界double bound 1.3 * sqrt(a);//x,y坐标变化步长double step 0.05;//二维扫描所有点,外层逐层扫描for (double y bound; y > -bound; y - ste…

DeepSpeed4Science:利用先进的AI系统优化技术实现科学发现

本文转载自微软 DeepSpeed 团队官方知乎账号&#xff1a;zhihu.com/people/deepspeed&#xff0c;由微软 DeepSpeed 团队翻译自官方英文博客&#xff1a;Announcing the DeepSpeed4Science Initiative: Enabling large-scale scientific discovery through sophisticated AI sy…

机器学习,深度学习

一 、Numpy 1.1 安装numpy 2.2 Numpy操作数组 jupyter扩展插件&#xff08;用于显示目录&#xff09; 1、pip install jupyter_contrib_nbextensions -i https://pypi.tuna.tsinghua.edu.cn/simple 2、pip install jupyter_nbextensions_configurator -i https://pypi.tuna.t…

26069-2022 硅单晶退火片 思维导图

声明 本文是学习GB-T 26069-2022 硅单晶退火片. 而整理的学习笔记,分享出来希望更多人受益,如果存在侵权请及时联系我们 1 范围 本文件规定了硅单晶退火片(以下简称退火片)的分类、技术要求、试验方法、检验规则、包装、标志、 运输、贮存、随行文件及订货单内容。 本文件…

如何去开展软件测试工作

1. 软件测试 在一般的项目中&#xff0c;一开始均为手动测试&#xff0c;由于自动化测试前期投入较大&#xff0c;一般要软件项目达到一定的规模&#xff0c;更新频次和质量均有一定要求时才会上自动化测试或软件测试。 1.1. 项目中每个成员的测试职责 软件测试从来不是某一…

windows server 远程桌面服务配置和授权解决方法

适用&#xff1a;win server 2016以上 win server默认的连接数是两个用户。 1.添加远程桌面授权服务 第一步&#xff1a;服务器管理 - 添加角色和功能打开添加角色和功能向导窗口&#xff0c;选择基于角色或给予功能安装 第二步&#xff1a;添加远程桌面会话主机和远程桌面授…

Serlet API详解

目录 一、HttpServlet 1.1 处理doGet请求 1.2 处理doPost请求 二、HttpServletRequest 2.1 核心方法 三、HttpServletRespons 3.1 核心方法 一、HttpServlet 在编写Servlet代码的时候&#xff0c;首先第一步要做的就是继承HttpServlet类&#xff0c;并重写其中的某些方法 核心…

Java-day18(网络编程)

网络编程 1.概述 Java提供跨平台的网络类库&#xff0c;可以实现无痛的网络连接&#xff0c;程序员面对的是一个统一的网络编程环境 网络编程的目的&#xff1a;直接或间接地通过网络协议与其他计算机进行通信 网络编程的两个主要问题&#xff1a; 1.如何准确定位网络上一台…

MybatisPlus自定义SQL用法

1、功能概述&#xff1f; MybatisPlus框架提供了BaseMapper接口供我们使用&#xff0c;大大的方便了我们的基础开发&#xff0c;但是BaseMapper中提供的方法很多情况下不够用&#xff0c;这个时候我们依旧需要自定义SQL,也就是跟mybatis的用法相同&#xff0c;自定义xml映射文…

VS CODE中的筛选器如何打开?

最近更新了vscode1.82版本&#xff0c;发现在git管理界面有一个“筛选器”功能&#xff0c;十分好用&#xff0c;后来关掉了&#xff0c;找了好久都没有找到办法打开这个筛选器功能&#xff0c;今天无意中不知道按到了哪个快捷键&#xff0c;打开了&#xff0c;就是下图这个&am…

矿山无人驾驶的“奇点时刻”

三年前&#xff0c;矿山无人驾驶赛道还处于整个自动驾驶产业“鄙视链的最底端”&#xff1b;但三年后的今天&#xff0c;这个赛道&#xff0c;却成了无人驾驶&#xff08;L4&#xff09;商业化落地难得的亮点——当前&#xff0c;头部的几家矿山无人驾驶公司都已实现去安全员运…

C#WPF通知更改公共类使用实例

本文实例演示C#WPF通知更改公共类使用实例,通过使用公共类简化了代码。其中的代码中也实现了命令的用法。 定义: INotifyPropertyChanged 接口:用于向客户端(通常是执行绑定的客户端)发出某一属性值已更改的通知。 首先创建WPF项目,添加按钮和文本控件 <Window x:C…

05-Zookeeper典型使用场景实战

上一篇&#xff1a;04-Zookeeper集群详解 1. Zookeeper 分布式锁加锁原理 如上实现方式在并发问题比较严重的情况下&#xff0c;性能会下降的比较厉害&#xff0c;主要原因是&#xff0c;所有的连接都在对同一个节点进行监听&#xff0c;当服务器检测到删除事件时&#xff0c…

平面设计cdr和ai有什么区别,哪个好用?2023年全新功能解析

平面设计cdr和ai有什么区别 我们做设计的同学经常会把cdr和ai来做比较。要知道&#xff0c;cdr和ai软件都是可以制作专业的矢量图。二者在功能上各有千秋&#xff0c;在绘图领域中也是平分秋色&#xff0c;绝大多数的效果&#xff0c;谁都能完成。但是对于操作方面&#xff0c;…

vue3 - 使用 xlsx 库将数据导出到 Excel 文件

GitHub Demo 地址 在线预览 xlsx是由SheetJS开发的一个处理excel文件的JavaScript库。它可以读取、编写和操作 Excel 文件 安装xlsx npm install xlsx --save实现一个通过的数据导出工具类 import * as XLSX from xlsx/*** description: 导出excel* param {any} dataList* p…

西域商品详情数据接口

西域平台是西域智慧供应链&#xff08;上海&#xff09;股份公司旗下的MRO工业品B2B电商采购平台。 西域平台成立于2002年&#xff0c;于2009年进入MRO工业品B2B电商行业。经过十多年深耕与探索&#xff0c;西域平台已为包括80%央国企及60%的全球500强企业在内的3万余家国内外…

Qt5开发及实例V2.0-第十章Qt网络与通信

Qt5开发及实例V2.0-第十章Qt网络与通信 第10章 Qt 5网络与通信10.1 获取本机网络信息10.2 基于UDP的网络广播程序10.2.1 UDP协议工作原理10.2.2 UDP 编程模型10.2.3 【实例】&#xff1a;UDP服务器编程10.2.4 【实例】&#xff1a;UDP客户端编程 10.3 基于TCP的网络聊天室程序1…

力扣(LeetCode)1333. 餐厅过滤器(C++)

优先队列 请读者读题&#xff0c;应该会发现两个重点&#xff1a;过滤器和排序。大家有没有发现这个效果&#xff0c;有点像xx点评: 大家选店一般在口味/距离/价格能接受的前提下&#xff0c;选评分最高的那家店hh&#xff0c;这就是过滤器的效果。排序是说&#xff0c;对满足…

【SQL】统一训练平台数据库实践--20230927

储存过程vlookup_peopledata_csodtraining 默认导出用今天批次的数据进行join on&#xff0c;先删除过渡表的资料&#xff0c;再将查询结果放在过渡表中。 BEGINDECLARE startdate varchar(50);SET startdate date_format(NOW(),%Y%m%d);DELETE FROM season.csod_data2;INSE…