SpringCloudAlibaba六微服务架构下的秒杀案例

package com.product.service; import com.alibaba.fastjson.JSON; import com.product.dao.GoodsDao; import com.product.entity.Goods; import com.product.utils.JSONUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; import java.util.ArrayList; import java.util.List; import java.util.Set; @Component public class GoodService { public static final String SKILL_GOODS_PHONE = "SKILL_GOODS_PHONE"; public static final String SKILL_GOODS_QUEUE = "SKILL_GOODS_QUEUE"; @Autowired private RedisTemplate redisTemplate; @Autowired private GoodsDao goodsDao; @Scheduled(fixedDelay = 5000) public void prepareGood() { System.out.println("开始加载商品"); Set<Long> set = redisTemplate.boundHashOps(SKILL_GOODS_PHONE).keys(); List<Long> ids = new ArrayList<>(); for (Long id : set) { ids.add(id); } List<Goods> list = null; //只查询出不在内存当中的商品信息，并加载到内存 if (CollectionUtils.isEmpty(ids)) { list = goodsDao.findAllGoods(); } else { list = goodsDao.findGoods(ids); } if (!CollectionUtils.isEmpty(list)) { for (Goods goods : list) { redisTemplate.boundHashOps(SKILL_GOODS_PHONE).put(goods.getId(), JSON.toJSONString(goods)); redisTemplate.boundListOps(SKILL_GOODS_QUEUE+goods.getId()).leftPush(convertToArray(goods.getStock_count(), goods.getId())); } } //查看当前缓存中所有的商品信息 Set keys = redisTemplate.boundHashOps(SKILL_GOODS_PHONE).keys(); for (Object s : keys) { Goods goods = JSONUtil.toEntity((String) redisTemplate.boundHashOps(SKILL_GOODS_PHONE).get(s), Goods.class); System.out.println(goods.getName() + " 库存剩余：" + goods.getStock_count()); } } private Long[] convertToArray(Integer stock_count, Long id) { Long[] idlong = new Long[stock_count]; for (int i = 0; i < stock_count; i++) { idlong[i] = id; } return idlong; } //查询商品信息 public Goods queryGoods (Long productId) { return JSONUtil.toEntity((String) redisTemplate.boundHashOps(SKILL_GOODS_PHONE).get(productId), Goods.class); } //更新商品信息 public void update(Goods goods) { goodsDao.save(goods); } }