本文介绍: Redis一个开源(BSD许可)的、内存中的数据结构存储系统,它可以用作数据库缓存消息中间件,并提供多种语言的API。Redis支持多种类型数据结构,如 字符串strings)、散列hashes)、列表lists)、集合sets)、有序集合(sorted sets)与范围查询bitmapshyperloglogs 和 地理空间geospatial)、索引半径查询


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

设置项目配置
在这里插入图片描述

添加项目依赖
在这里插入图片描述
完成项目初始化
在这里插入图片描述

(四)创建实体类

net.army.boot包里创建bean子包
在这里插入图片描述

1、创建地址实体类 – Address

net.army.boot.bean包里创建地址实体类Address
在这里插入图片描述

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
在这里插入图片描述

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
在这里插入图片描述

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<Family> familyList; //家庭成员

    public Person(String id, String firstName, String lastName, Address address, List<Family> 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<Family> getFamilyList() {
        return familyList;
    }

    public void setFamilyList(List<Family> 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接口
在这里插入图片描述

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<Person, String> {
}

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

在这里插入图片描述

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

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

点开测试类RedisDemoApplicationTests
在这里插入图片描述
注入PersonRepository实例
在这里插入图片描述

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

1、创建测试方法testAddPerson()

@Test                                                                                                         
public void testAddPerson() {                                                                                 
    // 添加第一个
    Address address = new Address("中国", "泸州");                                                                
    Family family1 = new Family("儿子", "张晓刚");                                                                 
    Family family2 = new Family("女儿", "张晓霞");                                                                 
    List<Family> familyList = new ArrayList<Family>();                                                        
    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<Family>();                                                                     
    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<Family>();                                                                     
    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<Family>();                                                                     
    familyList.add(family1);                                                                                  
    familyList.add(family2);                                                                                  
    person = new Person("4", "文勇", "张", address, familyList);                                                 
    personRepository.save(person);                                                                            
                                                                                                              
    System.out.println("成功添加了4条记录~");                                                                        
}                                                                                                                                                                                           

运行测试方法查看结果
在这里插入图片描述
打开Redis可视化工具查看
在这里插入图片描述
在这里插入图片描述

2、创建测试方法testFindAll()

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

运行测试方法查看结果
在这里插入图片描述

3、测试personRespository的其它方法

在这里插入图片描述
创建测试方法testFindById()

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

运行测试方法查看结果
在这里插入图片描述

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

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<Person, String> {
    //自定义个性化查询,方法名需要符合特定的规范
    List<Person> findByLastName(String lastName);
    Page<Person> findPersonByLastName(String lastName, Pageable pageable);
    List<Person> findPersonByLastNameAndFirstName(String lastName, String firstName);
    List<Person> findByAddress_City(String city);
    List<Person> 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<Person> page = personRepository.findPersonByLastName("张", pageable);
	// 输出页面内容                                                                
	for (Person person : page.getContent()) {                                
		System.out.println(person);                                          
	}                                                                        
}                                                                            

运行测试方法,查看结果
在这里插入图片描述

三、练习

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

查找姓“张”的记录
在这里插入图片描述

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

查找lastName为“唐”,firstName为“大明”的记录
在这里插入图片描述

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

查找“北京”的记录
在这里插入图片描述

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

查找“唐雨涵”
在这里插入图片描述

原文地址:https://blog.csdn.net/m0_62617719/article/details/131223032

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任

如若转载,请注明出处:http://www.7code.cn/show_50477.html

如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱suwngjj01@126.com进行投诉反馈,一经查实,立即删除

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注