Spring Boot整合Redis

03-25 1299阅读

文章目录

  • 一、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

              添加项目依赖

              Spring Boot整合Redis

              完成项目初始化

              Spring Boot整合Redis

              （四）创建实体类

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

              Spring Boot整合Redis

              1、创建地址实体类 - Address

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

              Spring Boot整合Redis

              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

              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

              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

              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

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

              （七）在测试类里编写测试方法

              点开测试类RedisDemoApplicationTests

              Spring Boot整合Redis

              注入PersonRepository实例

              Spring Boot整合Redis

              @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

              打开Redis可视化工具查看

              Spring Boot整合Redis

              Spring Boot整合Redis

              2、创建测试方法testFindAll()

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

              运行测试方法，查看结果

              Spring Boot整合Redis

              3、测试personRespository的其它方法

              Spring Boot整合Redis

              创建测试方法testFindById()

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

              运行测试方法，查看结果

              Spring Boot整合Redis

              （八）测试自定义个性化查询方法

              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

              三、练习

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

              查找姓“张”的记录

              Spring Boot整合Redis

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

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

              Spring Boot整合Redis

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

              查找“北京”的记录

              Spring Boot整合Redis

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

              查找“唐雨涵”

              Spring Boot整合Redis

VPS购买请点击我

文章版权声明：除非注明，否则均为主机测评原创文章，转载或复制请以超链接形式并注明出处。

相关阅读

目录[+]