基于Redis的List实现特价商品列表功能
更新时间：2021年08月30日 10:35:26 作者：南宫拾壹
本文通过场景分析给大家介绍了基于Redis的List实现特价商品列表,本文通过实例代码给大家介绍的非常详细，需要的朋友可以参考下
1、场景分析
淘宝京东的特价商品列表，
商品特点：
- 商品有限，并发量非常的大。
- 考虑分页
传统解决方案：数据库db，
但是在如此大的并发量的情况下，不可取。
一般会采用redis来处理。这些特价商品的数据不多，而且redis的list本身也支持分页。是天然处理这种列表的最佳选择解决方案。
2、分析
采用list数据，因为list数据结构有：lrange key 0 -1 可以进行数据的分页。
127.0.0.1:6379> lpush products p1 p2 p3 p4 p5 p6 p7 p8 p9 p10 (integer) 10 127.0.0.1:6379> lrange products 0 1 1) "p10" 2) "p9" 127.0.0.1:6379> lrange products 2 3 1) "p8" 2) "p7" 127.0.0.1:6379> lrange products 4 5 1) "p6" 2) "p5"
3 、具体实现
淘宝，京东的热门商品在双11的时候，可能有100多w需要搞活动：程序需要5分钟对特价商品进行刷新。
3.1 ProductListService类
- 初始化的活动的商品信息100个（从数据库去查询）
@PostContrcut使用
- 查询产品列表信息
换算的分页的起始位置和结束位置
package com.example.service;
import com.example.entity.Product;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
/**
* @Auther: 长颈鹿
* @Date: 2021/08/29/18:00
* @Description:
*/
@Service
@Slf4j
public class ProductListService {
@Autowired
private RedisTemplate redisTemplate;
// 数据热加载
@PostConstruct
public void initData(){
log.info("启动定时加载特价商品到redis的list中...");
new Thread(() -> runCourse()).start();
}
public void runCourse() {
while (true) {
// 从数据库中查询出特价商品
List<Product> productList = this.findProductsDB();
// 删除原来的特价商品
this.redisTemplate.delete("product:hot:list");
// 把特价商品添加到集合中
this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
try {
// 每隔一分钟执行一次
Thread.sleep(1000 * 60);
log.info("定时刷新特价商品....");
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
/**
* 数据库中查询特价商品
*
* @return
*/
public List<Product> findProductsDB() {
//List<Product> productList = productMapper.selectListHot();
List<Product> productList = new ArrayList<>();
for (long i = 1; i <= 100; i++) {
Product product = new Product();
product.setId((long) new Random().nextInt(1000));
product.setPrice((double) i);
product.setTitle("特价商品" + (i));
productList.add(product);
}
return productList;
}
}
3.2 商品的数据接口的定义和展示及分页
package com.example.controller;
import com.example.entity.Product;
import com.example.service.ProductListService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Auther: 长颈鹿
* @Date: 2021/08/29/18:04
* @Description:
*/
@RestController
public class ProductListController {
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private ProductListService productListService;
@GetMapping("/findProducts")
public List<Product> findProducts(int pageNo, int pageSize) {
// 从那个集合去查询
String key = "product:hot:list";
// 分页的开始结束的换算
if (pageNo <= 0) pageNo = 1;
int start = (pageNo - 1) * pageSize;
// 计算分页的结束页
int end = start + pageSize - 1;
// 根据redis的api去处理分页查询对应的结果
try {
List<Product> productList = this.redisTemplate.opsForList().range(key, start, end);
if (CollectionUtils.isEmpty(productList)) {
//todo: 查询数据库，存在缓存击穿的情况，大量的并发请求进来，可能把数据库冲
productList = productListService.findProductsDB();
}
return productList;
} catch (Exception ex) {
ex.printStackTrace();
return null;
}
}
}
3.3 定时任务
@Configuration // 主要用于标记配置类，兼备Component的效果。
@EnableScheduling // 开启定时任务
public class SaticScheduleTask {
// 添加定时任务
@Scheduled(cron = "* 0/5 * * * ?")
// 或直接指定时间间隔，例如：5秒
// @Scheduled(fixedRate=5000)
private void configureTasks() {
System.err.println("执行静态定时任务时间: " + LocalDateTime.now());
}
}
4、解决商品列表存在的缓存击穿问题
4.1 如何引起的缓存击穿的情况
public void runCourse() {
while (true) {
// 从数据库中查询出特价商品
List<Product> productList = this.findProductsDB();
// 删除原来的特价商品
this.redisTemplate.delete("product:hot:list");
// 把特价商品添加到集合中 需要时间
this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
try {
// 每隔一分钟执行一遍
Thread.sleep(1000 * 60);
log.info("定时刷新特价商品....");
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
出现原因:
- 特价商品的数据更换需要时间，刚好特价商品还没有放入到redis缓存中。
- 查询特价商品的并发量非常大，可能程序还正在写入特价商品到缓存中，这时查询缓存根本没有数据，就会直接冲入数据库中去查询特价商品。可能造成数据库冲垮。这个就叫做：缓存击穿
4.2 解决方案
主从轮询
可以开辟两块redis的集合空间A和B。定时器在更新缓存的时候，先更新B缓存，然后再更新A缓存。
一定要按照特定顺序来处理。
package com.example.service;
import com.example.entity.Product;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
/**
* @Auther: 长颈鹿
* @Date: 2021/08/29/18:00
* @Description:
*/
@Service
@Slf4j
public class ProductListService {
@Autowired
private RedisTemplate redisTemplate;
// 数据热加载
@PostConstruct
public void initData(){
log.info("启动定时加载特价商品到redis的list中...");
new Thread(() -> runCourse()).start();
}
public void runCourse() {
while (true) {
// 从数据库中查询出特价商品
List<Product> productList = this.findProductsDB();
// 删除原来的特价商品
this.redisTemplate.delete("product:hot:slave:list");
// 把特价商品添加到集合中
this.redisTemplate.opsForList().leftPushAll("product:hot:slave:list", productList);// 删除原来的特价商品
this.redisTemplate.delete("product:hot:master:list");
// 把特价商品添加到集合中
this.redisTemplate.opsForList().leftPushAll("product:hot:master:list", productList);
// // 删除原来的特价商品
// this.redisTemplate.delete("product:hot:list");
// // 把特价商品添加到集合中
// this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
try {
// 每隔一分钟执行一次
Thread.sleep(1000 * 60);
log.info("定时刷新特价商品....");
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
/**
* 数据库中查询特价商品
*
* @return
*/
public List<Product> findProductsDB() {
//List<Product> productList = productMapper.selectListHot();
List<Product> productList = new ArrayList<>();
for (long i = 1; i <= 100; i++) {
Product product = new Product();
product.setId((long) new Random().nextInt(1000));
product.setPrice((double) i);
product.setTitle("特价商品" + (i));
productList.add(product);
}
return productList;
}
}
package com.example.controller;
import com.example.entity.Product;
import com.example.service.ProductListService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Auther: 长颈鹿
* @Date: 2021/08/29/18:04
* @Description:
*/
@RestController
public class ProductListController {
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private ProductListService productListService;
@GetMapping("/findProducts")
public List<Product> findProducts(int pageNo, int pageSize) {
// 从那个集合去查询
String master_key = "product:hot:master:list";
String slave_key = "product:hot:slave:list";
String key = "product:hot:list";
// 分页的开始结束的换算
if (pageNo <= 0) pageNo = 1;
int start = (pageNo - 1) * pageSize;
// 计算分页的结束页
int end = start + pageSize - 1;
// 根据redis的api去处理分页查询对应的结果
try {
List<Product> productList = this.redisTemplate.opsForList().range(master_key, start, end);
// List<Product> productList = this.redisTemplate.opsForList().range(key, start, end);
if (CollectionUtils.isEmpty(productList)) {
// todo: 查询数据库，存在缓存击穿的情况，大量的并发请求进来，可能把数据库冲
productList = this.redisTemplate.opsForList().range(slave_key, start, end);
// productList = productListService.findProductsDB();
}
return productList;
} catch (Exception ex) {
ex.printStackTrace();
return null;
}
}
}
到此这篇关于基于Redis的List实现特价商品列表的文章就介绍到这了,更多相关redis list商品列表内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要给大家介绍了关于Redis基础学习之管道机制的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用Redis具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2018-11-11
本文主要介绍了搭建单机Redis缓存服务的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-04-04
这篇文章主要给大家介绍了关于如何利用Redis的有序集合实现排行榜功能的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者使用Redis具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧2019-03-03
有序集合zset保留了set集合不能有重复成员的特点，但与set集合不同的是，zset的每个member都有一个唯一的浮点数类型的分数score与之关联,这篇文章主要介绍了Redis的zset类型,需要的朋友可以参考下2023-08-08
缓存预热是一种在程序启动或缓存失效之后,主动将热点数据加载到缓存中的策略,本文将给大家分享一下如何实现Redis的缓存预热,文中有详细的实现代码,需要的朋友可以参考下2023-10-10
本文详细探讨了使用Redis实现分布式锁时需要考虑的问题,包括锁的竞争、锁的释放、超时管理、网络分区等,并提供了相应的解决方案和代码实例,有助于开发者正确且安全地使用Redis实现分布式锁2024-09-09
这篇文章主要为大家详细介绍了windows 64位下redis安装教程，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-10-10
大家好，本篇文章主要讲的是关于Redis数据库入门详细介绍，感兴趣的同学赶快来看一看吧，对你有帮助的话记得收藏一下，方便下次浏览2021-12-12
redis锁处理高并发问题十分常见，下面这篇文章主要给大家介绍了关于如何使用Redis锁解决高并发问题的相关资料，文中通过示例代码介绍的非常详细，需要的朋友可以参考借鉴，下面随着小编来一起学习学习吧2018-09-09
哨兵模式,是基于主从复制模式,主从复制的优点全都拥有,并且主从可以实现自动切换,故障转移等功能,本文主要介绍了Windows下搭建Redis哨兵集群模式的方法步骤,文中通过图文介绍的非常详细,感兴趣的小伙伴们可以参考一下,需要的朋友可以参考下2023-09-09
最新评论