springboot整合easy-es实现数据的增删改查

news2024/11/18 13:25:03

背景

目前公司的一个老项目，查询贼慢，需要想办法提升一下速度，于是就想到了ES，现在尝试一下将ES整合到项目中来提升检索效率。

ES是基于倒排索引实现的，倒排索引中一个表相当于一个索引，表中的每条记录都是一个文档（JSON数据），系统会先对字段数据进行分词，然后给词条建立索引，并映射到文档id。在查询的时候根据输入进行分词，然后根据词条走索引查询文档id，再根据文档id查询文档并放入结果集，最后将结果集返回。

一般来说，ES算是难度较高的一个技术栈，需要中高级才能熟练驾驭，新手入门比较难，因而我选中了对新手更加友好的easy-es，其在ES的基础上做了封装，使得使用起来和MybatisPlus很像，简单上手。

开始使用easy-es之前，建议先看一下避坑指南

Elastic Search下载

ES官网
按照官方推荐下载7.x的ES，我下载了和官方demo一样的7.14.0版本。
在这里插入图片描述
在这里插入图片描述
输入7.14.0搜索该版本并下载
在这里插入图片描述
在这里插入图片描述

下载完成之后解压，并去到bin目录，双击elasticsearch.bat文件启动elasticsearch。

Springboot整合ES

  1. 打开Springboot项目（或创建一个Springboot项目），先全局搜索elastic，看看项目是否已经引入过ES，如果有，需要去掉或者更改版本为7.14.0。印象中不同版本的Springboot默认引入的一定版本的ES。
  2. 在POM文件引入依赖
        <!-- 引入easy-es最新版本的依赖-->
        <dependency>
            <groupId>org.dromara.easy-es</groupId>
            <artifactId>easy-es-boot-starter</artifactId>
            <!--这里Latest Version是指最新版本的依赖,比如2.0.0,可以通过下面的图片获取-->
            <version>Latest Version</version>
        </dependency>

        <!-- 排除springboot中内置的es依赖,以防和easy-es中的依赖冲突-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.elasticsearch.client</groupId>
                    <artifactId>elasticsearch-rest-high-level-client</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.elasticsearch</groupId>
                    <artifactId>elasticsearch</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.14.0</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>7.14.0</version>
        </dependency>
  1. YAML文件增加ES配置（更多配置可以在官网看）
easy-es:
  enable: true #默认为true,若为false则认为不启用本框架
  address: 127.0.0.1:9200 # es的连接地址,必须含端口 若为集群,则可以用逗号隔开 例如:127.0.0.1:9200,127.0.0.2:9200
# username: elastic #若无 则可省略此行配置。因为刚下载的ES默认不用账号密码登录，所以注掉
#  password: WG7WVmuNMtM4GwNYkyWH #若无 则可省略此行配置
  1. 在启动类设置ES的mapper包扫描路径（一般应该设置成带*的通配格式，方便多模块项目的扫描。）同时注意，该mapper的包和mybatisplus的包不能是同一个，不然框架区分不开。
    在这里插入图片描述
@EsMapperScan("org.jeecg.modules.test.esmapper")
@SpringBootApplication
public class JeecgSystemApplication extends SpringBootServletInitializer {

    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
        return application.sources(JeecgSystemApplication.class);
    }

    public static void main(String[] args) throws UnknownHostException {
        ConfigurableApplicationContext application = SpringApplication.run(JeecgSystemApplication.class, args);
    }
}
  1. 创建实体类(加上@IndexName注解)
package org.jeecg.modules.message.entity;

import org.dromara.easyes.annotation.IndexField;
import org.dromara.easyes.annotation.IndexName;
import org.dromara.easyes.annotation.rely.Analyzer;
import org.dromara.easyes.annotation.rely.FieldType;
import org.jeecg.common.aspect.annotation.Dict;
import org.jeecg.common.system.base.entity.JeecgEntity;
import org.jeecgframework.poi.excel.annotation.Excel;
import org.springframework.format.annotation.DateTimeFormat;

import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;

import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

@Data
@IndexName
public class SysMessage{
	/** ID */
	@TableId(type = IdType.ASSIGN_ID)
	private java.lang.String id;
	/**推送内容*/
	private java.lang.String esContent;
	/**推送所需参数Json格式*/
	private java.lang.String esParam;
	/**接收人*/
	private java.lang.String esReceiver;
	/**推送失败原因*/
	private java.lang.String esResult;
	/**发送次数*/
	private java.lang.Integer esSendNum;
	/**推送状态 0未推送 1推送成功 2推送失败*/
	private java.lang.String esSendStatus;
	/**推送时间*/
	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
	private java.util.Date esSendTime;
	/**消息标题*/
	private java.lang.String esTitle;
	/**推送方式：1短信 2邮件 3微信*/
	private java.lang.String esType;
	/**备注*/
	private java.lang.String remark;
		/** 创建人 */
	private java.lang.String createBy;
	/** 创建时间 */
	@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
	@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
	private java.util.Date createTime;
	/** 更新人 */
	private java.lang.String updateBy;
	/** 更新时间 */
	@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
	@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
	private java.util.Date updateTime;
}
  1. 创建mapper类
package org.jeecg.modules.test.esmapper;


import org.dromara.easyes.core.core.BaseEsMapper;
import org.jeecg.modules.message.entity.SysMessage;
public interface DocumentMapper extends BaseEsMapper<SysMessage> {

}
  1. 编写测试类
	@Resource
	private DocumentMapper documentMapper;

	@GetMapping("/createIndex")
	@ApiOperation("创建索引")
	public Object createIndex(String a){
		Boolean index = documentMapper.createIndex();
		System.out.println(index);
		return index;
	}

	@GetMapping("/createDoc")
	@ApiOperation("创建文档")
	public Object createDoc(String a,String b){
		SysMessage sysMessage=new SysMessage();
		sysMessage.setEsContent(a);
		sysMessage.setEsTitle(b);
		sysMessage.setEsReceiver("系统管理员");
		sysMessage.setEsSendNum(10);
		Integer insert = documentMapper.insert(sysMessage);
		return insert;
	}
	@GetMapping("/updateDoc")
	@ApiOperation("updateDoc")
	public Object updateDoc(String a){
		LambdaEsUpdateWrapper<SysMessage> wrapper=new LambdaEsUpdateWrapper<>();
		wrapper.eq(SysMessage::getEsContent,a)
				.set(SysMessage::getEsContent,"更改后的标题");
		Integer update = documentMapper.update(null, wrapper);
		return update;
	}
	@GetMapping("/getDoc")
	@ApiOperation("查询文档")
	public Object getDoc(String a){
		List<SysMessage> list = EsWrappers.lambdaChainQuery(documentMapper).like(SysMessage::getEsContent, a).list();
		return list;
	}
  1. 浏览器安装一个ES可视化插件。我安装的是es-client
    在这里插入图片描述
    添加连接
    在这里插入图片描述
    在这里插入图片描述
    选中创建的连接，目前还没有索引。
    在这里插入图片描述
  2. 测试
    启动Springboot项目，调用createIndex接口，创建索引 。然后回到浏览器插件，点击刷新，可以看到创建了一个索引。
    在这里插入图片描述
    调用createDoc接口，创建一个文档记录
    在这里插入图片描述
    点击左侧的数据展示选项，右上角选中创建的索引，点击刷新，可以看到多了一条记录。
    在这里插入图片描述
    调用getDoc接口，查询记录，成功查出。
    在这里插入图片描述
    更新的语法和MybatisPlus的wrapper差不多。先用查询条件eq,in等去筛选要更新的记录，然后用set去设置新的值，然后调用update方法即可。（如下，通过“测试内容”找到记录，并将其的标题改成新的内容）
    在这里插入图片描述
    在浏览器刷新，可以看到数据更新了。
    在这里插入图片描述

删除的语法比更新还简单，也是创建一个esupdatewrapper，用eq、in等筛选，然后调用delete方法就可以了，就不演示了。

总结

Springboot整合ES最大可能遇到的问题就是ES版本的问题，也就是依赖冲突。如果依赖冲突，在项目启动的时候会有一个ERROR日志提醒，看到了就想办法去掉原来带着的ES依赖或者更改依赖版本为7.14.0

关于ES的数据更新，就要去了解ES同步数据库相关的知识了。

想要了解easy-es的更多特性，建议去看easy-es的官网文档。

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

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

相关文章

yolov1网络结构说明

yolov1网络结构说明

文章目录 一. 网络结构二. 网络说明1. 网络的输入2. 网络的输出(1) 5 5表示:每个网格使用两个先验框进行预测。(2) “5”表示&#xff1a;每个先验框包含的预测信息的数量。(3) 20表示&#xff1a;20个分类预测值(4) 每个网格能预测几个目标&#xff1f; 一. 网络结构 论文下…
阅读更多...
海外储能认证标准

海外储能认证标准

北美认证 UL9540 代表一个封装完整的储能系统功能安全认证&#xff0c;关注机械测试&#xff0c;电器测试和环境测试 UL9540A 关注消防本身&#xff0c;UL9540A测试主要从电池储能系统安装参数&#xff0c;安装通风要求&#xff0c;消防设施&#xff0c;消防策略和应对措施…
阅读更多...
一个小学数学题

一个小学数学题

如下面动图所示&#xff0c;问阴影部分的面积是不是不变的&#xff1f; 求解&#xff1a; 当弦BC和DE平行时&#xff0c;扇区 A B ⌢ \overset{\LARGE{\frown}}{AB} AB⌢不变&#xff0c;BC到DE的距离始终保持不变&#xff0c;假设两条线段之间的距离为H, 由三角形的面积公式&…
阅读更多...
TZOJ 1370 数值统计

TZOJ 1370 数值统计

答案&#xff1a; #include <stdio.h> int main() {int n0,i0;int fcount 0; //负数计数器int zcount 0; //整数计数器int pcount 0; //小数计数器while (scanf("%d", &n) 1 && n ! 0) //多组输入&#xff0c;并且不为0{double…
阅读更多...
LeetCode（37）矩阵置零【矩阵】【中等】

LeetCode（37）矩阵置零【矩阵】【中等】

目录 1.题目2.答案3.提交结果截图 链接&#xff1a; 73. 矩阵置零 1.题目 给定一个 m x n 的矩阵&#xff0c;如果一个元素为 0 &#xff0c;则将其所在行和列的所有元素都设为 0 。请使用 原地 算法。 示例 1&#xff1a; 输入&#xff1a;matrix [[1,1,1],[1,0,1],[1,1,1]…
阅读更多...
试试手气（Python）

试试手气（Python）

题目描述 试试手气 我们知道一个骰子有 6 个面&#xff0c;分别刻了 1 到 6 个点。下面给你 6 个骰子的初始状态&#xff0c;即它们朝上一面的点数&#xff0c;让你一把抓起摇出另一套结果。假设你摇骰子的手段特别精妙&#xff0c;每次摇出的结果都满足以下两个条件&#xff…
阅读更多...
Java多线程核心技术一-多线程基础其他内容

Java多线程核心技术一-多线程基础其他内容

接上篇&#xff1a; Java多线程核心技术一-基础篇synchronzied同步方法 Java多线程核心技术一-基础篇synchronzied同步语句块 1 String常量池特性与同步问题 JVM具有String常量池的功能&#xff0c;如下示例&#xff1a; public class Test01 {public static void main(Str…
阅读更多...
TZOJ 1367 计算两点间的距离

TZOJ 1367 计算两点间的距离

答案&#xff1a; #include <stdio.h> #include<math.h> //引用数学的库函数 int main() {double x1 0.0, y1 0.0, x2 0.0, y2 0.0; //由于输入的是实数&#xff0c;实数包括小数&#xff0c;所以不能 用int类型&#xff0c;只能用double类型while (sc…
阅读更多...
elementui中table进行表单验证

elementui中table进行表单验证

<el-form :model"ruleForm" ref"ruleForm" class"demo-ruleForm"><el-table :data"ruleForm.tableDataShou" border style"width: 100%;"><el-table-column type"index" label"序号" wi…
阅读更多...
Python - Real-ESRGAN 提升图像、视频清晰度 - 最高可达 4 K

Python - Real-ESRGAN 提升图像、视频清晰度 - 最高可达 4 K

目录 一.引言 二.Real-ESRGAN 理论 1.模型简介 2.经典退化模型 ◆ 退化过程全览 ◆ K - 高斯滤波 ◆ N - 噪声 ◆ ↓r - Resize ◆ jpeg - 压缩 3.高阶退化模型 4.环形和超调伪影 5.网络结构 ◆ ESRGAN 生成器 ◆ U-Net 鉴别器 三.Real-ESRGAN 实战 1.快速体验…
阅读更多...
CNS0项目创建交货单增加销售办事处

CNS0项目创建交货单增加销售办事处

1、业务需求 1.1、销售办事处介绍 销售办事处是指在企业中负责销售活动的区域性单位或部门。在SD模块中&#xff0c;可以表示企业的不同销售地点、销售办公室、分销中心或分公司。 销售办事处扮演着多种角色和职责&#xff0c;例如&#xff1a; 销售活动管理&#xff1a;销售…
阅读更多...
福州大学《嵌入式系统综合设计》 实验十二：图像压缩标准JPEG编解码

福州大学《嵌入式系统综合设计》 实验十二：图像压缩标准JPEG编解码

一、实验目的 掌握基于算能平台的JPEG压缩编码方法以及开发环境&#xff0c;包括开发主机环境搭建&#xff0c;硬件嵌入式开发板的连接&#xff0c;云平台的配置&#xff0c;编码程序的编译、运行等。 二、实验内容 搭建实验开发环境&#xff0c;并编写静止图像jpeg格式编解…
阅读更多...
Linux常用命令——badblocks命令

Linux常用命令——badblocks命令

在线Linux命令查询工具 badblocks 查找磁盘中损坏的区块 补充说明 badblock命令用于查找磁盘中损坏的区块。 硬盘是一个损耗设备&#xff0c;当使用一段时间后可能会出现坏道等物理故障。电脑硬盘出现坏道后&#xff0c;如果不及时更换或进行技术处理&#xff0c;坏道就会越…
阅读更多...
渗透测试考核（靶机1）

渗透测试考核（靶机1）

信息收集 主机发现 nbtscan -r 172.16.17.0/24 发现在局域网内&#xff0c;有两台主机名字比较可疑&#xff0c;177和134&#xff0c;猜测其为目标主机&#xff0c;其余的应该是局域网内的其他用户&#xff0c;因为其主机名字比较显眼&#xff0c;有姓名的拼音和笔记本电脑的…
阅读更多...
AI搜索相关性在网站和APP上的应用

AI搜索相关性在网站和APP上的应用

设定场景&#xff1a;您在寻找一件新衣服&#xff0c;所以在浏览最喜欢的网店。您跳到搜索栏上&#xff0c;输入您要找的东西。您期待出现什么结果&#xff1f; 高度准确、相关和即时的结果。 无论在什么网站上搜索&#xff0c;寻找什么&#xff0c;甚至在打错字或使用了错误的…
阅读更多...
【算法刷题】Day9

【算法刷题】Day9

文章目录 611. 有效三角形的个数![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/9d627e680e9144a2b67474a1d80aa030.png)题解&#xff1a;代码&#xff1a; LCR 179. 查找总价格为目标值的两个商品题解&#xff1a;代码&#xff1a; 611. 有效三角形的个数 原题链…
阅读更多...
双向ESD保护 汽车级TVS二极管 ESD9B3.3ST5G工作原理、特性参数、封装形式

双向ESD保护 汽车级TVS二极管 ESD9B3.3ST5G工作原理、特性参数、封装形式

什么是汽车级TVS二极管&#xff1f; TVS二极管是一种用于保护电子电路的电子元件。它主要用于电路中的过电压保护&#xff0c;防止电压过高而损坏其他部件。TVS二极管通常被称为“汽车级”是因为它们能够满足汽车电子系统的特殊要求。 在汽车电子系统中&#xff0c;由于车辆启…
阅读更多...
零基础自学编程，中文编程工具下载，中文编程工具构件之弹出菜单构件简介

零基础自学编程，中文编程工具下载，中文编程工具构件之弹出菜单构件简介

一、前言&#xff1a; 零基础自学编程&#xff0c;中文编程工具下载&#xff0c;中文编程工具构件之弹出菜单构件简介 编程系统化教程链接 https://jywxz.blog.csdn.net/article/details/134073098?spm1001.2014.3001.5502 给大家分享一款中文编程工具&#xff0c;零基础…
阅读更多...
二阶龙格塔库积分法求解混沌产生方程（求助）

二阶龙格塔库积分法求解混沌产生方程（求助）

最近论文中常常接触到激光产生混沌的方程&#xff0c;激光器作为非线性元件&#xff0c;在信息处理中具有非常大的潜力&#xff0c;其中激光产生混沌应用在通信中很有用处。论文中对于模拟数据部分&#xff0c;采用了以下公式来产生混沌&#xff1a;以此公式产生混沌的方法应用…
阅读更多...
【HTML】VScode不打开浏览器实时预览html

【HTML】VScode不打开浏览器实时预览html

1. 问题描述 预览HTML时&#xff0c;不想打开浏览器&#xff0c;想在VScode中直接实时预览 2. 解决方案 下载Microsoft官方的Live Preview 点击预览按钮即可预览
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023