springboot 秒杀系统（二）redis

上一步我们做的秒杀虽然在操作上没问题，

但性能上能有很大的提升空间。

我们可以先把秒杀数据加载到内存中，考虑到以后服务集群化，

所以加载的数据不存放在JVM中，而存在放redis

首先，我们都知道，redis在数据存取方面远远大于mysql

所以我们第一步优化是：可以将秒杀数据加载至REDIS中，

然后我们在查询数据的时候，优先从redis里查找。

注意：这里redis和MySQL最好在同一个网端，不然，测试出来的效果不一样

因为不同的网端网络消耗是有很大差别的

1，配置REDIS，并配置redis缓存和设置序列化。相关代码和类

spring:redis:host: 127.0.0.1port: 6379database: 0lettuce:pool:# 最大活跃链接数 默认8max-active: 20# 最大空闲连接数 默认8max-idle: 20# 最小空闲连接数 默认0min-idle: 5

import com.alibaba.fastjson.support.spring.FastJsonRedisSerializer;import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.StringRedisSerializer;import java.time.Duration;@Configuration
//开启缓存
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport{/*** @param redisConnectionFactory* @return*/@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);// 使用Jackson2JsonRedisSerialize 替换默认序列化Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);// 设置value的序列化规则和 key的序列化规则redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);redisTemplate.afterPropertiesSet();return redisTemplate;}/*** 这里主要配置redis缓存的序列化，注意和* @return*/@Beanpublic RedisCacheConfiguration redisCacheConfiguration(){FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);RedisCacheConfiguration configuration = RedisCacheConfiguration.defaultCacheConfig();configuration = configuration.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(fastJsonRedisSerializer)).entryTtl(Duration.ofDays(1));return configuration;}
}

/*** 必须重写序列化器，放弃用jackjson来做value的序列化，使用FastJson来做。* 重写一些序列化器，并实现RedisSerializer接口*/
public class FastJsonRedisSerializer<T> implements RedisSerializer<T> {public static final Charset DEFAULT_CHARSET = Charset.forName("UTF-8");private Class<T> clazz;public FastJsonRedisSerializer(Class<T> clazz) {super();this.clazz = clazz;}@Overridepublic byte[] serialize(T t) throws SerializationException {if (t == null) {return new byte[0];}return JSON.toJSONString(t, SerializerFeature.WriteClassName).getBytes(DEFAULT_CHARSET);}@Overridepublic T deserialize(byte[] bytes) throws SerializationException {if (bytes == null || bytes.length <= 0) {return null;}String str = new String(bytes, DEFAULT_CHARSET);return (T) JSON.parseObject(str, clazz);}
}

第二步，启动预热数据至redis（可选）

@Component
@Slf4j
public class InitredisData implements CommandLineRunner {@Autowiredprivate ProductService productService;@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate StringRedisTemplate stringRedisTemplate;@Overridepublic void run(String... args) throws Exception {log.info("预热redis数据");initRedis();}/*** 预热秒杀数据到redis*/public void initRedis(){List<JSONObject> list= productService.select();Map<String,JSONObject> map = new ConcurrentHashMap<String,JSONObject>();list.stream().forEach(jsonObject -> {System.out.println(jsonObject.toJSONString());redisTemplate.opsForValue().set("productcache::"+jsonObject.getString("seckillId"),jsonObject);});}
}

第三步，在查询商品的接口上加缓存配置

@Cacheable(value = "productcache", key = "#p0")public JSONObject findById(String seckillId){return  productDao.findById(seckillId);}

启动之后，redis会加载数据库的秒杀数据

OK，这个就是我们2.0版本的优化版，我们还是用上次的jmeter来压测一下

查询的QPS为245 秒杀的QPS为208，比之前调高了好几倍。

下一节继续优化。

springboot 秒杀系统（二）redis相关推荐

秒杀系统(二)——商品模块展示技术难点
秒杀系统--商品模块展示技术难点商品详情页商品详情页是展示商品详细信息的一个页面,承载在网站的大部分流量和订单的入口.京东商城目前有通用版.全球购.闪购.易车.惠买车.服装.拼购.今日抄底等许多套 ...
SpringBoot + 秒杀系统
本书源码 https://github.com/huangwenyi10/spring-boot-book-v2 目录创建秒杀系统雏形小结详情高并发优化流量削峰创建解决 Cannot ...
SpringBoot秒杀系统
秒杀系统库存今天带来一套秒杀库存扣减涉及到单体架构和集群架构希望能给你们带来帮助我也不想学但是bgs不教首先讲一下大致的扣减库存的思路 @RequestMapping("dedu ...
springboot 秒杀系统（一）
秒杀系统应该是很检验一个人的能力的项目.包括从前端到运营商到nginx到后端等等,很多地方可以优化. 前端的页面控制,运营商的CDN加速,nginx的动静分离等下面我来一步一步实现后端的秒杀功能的 ...
Springboot秒杀系统（乐观锁+RateLimiter令牌+Redis缓存）
本文主要是利用springboot,实现一个单机版秒杀demo,通过单机版实现,可以对基本并发秒杀的知识有一定的了解. 首先先提供秒杀业务实现类: /*** spring 注解加在实现类*/ @Ser ...
redis分布式锁及秒杀系统实战
本文分为两部分: 一.介绍redis分布式锁的原理和使用方法: 二.使用redis分布式锁实现一个简单的秒杀系统. 注意:本文使用java1.8,最后的例子为springboot项目. 目录 redi ...
【秒杀系统】从零开始打造简易秒杀系统（一）：防止超卖
前言大家好,好久不发文章了.(快一个月了- -)最近有很多学习的新知识想和大家分享,但无奈最近项目蛮忙的,很多文章写了一半搁置在了笔记里,待以后慢慢补充发布. 本文主要是通过实际代码讲解,帮助你一步 ...
java 超卖_Java生鲜电商平台-秒杀系统如何防止超买与超卖?(小程序/APP)
本文主要是通过实际代码讲解,帮助你一步步搭建一个简易的秒杀系统.从而快速的了解生鲜电商秒杀系统的主要难点,并且迅速上手实际项目. 我对生鲜电商秒杀系统文章的规划: 从零开始打造简易秒杀系统:乐观锁防止 ...
秒杀系统如何防止超卖？
前言本文主要是通过实际代码讲解,帮助你一步步搭建一个简易的秒杀系统.从而快速的了解秒杀系统的主要难点,并且迅速上手实际项目. 我对秒杀系统文章的规划: 从零开始打造简易秒杀系统:乐观锁防止超卖从零 ...

springboot 秒杀系统（二）redis

springboot 秒杀系统（二）redis相关推荐

最新文章

热门文章