10 Redis之SB整合Redis

7. SB整合Redis

Spring Boot 中可以直接使用 Jedis 实现对 Redis 的操作，但一般不这样用，而是使用 Redis操作模板 RedisTemplate 类的实例来操作 Redis。

RedisTemplate 类是一个对 Redis 进行操作的模板类。该模板类中具有很多方法，这些方法很多与 Redis 操作命令同名或类似。例如，delete()、keys()、scan()，还有事务相关的 multi()、exec()、discard()、watch()等。当然还有获取对各种 Value 类型进行操作的操作实例的两类方法 boundXxxOps(k)与 opsForXxx()。

7.1 需求

对于一个资深成熟的金融产品交易平台，其用户端首页一般会展示其最新金融产品列表，同时还为用户提供了产品查询功能。
另外，为了显示平台的实力与信誉，在平台首页非常显眼的位置还会展示平台已完成的总交易额与注册用户数量。

对于管理端，管理员可通过管理页面修改产品、上架新产品、下架老产品。

为了方便了解 Redis 与 Spring Boot 的整合流程，这里对系统进行了简化：用户端首页仅提供根据金融产品名称的查询，显眼位置仅展示交易总额。
管理端仅实现上架新产品功能。

7.2 准备

  1. 创建一个SB工程 , JDK8, SB版本2.7.4
  2. 导入依赖
  3. resource下创建一个文件夹webapp
  4. 创建一张product表
  5. 编写yaml文件
    <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.4</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.sunsplanter</groupId><artifactId>SB-Redis</artifactId><version>0.0.1-SNAPSHOT</version><name>SB-Redis</name><description>SB-Redis</description><properties><java.version>17</java.version></properties><dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.2</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.47</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.1.12</version></dependency><dependency>www.bjpowernode.com 187 / 248 Copyright© 动力节点<groupId>org.apache.tomcat.embed</groupId><artifactId>tomcat-embed-jasper</artifactId></dependency><dependency><groupId>javax.servlet</groupId><artifactId>jstl</artifactId><version>1.2</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><resources><resource><directory>src/main/java</directory><includes><include>**/*.xml</include></includes></resource><resource><directory>src/main/webapp</directory><targetPath>META-INF/resources</targetPath><includes><include>**/*.*</include></includes></resource></resources></build>
</project>

DROP TABLE IF EXISTS `product`;
CREATE TABLE `product` (`id` int(11) NOT NULL AUTO_INCREMENT,`name` varchar(20) DEFAULT NULL,`rate` double DEFAULT NULL,`amount` double DEFAULT NULL,`raised` double DEFAULT NULL,`cycle` int(11) DEFAULT NULL,`endTime` char(10) DEFAULT '0',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8;
www.bjpowernode.com 190 / 248 Copyright© 动力节点
INSERT INTO `product` VALUES (1,'天鑫添益 2',2.76,50000,20000,30,'2022-07-10'),(2,'国
泰添益',2.86,30000,30000,60,'2022-07-12'),(3,'国泰高鑫
',2.55,60000,50000,90,'2022-07-09'),(4,'国福民安
',2.96,30000,20000,7,'2022-05-10'),(5,'天益鑫多
',2.65,80000,60000,20,'2022-07-05'),(6,'惠农收益
',3.05,30000,20000,10,'2022-06-10'),(7,'惠农三鑫
',2.76,50000,30000,30,'2022-07-02'),(8,'励学收益',2.86,30000,20000,20,'2022-07-11');

mybatis:mapper-locations: classpath:com/sunsplanter/dao/*.xmltype-aliases-package: com.sunsplanter.beanspring:datasource:type: com.alibaba.druid.pool.DruidDataSourceurl: jdbc:mysql://localhost:3306/tanhua?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMTusername: rootpassword: ???driver-class-name: com.mysql.cj.jdbc.DriverLogging:pattern:console: level-%-5level - %msg%n

7.3 编写代码

在这里插入图片描述

7.3.1 controller

package com.sunsplanter.controller;@Controller
public class ProductController {@Autowiredprivate ProductService service;@GetMapping("/")public String indexHandle(Model model) {// 查询总交易额Double turnover = service.findTurnover();model.addAttribute("turnover", turnover);//查询所有产品List<Product> allProducts = service.findAllProducts();model.addAttribute("allProducts", allProducts);return "/index.jsp";}// 上架新产品，然后返回管理页面@PostMapping("/product/")public String registerHandle(Product product, Model model) {//添加新产品service.saveProduct(product);// 查询所有产品List<Product> allProducts = service.findAllProducts();model.addAttribute("allProducts", allProducts);return "/jsp/manager.jsp";}// 根据产品名称查询产品@GetMapping("/product/name")public String listHandle(String name, Model model) {List<Product> result = service.findProductsByName(name);model.addAttribute("result", result);model.addAttribute("name", name);return "/jsp/result.jsp";}
}

7.3.2 service

package com.sunsplanter.service;public interface ProductService {void saveProduct(Product product);List<Product> findAllProducts();Double findTurnover();List<Product> findProductsByName(String name);
}package com.sunsplanter.service.impl;@Service
public class ProductServiceImpl implements ProductService {@Autowiredprivate ProductDao dao;@Override@Transactional(rollbackFor = Exception.class)public void saveProduct(Product product) {dao.insertProduct(product);}@Overridepublic List<Product> findProductsByName(String name) {return dao.selectProductsByName(name);}@Overridepublic List<Product> findAllProducts() {return dao.selectAllProducts();}@Overridepublic Double findTurnover() {//获取当前日期并格式化Date date =new Date();SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");//从DB中查询turnoverObject turnover = dao.selectTurnover(sdf.format(date));return (Double) turnover;}
}

7.3.3 bean

package com.sunsplanter.bean;@Data
@AllArgsConstructor
@NoArgsConstructor
public class Product {private Integer id;private String name;//年华利率private Double rate;//募集总额private Double amount;//已募集金额private Double raised;//产品募集结束时间private Integer cycle;private String endtime;
}

7.3.4 dao接口和mapper.xml

package com.sunsplanter.dao;@Mapper
public interface ProductDao {void insertProduct(Product product);List<Product> selectAllProducts();List<Product> selectProductsByName(String name);Object selectTurnover(String date);
}

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.sunsplanter.dao.ProductDao"><insert id="insertProduct">insert into product(name, rate, amount, raised, cycle, endTime)values (#{name}, #{rate}, #{amount}, #{raised}, #{cycle}, #{endTime})</insert><select id="selectAllProducts" resultType="Product">select id,name,rate, amount,raised, cycle,endTimefrom product</select><select id="selectProductsByName" resultType="Product">select id,name,rate,amount,raised, cycle,endTimefrom productwhere name like '%'#{xxx}'%'</select><select id="selectTurnover" resultType="double">select sum(raised)from productwhere endTime is not null and endTime &lt; #{xxx}
</select></mapper>

7.4 测试与问题

以上是一个纯SpringBoot项目, 并未整合任何Redis.以下示例

7.5 整合Redis

Spring Boot 与 Redis 整合 大体上为以下几步

  1. 在 POM 中导入依赖
  2. 在配置文件中注册 Redis 连接信息与缓存信息
  3. 需要缓存到 Redis 中的实体类必须要序列化
  4. Spring Boot 启动类中要添加@EnableCaching 注解
  5. 查询方法上要添加@Cacheable 注解
  6. 对数据进行写操作的方法上添加@CacheEvict 注解
  7. 对于需要手工操作 Redis 的方法，需通过 RedisTemplate 来获取操作对象

7.5.0 学习SB中的Redis操作

7.5.0.1 @Cacheable

@Cacheable可以标记在一个方法上，也可以标记在一个类上。
当标记在一个方法上时表示该方法是支持缓存的，当标记在一个类上时则表示该类所有的方法都是支持缓存的。

对于一个支持缓存的方法，Spring会在其被调用后将其返回值缓存起来，以保证下次利用同样的参数来执行该方法时可以直接从缓存中获取结果，而不需要再次执行该方法。

Spring在缓存方法的返回值时是以键值对进行缓存的，值就是方法的返回结果，至于键的话，Spring又支持两种策略，默认策略和自定义策略，这个稍后会进行说明。需要注意的是当一个支持缓存的方法在对象内部被调用时是不会触发缓存功能的。

	常用的属性cacheNames/value ：用来指定缓存组件的名字key ：缓存数据时使用的 key，可以用它来指定。默认是使用方法参数的值。（这个 key 你可以使用 spEL 表达式来编写）condition ：可以用来指定符合条件的情况下才缓存keyGenerator ：key 的生成器。 key 和 keyGenerator 二选一使用cacheManager ：可以用来指定缓存管理器。从哪个缓存管理器里面获取缓存。unless ：否定缓存。当 unless 指定的条件为 true ，方法的返回值就不会被缓存。当然你也可以获取到结果进行判断。（通过 #result 获取方法结果）sync ：是否使用异步模式。

  1. value属性指定Cache名称

    value属性是必须指定的，其表示当前方法的返回值是会被缓存在哪个Cache上的，对应Cache的名称。其可以是一个Cache也可以是多个Cache，当需要指定多个Cache时其是一个数组。

   @Cacheable("cache1")//Cache是发生在cache1上的public User find(Integer id) {return null;}

  1. key属性自定义key

    该属性支持SpringEL表达式。
当我们没有指定该属性时，Spring将使用默认策略生成key。

我们这里先来看看自定义策略，至于默认策略会在后文单独介绍。
自定义策略是指我们可以通过Spring的EL表达式来指定我们的key。这里的EL表达式可以使用方法参数及它们对应的属性。使用方法参数时我们可以直接使用“#参数名”或者“#p参数index”。下面是几个使用参数作为key的示例。

   @Cacheable(value="users", key="#id")public User find(Integer id) {returnnull;}@Cacheable(value="users", key="#p0")public User find(Integer id) {returnnull;}@Cacheable(value="users", key="#user.id")public User find(User user) {returnnull;}@Cacheable(value="users", key="#p0.id")public User find(User user) {returnnull;}

除了上述使用方法参数作为key之外，Spring还为我们提供了一个root对象可以用来生成key。通过该root对象我们可以获取到以下信息。

在这里插入图片描述

   当我们要使用root对象的属性作为key时我们也可以将“#root”省略，因为Spring默认使用的就是root对象的属性。如：

   @Cacheable(value={"users", "xxx"}, key="caches[1].name")public User find(User user) {returnnull;}
  1. condition属性指定发生的条件
    有的时候我们可能并不希望缓存一个方法所有的返回结果。通过condition属性可以实现这一功能。
    condition属性默认为空，表示将缓存所有的调用情形。
    其值是通过SpringEL表达式来指定的，当为true时表示进行缓存处理；当为false时表示不进行缓存处理，即每次调用该方法时该方法都会执行一次。如下示例表示只有当user的id为偶数时才会进行缓存。
 @Cacheable(value={"users"}, key="#user.id", condition="#user.id%2==0")public User find(User user) {System.out.println("find user by user " + user);return user;}
7.5.0.2 @CacheEvict
   @CacheEvict是用来标注在需要清除缓存元素的方法或类上的。当标记在一个类上时表示其中所有的方法的**执行后**都会触发缓存的清除操作。@CacheEvict可以指定的属性有value、key、condition、allEntries和beforeInvocation。其中value、key和condition的语义与@Cacheable对应的属性类似。即value表示清除操作是发生在哪些Cache上的（对应Cache的名称）；key表示需要清除的是哪个key，如未指定则会使用默认策略生成的key；condition表示清除操作发生的条件。

  1. allEntries属性

    allEntries是boolean类型，表示是否需要清除缓存中的所有元素。默认为false，表示不需要。
    当指定了allEntries为true时，Spring Cache将删除所有除了指定的key以外的所有key。
    有的时候我们需要Cache一下清除所有的元素，这比一个一个清除元素更有效率。

   @CacheEvict(value="users", allEntries=true)public void delete(Integer id) {System.out.println("delete user by id: " + id);}

  1. beforeInvocation属性

    清除操作默认是在对应方法成功执行之后触发的，即方法如果因为抛出异常而未能成功返回时也不会触发清除操作。
    使用beforeInvocation可以改变触发清除操作的时间，当我们指定该属性值为true时，Spring会在调用该方法之前清除缓存中的指定元素。

   @CacheEvict(value="users", beforeInvocation=true)public void delete(Integer id) {System.out.println("delete user by id: " + id);}

7.5.0.3 RedisTemplate常用集合

RedisTemplate常用集合

7.5.1 准备

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

redis:host:redisport:6379#Sentinel高可用集群
#sentinel:
#  master: mymaster
#  nodes: redis:26380,redis:26381,redis:26382#Cluster分布式系统
#cluster:
#  nodes: redis:6380,redis:6381,edis:6382,edis:6383,redis:6384,redis:6385cache:type: rediscache-names: pc

7.5.2 修改实体类

由于要将查询的实体类对象缓存到 Redis，Redis 要求实体类必须序列化。所以需要实体类实现序列化接口。

class Product implements Serializable {

7.5.3 修改serviceImpl类

//注入RedisTemplate模板
@Autowired
private RedisTemplate<0bject,0bject> rt;

//清除名为pc的缓存空间. 且清除其内的所有条目，如果想要保留一些, 则需通过 key 属性指定要清理的 key 数据。
//该注解会在方法体执行前执行
@0verride
@Transactional(rollbackFor=Exception.class)
@CacheEvict(value ="pc",allEntries = true)
public void saveProduct(Product product){dao.insertProduct(product);
}@Override
public Double findTurnover(){//绑定键为"turnover的键值对, 然后就可以对其进行操作"BoundValue0perations<Object, 0bject> ops = rt.boundValue0ps("turnover");Object turnover = ops.get();//先从缓存中查, 如果缓存中没有, 再从DB中获取, 最终写入缓存if(turnover == null){Date date = new Date();SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd")turnover = dao.selectTurnover(sdf.format(date));//写入缓存ops.set(turnover,10,TimeUnit.SECONDS);}return (Double) turnover;
}

7.5.4 启动类增加注解

@EnableCaching 用于开启当前应用的缓存功能。

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

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

相关文章

多微信管理利器，让你高效社交，轻松管理！

多微信管理利器，让你高效社交，轻松管理！

随着工作和生活中微信号增加&#xff0c;管理多个微信账号也成了一项挑战。面对多个微信号&#xff0c;要应对各种消息、好友请求、群发等多重任务&#xff0c;往往会让我们不知所措。 这时&#xff0c;一款强大的微信管理系统将成为你的利器&#xff0c;帮你高效社交&#xf…
阅读更多...
Redis的高性能之道

Redis的高性能之道

前言&#xff1a;做码农这么多年&#xff0c;我也读过很多开源软件或者框架的源码&#xff0c;在我看来&#xff0c;Redis是我看过写得最优美、最像一件艺术品的软件&#xff0c;正如Redis之父自己说的那样&#xff0c;他宁愿以一个糟糕的艺术家身份而不是一名好程序员被别人记…
阅读更多...
【C++STL】快速排序算法(sort)的原理与使用

【C++STL】快速排序算法(sort)的原理与使用

一、sort算法原理 std::sort 是 C 标准库中提供的排序算法&#xff0c;它使用的是一种经典的排序算法——快速排序&#xff08;Quicksort&#xff09;或者是其变种。 快速排序是一种基于比较的排序算法&#xff0c;通过不断地选择一个基准值&#xff08;pivot&#xff09;&am…
阅读更多...
超声波手持气象站的工作原理

超声波手持气象站的工作原理

TH-CSQ5A超声波手持气象站是一种利用超声波技术进行气象要素测量的便携式设备。它集成了多种气象传感器&#xff0c;包括温度传感器、湿度传感器、风速传感器、风向传感器等&#xff0c;能够同时测量和记录多个气象参数。 超声波手持气象站的工作原理基于超声波的传播特性。它…
阅读更多...
全网最详细的Jmeter自动化测试

全网最详细的Jmeter自动化测试

&#x1f345; 视频学习&#xff1a;文末有免费的配套视频可观看 &#x1f345; 点击文末小卡片&#xff0c;免费获取软件测试全套资料&#xff0c;资料在手&#xff0c;涨薪更快 1、Jmeter的安装与部署 1.1 环境要求 jdk1.8、配置jdk环境变量&#xff08;JAVA_HOME:C:\Progr…
阅读更多...
java工程师面试突击中华石杉，开发人员必学

java工程师面试突击中华石杉，开发人员必学

如何高效的学习MyBatis源码呢&#xff1f; 市面上真正适合学习的MyBatis资料太少&#xff0c;有的书或资料虽然讲得比较深入&#xff0c;但是语言晦涩难懂&#xff0c;大多数人看完这些书基本都是从入门到放弃。学透MyBatis源码难道就真的就没有一种适合大多数同学的方法吗&am…
阅读更多...
【笔记】深度学习入门：基于Python的理论与实现（六）

【笔记】深度学习入门：基于Python的理论与实现（六）

深度学习 深度学习是加深了层的深度神经网络 加深网络 本节我们将这些已经学过的技术汇总起来&#xff0c;创建一个深度网络&#xff0c;挑战 MNIST 数据集的手写数字识别 向更深的网络出发 基于33的小型滤波器的卷积层。激活函数是ReLU。全连接层的后面使用Dropout层。基…
阅读更多...
4_怎么看原理图之协议类接口之SPI笔记

4_怎么看原理图之协议类接口之SPI笔记

SPI&#xff08;Serial Peripheral Interface&#xff09;是一种同步串行通信协议&#xff0c;通常用于在芯片之间传输数据。SPI协议使用四根线进行通信&#xff1a;主设备发送数据&#xff08;MOSI&#xff09;&#xff0c;从设备发送数据&#xff08;MISO&#xff09;&#x…
阅读更多...
机器学习-强化学习扩充

机器学习-强化学习扩充

AI RL DL 基于Action&#xff0c;Enviroment给予Reward enviroment是对手 alpha go is supervised learning reinforcement learning 学两个agent&#xff0c;让两个互相沟通。 使用一些预定义的规则来判断对话的好坏。 更多应用 强化学习的困难就是奖励延迟…
阅读更多...
android后端开发书籍，阿里内部核心Android进阶手册

android后端开发书籍，阿里内部核心Android进阶手册

努力的人&#xff0c;应该像好色那样好学 做Android开发的同学&#xff0c;对Gradle肯定不陌生&#xff0c;我们用它配置、构建工程&#xff0c;可能还会开发插件来促进我们的开发&#xff0c;我们必须了解Gradle&#xff0c;而不仅限于只会当配置构建工具&#xff0c;我想学习…
阅读更多...
only office-用着确实很省心

only office-用着确实很省心

小程一言 最近一直在使用各种办公软件进行学习笔记整理&#xff0c;但是在使用过程中&#xff0c;总感觉不是自己想要的一款软件&#xff0c;想要一款真正懂自己的软件&#xff0c;是一个选择的过程。最近在网上闲逛发现一款宝藏软件&#xff0c;好奇心驱使我去进行适用&#…
阅读更多...
【MySQL】基本查询（表的增删改查）-- 详解

【MySQL】基本查询（表的增删改查）-- 详解

CRUD&#xff1a;Create&#xff08;创建&#xff09;&#xff0c;Retrieve&#xff08;读取&#xff09;&#xff0c;Update&#xff08;更新&#xff09;&#xff0c;Delete&#xff08;删除&#xff09;。 一、Create insert [into] table_name [(column [, column] ...)] v…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023