SpringBoot3如何整合Redis？

news2024/11/16 12:44:39

SpringBoot应该不用介绍！它是Spring当前最火的一个框架，整合Spring Boot 3和Redis可以显著提升应用程序的性能，特别是在处理大量数据和需要快速访问的场景下。

在Spring Boot中，从1.x版本到2.x版本的Redis连接方式发生了变化，从使用Jedis切换到了使用Lettuce。这两者在连接Redis时的实现方式和特性有所不同，主要区别如下：

Jedis

连接方式：

  • Jedis是一个基于直连的连接池技术，每个Jedis实例都是线程不安全的。如果多个线程要使用Jedis实例，需要通过Jedis Pool来获取线程安全的连接。
  • Jedis基于阻塞I/O（BIO），每个操作都是同步的，即一个线程处理一个连接。

实现特性：

  • Jedis在单线程环境中表现良好，但在多线程环境下需要使用连接池来确保线程安全。
  • 对于高并发场景，每个操作都会阻塞当前线程，可能导致性能瓶颈。

Lettuce

连接方式：

  • Lettuce基于Netty框架实现了异步、非阻塞的连接操作。
  • Lettuce的连接是线程安全的，一个连接可以被多个线程共享，不需要使用连接池来管理连接。

实现特性：

  • Lettuce支持异步操作，每个操作都可以在单独的线程中执行，不会阻塞其他线程。
  • 在高并发和大规模连接的情况下，Lettuce的性能通常优于Jedis，因为它能更有效地利用系统资源，如多核处理器和内存。

总结

  • Jedis更像传统的BIO模式，适合于较简单的单线程或有限多线程的场景，但在高并发情况下需要注意线程安全性和连接管理。
  • Lettuce则更像现代NIO模式，通过异步和非阻塞的方式提升了性能和资源利用率，特别是在需要处理大量并发连接或异步操作的场景下表现优异。

因此，Spring Boot从2.x版本开始推荐使用Lettuce作为连接Redis的客户端，以提升系统的并发能力和性能表现。

1、添加POM依赖：

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Spring Data Redis -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <!--lombok,自动生成set、get等方法-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
</dependencies>

2、配置连接的application.yml文件：

spring:
  data:
    redis:
      host: localhost
      port: 6379
      database: 0
      password:  # 密码（默认为空）

3、写个简单的Dome来测试连接

创建一个配置类来配置Redis的连接工厂和Redis模板。

package com.example.demo.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * Redis配置类
 * 该类用于配置Redis连接和模板，以便在应用程序中使用Redis。
 */
@Configuration
public class RedisConfig {

    /**
     * Redis服务器主机地址
     */
    @Value("${spring.data.redis.host}")
    private String redisHost;

    /**
     * Redis服务器端口
     */
    @Value("${spring.data.redis.port}")
    private int redisPort;

    /**
     * Redis服务器密码
     */
    @Value("${spring.data.redis.password}")
    private String redisPassword;

    /**
     * 配置并返回RedisConnectionFactory
     * 使用LettuceConnectionFactory创建Redis连接工厂，并配置主机、端口和密码。
     *
     * @return RedisConnectionFactory
     */
    @Bean
    public RedisConnectionFactory redisConnectionFactory() {
        // 创建LettuceConnectionFactory实例
        LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(redisHost, redisPort);
        // 设置Redis密码
        lettuceConnectionFactory.setPassword(redisPassword);
        // 返回配置好的Redis连接工厂
        return lettuceConnectionFactory;
    }

    /**
     * 配置并返回RedisTemplate
     * 创建Redis模板实例，配置键值序列化方式，并关联到RedisConnectionFactory。
     *
     * @param redisConnectionFactory Redis连接工厂
     * @return RedisTemplate
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        // 创建Redis模板实例
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        // 设置Redis连接工厂
        template.setConnectionFactory(redisConnectionFactory);
        // 设置键的序列化方式为StringRedisSerializer
        template.setKeySerializer(new StringRedisSerializer());
        // 设置值的序列化方式为GenericJackson2JsonRedisSerializer
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        // 返回配置好的Redis模板实例
        return template;
    }

}

创建一个实体类

package com.example.demo.model;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;

/**
 * 用户类，用于表示应用程序中的用户信息。
 * 
 * @Data Lombok注解，用于自动生成getter和setter方法，以及构造函数等。
 * @NoArgsConstructor Lombok注解，生成一个无参的构造方法。
 * @AllArgsConstructor Lombok注解，生成一个全参的构造方法。
 * @Serializable 实现此接口的类的对象可以被序列化。
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
public class User implements Serializable {
    private String id;
    private String name;
    private int age;
}

然后在服务类中注入RedisTemplate并进行CRUD操作。

package com.example.demo.service;

import com.example.demo.model.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

/**
 * RedisService类提供了对Redis数据库的基本操作，包括存储、查询和删除数据。
 * 该类使用Spring的RedisTemplate来简化对Redis的操作。
 */
@Service
public class RedisService {

    /**
     * 自动注入RedisTemplate，用于操作Redis数据库。
     */
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    /**
     * 将给定的value保存到Redis中，使用指定的key进行标识。
     *
     * @param key   数据在Redis中的唯一标识符。
     * @param value 要保存到Redis中的数据。
     */
    public void save(String key, Object value) {
        redisTemplate.opsForValue().set(key, value);
    }

    /**
     * 根据指定的key从Redis中查询数据。
     *
     * @param key 数据在Redis中的唯一标识符。
     * @return 与key对应的数据。
     */
    public Object find(String key) {
        return redisTemplate.opsForValue().get(key);
    }

    /**
     * 根据指定的key从Redis中删除数据。
     *
     * @param key 要删除的数据在Redis中的标识符。
     */
    public void delete(String key) {
        redisTemplate.delete(key);
    }

    /**
     * 将User对象保存到Redis中，使用指定的key进行标识。
     *
     * @param key   数据在Redis中的唯一标识符。
     * @param user  要保存到Redis中的User对象。
     */
    public void saveUser(String key, User user) {
        redisTemplate.opsForValue().set(key, user);
    }

    /**
     * 根据指定的key从Redis中查询User对象。
     *
     * @param key 数据在Redis中的唯一标识符。
     * @return 与key对应的数据，这里是一个User对象。
     */
    public User findUser(String key) {
        return (User) redisTemplate.opsForValue().get(key);
    }

    /**
     * 根据指定的key从Redis中删除User对象。
     *
     * @param key 要删除的User对象在Redis中的标识符。
     */
    public void deleteUser(String key) {
        redisTemplate.delete(key);
    }
}

最后创建一个简单的控制器来测试Redis的CRUD操作。

package com.example.demo.controller;

import com.example.demo.model.User;
import com.example.demo.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

/**
 * Redis控制器，负责处理与Redis缓存相关的HTTP请求。
 */
@RestController
@RequestMapping("/redis")
public class RedisController {

    @Autowired
    private RedisService redisService;

    /**
     * 保存键值对到Redis缓存。
     * 如果键不存在，则保存键值对；否则返回提示信息。
     *
     * @param key 键
     * @param value 值
     * @return 保存结果的提示信息
     */
    @PostMapping("/save")
    public String save(@RequestParam String key, @RequestParam String value) {
        if (redisService.find(key) == null) {
            redisService.save(key, value);
            return "保存的!";
        }
        return "键已存在!";
    }

    /**
     * 通过键查询Redis缓存中的值。
     * 如果键存在，则返回对应的值；否则返回提示信息。
     *
     * @param key 键
     * @return 查询结果或提示信息
     */
    @GetMapping("/find")
    public Object find(@RequestParam String key) {
        if (redisService.find(key) != null) {
            return redisService.find(key);
        }
        return "没有找到!";
    }

    /**
     * 通过键从Redis缓存中删除值。
     * 如果键存在，则删除对应的值并返回提示信息；否则返回提示信息。
     *
     * @param key 键
     * @return 删除结果的提示信息
     */
    @DeleteMapping("/delete")
    public String delete(@RequestParam String key) {
        if (redisService.find(key) != null) {
            redisService.delete(key);
            return "删除的!";
        }
        return "没有找到!";
    }

    /**
     * 保存用户信息到Redis缓存。
     * 如果用户ID不存在，则保存用户信息并返回提示信息；否则返回提示信息。
     *
     * @param user 用户信息
     * @return 保存结果的提示信息
     */
    @PostMapping("/saveUser")
    public String saveUser(@RequestBody User user) {
        if (redisService.findUser(user.getId()) == null) {
            redisService.saveUser(user.getId(), user);
            return "用户已保存！";
        }
        return "用户已存在！";
    }

    /**
     * 通过用户ID查询Redis缓存中的用户信息。
     * 如果用户ID存在，则返回对应的用户信息；否则返回提示信息。
     *
     * @param id 用户ID
     * @return 查询结果或提示信息
     */
    @GetMapping("/findUser")
    public Object findUser(@RequestParam String id) {
        User user = redisService.findUser(id);
        if (user != null) {
            return user;
        }
        return "找不到用户！";
    }

    /**
     * 通过用户ID从Redis缓存中删除用户信息。
     * 如果用户ID存在，则删除用户信息并返回提示信息；否则返回提示信息。
     *
     * @param id 用户ID
     * @return 删除结果的提示信息
     */
    @DeleteMapping("/deleteUser")
    public String deleteUser(@RequestParam String id) {
        if (redisService.findUser(id) != null) {
            redisService.deleteUser(id);
            return "用户已删除！";
        }
        return "找不到用户！";
    }
}

测试效果图

 

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

点脂成金携手北京新颜兴医疗美容医院，共启战略合作新篇章

点脂成金携手北京新颜兴医疗美容医院，共启战略合作新篇章

2024年7月24日上午&#xff0c;点脂成金品牌方与北京新颜兴医疗美容医院在京举行了隆重的签约仪式&#xff0c;宣布达成战略合作关系&#xff0c;共同开启医疗美容领域的设备共享新篇章。 签约仪式在北京纯脂医疗美容门诊部有限公司举行&#xff0c;现场氛围热烈而庄重。点脂成…
阅读更多...
使用 WebSocket 实现实时聊天

使用 WebSocket 实现实时聊天

个人名片 &#x1f393;作者简介&#xff1a;java领域优质创作者 &#x1f310;个人主页&#xff1a;码农阿豪 &#x1f4de;工作室&#xff1a;新空间代码工作室&#xff08;提供各种软件服务&#xff09; &#x1f48c;个人邮箱&#xff1a;[2435024119qq.com] &#x1f4f1…
阅读更多...
基于opencv的人脸识别（实战）

基于opencv的人脸识别（实战）

前言 经过这几天的学习&#xff0c;我已经跃跃欲试了&#xff0c;相信大家也是&#xff0c;所以我决定自己做一个人脸识别程序。我会把自己的思路和想法都在这篇博客内讲清楚&#xff0c;大家可以当个参考&#xff0c;&#x1f31f;仅供学习使用&#x1f31f;。 &#x1f31f…
阅读更多...
黑马程序员2024最新SpringCloud微服务开发与实战 个人学习心得、踩坑、与bug记录Day5 全网最快最全

黑马程序员2024最新SpringCloud微服务开发与实战 个人学习心得、踩坑、与bug记录Day5 全网最快最全

你好,我是Qiuner. 为帮助别人少走弯路和记录自己编程学习过程而写博客 这是我的 github https://github.com/Qiuner ⭐️ gitee https://gitee.com/Qiuner &#x1f339; 如果本篇文章帮到了你 不妨点个赞吧~ 我会很高兴的 &#x1f604; (^ ~ ^) 想看更多 那就点个关注吧 我会…
阅读更多...
树莓派_Opencv学习笔记23：模版样本匹配

树莓派_Opencv学习笔记23：模版样本匹配

今日继续学习树莓派4B 4G&#xff1a;&#xff08;Raspberry Pi&#xff0c;简称RPi或RasPi&#xff09; 本人所用树莓派4B 装载的系统与版本如下: 版本可用命令 (lsb_release -a) 查询: ​ Opencv 版本是4.5.1&#xff1a; ​ Python 版本3.7.3&#xff1a; 今日学习Opencv样本…
阅读更多...
香烟商品销售网站

香烟商品销售网站

1 香烟商品销售网站概述 1.1 课题简介 1.2 设计目的 1.3 系统开发所采用的技术 1.4 系统功能模块 2 数据库设计 2.1 建立的数据库名称 2.2 所使用的表 3 香烟商品销售网站设计与实现 1. 注册登录&#xff1a; 2. 分页查询&#xff1a; 3. 分页条件&#xff08;精确、…
阅读更多...
速卖通卖家如何利用自养号测评，让店铺曝光量飙升？

速卖通卖家如何利用自养号测评，让店铺曝光量飙升？

在速卖通这个竞争激烈的跨境电商平台上&#xff0c;店铺曝光率是决定销售成败的关键因素之一。为了在众多商家中脱颖而出&#xff0c;增加速卖通店铺曝光显得尤为重要。速卖通怎么增加店铺曝光&#xff1f; 速卖通怎么增加店铺曝光? 1、优化产品列表 速卖通的产品列表是买家…
阅读更多...
数据库实验：连接查询

数据库实验：连接查询

一、实验目的&#xff1a; 1、掌握使用两种写法完成连接查询&#xff1a;叉积连接语法和内连接语法。 2、掌握使用外连接语法完成查询。 3、掌握使用派生表完成下列查询。 二、实验内容&#xff1a; 1. 使用连接实现查询&#xff0c;查询订单号为‘000005’的订单订购的玩具…
阅读更多...
windows 安装docker桌面版

windows 安装docker桌面版

下载 下载两个&#xff1a; git桌面版 docker desktop 启动docker 执行安装文件&#xff0c;启动 更新wsl2 假如报错&#xff0c;会提示失败原因。 win10会提示跳转到&#xff1a; https://learn.microsoft.com/zh-cn/windows/wsl/install-manual#step-4—download-the-l…
阅读更多...
CANoe编程实例--TCP/IP通信

CANoe编程实例--TCP/IP通信

1、简介 本实例将使用目前常用的开发工具C#来开发服务器端&#xff0c;以CANoe端作为客户端。服务器端和客户端&#xff0c;通过TCP/IP连接&#xff0c;实现数据交换。 首先在服务器端建立一个监听Socket&#xff0c;自动创建一个监听线程&#xff0c;随时监听是否有客户端的连…
阅读更多...
使用 Visual Studio 2022 自带的 cl.exe 编译 tensorRT自带测试样例 sampleOnnxMNIST

使用 Visual Studio 2022 自带的 cl.exe 编译 tensorRT自带测试样例 sampleOnnxMNIST

1. 新建任意文件夹&#xff0c;将 D:\install\tensorRT\TensorRT-8.6.1.6\samples\sampleOnnxMNIST 下面的 sampleOnnxMNIST.cpp 文件复制进来&#xff0c;同时 D:\install\tensorRT\TensorRT-8.6.1.6\samples\sampleOnnxMNIST 下面的 sample_onnx_mnist.vcxproj 中的内容&…
阅读更多...
WEBKIT 通过JavaScript 调用本地，硬件未来之窗OS硬件APP

WEBKIT 通过JavaScript 调用本地，硬件未来之窗OS硬件APP

以酒店为例我们需要调用shen份证读取&#xff0c;采集人脸&#xff0c;门锁写房卡&#xff0c;如何通过浏览器调用 1.通过本地http服务 2.通过webkit模式 这里说政务单位模式的集成 由于篇幅问题&#xff0c;怎么集成webkit就不说了 一、webkkit加载交互本地代码 browser.…
阅读更多...
【Kettle实现神通（数据库）MPP增量、全量数据ETL，同步任务Linux运行（通用）】

【Kettle实现神通（数据库）MPP增量、全量数据ETL，同步任务Linux运行（通用）】

1、背景介绍 具体Kettle操作步骤不做过多介绍&#xff0c;主要技术方案说明&#xff0c;Kettle8.2版本放在底部链接提取&#xff0c;本次采用Kettle实现源端&#xff1a;神通数据通用库、目标端&#xff1a;神通MPP增量数据同步&#xff0c;并在服务器端运行Job。 2、windows…
阅读更多...
Materials Today|用于婴儿监护的柔性电子设备 （柔性健康监测/柔性传感/可穿戴电子/电子皮肤/柔性电子）

Materials Today|用于婴儿监护的柔性电子设备 （柔性健康监测/柔性传感/可穿戴电子/电子皮肤/柔性电子）

西安交通大学方云生&#xff08;Yunsheng Fang&#xff09;、徐峰&#xff08;Feng Xu&#xff09;和西安交通大学第一附属医院林婷&#xff08;Ting Lin&#xff09;团队&#xff0c;在期刊《Materials Today》上发布了一篇题为“Soft electronics for advanced infant monito…
阅读更多...
关于@JsonSerialize序列化与@JsonDeserialize反序列化注解的使用（密码加密与解密举例）

关于@JsonSerialize序列化与@JsonDeserialize反序列化注解的使用（密码加密与解密举例）

注&#xff1a;另一种方式参考 关于TableField中TypeHandler属性&#xff0c;自定义的类型处理器的使用&#xff08;密码加密与解密举例&#xff09;http://t.csdnimg.cn/NZy4G 1.简介 1.1 序列化与反序列化 学习注解之前&#xff0c;我们可以先了解一下什么是序列化与反序列…
阅读更多...
JAVA里的配置文件（Properties）详解

JAVA里的配置文件（Properties）详解

package Properties;import java.util.Map; import java.util.Properties; import java.util.Set;public class demo1 {public static void main(String[] args) {/*Properties作为Map集合的操作*///1.创建集合的对象Properties pnew Properties();//2.添加数据//细节&#xff…
阅读更多...
谷粒商城实战笔记-79-商品服务-API-平台属性-销售属性维护

谷粒商城实战笔记-79-商品服务-API-平台属性-销售属性维护

文章目录 一&#xff0c;列表接口开发1&#xff0c;新建常量类2&#xff0c;路径参数识别规格参数和销售属性 二&#xff0c;其他接口三&#xff0c;编码经验-使用常量类为什么要用常量类&#xff1f;示例 这一节的主要内容是&#xff1a; 销售属性列表查询接口的开发将代码中的…
阅读更多...
C++ 沙漏图案（Hour-glass Pattern）

C++ 沙漏图案（Hour-glass Pattern）

给定正整数 n&#xff0c;以沙漏形式打印数字模式。示例&#xff1a; 输入&#xff1a;rows_no 7 输出&#xff1a; 1 2 3 4 5 6 7 2 3 4 5 6 7 3 4 5 6 7 4 5 6 7 5 6 7 6 7 7 6 7 5 6 7 4 5 6 7 3 4 5 6 7 2 3 4 5 6 7 1 2 3 4 5 6…
阅读更多...
等保2.0测评 — 容器测评对象选取

等保2.0测评 — 容器测评对象选取

之前有小伙伴提问到&#xff0c;关于容器到底要测评哪些内容&#xff0c;也就是测评对象的选取。 首先要区分的是容器与容器集群这两个概念。容器集群概念可参考该篇文章。 不使用容器扩展要求情况 当仅使用容器技术时&#xff0c;采用安全通用要求&#xff0c;无需使用容器…
阅读更多...
AFSim仿真系统-架构概览

AFSim仿真系统-架构概览

引言 本文档从最终用户的角度描述了AFSIM架构&#xff0c;旨在帮助最终用户深入了解AFSIM的操作概念。 核心架构 AFSIM基于面向对象的C架构&#xff0c;提供了一种可扩展和模块化的架构&#xff0c;使得许多附加功能能够轻松集成。AFSIM允许新的组件模型&#xff08;如传感器、…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023