栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

【Redis实现秒杀业务①】秒杀流程概述|基本业务实现

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

【Redis实现秒杀业务①】秒杀流程概述|基本业务实现

水果秒杀业务
    • 业务流程
    • 水果实体类
    • 新增水果
    • 秒杀业务基本实现

小伙伴们,从今天开始,我们一起用Redis来实现秒杀业务,要一起加油啊!

我们大概的思路就是设计一个水果秒杀小项目。

首先我们会有一种水果,该水果拥有名字、数量、抢购开始时间和抢购结束时间。

业务流程
  • 秒杀是否开始或结束,如果尚未开始或已经结束则无法下单
  • 库存是否充足,不足则无法下单
水果实体类

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Fruits implements Serializable {

    private static final long serialVersionUID = 1;

    private Long id;

    private String name;

    private Integer count;

    private Date startTime;

    private Date endTime;
}
新增水果

Controller

@RestController
@RequestMapping("/seckill")
public class SeckillController {

    @Autowired
    private SeckillService seckillService;


    
    @PostMapping
    public ResponseEntity insertFruits(@RequestBody Fruits fruits) {

        return seckillService.insertFruits(fruits);
    }

}

 

ServiceImpl

@Service
public class SeckillServiceImpl implements SeckillService {

    @Autowired
    private SeckillMapper seckillMapper;

    @Autowired
    private RedisIdWorker redisIdWorker;

    
    @Override
    public ResponseEntity insertFruits(Fruits fruits) {
			
		// 全局唯一ID工具类,详情可见系列文章上一篇
        long id = redisIdWorker.nextId("seckill:fruits");
        fruits.setId(id);
        int successFlag = seckillMapper.insertFruits(fruits);
        if (successFlag == 0) {
            return ResponseEntity.status(400).body("新增失败");
        }

        return ResponseEntity.ok("新增成功");

    }
}
 
秒杀业务基本实现 
    
    @PostMapping("/{id}")
    public ResponseEntity seckillFruits(@PathVariable("id") Long id) {

        return seckillService.seckillFruits(id);
    }

 
   
    @Override
    public ResponseEntity seckillFruits(Long id) {

        Fruits fruits = seckillMapper.selectFruits(id);
        if (fruits == null) {
            return ResponseEntity.status(400).body("水果卖光了,下次再来吧!");
        }

        LocalDateTime startTime = fruits.getStartTime();
        LocalDateTime endTime = fruits.getEndTime();
        Integer count = fruits.getCount();

        if (startTime.isAfter(LocalDateTime.now())) {
            return ResponseEntity.status(400).body("活动还没开始,去步尔斯特的主页看看吧!!");
        }
        if (endTime.isBefore(LocalDateTime.now())) {
            return ResponseEntity.status(400).body("活动已经结束了,去步尔斯特的主页看看吧!!");
        }
        if (count < 1) {
            return ResponseEntity.status(400).body("没有库存了,去步尔斯特的主页看看吧!!");
        }

        int updateFruits = seckillMapper.updateFruits(id);

        if (updateFruits == 0) {
            return ResponseEntity.status(400).body("水果卖光了,下次再来吧!");
        }
        return ResponseEntity.ok("抢购水果成功,去步尔斯特的主页看看吧!");
    }


转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号