SpringBoot——整合Redis

目录

Redis

创建Commodity表

启动MySQL和Redis

新建一个SpringBoot项目

pom.xml

application.properties

Commodity实体类

 ComMapper接口

ComService业务层接口

ComServiceImpl业务接口的实现类

ComController控制器

RedisConfig配置类

SpringbootRdisApplication启动类

启动项目，进行测试 

Redis

  • Redis是一个高性能的 key-value 数据库，支持多种数据结构，常用作缓存、消息代理和配置中心
  • 用途：
    • 1、缓存热点数据
      • 由于Redis的访问速度快、支持的数据类型很丰富，所以很适合用来存储热点数据，其内置的expire可以对缓存的数据设置过期时间，在缓存的数据过期后再设置新的缓存数据
    • 2、计数器
      • Redis的incrby命令是原子性地递增，因此可以运用于商城系统的高并发的秒杀活动、分布式序列号的生成等场景
    • 3、排行榜
      • 可以使用Redis的SortedSet进行热点数据的排序
    • 4、分布式锁
      • Redis的setnx命令的作用是，如果当前的缓存数据，不存在则设置缓存成功并返回1，否则设置缓存失败并返回0。可以利用这个特性在Redis集群中检测锁的有效时间，如果超时，那么等待的进程将有机会获得锁，从而防止项目出现死锁
  • 在SpringBoot中要存储和访问Redis中的数据，可以使用 RedisTemplate 和 StringRedisTemplate 模板类，用模板操作Redis实际就是通过set()/get()方法存取数据
    • StringRedisTemplate 是 RedisTemplate 的子类
    • StringRedisTemplate 只针对键值都是字符串类型的数据，而 RedisTemplate 可以操作对象类型的数据
    • StringRedisTemplate 默认使用 StringRedisSerializer 序列化器，而 RedisTemplate 默认使用 JdkSerializationRedisSerializer 序列化器
    • RedisTemplate 提供了5种数据结构的操作方法
      • opsForValue：操作字符串类型
      • opsForHash：操作哈希类型
      • opsForList：操作列表类型
      • opsForSet：操作集合类型
      • opsForZSet：操作有序集合类型
  • 当数据存储到 Redis中时，键和值都是通过SpringBoot提供的序列化器（Serializer）序列化到内存数据库中

项目总结

  1.  引入依赖：首先，在 pom.xml 文件中引入 Spring Boot Starter Data Redis 依赖，以便使用 Spring Boot 提供的 Redis 支持。
  2. 配置 Redis 连接信息：在 Spring Boot 项目的配置文件（如 application.properties 或 application.yml）中配置 Redis 的连接信息，包括主机地址、端口、密码等。
  3. 编写 Redis 配置类：如果需要自定义 RedisTemplate 的配置，可以创建一个 Redis 配置类，在其中配置 RedisTemplate。你可以自定义键值的序列化器、连接工厂等配置。
  4. 使用 RedisTemplate 进行操作：通过在需要使用 Redis 的地方注入 RedisTemplate，即可使用它来进行 Redis 的操作，包括存储、读取、删除等操作。
    1. 比如本项目中就是在ComServiceImpl业务接口的实现类中编写业务逻辑代码时，使用到了Redis进行数据的存取 
  5. 测试：编写单元测试或集成测试来验证 Redis 的功能是否正常。
  6. 这就是整合 Spring Boot 与 Redis 的基本工作流程和思路。通过这些步骤，你可以在 Spring Boot 项目中方便地使用 Redis 来实现缓存、分布式锁等功能。

创建Commodity表

CREATE DATABASE netshop;
USE netshop;
CREATE TABLE commodity(
    Pid INT(8) NOT NULL PRIMARY KEY,
    TCode CHAR(3) NOT NULL,
    SCode CHAR(8) NOT NULL,
    PName VARCHAR(32) NOT NULL,
    PPrice DECIMAL(7,2) NOT NULL,
    Stocks INT UNSIGNED DEFAULT 0
);
INSERT INTO commodity(Pid,TCode,SCode,PName,PPrice,Stocks) VALUES(1,'11A','SXLC001A','洛川红富士苹果冰糖心10斤箱装',44.80,3601);
INSERT INTO commodity(Pid,TCode,SCode,PName,PPrice,Stocks) VALUES(2,'11A','SXLC002A','烟台红富士苹果10斤箱装',29.80,5698);
INSERT INTO commodity(Pid,TCode,SCode,PName,PPrice,Stocks) VALUES(3,'11A','SXLC003A','库尔勒香梨10斤箱装',69.80,8902);

启动MySQL和Redis

命令行启动MySQL，不要关闭小黑窗

双击redis-server.exe，启动redis服务器

新建一个SpringBoot项目

  • 添加Spring Boot基本框架：Spring Web
  • Lombok模型简化组件：Lombok
  • MyBatis框架：MyBatis Framework
  • MySQL的驱动：MySQL Driver
  • Redis框架：Spring Data Redis(Access+Driver)

项目结构：

pom.xml

  • 常见报错的解决办法：加个版本号<version>，或者降一下版本号
  • 推荐使用spring-boot-starter-data-redis，我查了很多办法也解决不了这个依赖的报错，所以在此用了spring-data-redis，需要手动配置Redis 相关的 bean 和属性。这可能导致配置错误或遗漏，从而导致应用无法正确连接到 Redis。
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
		 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.3.12.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>
	<groupId>com.study</groupId>
	<artifactId>springboot_redis</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<name>springboot_redis</name>
	<description>Demo project for Spring Boot</description>
	<properties>
		<java.version>8</java.version>
	</properties>
	<dependencies>
		<!--推荐使用spring-boot-starter-data-redis,免去手动配置-->
		<dependency>
			<groupId>org.springframework.data</groupId>
			<artifactId>spring-data-redis</artifactId>
			<version>2.4.1</version>
		</dependency>

		<!--SpringBoot默认使用Lettuce客户端,相比于Jedis,线程安全且可支持并发访问-->
		<dependency>
			<groupId>io.lettuce</groupId>
			<artifactId>lettuce-core</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.mybatis.spring.boot</groupId>
			<artifactId>mybatis-spring-boot-starter</artifactId>
			<version>2.2.2</version>
		</dependency>

		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
		</dependency>
		<dependency>
			<groupId>org.projectlombok</groupId>
			<artifactId>lombok</artifactId>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.mybatis.spring.boot</groupId>
			<artifactId>mybatis-spring-boot-starter-test</artifactId>
			<version>2.2.2</version>
			<scope>test</scope>
		</dependency>
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
				<configuration>
					<excludes>
						<exclude>
							<groupId>org.projectlombok</groupId>
							<artifactId>lombok</artifactId>
						</exclude>
					</excludes>
				</configuration>
			</plugin>
		</plugins>
	</build>

</project>

application.properties配置文件

# 连接MySQL数据库
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/netshop?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&useSSL=true
spring.datasource.username=root
spring.datasource.password=admin
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

# 连接Redis
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
# Redis数据库索引(默认为0)
spring.redis.database=0

Commodity实体类

package com.study.springboot_redis.model;

import lombok.Data;
import java.io.Serializable;

@Data //该注解包含了getter,setter,toString()等方法
public class Commodity implements Serializable {//序列化

    private int pid;//商品号
    private String tcode;//商品分类编码
    private String scode;//商家编码
    private String pname;//商品名称
    private float pprice;//商品价格
    private int stocks;//商品库存
}

 ComMapper接口

package com.study.springboot_redis.mapper;

import com.study.springboot_redis.model.Commodity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;


/**
 * 这是一个公共接口，定义了与commodity表进行交互的方法
 */
@Mapper //这个注解表示该接口是一个Mapper接口，用于与数据库进行交互
public interface ComMapper {

    //@Param("pid")注解用于将方法参数与SQL语句中的pid参数进行映射
    @Select("SELECT * FROM commodity WHERE Pid = #{pid}")
    Commodity queryByPid(@Param("pid") int pid);
}

ComService业务层接口

package com.study.springboot_redis.service;

import com.study.springboot_redis.model.Commodity;

/**
 * 业务层
 */
public interface ComService {

    public String getPNameFromRedis(int pid);//从Redis获取商品名称
    public Commodity getComFromRedis(int pid);//从Redis获取商品记录对象
}

ComServiceImpl业务接口的实现类

package com.study.springboot_redis.service;

import com.study.springboot_redis.mapper.ComMapper;
import com.study.springboot_redis.model.Commodity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.data.redis.core.StringRedisTemplate;

/**
 * 业务接口的实现类
 * 用模板操作Redis实际就是通过set()/get()方法存取数据
 */
@Service //将一个类标识为服务层组件
public class ComServiceImpl implements ComService{

    @Autowired
    ComMapper comMapper;

    @Autowired
    StringRedisTemplate stringRedisTemplate;//StringRedisTemplate模板用于从Redis存取字符串,注入该模板

    @Autowired
    RedisTemplate<String,Object> redisTemplate;//RedisTemplate模板用于从Redis存取对象,注入该模板

    @Override
    public String getPNameFromRedis(int pid) {
        Commodity commodity = comMapper.queryByPid(pid);//从MyBatis接口读取商品记录
        stringRedisTemplate.opsForValue().set("pname",commodity.getPname());//使用set()方法存入Redis
        return stringRedisTemplate.opsForValue().get("pname");//使用get()方法从Redis中获取
    }

    @Override
    public Commodity getComFromRedis(int pid) {
        Commodity commodity = comMapper.queryByPid(pid);
        redisTemplate.opsForValue().set(String.valueOf(commodity.getPid()),commodity);
        return (Commodity) redisTemplate.opsForValue().get(String.valueOf(pid));
    }
}

ComController控制器

package com.study.springboot_redis.controller;

import com.study.springboot_redis.model.Commodity;
import com.study.springboot_redis.service.ComServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("com")
public class ComController {

    @Autowired //注入业务层操作Redis的服务实体
    ComServiceImpl comService;

    @RequestMapping("getpname")//从Redis获取商品名称
    public String getPNameByPid(int pid){
        return comService.getPNameFromRedis(pid);
    }

    @RequestMapping("getcom")//从Redis获取商品记录对象
    public Commodity getComByPid(int pid){
        return comService.getComFromRedis(pid);
    }
}

RedisConfig配置类

package com.study.springboot_redis.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
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;


@Configuration //声明该类为配置类
public class RedisConfig {
    /**
     * RedisTemplate使用JdkSeriallizationRedisSerializer来序列化数据,以二进制的形式存储,不便可视化,所以在此自定义序列化器
     * 在此自定义一个JSON格式的序列化类
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory connectionFactory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setKeySerializer(new StringRedisSerializer());

        //GenericJackson2JsonRedisSerializer这个序列化器是一个通用的 JSON 序列化器，
        // 它可以序列化和反序列化任意类型的对象，而不需要指定对象的类型
        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        redisTemplate.setConnectionFactory(connectionFactory);
        return redisTemplate;
    }
}

SpringbootRdisApplication启动类

package com.study.springboot_redis;

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

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

启动项目，进行测试 

  • 访问网址：http://localhost:8080/com/getpname?pid=1
  • 取出pid=1的商品名称，页面返回一个字符串

  • 访问网址：http://localhost:8080/com/getcom?pid=1 
  • 取出pid=1的商品对象

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

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

相关文章

c++|多态

c++|多态

c|多态 1 多态的概念2 多态的定义及其实现2.1 满足多态的条件2.2 虚函数2.3 虚函数的重写2.4 析构函数适合加virtural吗2.4 C11 override 和 final2.5 三个概念的对比 3 多态的原理4 抽象类4.1 概念4.2 纯虚函数 1 多态的概念 多态的概念&#xff1a;通俗来说&#xff0c;就是…
阅读更多...
微信小程序实现容器图片流式布局功能，配合小程序原生框架使用。

微信小程序实现容器图片流式布局功能，配合小程序原生框架使用。

小程序实现容器图片流式布局功能&#xff0c;因为目前论坛上也有很多博主出过类似的文章&#xff0c;这里我就以一个小白角度去讲一下如何实现的吧。给作者一点点鼓励&#xff0c;先点个赞赞吧&#x1f44d;&#xff0c;蟹蟹&#xff01;&#xff01; 目标 实现下方效果图 技术…
阅读更多...
HarmonyOS鸿蒙应用开发——安装与配置

HarmonyOS鸿蒙应用开发——安装与配置

今天脑子又抽风&#xff0c;前端转完学后端之后&#xff0c;今天大周末早上醒来突然又想学鸿蒙了&#xff0c;刚好有个比赛需要用到鸿蒙&#xff0c;于是乎我就随便点开b站看了一下鸿蒙视频&#xff0c;然后马上来写这篇博客&#xff0c;后续我的鸿蒙的博客可能会跳着、不连续地…
阅读更多...
springboot集成达梦数据库8

springboot集成达梦数据库8

springboot集成达梦数据库8 官方文档&#xff1a;[https://eco.dameng.com/document/dm/zh-cn/start/java-development.html](https://eco.dameng.com/document/dm/zh-cn/start/java-development.html) 引入maven依赖 <!--添加数据库驱动安装包--> <dependency> …
阅读更多...
十六进制转十进制

十六进制转十进制

十六进制转十进制 在玩编程的时候常会碰到十六进制转换的问题。对于专业的大佬大咖这不是问题&#xff0c;小人物总会有些麻烦。我在研究调色板时也遇到进制转换问题。前些时在本站发了十进制转十六进制的博文&#xff0c;今再写十六进制转十进制的转换方法。供大家参考。 下面…
阅读更多...
awk编辑器

awk编辑器

目录 工作原理 命令格式 普通格式 BEGIN格式 语句循环格式 awk常见的内建变量&#xff08;可直接用&#xff09; 按行打印行内容 统计行数量 按字段输出文本 通过管道、双引号调用 Shell 命令 awk编辑器是一种流编辑器 工作原理 逐行读取文本,默认以空格或tab键为分…
阅读更多...
光环P3O不错的一个讲座

光环P3O不错的一个讲座

光环P3O不错的一个讲座&#xff0c;地址&#xff1a;https://apphfuydjku5721.h5.xiaoeknow.com/v2/course/alive/l_663dc840e4b0694c62c32d1d?app_idapphfuydJkU5721&share_fromu_5c987304d8515_wH2E5HgCgx&share_type5&share_user_idu_5c987304d8515_wH2E5HgCgx…
阅读更多...
AIGC-风格迁移-“DEADiff:稳定可控的文本到图像风格化扩散模型 “-CVPR2024

AIGC-风格迁移-“DEADiff:稳定可控的文本到图像风格化扩散模型 “-CVPR2024

DEADiff: An Efficient Stylization Diffusion Model with Disentangled Representations 代码&#xff1a;https://tianhao-qi.github.io/DEADiff/ 论文&#xff1a;https://arxiv.org/pdf/2403.06951 本文介绍了一种名为DEADiff的方法&#xff0c;旨在解决基于扩散的文本到图…
阅读更多...
又翻车了！谷歌急于手动删除搜索中的奇怪AI答案｜TodayAI

又翻车了！谷歌急于手动删除搜索中的奇怪AI答案｜TodayAI

谷歌公司近日确认&#xff0c;正在“迅速采取行动”删除一些AI工具的奇怪回应。社交媒体上充斥着谷歌新AI概览产品&#xff08;AI Overview&#xff09;说出奇怪话语的例子&#xff0c;从告诉用户在披萨上涂胶水到建议他们吃石头。这次混乱的AI发布导致谷歌不得不手动禁用某些搜…
阅读更多...
车灯合面合壳密封使用UV胶的优缺点是什么呢?汽车车灯的灯罩如果破损破裂破洞了要怎么修复？

车灯合面合壳密封使用UV胶的优缺点是什么呢?汽车车灯的灯罩如果破损破裂破洞了要怎么修复？

车灯合面合壳密封使用UV胶的优缺点是什么呢? 车灯合壳密封使用UV胶的优缺点如下&#xff1a; 优点&#xff1a; 快速固化&#xff1a;UV胶通过紫外线照射可以在短时间内迅速固化&#xff0c;大大缩短了车灯制造的工艺流程时间&#xff0c;提高了生产效率。高度透明&#xff…
阅读更多...
二叉树——进阶（递归创建，非递归，广度优先，翻转，深度，对称）

二叉树——进阶（递归创建，非递归，广度优先，翻转，深度，对称）

二叉树——进阶 二叉树的递归创建非递归前中后序遍历非递归前序遍历非递归中序遍历非递归后序遍历 广度优先遍历二叉树&#xff08;层序遍历&#xff09;翻转二叉树 二叉树深度最大深度最小深度 对称二叉树 二叉树的递归创建 1&#xff0c;二叉树是一种结构相对固定的数据&…
阅读更多...
金融信贷风控系统设计模式应用之模版方法

金融信贷风控系统设计模式应用之模版方法

背景介绍 风控系统每种场景 如个人消费贷 都需要跑很多规则 规则1 申请人姓名身份证号实名验证规则2 申请人手机号码实名认证规则3 银行卡预留手机号码实名认证规则4 申请人银行卡预留手机号码在网状态检验规则5 申请人银行借记卡有效性核验规则6 户籍地址与身份证号归属地比…
阅读更多...
微信小程序知识点1

微信小程序知识点1

一. 页面样式和结构 1.1 小程序组件(html) (1) 区域布局组件 view 定义块级区域&#xff0c;相当于网页中的 div 标签text 定义行内区域&#xff0c;相当于网页中的 span标签 (2) 链接跳转组件 navigator 组件相当于网页中的 a 标签&#xff0c;用来实现页面之间的跳转。 …
阅读更多...
基于卷积神经网络的交通标志识别(pytorch，opencv，yolov5)

基于卷积神经网络的交通标志识别(pytorch，opencv，yolov5)

文章目录 数据集介绍&#xff1a;resnet18模型代码加载数据集&#xff08;Dataset与Dataloader&#xff09;模型训练训练准确率及损失函数&#xff1a;resnet18交通标志分类源码yolov5检测与识别&#xff08;交通标志&#xff09; 本文共包含两部分&#xff0c; 第一部分是用re…
阅读更多...
力扣刷题---2206. 将数组划分成相等数对【简单】

力扣刷题---2206. 将数组划分成相等数对【简单】

题目描述&#x1f357; 给你一个整数数组 nums &#xff0c;它包含 2 * n 个整数。 你需要将 nums 划分成 n 个数对&#xff0c;满足&#xff1a; 每个元素 只属于一个 数对。 同一数对中的元素 相等 。 如果可以将 nums 划分成 n 个数对&#xff0c;请你返回 true &#xf…
阅读更多...
高开高走的续作，可不止《庆余年2》

高开高走的续作，可不止《庆余年2》

说起最近霸屏的影视剧&#xff0c;莫过于《庆余年2》。火爆全网的讨论度总归是没有辜负观众们五年的等待&#xff0c;在五月的影视市场独占鳌头已成定局。张若昀、陈道明、李沁等一众演员稳定发挥&#xff0c;剧情节奏随着故事发展渐入佳境&#xff0c;评分一路高涨。 对影视作…
阅读更多...
【网络安全】社会工程学攻击与防范

【网络安全】社会工程学攻击与防范

一、社会工程学概述 1、社会工程学的定义 通过利用人们的心理弱点、本能反应、好奇心、信任、贪婪等一些心理陷阱进行的诸如欺骗、伤害、信息盗取、利益谋取等对社会及人类带来危害的行为或方法。 当网络恶意攻击者无法通过纯粹的计算机技术达到目的时&#xff0c;高超的情商…
阅读更多...
统计信号处理基础 习题解答10-4

统计信号处理基础 习题解答10-4

题目&#xff1a; 重复习题10.3&#xff0c;但条件PDF变为&#xff1a; 以及均匀先验。如果非常大&#xff0c;这样先验知识很少&#xff0c;则会出现什么情况。 解答&#xff1a; 如果记 那么&#xff0c;根据条件独立性质&#xff0c;得到&#xff1a; 其中&#xff0c;&am…
阅读更多...
Web3 游戏平台 Creo Engine 销毁代币总量的20%，以促进长远发展

Web3 游戏平台 Creo Engine 销毁代币总量的20%，以促进长远发展

Creo Engine 5月16日进行了第三次代币销毁&#xff0c;这次的销毁占代币总量的 20%。一共销毁了2亿 $CERO 代币&#xff0c;市场价值接近 2000 万美元。 Creo Engine 致力于连接世界、为玩家提供一站式游戏中心&#xff0c;并提升 Web3 游戏体验。 Creo Engine 发布于2022年&am…
阅读更多...
Python学习---基于TCP协议的网络通信程序案例

Python学习---基于TCP协议的网络通信程序案例

TCP简介&#xff1a; ●TCP 面向连接、可靠的、基于字节流的传输控制协议 ●TCP的特点 ○面向连接 ○可靠传输 ■应答机制 ■超时重传 ■错误校验 ■流量管控 ●TCP通信模型 TCP严格区分客户…
阅读更多...
最新文章

Copyright @ 2022~2023