首页 > 资讯 > 后端开发 > Python >Springboot集成Elasticsearch的步骤与相关功能

592

分享到

Springboot集成Elasticsearch的步骤与相关功能

2024-04-02 19:04:59 592人浏览安东尼

Python 官方文档：入门教程 => 点击学习

摘要

目录集成配置步骤步骤1：加入 Maven 相关依赖步骤2：配置 elasticsearch 的主机和端口步骤3：配置 Elaseticsearch 客户端步骤4：创建文档实体步骤5：

1. 添加文档
2. 修改文档
3. 根据ID查询文档
4. 根据ID删除文档
5. 查询所有文档
6. 条件查询（单个条件）
7. 条件查询（多条件）
8. 分页查询（降序）
9. 分页查询（升序）
10. 分页查询
11. 范围查询（ > ）
12. 范围查询（ >= ）
13. 范围查询（ < ）
14. 范围查询（ <= ）
附：ElasticSearch中对索引的一些常用操作

总结

集成配置步骤

步骤1：加入 Maven 相关依赖


<!-- 指定 SpringBoot 版本 -->
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.5.7</version>
    <relativePath/>
</parent>
 
<!-- 相关jar包 -->
<dependencies>
    <!-- SpringBoot核心jar包 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <!-- web开发包：包含Tomcat和springMVC -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-WEB</artifactId>
    </dependency>
    <!-- ES 核心包 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>
    <!-- lombok 实体简化插件 -->
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
</dependencies>

步骤2：配置 elasticsearch 的主机和端口


elasticsearch:
  host: 127.0.0.1
  port: 9200

步骤3：配置 Elaseticsearch 客户端


@Data
@Configuration
@ConfigurationProperties(prefix = "elasticsearch")
public class ElasticSearchConfig extends AbstractElasticsearchConfiguration {
 
    private String host;
    private Integer port;
 
    @Override
    public RestHighLevelClient elasticsearchClient() {
        return new RestHighLevelClient(RestClient.builder(new HttpHost(host, port)));
    }
 
}

步骤4：创建文档实体


@Data
@Document(indexName = "users")
public class User {
 
    @Id
    @Field(type = FieldType.Long)
    private Long id;
 
    @Field(type = FieldType.Text)
    private String name;
 
    @Field(type = FieldType.KeyWord)
    private String sex;
 
    @Field(type = FieldType.Integer)
    private Integer age;
 
    @Field(type = FieldType.Text)
    private String address;
 
}

步骤5：创建 controller，service， dao 层

（5.1）contrller 层


@RestController
@RequestMapping("/user")
public class UserController {
 
    @Autowired
    private UserService userService;
 
}

（5.2）service 层


public interface UserService {
 
}

（5.3）service 实现层（UserDao 见 5.4）


@Service
public class UserServiceImpl implements UserService {
 
    @Autowired
    private UserDao userDao;
 
}

（5.4）dao 层


@Repository
public interface UserDao extends ElasticsearchRepository<User, Long> {
 
}

整个相关类创建完成后，项目结构应该如下图所示：

相关功能实现

这里以实际功能举例，并列出 controller 和 service 层的实现类写法作为参考。

主流的一些功能，ES 已经给你封装，默认给与了支持（如：示例1-6），这些相关的实现不需要我们再写 dao 层，但一些较为业务性的查询，还需要自己手动来写。

1. 添加文档

controller 层：


@PostMapping("/save")
public String save(@RequestBody User user) {
    long id = System.currentTimeMillis();
    user.setId(id);
    userService.save(user);
    return "新增成功,id为：" + id;
}

service 层：


@Override
public Long save(User user) {
    userDao.save(user);
    return user.getId();
}

测试效果：

2. 修改文档

【注】新增文档和修改文档操作，dao 层都是调用的 save() 方法，当 id 不存在的时候，ES（ElasticSearch）就会执行新增操作，当 id 对象已经存在的时候，就会执行修改操作。

controller 层：


@PostMapping("/update")
public String update(@RequestBody User user) {
    userService.save(user);
    return "修改成功";
}

service 层：


@Override
public Long save(User user) {
    userDao.save(user);
    return user.getId();
}

测试效果：

3. 根据ID查询文档

controller 层：


@GetMapping("/{id}")
public User getById(@PathVariable("id") Long id) {
    return userService.getById(id);
}

service 层：


@Override
public User getById(Long id) {
    Optional<User> find = userDao.findById(id);
    if (find.isPresent()) {
        return find.get();
    }
    return null;
}

测试效果：

4. 根据ID删除文档

controller 层：


@DeleteMapping("/{id}")
public String deleteById(@PathVariable("id") Long id) {
    userService.deleteById(id);
    return "删除成功";
}

service 层：


@Override
public void deleteById(Long id) {
    userDao.deleteById(id);
}

测试效果：

5. 查询所有文档

controller 层：


@GetMapping("/all")
public List<User> all() {
    return userService.getAll();
}

service 层：


@Override
public List<User> getAll() {
    Iterable<User> users = userDao.findAll();
    if (users == null) {
        return Collections.emptyList();
    }
    List<User> userList = new ArrayList<User>();
    users.forEach(o -> userList.add(o));
    return userList;
}

测试效果：

6. 条件查询（单个条件）

如：查询name包含"玛丽"的数据

controller 层：


@GetMapping("/listByName")
public List<User> listByName(String name) {
    return userService.getListByName(name);
}

service 层：


@Override
public List<User> getListByName(String name) {
    return userDao.findByName(name);
}

dao 层：测试效果：

7. 条件查询（多条件）

如：查询 name包含"玛丽"，年龄为25的数据。

controller 层：


@GetMapping("/listByNameAndAge")
public List<User> listByNameAndAge(String name, Integer age) {
    return userService.getListByNameAndAge(name, age);
}

service 层：


@Override
public List<User> getListByNameAndAge(String name, Integer age) {
    return userDao.findByNameAndAge(name, age);
}

dao 层：


List<User> findByNameAndAge(String name, Integer age);

8. 分页查询（降序）

controller 层：


@GetMapping("/listOrderByAgeDesc")
public List<User> listOrderByAgeDesc() {
    return userService.getListOrderByAgeDesc();
}

service 层：


@Override
public List<User> getListOrderByAgeDesc() {
    return userDao.findByOrderByAgeDesc();
}

dao 层：


List<User> findByOrderByAgeDesc();

测试效果：

9. 分页查询（升序）

controller 层：


@GetMapping("/listOrderByAgeAsc")
public List<User> listOrderByAgeAsc() {
    return userService.getListOrderByAgeAsc();
}

service 层：


@Override
public List<User> getListOrderByAgeAsc() {
    return userDao.findByOrderByAgeAsc();
}

dao 层：


List<User> findByOrderByAgeAsc();

测试效果：

10. 分页查询

controller 层：


@GetMapping("/page")
public Page<User> page(Integer pageNum, Integer pageSize) {
    return userService.getPage(pageNum, pageSize);
}

service 层：


@Override
public Page<User> getPage(int pageNum, int pageSize) {
    // 注意，这里的pageNum是从0开始的，如果要查询第1页数据，pageNum应该为0
    Pageable pageable = PageRequest.of(pageNum, pageSize);
    return userDao.findAll(pageable);
}

测试效果：

11. 范围查询（ > ）

controller 层：


@GetMapping("/listGreaterThanAge")
public List<User> listGreaterThanAge(Integer age) {
    return userService.getListGreaterThanAge(age);
}

service 层：


@Override
public List<User> getListGreaterThanAge(Integer age) {
    return userDao.findByAgeGreaterThan(age);
}

dao 层：


List<User> findByAgeGreaterThan(Integer age);

测试效果：

12. 范围查询（ >= ）

controller 层：


@GetMapping("/listGreaterThanEqualAge")
public List<User> listGreaterThanEqualAge(Integer age) {
    return userService.getListGreaterThanEqualAge(age);
}

service 层：


@Override
public List<User> getListGreaterThanEqualAge(Integer age) {
    return userDao.findByAgeGreaterThanEqual(age);
}

dao 层：


List<User> findByAgeGreaterThanEqual(Integer age);

测试效果：

13. 范围查询（ < ）

controller 层：


@GetMapping("/listLessThanAge")
public List<User> listLessThanAge(Integer age) {
    return userService.getListLessThanAge(age);
}

service 层：


@Override
public List<User> getListLessThanAge(Integer age) {
    return userDao.findByAgeLessThan(age);
}

dao 层：


List<User> findByAgeLessThan(Integer age);

测试效果：

14. 范围查询（ <= ）

controller 层：


@GetMapping("/listLessThanEqualAge")
public List<User> listLessThanEqualAge(Integer age) {
    return userService.getListLessThanEqualAge(age);
}

service 层：


@Override
public List<User> getListLessThanEqualAge(Integer age) {
    return userDao.findByAgeLessThanEqual(age);
}

dao 层：


List<User> findByAgeLessThanEqual(Integer age);

测试效果：

附：ElasticSearch中对索引的一些常用操作

1. 获取Elasticsearch中所有的index:

curl -XGET 'localhost:9200/_cat/indices?v&pretty'

2. 获取某索引下所有的type:

获取elasticsearch索引下所有的type定义

curl -XGET 'localhost:9200/elasticsearch/_mapping'

3. 删除索引:

删除elasticsearch1索引

curl -XDELETE 'localhost:9200/elasticsearch1?pretty'

4. 删除某索引下的某type数据：

删除索引elasticsearch下的article类型

curl -XDELETE 'http://localhost:9200/elasticsearch/article/'

5. 查看某索引的某type下所有的数据：

查找elasticsearch索引中所有的类型为Company的数据

http://localhost:9200/elasticsearch/Company/_search

总结

到此这篇关于Springboot集成Elasticsearch的文章就介绍到这了,更多相关Springboot集成Elasticsearch内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: Springboot集成Elasticsearch的步骤与相关功能

本文链接: https://www.lsjlt.com/news/159845.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

猜你喜欢

Springboot集成Elasticsearch的步骤与相关功能

目录集成配置步骤步骤1：加入 Maven 相关依赖步骤2：配置 elasticsearch 的主机和端口步骤3：配置 Elaseticsearch 客户端步骤4：创建文档实体步骤5：...

99+

2024-04-02
SpringBoot集成EasyExcel的步骤

目录一、EasyExcel简介二、常用注解三、依赖四、监听五、接口导入Excel六、接口导出Excel (HttpServletResponse response, HttpS...

99+

2024-04-02
springboot集成apidoc的步骤

本篇内容主要讲解“springboot集成apidoc的步骤”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“springboot集成apidoc的步骤”吧!一、apidoc简介apidoc通过在你...

99+

2023-06-19
springboot集成opencv实现人脸识别功能的详细步骤

目录前言什么是opencv？项目集成步骤准备工作代码Linux安装opencvLinux启动github直接白嫖前言项目中检测人脸图片是否合法的功能，之前用的是百度的人脸识别接口，...

99+

2024-04-02
springboot 集成dubbo的步骤详解

目录第一步搭建zookeeper环境第二步 springboot集成dubbo1.项目目录机构2.代码编写2.1 api目录2.2 consumer目录 web访问、接口调用以及d...

99+

2024-04-02
springboot集成mybatisplus的详细步骤

目录Mybatis-Plus介绍简介特性（官网提供）一、引入POM依赖二、配置文件application.yml三、编写表映射实体类四、编写Mapper五、测试Controller六...

99+

2022-11-13

springboot集成mybatisplus springboot mybatisplus
SpringBoot Admin2.0集成Arthas的实现步骤

小编给大家分享一下SpringBoot Admin2.0集成Arthas的实现步骤，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！项目最初使用 Arthas 主要有...

99+

2023-06-14
SpringBoot Admin2.0 集成Arthas的实现步骤

目录技术选型相关整体结构实现效果改造方案1. 整体工程结构2. 外部链接配置 3. 对应 Spring MVC controller 实现 4. Arthas Spring Bo...

99+

2024-04-02
SpringBoot集成Caffeine缓存的实现步骤

目录Maven依赖配置示例 Maven依赖要开始使用咖啡因Caffeine和Spring Boot，我们首先添加spring-boot-starter-cache和咖啡因Ca...

99+

2024-04-02
SpringBoot项目集成FTP的方法步骤

目录写在前面FTP相关软件安装开始集成引入相关jar包引入FTPUtils.java和FTPHelper.java如何使用写在前面 FTP是一个文件传输协议，被开发人员广泛用于在互...

99+

2024-04-02
PHP 中基于 Elasticsearch 的相关搜索功能开发实践

概述在现代Web开发中，搜索功能是一个非常重要的部分。而Elasticsearch作为一个强大而灵活的分布式搜索引擎，被广泛应用于各类Web应用中。本文将介绍如何在PHP中使用Elasticsearch开发相关搜索功能，并附上具体的代码示例...

99+

2023-10-21

elasticsearch 开发实践相关搜索
SAP SD与FI集成相关的流程与配置是什么

这篇“SAP SD与FI集成相关的流程与配置是什么”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“SAP SD与FI集成相关的...

99+

2023-06-05
springboot集成JWT实现身份认证(权鉴)的方法步骤

目录一、什么是JWT二、JWT组成三、JWT运行原理四、springboot集成JWT一、什么是JWT JSON Web Token (JWT)，它是目前最流行的跨域身份验证解决方案...

99+

2023-05-16

springboot JWT身份认证 springboot JWT身份权鉴
SpringBoot集成Mybatis-plus并实现自动生成相关文件的示例代码

Mybatis-Plus是一个优秀的Mybatis增强工具，目前更新到3.1.1。Mybatis-Plus原生提供了很多单表操作的方法，极大简化了繁琐的curd的操作，同时又支持xm...

99+

2024-04-02
在Ant Design Pro登录功能中集成图形验证码组件的方法步骤

前言：本篇文章只介绍在Ant Design Pro登录功能中集成图形验证码组件的方法步骤，服务端方法请参考《基于OAuth2.0授权系统的验证码功能》正文：在Ant Desig...

99+

2024-04-02
使用PHP开发抽奖功能的步骤与技巧

标题：使用PHP开发抽奖功能的步骤与技巧在网站开发中，抽奖功能常常被用来增加用户互动性和吸引力。使用PHP语言来开发抽奖功能是一种常见的方式。在本文中，将介绍如何使用PHP来开发一个...

99+

2024-02-29

php 步骤抽奖
关于Mysql搭建主从复制功能的步骤实现

目录1.描述2.开始远程连接3.开启bin-log日志4.重启两台mysql5.授权Ⅰ授权Ⅱ6.配置从服务器7.启动从库的复制功能8.检查从库复制功能状态1.描述在实际的生产中，为了解决Mysql的单点故障已经提高My...

99+

2023-05-23

Mysql 主从复制搭建主从复制
SpringBoot集成Mybatis-plus并实现自动生成相关文件的示例代码怎么写

这篇文章给大家介绍SpringBoot集成Mybatis-plus并实现自动生成相关文件的示例代码怎么写，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。Mybatis-Plus是一个优秀的Mybatis增强工具，目前更新...

99+

2023-06-22
win7系统自动播放功能关闭的步骤是什么

这篇文章给大家介绍win7系统自动播放功能关闭的步骤是什么，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。在win7系统中，经常会出现一些自动播放的内容。这之中有很多内容是不需要自动播放的。有的用户想要关闭自动播放功能，...

99+

2023-06-28
springboot业务功能实战之告别轮询websocket的集成使用

目录后端代码前段代码总结后端代码首先加入pom文件 <dependency> <groupId>org.spring...

99+

2022-11-13

springboot集成websocket websocket集成使用