SpringBoot集成Elasticsearch 7.x | spring-boot-starter-data-elasticsear ...

何小豆儿在此  金牌会员 | 7 天前 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 805|帖子 805|积分 2415

媒介



  • 由 Spring 提供，是 Spring 在 ES 官方接口基础之上的二次封装，使用简朴，易于上手；
  • 缺点是更新太慢，SpringBoot 2.2.x 才提供对 es7.x 的支持，版本关联性很大，不易维护；
不外在此照旧讲一下 starter 启动器下的 集成步骤，万一官方更新速率加快了呢。
Java High Level Rest Client方式 去集成 Elasticsearch（这个是目前公司常用的方式）
添加maven依靠

  1. <!--spring boot 整合 elasticsearch -->
  2. <!--不用填写具体版本，spring boot 会自动找与之适配的 -->
  3. <dependency>
  4.   <groupId>org.springframework.boot</groupId>
  5.   <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  6. </dependency>
复制代码
配置application.properties

旧版本
  1. server.port=8091
  3. spring.elasticsearch.rest.uris=http://127.0.0.1:9200
  4. spring.elasticsearch.rest.username=elastic
  5. spring.elasticsearch.rest.password=1234567
复制代码
新版本(去掉了rest)
  1. server.port=8091
  3. spring.elasticsearch.uris=http://127.0.0.1:9200
  4. spring.elasticsearch.username=elastic
  5. spring.elasticsearch.password=1234567
复制代码
测试实体类

创建一个员工的实体类
关键注解 @Document、@Id、@Field
  1. package com.example.springbootfull.elasticsearch.bean;
  3. import org.springframework.data.annotation.Id;
  4. import org.springframework.data.elasticsearch.annotations.DateFormat;
  5. import org.springframework.data.elasticsearch.annotations.Document;
  6. import org.springframework.data.elasticsearch.annotations.Field;
  8. import java.math.BigDecimal;
  9. import java.util.Date;
  11. /**
  12. * 员工实体类
  13. * @Document：作用在类上，标记实体类为文档对象。 indexName（索引名称，相当于数据库的表名称）
  14. * @Id：作用在成员变量上，标记一个字段作为id主键。 在Elasticsearch中，文档ID是唯一的，用于标识文档。
  15. * @Field：定义Java对象属性与Elasticsearch文档字段之间的映射关系。
  16. * @author
  17. */
  18. @Document(indexName = "employee_info")
  19. public class EmployeeInfo {
  21.     @Id
  22.     private Long id;
  24.     /**
  25.      * 工号
  26.      */
  27.     @Field(name = "job_no")
  28.     private String jobNo;
  30.     /**
  31.      * 姓名
  32.      */
  33.     @Field(name = "name")
  34.     private String name;
  36.     /**
  37.      * 英文名
  38.      */
  39.     @Field(name = "english_name")
  40.     private String englishName;
  42.     /**
  43.      * 工作岗位
  44.      */
  45.     private String job;
  47.     /**
  48.      * 性别
  49.      */
  50.     private Integer sex;
  52.     /**
  53.      * 年龄
  54.      */
  55.     private Integer age;
  57.     /**
  58.      * 薪资
  59.      */
  60.     private BigDecimal salary;
  62.     /**
  63.      * 入职时间
  64.      */
  65.     @Field(name = "job_day", format = DateFormat.date_time)
  66.     private Date jobDay;
  68.     /**
  69.      * 备注
  70.      */
  71.     private String remark;
  73.     public Long getId() {
  74.         return id;
  75.     }
  77.     public void setId(Long id) {
  78.         this.id = id;
  79.     }
  81.     public String getJobNo() {
  82.         return jobNo;
  83.     }
  85.     public void setJobNo(String jobNo) {
  86.         this.jobNo = jobNo;
  87.     }
  89.     public String getName() {
  90.         return name;
  91.     }
  93.     public void setName(String name) {
  94.         this.name = name;
  95.     }
  97.     public String getEnglishName() {
  98.         return englishName;
  99.     }
  101.     public void setEnglishName(String englishName) {
  102.         this.englishName = englishName;
  103.     }
  105.     public String getJob() {
  106.         return job;
  107.     }
  109.     public void setJob(String job) {
  110.         this.job = job;
  111.     }
  113.     public Integer getSex() {
  114.         return sex;
  115.     }
  117.     public void setSex(Integer sex) {
  118.         this.sex = sex;
  119.     }
  121.     public Integer getAge() {
  122.         return age;
  123.     }
  125.     public void setAge(Integer age) {
  126.         this.age = age;
  127.     }
  129.     public BigDecimal getSalary() {
  130.         return salary;
  131.     }
  133.     public void setSalary(BigDecimal salary) {
  134.         this.salary = salary;
  135.     }
  137.     public Date getJobDay() {
  138.         return jobDay;
  139.     }
  141.     public void setJobDay(Date jobDay) {
  142.         this.jobDay = jobDay;
  143.     }
  145.     public String getRemark() {
  146.         return remark;
  147.     }
  149.     public void setRemark(String remark) {
  150.         this.remark = remark;
  151.     }
  153.     public EmployeeInfo() {
  154.     }
  156.     public EmployeeInfo(Long id, String jobNo, String name, String englishName, String job, Integer sex, Integer age, BigDecimal salary, Date jobDay, String remark) {
  157.         this.id = id;
  158.         this.jobNo = jobNo;
  159.         this.name = name;
  160.         this.englishName = englishName;
  161.         this.job = job;
  162.         this.sex = sex;
  163.         this.age = age;
  164.         this.salary = salary;
  165.         this.jobDay = jobDay;
  166.         this.remark = remark;
  167.     }
  169.     @Override
  170.     public String toString() {
  171.         return "EmployeeInfo{" +
  172.                 "id=" + id +
  173.                 ", jobNo='" + jobNo + '\'' +
  174.                 ", name='" + name + '\'' +
  175.                 ", englishName='" + englishName + '\'' +
  176.                 ", job='" + job + '\'' +
  177.                 ", sex=" + sex +
  178.                 ", age=" + age +
  179.                 ", salary=" + salary +
  180.                 ", jobDay=" + jobDay +
  181.                 ", remark='" + remark + '\'' +
  182.                 '}';
  183.     }
  184. }
复制代码
方式一：继续 ElasticsearchRepository（适合简朴查询）

   ElasticsearchRepository 提供了一个高级的抽象，使得你可以在不编写任何实当代码的情况下，直接使用预界说的CRUD方法和查询方法。
  业务层接口继续 ElasticsearchRepository 类
泛型的参数分别是实体类型和主键类型
例如：
  1. public interface EmployeeInfoRepository extends ElasticsearchRepository<EmployeeInfo, Long> {
  3. }
复制代码
然后就可以直接使用了
直接使用

添加单个文档
  1. package com.example.springbootfull.elasticsearch.controller;
  3. import com.example.springbootfull.elasticsearch.bean.EmployeeInfo;
  4. import com.example.springbootfull.elasticsearch.service.EmployeeInfoRepository;
  5. import com.example.springbootfull.elasticsearch.service.EmployeeInfoService;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.web.bind.annotation.GetMapping;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.RestController;
  11. import java.math.BigDecimal;
  12. import java.text.SimpleDateFormat;
  13. import java.util.ArrayList;
  14. import java.util.Iterator;
  15. import java.util.List;
  17. @RestController
  18. @RequestMapping("/employeeInfo")
  19. public class EmployeeElasticController {
  21.     @Autowired
  22.     private EmployeeInfoRepository elasticRepository;
  24.     @RequestMapping("/save")
  25.     public String save() throws Exception {
  26.         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
  27.         EmployeeInfo employeeInfo = new EmployeeInfo(6001L, "2001", "张三", "zhangsan", "Java", 1, 19, new BigDecimal("12500.01"), simpleDateFormat.parse("2019-09-10"), "备注");
  28.         elasticRepository.save(employeeInfo);
  29.         return "success";
  30.     }
  31.    
  32. }
复制代码
执行后，es上面新增成功了。

想自界说自己的Repository接口

   就要遵守 自界说方法命名规范
  【自界说方法命名约定】：

例如：我们来按照年龄区间查询，界说如许的一个方法findByAgeBetween：
  1. /**
  2. * 需要继承ElasticsearchRepository接口
  3. * 由于Item实体类中id为Long类型
  4. */
  5. public interface EmployeeInfoRepository extends ElasticsearchRepository<EmployeeInfo, Long>
  7.     /**
  8.      * 方法名必须遵守SpringData的规范
  9.      * 年龄区间查询
  10.      */
  11.     List<EmployeeInfo> findByAgeBetween(int age1, int age2);
  12. }
复制代码
然后，再通过saveAll新增多些数据，再进行自界说的方法进行查询
  1. package com.example.springbootfull.elasticsearch.controller;
  3. import com.example.springbootfull.elasticsearch.bean.EmployeeInfo;
  4. import com.example.springbootfull.elasticsearch.service.EmployeeInfoRepository;
  5. import com.example.springbootfull.elasticsearch.service.EmployeeInfoService;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.web.bind.annotation.GetMapping;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.RestController;
  11. import java.math.BigDecimal;
  12. import java.text.SimpleDateFormat;
  13. import java.util.ArrayList;
  14. import java.util.Iterator;
  15. import java.util.List;
  17. @RestController
  18. @RequestMapping("/employeeInfo")
  19. public class EmployeeElasticController {
  21.     @Autowired
  22.     private EmployeeInfoRepository elasticRepository;
  24.     @RequestMapping("/saveAll")
  25.     public String saveAll() throws Exception {
  26.         List<EmployeeInfo> list = new ArrayList<>();
  27.         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
  28.         list.add(new EmployeeInfo(1001L, "2001", "张三", "zhangsan", "Java", 1, 19, new BigDecimal("12500.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  29.         list.add(new EmployeeInfo(1002L, "2002", "李四", "lisi", "PHP", 1, 18, new BigDecimal("11600.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  30.         list.add(new EmployeeInfo(1003L, "2003", "王五", "wangwu", "C++", 1, 20, new BigDecimal("9900.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  31.         list.add(new EmployeeInfo(1004L, "2004", "赵六", "zhaoliu", "Java Leader", 1, 20, new BigDecimal("20000.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  32.         list.add(new EmployeeInfo(1005L, "2005", "小五", "xiaowu", "H5", 1, 17, new BigDecimal("10600.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  33.         list.add(new EmployeeInfo(1006L, "2006", "小六", "xaioliu", "web", 1, 20, new BigDecimal("12600.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  34.         list.add(new EmployeeInfo(1007L, "2007", "小七", "xiaoqi", "app", 1, 22, new BigDecimal("20000.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  35.         list.add(new EmployeeInfo(1008L, "2008", "小八", "xaioba", "Java", 1, 21, new BigDecimal("11000.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  36.         list.add(new EmployeeInfo(1009L, "2009", "小九", "xiaojiu", "Java", 1, 20, new BigDecimal("14000.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  37.         list.add(new EmployeeInfo(1010L, "2010", "大十", "dashi", "Java", 1, 20, new BigDecimal("13000.01"), simpleDateFormat.parse("2019-09-10"), "备注"));
  38.         elasticRepository.saveAll(list);
  39.         return "success -> " + list.size();
  40.     }
  42.     @RequestMapping("/findByAgeBetween")
  43.     public String findByAgeBetween(){
  44.         elasticRepository.findByAgeBetween(10,20);
  45.         return "success";
  46.     }
  47.    
  48. }
复制代码
使用 findByAgeBetween 查询后的结果

方式二：使用ElasticsearchRestTemplate（更适合用于复杂查询）

   与 ElasticsearchRepository 相比，ElasticsearchRestTemplate 更适合用于复杂查询 。
比如 多个条件组合、范围查询、模糊查询、聚合查询等复杂场景
还支持分页、排序、过滤等高级功能
  添加单个文档

  1. @RestController
  2. @RequestMapping("/employeeInfo")
  3. public class EmployeeElasticController {
  5.     @Autowired
  6.     private ElasticsearchRestTemplate elasticsearchRestTemplate;
  7.    
  8.     @RequestMapping("/template/save")
  9.     public String  templateSave() throws Exception  {
  10.         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
  11.         EmployeeInfo employeeInfo = new EmployeeInfo(8888L, "2001", "张八", "zhangsan", "Java", 1, 19, new BigDecimal("12500.01"), simpleDateFormat.parse("2019-09-10"), "备注");
  12.         elasticsearchRestTemplate.save(employeeInfo);
  13.         return "success";
  14.     }
复制代码

简朴查询-通过id

  1. @RestController
  2. @RequestMapping("/employeeInfo")
  3. public class EmployeeElasticController {
  5.     @Autowired
  6.     private ElasticsearchRestTemplate elasticsearchRestTemplate;
  7.    
  8.     @RequestMapping("/getEmployeeInfo")
  9.     public EmployeeInfo getEmployeeInfo() {
  10.         return elasticsearchRestTemplate.get("6001", EmployeeInfo.class);
  11.     }
复制代码
查询结果如下

批量添加、删除、复杂的查询 等等 其余的我就不多说了
【参考文章】
【1】SpringBoot-starter-data整合Elasticsearch
【2】SpringBoot之ElasticsearchRestTemplate常用示例
【3】Spring Data Elasticsearch篇(3):ElasticsearchRepository文档操作

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

何小豆儿在此

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表