一. 秒杀商品存入缓存

1. 客户访问-> seckill服务查询mysql-> seckill_goods表-> 缓存数据到MySQL-> 一是缓解高并发下数据库的查找压力, 二是利用redis的原子性操作避免超卖问题.

2. 新建服务changgou_service_seckill

(1)添加依赖: common-db/ eureka/ order-api/ seckill-api/ goods-api/ amqp/ oauth2
(2)添加changgou_service_seckill_api模块: 创建seckill/pojo/SeckillGoods.java 和 SeckillOrder.java
(3)启动类SeckillApplication.java
@SpringBootApplication
@EnableEurekaClient
@MapperScan(basePackages = {"com.changgou.seckill.dao"})
@EnableScheduling
public class SecKillApplication {public static void main(String[] args) {//TimeZone.setDefault(TimeZone.getTimeZone("Asia/Shanghai"));SpringApplication.run(SecKillApplication.class, args);}//idWorker@Beanpublic IdWorker idWorker(){return new IdWorker(1, 1); //传入snowflake算法的参数(工作id, 序列号范围)}/*** 设置 redisTemplate 的序列化设置* @param redisConnectionFactory* @return*/@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {// 1.创建 redisTemplate 模版RedisTemplate<Object, Object> template = new RedisTemplate<>();// 2.关联 redisConnectionFactorytemplate.setConnectionFactory(redisConnectionFactory);// 3.创建 序列化类GenericToStringSerializer genericToStringSerializer = new GenericToStringSerializer(Object.class);// 6.序列化类，对象映射设置// 7.设置 value 的转化格式和 key 的转化格式template.setValueSerializer(genericToStringSerializer);template.setKeySerializer(new StringRedisSerializer());template.afterPropertiesSet();return template;}@Beanpublic TokenDecode tokenDecode() {return new TokenDecode();}
}(4)配置文件application.yml
server:port: 9011
spring:jackson:time-zone: GMT+8application:name: seckilldatasource:driver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://192.168.200.128:3306/changgou_seckill?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT%2b8username: rootpassword: rootmain:allow-bean-definition-overriding: true #当遇到同样名字的时候，是否允许覆盖注册redis:host: 192.168.200.128rabbitmq:host: 192.168.200.128
eureka:client:service-url:defaultZone: http://127.0.0.1:6868/eurekainstance:prefer-ip-address: true
feign:hystrix:enabled: trueclient:config:default:   #配置全局的feign的调用超时时间  如果 有指定的服务配置 默认的配置不会生效connectTimeout: 60000 # 指定的是 消费者 连接服务提供者的连接超时时间 是否能连接  单位是毫秒readTimeout: 20000  # 指定的是调用服务提供者的 服务 的超时时间（）  单位是毫秒
#hystrix 配置
hystrix:command:default:execution:timeout:#如果enabled设置为false，则请求超时交给ribbon控制enabled: trueisolation:strategy: SEMAPHOREthread:# 熔断器超时时间，默认：1000/毫秒timeoutInMilliseconds: 20000(5)整合oauth2: 1) 把oauth2微服务的public.key公钥复制到到seckill的resources下2) 复制seckill/config/ResourcesServerConfig.java
@Configuration
@EnableResourceServer
//开启方法上的PreAuthorize注解
@EnableGlobalMethodSecurity(prePostEnabled = true, securedEnabled = true)
public class ResourceServerConfig extends ResourceServerConfigurerAdapter {//公钥private static final String PUBLIC_KEY = "public.key";/**** 定义JwtTokenStore* @param jwtAccessTokenConverter* @return*/@Beanpublic TokenStore tokenStore(JwtAccessTokenConverter jwtAccessTokenConverter) {return new JwtTokenStore(jwtAccessTokenConverter);}/**** 定义JJwtAccessTokenConverter* @return*/@Beanpublic JwtAccessTokenConverter jwtAccessTokenConverter() {JwtAccessTokenConverter converter = new JwtAccessTokenConverter();converter.setVerifierKey(getPubKey());return converter;}/*** 获取非对称加密公钥 Key* @return 公钥 Key*/private String getPubKey() {Resource resource = new ClassPathResource(PUBLIC_KEY);try {InputStreamReader inputStreamReader = new InputStreamReader(resource.getInputStream());BufferedReader br = new BufferedReader(inputStreamReader);return br.lines().collect(Collectors.joining("\n"));} catch (IOException ioe) {return null;}}/**** Http安全配置，对每个到达系统的http请求链接进行校验* @param http* @throws Exception*/@Overridepublic void configure(HttpSecurity http) throws Exception {//所有请求必须认证通过http.authorizeRequests().antMatchers("/seckillgoods/list/**").permitAll().anyRequest().authenticated();    //其他地址需要认证授权}
}(6)添加网关路径过滤类: 1) UrlFilter.java://所有需要传递令牌的地址public static String filterPath = "/api/worder/**,/api/seckill);2) 网关配置文件中设置跳转:#秒杀微服务- id: changgou_seckill_routeuri: lb://seckillpredicates:- Path=/api/seckill/**filters:- StripPrefix=1

2. 秒杀时间段:

        1) 分析: 2个小时-> 一天12个秒杀时间-> 商品开始时间<当前时间<商品结束时间

        2) 时间工具类: 日期转换DateUtil放入changgou_common模块

//测试-> i*2public static void main(String[] args) {//存储数据List<Date> dateList = new ArrayList<>();//获取今天凌晨时间点Date startHour = toDayStartHour(new Date());//循环12次-> 0/2/4/6/8/10/12for (int i=0; i<12; i++){//当前凌晨时间点->递增2小时dateList.add(addDateHour(startHour, i*2));}for (Date date : dateList) {SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String format = simpleDateFormat.format(date);System.out.println(format);}}

3. 查询数据库符合条件的秒杀商品: 

    1) 实现流程:

1.查询所有符合条件的秒杀商品1) 获取时间段集合并循环遍历出每一个时间段2) 获取每一个时间段名称,用于后续redis中key的设置3) 状态必须为审核通过 status=14) 商品库存个数>0 5) 秒杀商品开始时间>=当前时间段6) 秒杀商品结束<当前时间段+2小时7) 排除之前已经加载到Redis缓存中的商品数据8) 执行查询获取对应的结果集
2.将秒杀商品存入缓存

    2) 开启定时任务注解:  启动类添加注解@EnableScheduling

(1) 创建seckill/task/SeckillApplication.java 
//每隔30秒查询数据库seckill_goods表中符合秒杀的商品存入redis
@Component
public class SecKillGoodsPushTask {public static final String SECKILL_GOODS_KEY="seckill_goods_";private static final String SECKILL_GOODS_STOCK_COUNT_KEY = "seckill_goods_stock_count_";@Autowiredprivate SeckillGoodsMapper seckillGoodsMapper;@Autowiredprivate RedisTemplate redisTemplate;@Scheduled(cron = "0/30 * * * * ?")public void loadSecKillGoodsToRedis(){/*** 1.查询所有符合条件的秒杀商品*     1) 获取时间段集合并循环遍历出每一个时间段*     2) 获取每一个时间段名称,用于后续redis中key的设置*     3) 状态必须为审核通过 status=1*     4) 商品库存个数>0*     5) 秒杀商品开始时间>=当前时间段*     6) 秒杀商品结束<当前时间段+2小时*     7) 排除之前已经加载到Redis缓存中的商品数据*     8) 执行查询获取对应的结果集* 2.将秒杀商品存入缓存*/List<Date> dateMenus = DateUtil.getDateMenus(); //5个时间段for (Date dateMenu : dateMenus) {SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String redisExtName = DateUtil.date2Str(dateMenu);Example example = new Example(SeckillGoods.class);Example.Criteria criteria = example.createCriteria();criteria.andEqualTo("status", "1");criteria.andGreaterThan("stockCount", 0);criteria.andGreaterThanOrEqualTo("startTime", simpleDateFormat.format(dateMenu));criteria.andLessThan("endTime", simpleDateFormat.format(DateUtil.addDateHour(dateMenu,2)));Set keys = redisTemplate.boundHashOps(SECKILL_GOODS_KEY + redisExtName).keys();//key field valueif (keys!=null&&keys.size()>0){criteria.andNotIn("id", keys); //id == field}List<SeckillGoods> seckillGoodsList = seckillGoodsMapper.selectByExample(example);//添加到缓存中for (SeckillGoods seckillGoods : seckillGoodsList) {               redisTemplate.opsForHash().put(SECKILL_GOODS_KEY+redisExtName,seckillGoods.getId(), seckillGoods);//加载秒杀商品库存 -> redis原子性操作, 先与扣减缓存的库存, 再异步扣减mysql的库存               redisTemplate.opsForValue().set(SECKILL_GOODS_STOCK_COUNT_KEY+seckillGoods.getId(), seckillGoods.getStockCount());}}}
}(2) 创建seckill/dao/SeckillGoodsMapper.java

 

二. 促销商品首页: 每2小时加载时间菜单-> 后台查询时间菜单-> 菜单第一个时间段作为key-> 在redis中查询秒杀商品-> 显示到页面 

(1)创建模块: changgou_web_seckill 渲染服务-> 调用seckill服务获取数据
(2)添加依赖: seckill_api / thymeleaf
(3)启动类: SeckillWebApplication.java  @EbanleFeignClients(basePackages={"com.changgou.seckill.feign"})
(4)配置文件yml: 
server:port: 9104
eureka:client:service-url:defaultZone: http://127.0.0.1:6868/eurekainstance:prefer-ip-address: true
feign:hystrix:enabled: trueclient:config:default:   #配置全局的feign的调用超时时间  如果 有指定的服务配置 默认的配置不会生效connectTimeout: 60000 # 指定的是 消费者 连接服务提供者的连接超时时间 是否能连接  单位是毫秒readTimeout: 80000  # 指定的是调用服务提供者的 服务 的超时时间（）  单位是毫秒
spring:jackson:time-zone: GMT+8thymeleaf:cache: falseapplication:name: seckill-webmain:allow-bean-definition-overriding: trueredis:host: 192.168.200.128
#hystrix 配置
hystrix:command:default:execution:timeout:#如果enabled设置为false，则请求超时交给ribbon控制enabled: trueisolation:strategy: SEMAPHOREthread:timeoutInMilliseconds: 60000
#请求处理的超时时间
ribbon:ReadTimeout: 4000#请求连接的超时时间ConnectTimeout: 3000(5) 网关对接: #秒杀渲染微服务- id: changgou_seckill_web_routeuri: lb://seckill-webpredicates:- Path=/api/wseckillgoods/**,/api/wseckillorder/**filters:- StripPrefix=1(6)com.changgou.seckill.web.controller
@Controller
@RequestMapping("/wseckillgoods")
public class SecKillGoodsController {@Autowiredprivate SecKillGoodsFeign secKillGoodsFeign;//跳转秒杀首页@RequestMapping("/toIndex")public String toIndex(){return "seckill-index";}//获取秒杀时间段集合信息@RequestMapping("/timeMenus")@ResponseBodypublic List<String> dateMenus() {//获取当前时间段相关的信息集合List<Date> dateMenus = DateUtil.getDateMenus();List<String> result = new ArrayList<>();SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");for (Date dateMenu : dateMenus) {String format = simpleDateFormat.format(dateMenu);result.add(format);}return result;}//秒杀商品查询@RequestMapping("/list")@ResponseBodypublic Result<List<SeckillGoods>> list(String time) {return secKillGoodsFeign.list(DateUtil.formatStr(time));}
}

(2). 根据秒杀时间段显示商品-> 秒杀渲染服务

(1)com.changgou.seckill.service.impl
@Service
public class SecKillGoodsServiceImpl implements SecKillGoodsService {@Autowiredprivate RedisTemplate redisTemplate;public static final String SECKILL_GOODS_KEY="seckill_goods_";private static final String SECKILL_GOODS_STOCK_COUNT_KEY = "seckill_goods_stock_count_";@Overridepublic List<SeckillGoods> list(String time) {List<SeckillGoods> list = redisTemplate.boundHashOps(SECKILL_GOODS_KEY + time).values();//更新库存数据的来源for (SeckillGoods seckillGoods : list) {String value = (String) redisTemplate.opsForValue().get(SECKILL_GOODS_STOCK_COUNT_KEY + seckillGoods.getId());seckillGoods.setStockCount(Integer.parseInt(value));}return list;}
}(2)com.changgou.seckill.controller
@RestController
@RequestMapping("/seckillgoods")
public class SecKillGoodsController {@Autowiredprivate SecKillGoodsService secKillGoodsService;//秒杀商品查询@RequestMapping("/list")public Result<List<SeckillGoods>> list(@RequestParam("time")String time) {List<SeckillGoods> seckillGoodsList = secKillGoodsService.list(time);return new Result<>(true, StatusCode.OK, "查询成功", seckillGoodsList);}
}(3)com.changgou.seckill.feign
@FeignClient(name = "seckill")
public interface SecKillGoodsFeign {@RequestMapping("/seckillgoods/list")public Result<List<SeckillGoods>> list(@RequestParam("time")String time);
}

(3) 立即抢购按钮-> Vue.js

@GetMapping("/add")
@AccessLimit
public Result add(@RequestParam("time")String time, @RequestParam("id")Long id, String random) {//下单接口隐藏String cookieValue = this.readCookie();String redisRandomCode = (String) redisTemplate.opsForValue().get("randomcode_" + cookieValue);if (StringUtils.isEmpty(redisRandomCode)){return new Result(false, StatusCode.ERROR, "下单失败");}if (!random.equals(redisRandomCode)){return new Result(false, StatusCode.ERROR, "下单失败");}//下单操作Result result = secKillOrderFeign.add(time, id);return result;}