當前位置:網站首頁>【Redis實現秒殺業務①】秒殺流程概述|基本業務實現

【Redis實現秒殺業務①】秒殺流程概述|基本業務實現

2022-06-24 09:05:07步爾斯特


小夥伴們,從今天開始,我們一起用Redis來實現秒殺業務,要一起加油啊!

我們大概的思路就是設計一個水果秒殺小項目。

首先我們會有一種水果,該水果擁有名字、數量、搶購開始時間和搶購結束時間。

業務流程

  • 秒殺是否開始或結束,如果尚未開始或已經結束則無法下單
  • 庫存是否充足,不足則無法下單
    在這裏插入圖片描述

水果實體類

在這裏插入圖片描述

/** * 水果 * * @author issavior */
@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

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

    @Autowired
    private SeckillService seckillService;


    /** * 新增水果 * @param fruits 水果 * @return ResponseEntity<Object> */
    @PostMapping
    public ResponseEntity<Object> insertFruits(@RequestBody Fruits fruits) {
    

        return seckillService.insertFruits(fruits);
    }

}

ServiceImpl

/** * @author issavior */
@Service
public class SeckillServiceImpl implements SeckillService {
    

    @Autowired
    private SeckillMapper seckillMapper;

    @Autowired
    private RedisIdWorker redisIdWorker;

    /** * 新增水果 * * @param fruits 新增的水果數據 * @return ResponseEntity<Object> */
    @Override
    public ResponseEntity<Object> 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("新增成功");

    }
}

秒殺業務基本實現

    /** * 搶購水果 * * @param id 搶購水果的主鍵ID * @return ResponseEntity<Object> */
    @PostMapping("/{id}")
    public ResponseEntity<Object> seckillFruits(@PathVariable("id") Long id) {
    

        return seckillService.seckillFruits(id);
    }

   /** * 搶購水果 * * @param id 搶購水果的ID * @return ResponseEntity<Object> */
    @Override
    public ResponseEntity<Object> 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("搶購水果成功,去步爾斯特的主頁看看吧!");
    }

版權聲明
本文為[步爾斯特]所創,轉載請帶上原文鏈接,感謝
https://cht.chowdera.com/2022/175/202206240728174421.html

隨機推薦