请选择 进入手机版 | 继续访问电脑版

[Redis] 基于Redis的List实现特价商品列表功能

[复制链接]
查看47 | 回复14 | 2021-9-14 01:03:06 | 显示全部楼层 |阅读模式
目次

 1、场景分析

淘宝京东的特价商品列表,

商品特点:

  • 商品有限,并发量非常的大。
  • 思量 分页

传统办理 方案:数据库db,

但是在云云 大的并发量的环境 下,不可取。

一样平常 会采用redis来处理。这些特价商品的数据不多,而且redis的list本身也支持分页。是自然 处理这种列表的最佳选择办理 方案。

2、分析

采用list数据,由于 list数据布局 有:lrange key 0 -1 可以举行 数据的分页。

  1. 127.0.0.1:6379> lpush products p1 p2 p3 p4 p5 p6 p7 p8 p9 p10
  2. (integer) 10
  3. 127.0.0.1:6379> lrange products 0 1
  4. 1) "p10"
  5. 2) "p9"
  6. 127.0.0.1:6379> lrange products 2 3
  7. 1) "p8"
  8. 2) "p7"
  9. 127.0.0.1:6379> lrange products 4 5
  10. 1) "p6"
  11. 2) "p5"
复制代码

3 、具体 实现

淘宝,京东的热门商品在双11的时间 ,大概 有100多w必要 搞活动:程序必要 5分钟对特价商品举行 革新 。

3.1 ProductListService类

  •  初始化的活动的商品信息100个(从数据库去查询)

@PostContrcut使用

  •  查询产品列表信息

换算的分页的起始位置和竣事 位置

  1. package com.example.service;
  2. import com.example.entity.Product;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.data.redis.core.RedisTemplate;
  6. import org.springframework.stereotype.Service;
  7. import javax.annotation.PostConstruct;
  8. import java.util.ArrayList;
  9. import java.util.List;
  10. import java.util.Random;
  11. /**
  12. * @Auther: 长颈鹿
  13. * @Date: 2021/08/29/18:00
  14. * @Description:
  15. */
  16. @Service
  17. @Slf4j
  18. public class ProductListService {
  19. @Autowired
  20. private RedisTemplate redisTemplate;
  21. // 数据热加载
  22. @PostConstruct
  23. public void initData(){
  24. log.info("启动定时加载特价商品到redis的list中...");
  25. new Thread(() -> runCourse()).start();
  26. }
  27. public void runCourse() {
  28. while (true) {
  29. // 从数据库中查询出特价商品
  30. List<Product> productList = this.findProductsDB();
  31. // 删除原来的特价商品
  32. this.redisTemplate.delete("product:hot:list");
  33. // 把特价商品添加到集合中
  34. this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
  35. try {
  36. // 每隔一分钟执行一次
  37. Thread.sleep(1000 * 60);
  38. log.info("定时刷新特价商品....");
  39. } catch (Exception ex) {
  40. ex.printStackTrace();
  41. }
  42. }
  43. }
  44. /**
  45. * 数据库中查询特价商品
  46. *
  47. * @return
  48. */
  49. public List<Product> findProductsDB() {
  50. //List<Product> productList = productMapper.selectListHot();
  51. List<Product> productList = new ArrayList<>();
  52. for (long i = 1; i <= 100; i++) {
  53. Product product = new Product();
  54. product.setId((long) new Random().nextInt(1000));
  55. product.setPrice((double) i);
  56. product.setTitle("特价商品" + (i));
  57. productList.add(product);
  58. }
  59. return productList;
  60. }
  61. }
复制代码

3.2 商品的数据接口的定义和展示及分页

  1. package com.example.controller;
  2. import com.example.entity.Product;
  3. import com.example.service.ProductListService;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.data.redis.core.RedisTemplate;
  6. import org.springframework.util.CollectionUtils;
  7. import org.springframework.web.bind.annotation.GetMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9. import java.util.List;
  10. /**
  11. * @Auther: 长颈鹿
  12. * @Date: 2021/08/29/18:04
  13. * @Description:
  14. */
  15. @RestController
  16. public class ProductListController {
  17. @Autowired
  18. private RedisTemplate redisTemplate;
  19. @Autowired
  20. private ProductListService productListService;
  21. @GetMapping("/findProducts")
  22. public List<Product> findProducts(int pageNo, int pageSize) {
  23. // 从那个集合去查询
  24. String key = "product:hot:list";
  25. // 分页的开始结束的换算
  26. if (pageNo <= 0) pageNo = 1;
  27. int start = (pageNo - 1) * pageSize;
  28. // 计算分页的结束页
  29. int end = start + pageSize - 1;
  30. // 根据redis的api去处理分页查询对应的结果
  31. try {
  32. List<Product> productList = this.redisTemplate.opsForList().range(key, start, end);
  33. if (CollectionUtils.isEmpty(productList)) {
  34. //todo: 查询数据库,存在缓存击穿的情况,大量的并发请求进来,可能把数据库冲
  35. productList = productListService.findProductsDB();
  36. }
  37. return productList;
  38. } catch (Exception ex) {
  39. ex.printStackTrace();
  40. return null;
  41. }
  42. }
  43. }
复制代码

3.3 定时任务

  1. @Configuration // 主要用于标记配置类,兼备Component的效果。
  2. @EnableScheduling // 开启定时任务
  3. public class SaticScheduleTask {
  4. // 添加定时任务
  5. @Scheduled(cron = "* 0/5 * * * ?")
  6. // 或直接指定时间间隔,例如:5秒
  7. // @Scheduled(fixedRate=5000)
  8. private void configureTasks() {
  9. System.err.println("执行静态定时任务时间: " + LocalDateTime.now());
  10. }
  11. }
复制代码

4、办理 商品列表存在的缓存击穿题目

 4.1 怎样 引起的缓存击穿的环境

  1. public void runCourse() {
  2. while (true) {
  3. // 从数据库中查询出特价商品
  4. List<Product> productList = this.findProductsDB();
  5. // 删除原来的特价商品
  6. this.redisTemplate.delete("product:hot:list");
  7. // 把特价商品添加到集合中 需要时间
  8. this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
  9. try {
  10. // 每隔一分钟执行一遍
  11. Thread.sleep(1000 * 60);
  12. log.info("定时刷新特价商品....");
  13. } catch (Exception ex) {
  14. ex.printStackTrace();
  15. }
  16. }
  17. }
复制代码

出现缘故原由 :

  • 特价商品的数据更换必要 时间,刚好特价商品还没有放入到redis缓存中。
  • 查询特价商品的并发量非常大,大概 程序还正在写入特价商品到缓存中,这时查询缓存根本没有数据,就会直接冲入数据库中去查询特价商品。大概 造成数据库冲垮。这个就叫做:缓存击穿

4.2 办理 方案

主从轮询

可以开辟 两块redis的集合空间A和B。定时器在更新缓存的时间 ,

  1. 先更新B缓存
复制代码
  1. 然后再更新A缓存
复制代码

肯定 要按照特定次序 来处理。

  1. package com.example.service;
  2. import com.example.entity.Product;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.data.redis.core.RedisTemplate;
  6. import org.springframework.stereotype.Service;
  7. import javax.annotation.PostConstruct;
  8. import java.util.ArrayList;
  9. import java.util.List;
  10. import java.util.Random;
  11. /**
  12. * @Auther: 长颈鹿
  13. * @Date: 2021/08/29/18:00
  14. * @Description:
  15. */
  16. @Service
  17. @Slf4j
  18. public class ProductListService {
  19. @Autowired
  20. private RedisTemplate redisTemplate;
  21. // 数据热加载
  22. @PostConstruct
  23. public void initData(){
  24. log.info("启动定时加载特价商品到redis的list中...");
  25. new Thread(() -> runCourse()).start();
  26. }
  27. public void runCourse() {
  28. while (true) {
  29. // 从数据库中查询出特价商品
  30. List<Product> productList = this.findProductsDB();
  31. // 删除原来的特价商品
  32. this.redisTemplate.delete("product:hot:slave:list");
  33. // 把特价商品添加到集合中
  34. this.redisTemplate.opsForList().leftPushAll("product:hot:slave:list", productList);// 删除原来的特价商品
  35. this.redisTemplate.delete("product:hot:master:list");
  36. // 把特价商品添加到集合中
  37. this.redisTemplate.opsForList().leftPushAll("product:hot:master:list", productList);
  38. // // 删除原来的特价商品
  39. // this.redisTemplate.delete("product:hot:list");
  40. // // 把特价商品添加到集合中
  41. // this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
  42. try {
  43. // 每隔一分钟执行一次
  44. Thread.sleep(1000 * 60);
  45. log.info("定时刷新特价商品....");
  46. } catch (Exception ex) {
  47. ex.printStackTrace();
  48. }
  49. }
  50. }
  51. /**
  52. * 数据库中查询特价商品
  53. *
  54. * @return
  55. */
  56. public List<Product> findProductsDB() {
  57. //List<Product> productList = productMapper.selectListHot();
  58. List<Product> productList = new ArrayList<>();
  59. for (long i = 1; i <= 100; i++) {
  60. Product product = new Product();
  61. product.setId((long) new Random().nextInt(1000));
  62. product.setPrice((double) i);
  63. product.setTitle("特价商品" + (i));
  64. productList.add(product);
  65. }
  66. return productList;
  67. }
  68. }
复制代码
  1. package com.example.controller;
  2. import com.example.entity.Product;
  3. import com.example.service.ProductListService;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.data.redis.core.RedisTemplate;
  6. import org.springframework.util.CollectionUtils;
  7. import org.springframework.web.bind.annotation.GetMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9. import java.util.List;
  10. /**
  11. * @Auther: 长颈鹿
  12. * @Date: 2021/08/29/18:04
  13. * @Description:
  14. */
  15. @RestController
  16. public class ProductListController {
  17. @Autowired
  18. private RedisTemplate redisTemplate;
  19. @Autowired
  20. private ProductListService productListService;
  21. @GetMapping("/findProducts")
  22. public List<Product> findProducts(int pageNo, int pageSize) {
  23. // 从那个集合去查询
  24. String master_key = "product:hot:master:list";
  25. String slave_key = "product:hot:slave:list";
  26. String key = "product:hot:list";
  27. // 分页的开始结束的换算
  28. if (pageNo <= 0) pageNo = 1;
  29. int start = (pageNo - 1) * pageSize;
  30. // 计算分页的结束页
  31. int end = start + pageSize - 1;
  32. // 根据redis的api去处理分页查询对应的结果
  33. try {
  34. List<Product> productList = this.redisTemplate.opsForList().range(master_key, start, end);
  35. // List<Product> productList = this.redisTemplate.opsForList().range(key, start, end);
  36. if (CollectionUtils.isEmpty(productList)) {
  37. // todo: 查询数据库,存在缓存击穿的情况,大量的并发请求进来,可能把数据库冲
  38. productList = this.redisTemplate.opsForList().range(slave_key, start, end);
  39. // productList = productListService.findProductsDB();
  40. }
  41. return productList;
  42. } catch (Exception ex) {
  43. ex.printStackTrace();
  44. return null;
  45. }
  46. }
  47. }
复制代码

到此这篇关于基于Redis的List实现特价商品列表的文章就先容 到这了,更多干系 redis list商品列表内容请搜索 脚本之家从前 的文章或继续欣赏 下面的干系 文章渴望 大家以后多多支持脚本之家!


免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
回复

使用道具 举报

avatar 123457265 | 2021-9-14 07:09:16 | 显示全部楼层
学习雷锋,好好回帖!
回复

使用道具 举报

avatar 123457748 | 2021-9-19 21:05:24 | 显示全部楼层
白富美?高富帅?
回复

使用道具 举报

avatar 水月花郎稳 | 2021-9-22 19:51:11 | 显示全部楼层
怎么我回帖都没人理我呢?
回复

使用道具 举报

avatar 明月照大江754 | 2021-9-27 01:45:31 | 显示全部楼层
今天是个特别的日子,值得纪念!
回复

使用道具 举报

avatar 刘久田 | 2021-10-4 10:02:19 | 显示全部楼层
admin楼主的帖子实在是写得太好了。文笔流畅,修辞得体!
回复

使用道具 举报

avatar 福安到安顺屏 | 2021-10-11 19:13:48 | 显示全部楼层
听admin楼主一席话,省我十本书!
回复

使用道具 举报

avatar 木子李皓 | 2021-10-11 19:13:50 | 显示全部楼层
admin楼主,你妈妈喊你回家吃药!
回复

使用道具 举报

avatar 飞儿506 | 2021-10-13 20:51:17 | 显示全部楼层
缺乏激情了!
回复

使用道具 举报

avatar 卡庙寺 | 2021-10-14 13:08:06 | 显示全部楼层
论坛的人气越来越旺了!
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则