【Spring Boot 3】【Redis】基本数据类型操作

【Spring Boot 3】【Redis】基本数据类型操作

  • 背景
  • 介绍
  • 开发环境
  • 开发步骤及源码
  • 工程目录结构

背景

软件开发是一门实践性科学，对大多数人来说，学习一种新技术不是一开始就去深究其原理，而是先从做出一个可工作的DEMO入手。但在我个人学习和工作经历中，每次学习新技术总是要花费或多或少的时间、检索不止一篇资料才能得出一个可工作的DEMO，这占用了我大量的时间精力。因此本文旨在通过一篇文章即能还原出可工作的、甚至可用于生产的DEMO，期望初学者能尽快地迈过0到1的这一步骤，并在此基础上不断深化对相关知识的理解。
为达以上目的，本文会将开发环境、工程目录结构、开发步骤及源码尽量全面地展现出来，文字描述能简则简，能用代码注释的绝不在正文中再啰嗦一遍，正文仅对必要且关键的信息做重点描述。

介绍

本文介绍开发Spring Boot应用时借助Spring Data Redis实现对Redis五种基本数据（字符串string、哈希hash、列表list、集合set、有序集合zset）类型的操作。

开发环境

分类名称版本
操作系统WindowsWindows 11
JDKOracle JDK21.0.1
IDEIntelliJ IDEA2023.2.4
构建工具Apache Maven3.9.3
缓存Redis7.2

开发步骤及源码

1> 创建Maven工程，添加依赖。

    <properties>
        <spring-boot.version>3.2.1</spring-boot.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
            <version>${spring-boot.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <version>${spring-boot.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.15.3</version>
        </dependency>
    </dependencies>

2> 添加应用配置（src/main/resources/application.yml）。

spring:
  data:
    redis:
      # 连接地址
      host: 127.0.0.1
      # 端口
      port: 6379
      # Redis数据库索引，默认为 0
      database: 0
      # 用户名（可选）
      # username:
      # 密码（可选）
      # password:

3> 定义SpringBoot应用启动类。

package com.jiyongliang.springboot;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class SpringBoot3RedisDataApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringBoot3RedisDataApplication.class, args);
    }
}

4> 字符串（string）

package com.jiyongliang.springboot;

import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

@SpringBootTest
class RedisStringTests {

    @Autowired
    RedisTemplate<String, Object> redisTemplate;

    String key = "string-key";

    @AfterEach
    void afterEach() {
        redisTemplate.delete(key);
    }

    @Test
    void testString() {
        // 添加字符串缓存数据
        redisTemplate.opsForValue().set(key, "string data");
        // 获取字符串缓存数据
        String cachedString = (String) redisTemplate.opsForValue().get(key);
        Assertions.assertThat(cachedString)
                .isNotNull()
                .isEqualTo("string data");
    }
}

5> 哈希（hash）

package com.jiyongliang.springboot;

import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

import java.util.HashMap;
import java.util.Map;

@SpringBootTest
class RedisHashTests {

    @Autowired
    RedisTemplate<String, Object> redisTemplate;

    String key = "hash-single-key";

    @BeforeEach
    void beforeEach() {
        redisTemplate.delete(key);
    }

    @Test
    void testHash() {
        // 添加单个Hash缓存数据
        redisTemplate.opsForHash().put(key, "hash key", "hash value");
        // 获取单个Hash缓存数据
        String cachedHash = (String) redisTemplate.opsForHash().get(key, "hash key");
        Assertions.assertThat(cachedHash).isEqualTo("hash value");
        redisTemplate.delete(key);
        // 添加map缓存数据
        Map<String, String> map = new HashMap<>();
        map.put("map-key-1", "map value 1");
        map.put("map-key-2", "map value 2");
        map.put("map-key-3", "map value 3");
        redisTemplate.opsForHash().putAll(key, map);
        // 获取map缓存数据
        Map<Object, Object> cachedHashMap = redisTemplate.opsForHash().entries(key);
        Assertions.assertThat(cachedHashMap)
                .isNotNull()
                .containsEntry("map-key-1", "map value 1")
                .containsEntry("map-key-2", "map value 2")
                .containsEntry("map-key-3", "map value 3");
    }
}

6> 列表（list）

package com.jiyongliang.springboot;

import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

import java.util.List;

@SpringBootTest
class RedisListTests {

    @Autowired
    RedisTemplate<String, Object> redisTemplate;

    String key = "list-key";

    @BeforeEach
    void beforeEach() {
        redisTemplate.delete(key);
    }

    @Test
    void testList() {
        // 添加List缓存数据
        redisTemplate.opsForList().leftPush(key, "list value 3");
        redisTemplate.opsForList().leftPush(key, "list value 2");
        redisTemplate.opsForList().leftPush(key, "list value 1");
        redisTemplate.opsForList().rightPush(key, "list value 4");
        redisTemplate.opsForList().rightPush(key, "list value 5");
        // 获取全部List缓存数据
        List<Object> cachedList = redisTemplate.opsForList().range(key, 0, -1);
        Assertions.assertThat(cachedList)
                .isNotNull()
                .isNotEmpty()
                .hasToString("[list value 1, list value 2, list value 3, list value 4, list value 5]");
        // 获取指定下标数据
        String listValue = (String) redisTemplate.opsForList().index(key, 2);
        Assertions.assertThat(listValue).isEqualTo("list value 3");
        listValue = (String) redisTemplate.opsForList().index(key, 5);
        Assertions.assertThat(listValue).isNull();
        // 从左边开始取数据
        listValue = (String) redisTemplate.opsForList().leftPop(key);
        Assertions.assertThat(listValue).isEqualTo("list value 1");
        // 从右边开始取数据
        listValue = (String) redisTemplate.opsForList().rightPop(key);
        Assertions.assertThat(listValue).isEqualTo("list value 5");
        // 获取list长度
        Long length = redisTemplate.opsForList().size(key);
        Assertions.assertThat(length).isNotNull().isEqualTo(3);
        Assertions.assertThat(redisTemplate.opsForList().range(key, 0, -1))
                .isNotNull()
                .isNotEmpty()
                .hasToString("[list value 2, list value 3, list value 4]");
    }
}

7> 集合（set）

package com.jiyongliang.springboot;

import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

import java.util.Arrays;
import java.util.Set;
import java.util.stream.Collectors;

@SpringBootTest
class RedisSetTests {

    @Autowired
    RedisTemplate<String, Object> redisTemplate;

    String key1 = "set-key-1";

    String key2 = "set-key-2";

    @BeforeEach
    void beforeEach() {
        redisTemplate.delete(key1);
        redisTemplate.delete(key2);
    }

    @Test
    void testSet() {
        // 添加Set缓存数据
        String[] setData = new String[]{"A", "B", "C", "D", "D", "C", "D", "E", "F", "F", "G"};
        Long addCount = redisTemplate.opsForSet().add(key1, setData);
        Set<String> expected = Arrays.stream(setData).collect(Collectors.toSet());
        Assertions.assertThat(addCount).isNotNull().isEqualTo(expected.size());
        // 获取Set缓存数据
        Set<Object> cachedSet = redisTemplate.opsForSet().members(key1);
        Assertions.assertThat(cachedSet)
                .isNotNull()
                .hasSameSizeAs(expected)
                .containsAll(expected);
        // 判断是否在Set缓存数据中
        Assertions.assertThat(redisTemplate.opsForSet().isMember(key1, "F")).isTrue();
        Assertions.assertThat(redisTemplate.opsForSet().isMember(key1, "X")).isFalse();
        // 返回缓存Set的并集
        String[] setTempData = new String[]{"A", "X", "E", "Y", "G", "Z"};
        redisTemplate.opsForSet().add(key2, setTempData);
        Set<Object> unionSet = redisTemplate.opsForSet().union(key1, key2);
        Assertions.assertThat(unionSet)
                .isNotNull()
                .hasSize(expected.size() + 3)
                .containsAll(expected)
                .containsAll(Set.of("X", "Y", "Z"));
        // 返回缓存Set的交集
        Set<Object> intersectSet = redisTemplate.opsForSet().intersect(key1, key2);
        Assertions.assertThat(intersectSet)
                .isNotNull()
                .hasSize(3)
                .containsAll(Set.of("A", "E", "G"));
        // 返回缓存的set-key-1中存在但set-key-2中不存在的数据
        Set<Object> differenceSet = redisTemplate.opsForSet().difference(key1, key2);
        Assertions.assertThat(differenceSet)
                .isNotNull()
                .hasSize(expected.size() - 3)
                .containsAll(Set.of("B", "C", "D", "F"));
    }
}

8> 有序集合（zset）

package com.jiyongliang.springboot;

import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

import java.util.Set;

@SpringBootTest
class RedisZSetTests {

    @Autowired
    RedisTemplate<String, Object> redisTemplate;

    String key = "zset-key";

    @BeforeEach
    void beforeEach() {
        redisTemplate.delete(key);
    }

    @Test
    void testZSet() {
        // 添加ZSet缓存数据
        redisTemplate.opsForZSet().add(key, "X", 1);
        redisTemplate.opsForZSet().add(key, "Y", 2);
        redisTemplate.opsForZSet().add(key, "Z", 3);
        // 值相同的情况下，权重会被覆盖
        redisTemplate.opsForZSet().add(key, "X", 1);
        redisTemplate.opsForZSet().add(key, "Y", 3);
        redisTemplate.opsForZSet().add(key, "Z", 5);
        // 获取ZSet缓存数据
        Set<Object> cachedZSet = redisTemplate.opsForZSet().range(key, 0, -1);
        Assertions.assertThat(cachedZSet)
                .isNotNull()
                .hasSize(3)
                .containsAll(Set.of("X", "Y", "Z"));
        // 获取值对应的权重
        Double score = redisTemplate.opsForZSet().score(key, "Y");
        Assertions.assertThat(score).isNotNull().isEqualTo(3);
        // 获取值对应的排名（从0开始）
        Long rank = redisTemplate.opsForZSet().rank(key, "Y");
        Assertions.assertThat(rank).isNotNull().isEqualTo(1);
        // 根据score范围获取值
        Set<Object> rangedZSet = redisTemplate.opsForZSet().rangeByScore(key, 1, 4);
        Assertions.assertThat(rangedZSet)
                .isNotNull()
                .hasSize(2)
                .containsAll(Set.of("X", "Y"));
    }
}

9> 数据过期

package com.jiyongliang.springboot;

import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

import java.util.concurrent.TimeUnit;

@SpringBootTest
class RedisExpireTests {

    @Autowired
    RedisTemplate<String, Object> redisTemplate;

    String key = "expire-key";

    @BeforeEach
    void beforeEach() {
        redisTemplate.delete(key);
    }

    @Test
    void testExpire() throws InterruptedException {
        redisTemplate.opsForValue().set(key, "expire data");
        Assertions.assertThat(redisTemplate.opsForValue().get(key))
                .isNotNull()
                .isEqualTo("expire data");
        redisTemplate.opsForValue().getOperations().expire(key, 3, TimeUnit.SECONDS);
        TimeUnit.SECONDS.sleep(3);
        Assertions.assertThat(redisTemplate.opsForValue().get(key)).isNull();
    }
}

10> 单元测试结果
单元测试结果

工程目录结构

工程目录结构

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/335248.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

tidb Cloud 连接spring boot 项目

tidb Cloud 连接spring boot 项目

一、 免费试用tidbitcloud TiDB Cloud Documentation | PingCAP Docs 1.github账号登录 2.创建集群 3.点击对应集群cludter0 导入数据 导入 本地导入只支持csv文件&#xff0c;其他导入需要AWZ账号使用S3云存储 二、连接spingboot项目 选择java&#xff0c;复制下面的jd…
阅读更多...
前台vue配置

前台vue配置

前台 vue环境 1.傻瓜式安装node: 官网下载&#xff1a;https://nodejs.org/zh-cn/2.安装cnpm: >: npm install -g cnpm --registryhttps://registry.npm.taobao.org3.安装vue最新脚手架: >: cnpm install -g vue/cli注&#xff1a;如果2、3步报错&#xff0c;清除缓…
阅读更多...
美团RASP大规模研发部署实践总结

美团RASP大规模研发部署实践总结

01 背景 RASP 是 Runtime Application Self-Protection&#xff08;运行时应用自我保护&#xff09;的缩写&#xff0c;是一种应用程序安全技术。RASP 技术能够在应用程序运行时检测并阻止应用级别的攻击。随着云计算和大数据的发展&#xff0c;应用程序安全越来越受到重视。其…
阅读更多...
总结网络中的一些基本概念

总结网络中的一些基本概念

1. IP地址 描述一个设备在网络上的位置&#xff0c;而且计算机是通过数字来描述IP地址的。例如&#xff08;生活中的地址&#xff09; 2. 端口号 描述一个主机上的哪个应用程序&#xff0c;有了IP可以确定主机&#xff0c;但是一个主机上可能有很多程序在使用网络&#xff0c;…
阅读更多...
CloudPanel RCE漏洞复现（CVE-2023-35885）

CloudPanel RCE漏洞复现（CVE-2023-35885）

0x01 产品简介 CloudPanel 是一个基于 Web 的控制面板或管理界面，旨在简化云托管环境的管理。它提供了一个集中式平台，用于管理云基础架构的各个方面，包括虚拟机 （VM）、存储、网络和应用程序。 0x02 漏洞概述 由于2.3.1 之前的 CloudPanel 具有不安全的文件管理器 cook…
阅读更多...
Docker技巧汇总

Docker技巧汇总

Docker技巧汇总 前言使用流程安装配置镜像管理创建并运行容器使用容器/常用命令导出和导入查看元数据挂载数据卷端口映射/转发VS Code连接Docker 前言 Docker 是一个开源的应用容器引擎&#xff0c;可以让开发者打包他们的应用以及依赖包到一个轻量级、可移植的容器中&#xf…
阅读更多...
go语言（八）---- map

go语言（八）---- map

map的声明方式有以下三种。 package mainimport "fmt"func main() {//第一种声明方式//声明map1是一个map类型&#xff0c;key是String&#xff0c;value是Stringvar myMap1 map[string] stringif myMap1 nil {fmt.Println("myMap1 是一个空map")}//在使…
阅读更多...
AI时代—ChatGPT-4.5的正确打开方式

AI时代—ChatGPT-4.5的正确打开方式

前言 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家&#xff1a;https://www.captainbed.cn/z ChatGPT体验地址 文章目录 前言4.5key价格泄漏ChatGPT4.0使用地址ChatGPT正确打开方式最新功能语音助手存档…
阅读更多...
Python初识——小小爬虫

Python初识——小小爬虫

一、找到网页端url 打开浏览器&#xff0c;打开百度官方网页点击图片&#xff0c;打开百度图片 鼠标齿轮向下滑&#xff0c;点击宠物图片 进入宠物图片网页&#xff0c;在网页空白处点击鼠标右键&#xff0c;弹出的框中最下方显示“检查”选项&#xff0c;点击&#xff08;我是…
阅读更多...
搭建一个JavaWeb项目流程详解

搭建一个JavaWeb项目流程详解

搭建一个JavaWeb项目流程 本文致力于&#xff0c;让编程者一步步明白书写一个JavaWeb项目应该做些什么&#xff0c;梳理清楚流程框架&#xff0c;需要的jar包&#xff0c;同时手写了一个分页工具类也在其中&#xff0c;让你在编程中更加丝滑。 1.src\main\java\com\einmeer\qia…
阅读更多...
springboot中一些注解

springboot中一些注解

springboot中一些注解 1:项目启动时会去扫描启动的注解&#xff0c;一般是启动时就想要被加载的方法&#xff1a; 2:springBoot中MSApplication启动类的一些其他注解&#xff1a; EnableAsync&#xff1a;这是一个Spring框架的注解&#xff0c;它用于开启方法异步调用的功能。当…
阅读更多...
【MySQL自身的性能优化】InnoDB 的 Buffer Pool

【MySQL自身的性能优化】InnoDB 的 Buffer Pool

这里写目录标题 一、引入缓存的重要性二、InnoDB 的 Buffer Pool1. Buffer Pool 内部组成2. free 链表管理空闲页3. flush 链表管理脏页4. LRU 链表提高缓存命中那咱需要咋地解决预读问题呢&#xff1f;那咱需要咋地解决 Buffer Pool 污染问题呢&#xff1f; 5. 脏页什么时候被…
阅读更多...
pyqt5+python子域名扫描程序

pyqt5+python子域名扫描程序

import sysfrom PyQt5 import uic from PyQt5.QtWidgets import * #requests库内置了不同的方法来发送不同类型的http请求 import requests#BS主要功能是从网页抓取数据&#xff0c;提供一些简单的、python 式的函数用来处理导航、搜索、修改分析树等功能 from bs4 import Beau…
阅读更多...
WebSocket协议、与HTTP对比

WebSocket协议、与HTTP对比

WebSocket 也可前往本人的个人网站进行阅读 WebSocket 和 HTTP WebSocket和HTTP协议一样&#xff0c;都是基于TCP协议实现的应用层协议。 HTTP协议通常是单边通信&#xff0c;主要用于传输静态文档、请求-响应通信&#xff0c;适用于Web浏览器加载网页、API调用等。然而Web…
阅读更多...
NX二次开发获取圆弧的四个象限点

NX二次开发获取圆弧的四个象限点

我是用来用来画水路线框的UF_MODL_ask_curve_points&#xff08;&#xff09;可以按弧长或者弧度获取曲线的等分点&#xff0c;取PI/2的圆弧&#xff0c;即将圆弧四等分&#xff0c;你也可以取任意等分点。 int GetArcPoint(tag_t arc_tag,double point[4][3]) {if(arc_tag0)r…
阅读更多...
KubeSphere 核心实战之二【在kubesphere平台上部署redis】（实操篇 2/4）

KubeSphere 核心实战之二【在kubesphere平台上部署redis】（实操篇 2/4）

文章目录 1、登录kubesphere平台2、redis部署分析3、redis容器启动代码4、kubesphere平台部署redis4.1、创建redis配置集4.2、创建redis工作负载4.3、创建redis服务 5、测试连接redis 在kubesphere平台上部署redis应用都是基于redis镜像进行部署的&#xff0c;所以所有的部署操…
阅读更多...
DRmare Music Converter - 一款高效的音乐转换工具，让您的音乐无处不在！

DRmare Music Converter - 一款高效的音乐转换工具，让您的音乐无处不在！

DRmare Music Converter是一款专业的音乐转换工具&#xff0c;旨在帮助用户更方便地管理和享受音乐。无论您是使用Mac还是Windows操作系统&#xff0c;DRmare Music Converter都能为您提供高效、便捷的音乐转换体验。 DRmare Music Converter支持多种音频格式的转换&#xff0…
阅读更多...
伊恩·斯图尔特《改变世界的17个方程》波动方程笔记

伊恩·斯图尔特《改变世界的17个方程》波动方程笔记

主要是课堂的补充&#xff08;yysy&#xff0c;我觉得课堂的教育模式真有够无聊的&#xff0c;PPT、写作业、考试&#xff0c;感受不到知识的魅力。 它告诉我们什么&#xff1f; 小提琴琴弦上某个小段的加速度&#xff0c;与相邻段相对于该段的平均位移成正比。 为什么重要&…
阅读更多...
Studio One2024免费版下载及入门教程分享

Studio One2024免费版下载及入门教程分享

众所周知&#xff0c;Studio One是一个专业的音频编辑软件&#xff0c;近几年随着音视频剪辑越来越火&#xff0c;Studio One也逐渐被人们所熟知。最近&#xff0c;就有许多小伙伴私信我&#xff0c;寻求Studio One的入门教程。 这不&#xff0c;今天小编就给大家带来了音频剪…
阅读更多...
一个好用的工具，对网工来说是绝杀技！

一个好用的工具，对网工来说是绝杀技！

上午好&#xff0c;我是老杨。 提到用人&#xff0c;很多单位和管理者第一反应都是应聘者的能力。能力到底怎么界定&#xff0c;其实每个人都有不同的判定标准。 在我看来&#xff0c;做事专注&#xff0c;且能尽可能“偷懒”的网工 &#xff0c;就是我个人筛选员工的标准。 …
阅读更多...
最新文章

Copyright @ 2022~2023