相关推荐recommended
Spring Boot整合Redis
作者:mmseoamin日期:2023-12-13

文章目录

  • 一、Redis概述
  • 二、使用Spring Boot 整合 Redis
    • (一)搭建Redis环境
    • (二)下载和安装Redis可视化管理工具
    • (三)创建Spring Boot项目RedisDemo
    • (四)创建实体类
      • 1、创建地址实体类 - Address
      • 2、创建家庭实体类 - Family
      • 3、创建个人实体类 - Person
      • (五)创建仓库接口 - PersonRepository
      • (六)在全局配置文件配置Redis属性
      • (七)在测试类里编写测试方法
        • 1、创建测试方法testAddPerson()
        • 2、创建测试方法testFindAll()
        • 3、测试personRespository的其它方法
        • (八)测试自定义个性化查询方法
          • 1、在PersonRepository接口定义方法
          • 2、在测试类创建测试方法testFindPersonByLastName()
          • 三、练习
            • 任务1、在测试类创建测试方法testFindByLastName()
            • 任务2、在测试类创建测试方法testFindPersonByLastNameAndFirstName()
            • 任务3、在测试类创建测试方法testFindByAddress_City()
            • 任务4、在测试类创建测试方法testFindByFamilyList_Name()

              一、Redis概述

              Redis是一个开源(BSD许可)的、内存中的数据结构存储系统,它可以用作数据库、缓存和消息中间件,并提供多种语言的API。

              Redis支持多种类型的数据结构,如 字符串(strings)、散列(hashes)、列表(lists)、集合(sets)、有序集合(sorted sets)与范围查询、bitmaps、 hyperloglogs 和 地理空间(geospatial)、索引半径查询。

              Redis 内置了复制(replication),LUA脚本(Lua scripting),LRU驱动事件(LRU eviction),事务(transactions) 和不同级别的磁盘持久化(persistence), 并通过 Redis哨兵(Sentinel)和自动 分区(Cluster)提供高可用性(high availability)。

              Redis官网与在线教程

              官网:https://redis.io/

              中文网站:http://www.redis.cn/

              在线教程:https://www.redis.net.cn/tutorial/3502.html

              二、使用Spring Boot 整合 Redis

              (一)搭建Redis环境

              请参考《Redis和Redis可视化管理工具的下载和安装》

              (二)下载和安装Redis可视化管理工具

              请参考《Redis和Redis可视化管理工具的下载和安装》

              (三)创建Spring Boot项目RedisDemo

              设置项目配置

              Spring Boot整合Redis,在这里插入图片描述,第1张

              添加项目依赖

              Spring Boot整合Redis,在这里插入图片描述,第2张

              完成项目初始化

              Spring Boot整合Redis,在这里插入图片描述,第3张

              (四)创建实体类

              在net.army.boot包里创建bean子包

              Spring Boot整合Redis,在这里插入图片描述,第4张

              1、创建地址实体类 - Address

              在net.army.boot.bean包里创建地址实体类Address

              Spring Boot整合Redis,在这里插入图片描述,第5张

              package net.army.boot.bean;
              import org.springframework.data.redis.core.index.Indexed;
              /**
               * 功能:地址实体类
               * 日期:2023年06月16日
               * 作者:梁辰兴
               */
              public class Address {
                  @Indexed
                  private String country; //国家
                  @Indexed
                  private String city; //城市
                  public Address(String country, String city) {
                      this.country = country;
                      this.city = city;
                  }
                  public String getCountry() {
                      return country;
                  }
                  public void setCountry(String country) {
                      this.country = country;
                  }
                  public String getCity() {
                      return city;
                  }
                  public void setCity(String city) {
                      this.city = city;
                  }
                  @Override
                  public String toString() {
                      return "Address{" +
                              "country='" + country + '\'' +
                              ", city='" + city + '\'' +
                              '}';
                  }
              }
              

              注意:索引类Indexed不要导入错误 - import org.springframework.data.redis.core.index.Indexed;

              2、创建家庭实体类 - Family

              在net.army.boot.bean包里创建家庭实体类Family

              Spring Boot整合Redis,在这里插入图片描述,第6张

              package net.army.boot.bean;
              import org.springframework.data.redis.core.index.Indexed;
              /**
               * 功能:家庭实体类
               * 日期:2023年06月16日
               * 作者:梁辰兴
               */
              public class Family {
                  @Indexed
                  private String type; //成员类型
                  @Indexed
                  private String name; //成员名
                  public Family(String type, String name) {
                      this.type = type;
                      this.name = name;
                  }
                  public String getType() {
                      return type;
                  }
                  public void setType(String type) {
                      this.type = type;
                  }
                  public String getName() {
                      return name;
                  }
                  public void setName(String name) {
                      this.name = name;
                  }
                  @Override
                  public String toString() {
                      return "Family{" +
                              "type='" + type + '\'' +
                              ", name='" + name + '\'' +
                              '}';
                  }
              }
              

              3、创建个人实体类 - Person

              在net.army.boot.bean包里创建个人实体类Person

              Spring Boot整合Redis,在这里插入图片描述,第7张

              package net.army.boot.bean;
              import org.springframework.data.annotation.Id;
              import org.springframework.data.redis.core.RedisHash;
              import org.springframework.data.redis.core.index.Indexed;
              import java.util.List;
              /**
               * 功能:个人实体类
               * 日期:2023年06月16日
               * 作者:梁辰兴
               */
              @RedisHash("persons")
              public class Person {
                  @Id  //主键
                  private String id;
                  //生成二级索引,方便查询
                  @Indexed
                  private String firstName; //名
                  @Indexed
                  private String lastName; //姓
                  private Address address; //家庭地址
                  private List familyList; //家庭成员
                  public Person(String id, String firstName, String lastName, Address address, List familyList) {
                      this.id = id;
                      this.firstName = firstName;
                      this.lastName = lastName;
                      this.address = address;
                      this.familyList = familyList;
                  }
                  public String getId() {
                      return id;
                  }
                  public void setId(String id) {
                      this.id = id;
                  }
                  public String getFirstName() {
                      return firstName;
                  }
                  public void setFirstName(String firstName) {
                      this.firstName = firstName;
                  }
                  public String getLastName() {
                      return lastName;
                  }
                  public void setLastName(String lastName) {
                      this.lastName = lastName;
                  }
                  public Address getAddress() {
                      return address;
                  }
                  public void setAddress(Address address) {
                      this.address = address;
                  }
                  public List getFamilyList() {
                      return familyList;
                  }
                  public void setFamilyList(List familyList) {
                      this.familyList = familyList;
                  }
                  @Override
                  public String toString() {
                      return "Person{" +
                              "id='" + id + '\'' +
                              ", firstName='" + firstName + '\'' +
                              ", lastName='" + lastName + '\'' +
                              ", address=" + address +
                              ", familyList=" + familyList +
                              '}';
                  }
              }
              

              说明:注解@RedisHash(“persons”),表明在redis数据库中开启一个persons的内存空间,所有person操作相关的数据均保存在此空间(redis是内存数据库)。

              (五)创建仓库接口 - PersonRepository

              在net.army.boot包里创建repository子包,再在子包下创建PersonRepository接口

              Spring Boot整合Redis,在这里插入图片描述,第8张

              package net.army.boot.repository;
              import net.army.boot.bean.Person;
              import org.springframework.data.repository.CrudRepository;
              /**
               * 功能:个人仓库接口
               * 日期:2023年06月16日
               * 作者:梁辰兴
               */
              public interface PersonRepository extends CrudRepository {
              }
              

              (六)在全局配置文件配置Redis属性

              Spring Boot整合Redis,在这里插入图片描述,第9张

              spring.redis.port=6379
              spring.redis.host=127.0.0.1
              spring.redis.password=
              

              (七)在测试类里编写测试方法

              点开测试类RedisDemoApplicationTests

              Spring Boot整合Redis,在这里插入图片描述,第10张

              注入PersonRepository实例

              Spring Boot整合Redis,在这里插入图片描述,第11张

              @Autowired // 注入个人仓库
              private PersonRepository personRepository;
              

              1、创建测试方法testAddPerson()

              @Test           
              public void testAddPerson() {                                  
                  // 添加第一个人   
                  Address address = new Address("中国", "泸州");                 
                  Family family1 = new Family("儿子", "张晓刚");                  
                  Family family2 = new Family("女儿", "张晓霞");                  
                  List familyList = new ArrayList();         
                  familyList.add(family1);                                   
                  familyList.add(family2);                                   
                  Person person = new Person("1", "无忌", "张", address, familyList);                                          
                  personRepository.save(person);                             
                              
                  // 添加第二个人   
                  address = new Address("中国", "上海");                         
                  family1 = new Family("儿子", "李功晨");                         
                  family2 = new Family("女儿", "李晓丽");                         
                  familyList = new ArrayList();                      
                  familyList.add(family1);                                   
                  familyList.add(family2);                                   
                  person = new Person("2", "承鹏", "李", address, familyList);  
                  personRepository.save(person);                             
                              
                  // 添加第三个人   
                  address = new Address("中国", "北京");                         
                  family1 = new Family("儿子", "唐玉海");                         
                  family2 = new Family("女儿", "唐雨涵");                         
                  familyList = new ArrayList();                      
                  familyList.add(family1);                                   
                  familyList.add(family2);                                   
                  person = new Person("3", "大明", "唐", address, familyList);  
                  personRepository.save(person);                             
                              
                  // 添加第四个人   
                  address = new Address("中国", "北京");                         
                  family1 = new Family("儿子", "张大明");                         
                  family2 = new Family("女儿", "张丽丽");                         
                  familyList = new ArrayList();                      
                  familyList.add(family1);                                   
                  familyList.add(family2);                                   
                  person = new Person("4", "文勇", "张", address, familyList);  
                  personRepository.save(person);                             
                              
                  System.out.println("成功地添加了4条记录~");                         
              }                                              
              

              运行测试方法,查看结果

              Spring Boot整合Redis,在这里插入图片描述,第12张

              打开Redis可视化工具查看

              Spring Boot整合Redis,在这里插入图片描述,第13张

              Spring Boot整合Redis,在这里插入图片描述,第14张

              2、创建测试方法testFindAll()

              @Test      
              public void testFindAll() {                               
              	Iterable persons = personRepository.findAll();
              	persons.forEach(person -> System.out.println(person));
              }         
              

              运行测试方法,查看结果

              Spring Boot整合Redis,在这里插入图片描述,第15张

              3、测试personRespository的其它方法

              Spring Boot整合Redis,在这里插入图片描述,第16张

              创建测试方法testFindById()

              @Test
              public void testFindById() {
                  Optional person = personRepository.findById("2");
              	System.out.println(person);
              }
              

              运行测试方法,查看结果

              Spring Boot整合Redis,在这里插入图片描述,第17张

              (八)测试自定义个性化查询方法

              1、在PersonRepository接口定义方法

              package net.army.boot.repository;
              import net.army.boot.bean.Person;
              import org.springframework.data.domain.Page;
              import org.springframework.data.domain.Pageable;
              import org.springframework.data.repository.CrudRepository;
              import java.util.List;
              /**
               * 功能:个人仓库接口
               * 日期:2023年06月16日
               * 作者:梁辰兴
               */
              public interface PersonRepository extends CrudRepository {
                  //自定义个性化查询,方法名需要符合特定的规范
                  List findByLastName(String lastName);
                  Page findPersonByLastName(String lastName, Pageable pageable);
                  List findPersonByLastNameAndFirstName(String lastName, String firstName);
                  List findByAddress_City(String city);
                  List findByFamilyList_Name(String name);
              }
              

              2、在测试类创建测试方法testFindPersonByLastName()

              @Test                         
              public void testFindPersonByLastName() {                                     
              	// 降序排序                   
              	Sort.Direction sort = Sort.Direction.DESC;                               
              	// 创建分页器                  
              	Pageable pageable = PageRequest.of(0, 2, sort, "id");                    
              	// 获取页面                   
              	Page page = personRepository.findPersonByLastName("张", pageable);
              	// 输出页面内容                 
              	for (Person person : page.getContent()) {                                
              		System.out.println(person);                                          
              	}                         
              }                             
              

              运行测试方法,查看结果

              Spring Boot整合Redis,在这里插入图片描述,第18张

              三、练习

              任务1、在测试类创建测试方法testFindByLastName()

              查找姓“张”的记录

              Spring Boot整合Redis,在这里插入图片描述,第19张

              任务2、在测试类创建测试方法testFindPersonByLastNameAndFirstName()

              查找lastName为“唐”,firstName为“大明”的记录

              Spring Boot整合Redis,在这里插入图片描述,第20张

              任务3、在测试类创建测试方法testFindByAddress_City()

              查找“北京”的记录

              Spring Boot整合Redis,在这里插入图片描述,第21张

              任务4、在测试类创建测试方法testFindByFamilyList_Name()

              查找“唐雨涵”

              Spring Boot整合Redis,在这里插入图片描述,第22张