redis的使用场景

目录

1. 热点数据缓存

1.1 什么是缓存？

1.2 缓存的原理

1.3 什么样的数据适合放入缓存中

1.4 哪个组件可以作为缓存

1.5 java使用redis如何实现缓存功能

1.5.1 需要的依赖

1.5.2  配置文件

 1.5.3 代码

 1.5.4 发现

1.6 使用缓存注解完成缓存功能

2. 分布式锁

2.1模拟高并发

2.2 使用syn和lock锁

2.3 模拟多服务器

 2.4 nginx代理集群

2.5 使用redis解决分布式锁文件

1. 热点数据缓存

1.1 什么是缓存？

 为了把一些经常访问的数据，放入缓存中以减少对数据库的访问频率。从而减少数据库的压力，提高程序的性能。（内存中存储）

1.2 缓存的原理

1.3 什么样的数据适合放入缓存中

  1. 查询频率高且修改频率低
  2.  数据安全性低

1.4 哪个组件可以作为缓存

  1. redis组件
  2. memory组件
  3. ehcache组件

1.5 java使用redis如何实现缓存功能

1.5.1 需要的依赖

 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.4.3</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency>

1.5.2  配置文件

server.port=8080#数据源
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/1suo?useUnicode=true&characterEncoding=utf-8&useSSL=false
spring.datasource.username=root
spring.datasource.password=12345678#mybatisplus的sql日志
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
#mapper映射文件
mybatis-plus.mapper-locations=classpath*:mapper/*.xml#redis配置
spring.redis.host=172.16.7.192
spring.redis.port=6379
spring.redis.database=1

 1.5.3 代码

控制层

package com.ls.controller;import com.ls.entity.Clazz;
import com.ls.service.ClazzService;
import com.ls.vo.R;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;/*** @program: springboot-redis-cache* @description:* @author: 1suo* @create: 2024-07-24 19:56**/
@RestController
@RequestMapping("clazz")
public class ClazzController {@Autowiredprivate ClazzService clazzService;@DeleteMapping("delete")public R delete(Integer id) {return clazzService.delete(id);}@GetMapping("get")public R get(Integer id) {return clazzService.get(id);}@GetMapping("getAll")public R getAll() {return clazzService.getAll();}@PostMapping("save")public R save(@RequestBody Clazz clazz) {return clazzService.save(clazz);}@PutMapping("update")public R update(Clazz clazz) {return clazzService.update(clazz);}
}

业务层

package com.ls.service.impl;import com.ls.dao.ClazzDao;
import com.ls.entity.Clazz;
import com.ls.service.ClazzService;
import com.ls.vo.R;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Service;
import sun.dc.pr.PRError;import java.util.ArrayList;
import java.util.List;/*** @program: springboot-redis-cache* @description:* @author: 1suo* @create: 2024-07-24 19:57**/
@Service
public class ClazzServiceImpl implements ClazzService {@Autowiredprivate ClazzDao clazzDao;@Autowiredprivate RedisTemplate<String, Object> redisTemplate;@Overridepublic R save(Clazz clazz) {int insert = clazzDao.insert(clazz);return new R(200,"保存成功",clazz);}@Overridepublic R update(Clazz clazz) {int update = clazzDao.updateById(clazz);if (update>0){redisTemplate.opsForValue().set("clazz::" + clazz.getCid(),clazz);}return new R(200,"更新成功",clazz);}@Overridepublic R delete(Integer id) {int delete = clazzDao.deleteById(id);if (delete>0){redisTemplate.delete("clazz::" + id);}return new R(200,"删除成功",id);}@Overridepublic R get(Integer id) {ValueOperations<String, Object> forValue = redisTemplate.opsForValue();Object o = forValue.get("clazz::" + id);if(o!=null){return new R(200,"查询成功",(Clazz)o);}Clazz clazz = clazzDao.selectById(id);if (clazz!=null){forValue.set("clazz::" + id,clazz);}return new R(500,"查询成功",clazz);}@Overridepublic R getAll() {List<Clazz> list = clazzDao.selectList(null);return new R(200,"查询成功",list);}
}

dao层

package com.ls.dao;import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ls.entity.Clazz;/*** @program: springboot-redis-cache* @description:* @author: 1suo* @create: 2024-07-25 08:41**/
public interface ClazzDao extends BaseMapper<Clazz> {
}

实体类

package com.ls.entity;import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;/*** @program: springboot-redis-cache* @description:* @author: 1suo* @create: 2024-07-24 19:56**/
@Data
@NoArgsConstructor
@AllArgsConstructor@TableName("tbl_clazz")
public class Clazz {@TableId(type = IdType.AUTO)private Integer cid;private String cname;
}

 配置类

package com.ls.config;import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory){RedisTemplate<String, Object> template = new RedisTemplate<>();//创建redisTemplate对象StringRedisSerializer serializer = new StringRedisSerializer();//字符串序列化对象Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);//Jackson的序列化对象ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(om);template.setConnectionFactory(factory);
//        key序列化方式template.setKeySerializer(serializer);
//        value序列化template.setValueSerializer(jackson2JsonRedisSerializer);
//        value hashmap序列化template.setHashValueSerializer(jackson2JsonRedisSerializer);template.setKeySerializer(serializer);return template;}
}

@MapperScan("com.ls.dao") 注解，将dao层自动代理为Mapper代理对象。

 1.5.4 发现

业务层代码除了要维护核心业务功能外，额外还要维护缓存的代码。

解决: 使用AOP面向切面编程。（spring框架用aop切面实现）

1.6 使用缓存注解完成缓存功能

必须spring缓存使用的组件。 

config:为解决序列化的问题

 @Beanpublic CacheManager cacheManager(RedisConnectionFactory factory) {RedisSerializer<String> redisSerializer = new StringRedisSerializer();Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);//解决查询缓存转换异常的问题ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(om);// 配置序列化（解决乱码的问题）,过期时间600秒RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofSeconds(600)) //缓存过期10分钟 ---- 业务需求。.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))//设置key的序列化方式.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) //设置value的序列化.disableCachingNullValues();RedisCacheManager cacheManager = RedisCacheManager.builder(factory).cacheDefaults(config).build();return cacheManager;}

 开启缓存注解

 

 使用
 

package com.ls.service.impl;import com.ls.dao.ClazzDao;
import com.ls.entity.Clazz;
import com.ls.service.ClazzService;
import com.ls.vo.R;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.CachePut;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Service;
import sun.dc.pr.PRError;import java.util.ArrayList;
import java.util.List;/*** @program: springboot-redis-cache* @description:* @author: 1suo* @create: 2024-07-24 19:57**/
@Service
public class ClazzServiceImpl implements ClazzService {@Autowiredprivate ClazzDao clazzDao;@Autowiredprivate RedisTemplate<String, Object> redisTemplate;@Overridepublic R save(Clazz clazz) {int insert = clazzDao.insert(clazz);return new R(200,"保存成功",clazz);}@CachePut(cacheNames = "clazz", key = "#clazz.cid")@Overridepublic Clazz update(Clazz clazz) {int update = clazzDao.updateById(clazz);return clazz;}@CacheEvict(cacheNames = "clazz", key = "#id")@Overridepublic R delete(Integer id) {int delete = clazzDao.deleteById(id);return new R(200,"删除成功",id);}@Cacheable(cacheNames = "clazz", key = "#id")@Overridepublic Clazz get(Integer id) {Clazz clazz = clazzDao.selectById(id);return clazz;}@Overridepublic R getAll() {List<Clazz> list = clazzDao.selectList(null);return new R(200,"查询成功",list);}
}

 

2. 分布式锁
 

2.1模拟高并发
 

使用jmeter压测工具：
 

第一步：
 

 

 第二步：
 

 第三步：
 

 通过压测发现库存超卖和重卖了，解决办法使用锁。
 

2.2 使用syn和lock锁
 

public String decrement(Integer productid) {//根据id查询商品的库存int num = stockDao.findById(productid);synchronized (this) {if (num > 0) {//修改库存stockDao.update(productid);System.out.println("商品编号为:" + productid + "的商品库存剩余:" + (num - 1) + "个");return "商品编号为:" + productid + "的商品库存剩余:" + (num - 1) + "个";} else {System.out.println("商品编号为:" + productid + "的商品库存不足。");return "商品编号为:" + productid + "的商品库存不足。";}}}
 

 上面使用syn和lock虽然解决了并发问题，但是我们未来项目部署时可能要部署集群模式。
 

2.3 模拟多服务器
 

 

点击增加一个服务器，同时启动后，实现模拟多服务器。 下面是服务器配置。
 

 

 启动俩个服务器：
 

 

 2.4 nginx代理集群
 

下载window版本的nginx实现代理集群。
 

 

nginx.conf配置文件：
 

 通过压测发现本地锁 无效了，使用redis解决分布式锁文件。
 

2.5 使用redis解决分布式锁文件
 

 

 核心代码：
 

@Service
public class StockService {@Autowiredprivate StockDao stockDao;@Autowiredprivate RedissonClient redisson;//public String decrement(Integer productid) {RLock lock = redisson.getLock("product::" + productid);lock.lock();try {//根据id查询商品的库存: 提前预热到redis缓存中int num = stockDao.findById(productid);if (num > 0) {//修改库存---incr---定时器[redis  数据库同步]stockDao.update(productid);System.out.println("商品编号为:" + productid + "的商品库存剩余:" + (num - 1) + "个");return "商品编号为:" + productid + "的商品库存剩余:" + (num - 1) + "个";} else {System.out.println("商品编号为:" + productid + "的商品库存不足。");return "商品编号为:" + productid + "的商品库存不足。";}}finally {lock.unlock();}}
}
 












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


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











相关文章










【Python Web】Flask扩展开发指南








【Python Web】Flask扩展开发指南




Flask是一个轻量级的Python Web框架&#xff0c;它提供了丰富的扩展库和工具&#xff0c;可以帮助开发者快速构建Web应用。本篇博客将介绍如何进行Flask扩展开发&#xff0c;包括扩展的创建、配置、使用等方面的内容。 目录 
Flask扩展开发指南 
一、Flask扩展简介 
二、创建Fl…




阅读更多...

















原子操作类（持续更新，未完结）








原子操作类（持续更新，未完结）




目录 基本类型原子类数组类型原子类引用类型原子类对象的属性修改原子类原子操作增强类LongAdder 高性能原理说明LongAdder源码深度解析LongAdder小总结 相关文献 分组来给大家讲解相关原子类的常用api使用&#xff0c;不会全部都讲完&#xff0c;只是抽取几个比较经典的讲一下…




阅读更多...

















c++树（三）重心








c++树（三）重心




目录 
重心的基础概念 
定义&#xff1a;使最大子树大小最小的点叫做树的重心 
树的重心求解方式 
例题&#xff1a; 
重心的性质 
性质1&#xff1a;重心点的最大子树大小不大于整棵树大小的一半。 
性质1证明&#xff1a; 
性质1的常用推导 
推导1&#xff1a; 
推导2&#x…




阅读更多...

















AI绘画SD中 ControlNet 组件 IP-Adapter 实现风格迁移，AI绘画垫图神器！








AI绘画SD中 ControlNet 组件 IP-Adapter 实现风格迁移，AI绘画垫图神器！




大家好&#xff0c;我是画画的小强 
今天给大家介绍一下AI绘画SD中ControlNet 的 IP-Adapter 组件&#xff0c;该组件可以方便快捷的帮我们对图片的风格进行迁移&#xff0c;简而言之就是可以参考你放置的图片风格来生成其他图片。 
它的效果和reference only有点类似&#xff…




阅读更多...

















了解网络是如何运作








了解网络是如何运作




“Web 的工作原理”提供了一个简化的视图，用于了解在计算机或手机上的 Web 浏览器中查看网页时发生的情况。 这个理论对于短期内编写 Web 代码来说并不是必需的，但不久之后，你就会真正开始从理解后台发生的事情中受益。 客户端和服务器 连接到 Internet 的计算机称为客户端和…




阅读更多...

















四、面向对象2（30小时精通C++和外挂实战）








四、面向对象2（30小时精通C++和外挂实战）




四、面向对象2&#xff08;30小时精通C和外挂实战&#xff09; B-01-对象的内存B-02-构造函数B-04-成员变量的初始化B-05-析构函数B-06-内存管理B-07-类的声明和实现分离B-08-命名空间B-09-继承B-10-成员访问权限 B-01-对象的内存 在C中对象可以自由的放在3中地方&#xff0c;而…




阅读更多...

















【算法】插入排序 与 希尔排序 概念+图解+代码【Python C C++】








【算法】插入排序 与 希尔排序 概念+图解+代码【Python C C++】




1.插入排序 
1.1概念 
插入排序(InsertionSort)&#xff0c;一般也被称为直接插入排序。 
对于少量元素的排序&#xff0c;它是一个有效的算法。插入排序是一种最简单的排序方法&#xff0c;它的基本思想是将一个元素插入到已经排好序的有序表中&#xff0c;从而构造出一个新的…




阅读更多...

















mathtype7.4永久激活码(mathtype7永久注册码网盘下载）








mathtype7.4永久激活码(mathtype7永久注册码网盘下载）




大家好&#xff0c;我是你们的数学小能手&#xff01;今天我要安利一款超实用的工具——MathType&#xff0c;让你在数学的世界里游刃有余&#xff0c;轻松搞定各种公式和计算。准备好被种草了吗&#xff1f;跟我一起来瞧瞧吧&#xff01; 
MathType是理科生专用的必备工具&…




阅读更多...

















EXCEL 排名(RANK,COUNTIFS)








EXCEL 排名(RANK,COUNTIFS)




1.单列排序 
需求描述&#xff1a;如有下面表格&#xff0c;需要按笔试成绩整体排名。 解决步骤&#xff1a; 
我们使用RANK函数即可实现单列整体排名。 Number 选择第一列。 
Ref 选择这一整列&#xff08;CtrlShift向下箭头、再按F4&#xff09;。 
"确定"即可计算…




阅读更多...

















一键解锁百变发型！上交联合Tiamat震撼发布Stable-Hair发型移植黑科技！








一键解锁百变发型！上交联合Tiamat震撼发布Stable-Hair发型移植黑科技！




Stable-Hair 是一种基于扩散的新型发型转移方法&#xff0c;可以稳健地转移各种现实世界的发型。在各种具有挑战性的发型上实现了高度详细和高保真度的转移&#xff0c;效果令人印象深刻&#xff0c;同时保留了原始身份内容和结构。 相关链接 
论文链接: https://arxiv.org/pdf…




阅读更多...

















案例实践 | 基于长安链的福建省气象综合治理区块链平台








案例实践 | 基于长安链的福建省气象综合治理区块链平台




案例名称-【福建省气象综合治理区块链平台】  ■ 实施单位  福建福链科技有限公司  ■ 业主单位  福建省气象信息中心  ■ 上线时间  2023年10月  ■ 用户群体  福建省气象、防灾减灾相关单位  ■ 用户规模  全省2100余个气象站、气象局以及防灾减灾部门  案例背景与解决痛点 
…




阅读更多...

















跟代码执行流程，读Megatron源码（四）megatron初始化脚本initialize.py之initialize_megatron()分布式环境初始化








跟代码执行流程，读Megatron源码（四）megatron初始化脚本initialize.py之initialize_megatron()分布式环境初始化




在前文中&#xff0c;我们讲述了pretrain函数的执行流程&#xff0c;其首要步骤是megatron分组的初始化与环境的配置。本文将深入initialize_megatron函数源码&#xff0c;剖析其初始化分布式训练环境的内部机制。 注&#xff1a;在此假设读者具备3D并行相关知识 
一. initiali…




阅读更多...

















【MARL】MADDPG + attention 实现（+论文解读）








【MARL】MADDPG + attention 实现（+论文解读）




文章目录 前言注意力机制论文里的attention回顾知识-MADDPG讲解1.Q的定义2.Q的恒等式3.论文里的attention4.好处 实现 和 修改结果展示原论文代码 翻改版修改后原maddpg代码 前言 
导师让在MADDPG上加一个注意力机制&#xff0c;试了很多种&#xff0c;下面的参考的论文的效果最…




阅读更多...

















C++——保持原有库头文件不变的情况下，成功编译运行工程








C++——保持原有库头文件不变的情况下，成功编译运行工程




问&#xff1a;想要保持原来库方式&#xff0c;应该怎么操作呢&#xff1f;  答&#xff1a;如果想保持原来的方式&#xff0c;则只需要将 库所在路径 tracker/detector/rknn_model_zoo/utils 加入到 工程库包含中即可。




阅读更多...

















基于jeecgboot-vue3的Flowable流程-自定义业务表单流程历史信息显示








基于jeecgboot-vue3的Flowable流程-自定义业务表单流程历史信息显示




因为这个项目license问题无法开源&#xff0c;更多技术支持与服务请加入我的知识星球。 1、对于自定义业务表单的流程历史记录信息做了调整&#xff0c;增加显示自定义业务表单 
<el-tab-pane label"表单信息" name"form"><div v-if"customF…




阅读更多...

















ESP32开发进阶：OLED屏幕显示旋转的3D模型








ESP32开发进阶：OLED屏幕显示旋转的3D模型




一、硬件接线 我选择的是最常见的一块板子&#xff1a;ESP-WROOM-32&#xff0c;硬件接线如下&#xff1a; 21 - SDA        22 - SCL 二、Arduino端代码 我们使用Arduino和Adafruit SSD1306库在OLED显示屏上绘制和旋转一个3D立方体。         首先&#xff0c;定义立方体顶点和…




阅读更多...

















CSS（七）——CSS 列表和CSS Table（表格）








CSS（七）——CSS 列表和CSS Table（表格）




目录 CSS 列表 
列表 
作为列表项标记的图像 
列表 - 简写属性 
移除默认设置 
所有的CSS列表属性 
CSS 表格 
表格边框 
折叠边框&#xff08;border-collapse&#xff09; 
表格宽度和高度 
表格文字对齐 
表格填充 
表格颜色 CSS 列表 
CSS 列表属性作用如下&#xff1a; 
设…




阅读更多...

















C#开发的全屏图片切换效果应用 - 开源研究系列文章 - 个人小作品








C#开发的全屏图片切换效果应用 - 开源研究系列文章 - 个人小作品




这天无聊&#xff0c;想到上次开发的图片显示软件《 PhotoNet看图软件 》&#xff0c;然后想到开发一个全屏图片切换效果的应用&#xff0c;类似于屏幕保护程序&#xff0c;于是就写了此博文。这个应用比较简单&#xff0c;主要是全屏切换换图片效果的问题。 1、 项目目录&…




阅读更多...

















【Vue3】watch 监视 ref 定义的数据








【Vue3】watch 监视 ref 定义的数据




【Vue3】watch 监视 ref 定义的数据 背景简介开发环境开发步骤及源码参数说明 背景 
随着年龄的增长&#xff0c;很多曾经烂熟于心的技术原理已被岁月摩擦得愈发模糊起来&#xff0c;技术出身的人总是很难放下一些执念&#xff0c;遂将这些知识整理成文&#xff0c;以纪念曾经努…




阅读更多...

















【C++进阶学习】第八弹——红黑树的原理与实现——探讨树形结构存储的最优解








【C++进阶学习】第八弹——红黑树的原理与实现——探讨树形结构存储的最优解




二叉搜索树&#xff1a;【C进阶学习】第五弹——二叉搜索树——二叉树进阶及set和map的铺垫-CSDN博客 
AVL树&#xff1a; 
​​​​​​【C进阶学习】第七弹——AVL树——树形结构存储数据的经典模块-CSDN博客 
前言&#xff1a; 在前面&#xff0c;我们已经学习了二叉搜索树和…




阅读更多...


















推荐文章












最新文章


















Copyright @ 2022~2023