淘寶京東的特價(jià)商品列表，
商品特點(diǎn)：
傳統(tǒng)解決方案：數(shù)據(jù)庫(kù)db，
但是在如此大的并發(fā)量的情況下，不可取。
一般會(huì)采用redis來(lái)處理。這些特價(jià)商品的數(shù)據(jù)不多，而且redis的list本身也支持分頁(yè)。是天然處理這種列表的最佳選擇解決方案。
采用list數(shù)據(jù)，因?yàn)閘ist數(shù)據(jù)結(jié)構(gòu)有：lrange key 0 -1 可以進(jìn)行數(shù)據(jù)的分頁(yè)。
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"
淘寶，京東的熱門(mén)商品在雙11的時(shí)候，可能有100多w需要搞活動(dòng)：程序需要5分鐘對(duì)特價(jià)商品進(jìn)行刷新。
@PostContrcut使用
換算的分頁(yè)的起始位置和結(jié)束位置
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: 長(zhǎng)頸鹿
* @Date: 2021/08/29/18:00
* @Description:
*/
@Service
@Slf4j
public class ProductListService {
@Autowired
private RedisTemplate redisTemplate;
// 數(shù)據(jù)熱加載
@PostConstruct
public void initData(){
log.info("啟動(dòng)定時(shí)加載特價(jià)商品到redis的list中...");
new Thread(() -> runCourse()).start();
}
public void runCourse() {
while (true) {
// 從數(shù)據(jù)庫(kù)中查詢出特價(jià)商品
ListProduct> productList = this.findProductsDB();
// 刪除原來(lái)的特價(jià)商品
this.redisTemplate.delete("product:hot:list");
// 把特價(jià)商品添加到集合中
this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
try {
// 每隔一分鐘執(zhí)行一次
Thread.sleep(1000 * 60);
log.info("定時(shí)刷新特價(jià)商品....");
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
/**
* 數(shù)據(jù)庫(kù)中查詢特價(jià)商品
*
* @return
*/
public ListProduct> findProductsDB() {
//ListProduct> productList = productMapper.selectListHot();
ListProduct> 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("特價(jià)商品" + (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: 長(zhǎng)頸鹿
* @Date: 2021/08/29/18:04
* @Description:
*/
@RestController
public class ProductListController {
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private ProductListService productListService;
@GetMapping("/findProducts")
public ListProduct> findProducts(int pageNo, int pageSize) {
// 從那個(gè)集合去查詢
String key = "product:hot:list";
// 分頁(yè)的開(kāi)始結(jié)束的換算
if (pageNo = 0) pageNo = 1;
int start = (pageNo - 1) * pageSize;
// 計(jì)算分頁(yè)的結(jié)束頁(yè)
int end = start + pageSize - 1;
// 根據(jù)redis的api去處理分頁(yè)查詢對(duì)應(yīng)的結(jié)果
try {
ListProduct> productList = this.redisTemplate.opsForList().range(key, start, end);
if (CollectionUtils.isEmpty(productList)) {
//todo: 查詢數(shù)據(jù)庫(kù)，存在緩存擊穿的情況，大量的并發(fā)請(qǐng)求進(jìn)來(lái)，可能把數(shù)據(jù)庫(kù)沖
productList = productListService.findProductsDB();
}
return productList;
} catch (Exception ex) {
ex.printStackTrace();
return null;
}
}
}
@Configuration // 主要用于標(biāo)記配置類，兼?zhèn)銫omponent的效果。
@EnableScheduling // 開(kāi)啟定時(shí)任務(wù)
public class SaticScheduleTask {
// 添加定時(shí)任務(wù)
@Scheduled(cron = "* 0/5 * * * ?")
// 或直接指定時(shí)間間隔，例如：5秒
// @Scheduled(fixedRate=5000)
private void configureTasks() {
System.err.println("執(zhí)行靜態(tài)定時(shí)任務(wù)時(shí)間: " + LocalDateTime.now());
}
}
public void runCourse() {
while (true) {
// 從數(shù)據(jù)庫(kù)中查詢出特價(jià)商品
ListProduct> productList = this.findProductsDB();
// 刪除原來(lái)的特價(jià)商品
this.redisTemplate.delete("product:hot:list");
// 把特價(jià)商品添加到集合中 需要時(shí)間
this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
try {
// 每隔一分鐘執(zhí)行一遍
Thread.sleep(1000 * 60);
log.info("定時(shí)刷新特價(jià)商品....");
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
出現(xiàn)原因:
主從輪詢
可以開(kāi)辟兩塊redis的集合空間A和B。定時(shí)器在更新緩存的時(shí)候，先更新B緩存，然后再更新A緩存。
一定要按照特定順序來(lái)處理。
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: 長(zhǎng)頸鹿
* @Date: 2021/08/29/18:00
* @Description:
*/
@Service
@Slf4j
public class ProductListService {
@Autowired
private RedisTemplate redisTemplate;
// 數(shù)據(jù)熱加載
@PostConstruct
public void initData(){
log.info("啟動(dòng)定時(shí)加載特價(jià)商品到redis的list中...");
new Thread(() -> runCourse()).start();
}
public void runCourse() {
while (true) {
// 從數(shù)據(jù)庫(kù)中查詢出特價(jià)商品
ListProduct> productList = this.findProductsDB();
// 刪除原來(lái)的特價(jià)商品
this.redisTemplate.delete("product:hot:slave:list");
// 把特價(jià)商品添加到集合中
this.redisTemplate.opsForList().leftPushAll("product:hot:slave:list", productList);// 刪除原來(lái)的特價(jià)商品
this.redisTemplate.delete("product:hot:master:list");
// 把特價(jià)商品添加到集合中
this.redisTemplate.opsForList().leftPushAll("product:hot:master:list", productList);
// // 刪除原來(lái)的特價(jià)商品
// this.redisTemplate.delete("product:hot:list");
// // 把特價(jià)商品添加到集合中
// this.redisTemplate.opsForList().leftPushAll("product:hot:list", productList);
try {
// 每隔一分鐘執(zhí)行一次
Thread.sleep(1000 * 60);
log.info("定時(shí)刷新特價(jià)商品....");
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
/**
* 數(shù)據(jù)庫(kù)中查詢特價(jià)商品
*
* @return
*/
public ListProduct> findProductsDB() {
//ListProduct> productList = productMapper.selectListHot();
ListProduct> 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("特價(jià)商品" + (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: 長(zhǎng)頸鹿
* @Date: 2021/08/29/18:04
* @Description:
*/
@RestController
public class ProductListController {
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private ProductListService productListService;
@GetMapping("/findProducts")
public ListProduct> findProducts(int pageNo, int pageSize) {
// 從那個(gè)集合去查詢
String master_key = "product:hot:master:list";
String slave_key = "product:hot:slave:list";
String key = "product:hot:list";
// 分頁(yè)的開(kāi)始結(jié)束的換算
if (pageNo = 0) pageNo = 1;
int start = (pageNo - 1) * pageSize;
// 計(jì)算分頁(yè)的結(jié)束頁(yè)
int end = start + pageSize - 1;
// 根據(jù)redis的api去處理分頁(yè)查詢對(duì)應(yīng)的結(jié)果
try {
ListProduct> productList = this.redisTemplate.opsForList().range(master_key, start, end);
// ListProduct> productList = this.redisTemplate.opsForList().range(key, start, end);
if (CollectionUtils.isEmpty(productList)) {
// todo: 查詢數(shù)據(jù)庫(kù)，存在緩存擊穿的情況，大量的并發(fā)請(qǐng)求進(jìn)來(lái)，可能把數(shù)據(jù)庫(kù)沖
productList = this.redisTemplate.opsForList().range(slave_key, start, end);
// productList = productListService.findProductsDB();
}
return productList;
} catch (Exception ex) {
ex.printStackTrace();
return null;
}
}
}
到此這篇關(guān)于基于Redis的List實(shí)現(xiàn)特價(jià)商品列表的文章就介紹到這了,更多相關(guān)redis list商品列表內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
標(biāo)簽：大慶 果洛 吉安 北京 臺(tái)州 朝陽(yáng) 楊凌 江蘇
巨人網(wǎng)絡(luò)通訊聲明：本文標(biāo)題《基于Redis的List實(shí)現(xiàn)特價(jià)商品列表功能》，本文關(guān)鍵詞 基于,Redis,的,List,實(shí)現(xiàn),特價(jià),；如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問(wèn)題，煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們，我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò)，涉及言論、版權(quán)與本站無(wú)關(guān)。
