快捷導(dǎo)航

SpringBoot異步任務(wù)實現(xiàn)下單校驗庫存的項目實踐

更新時間：2023年09月27日 09:54:38 作者：DaenCode

在開發(fā)中,異步任務(wù)應(yīng)用的場景非常的廣泛,本文主要介紹了SpringBoot異步任務(wù)實現(xiàn)下單校驗庫存的項目實踐,具有一定的參考價值,感興趣的可以了解一下

??前言

在開發(fā)中，異步任務(wù)應(yīng)用的場景非常的廣泛，本文章以下單時校驗庫存為例來看看SpringBoot中異步任務(wù)的使用。使用異步任務(wù)可以提高系統(tǒng)的響應(yīng)性能，提高系統(tǒng)的并發(fā)能力，改善用戶體驗，減少資源的浪費，提高系統(tǒng)的可擴展性。

??思維導(dǎo)圖

在這里插入圖片描述

??流程圖

在這里插入圖片描述

??必不可少的注解

@EnableAsync：用于標(biāo)識啟動類，開啟異步任務(wù)。
@Component：標(biāo)識異步任務(wù)類。
@Async：標(biāo)識定時任務(wù)方法。

??獲取異步結(jié)果的API

方法	描述
`boolean cancel(boolean mayInterruptIfRunning)`	取消異步任務(wù)的執(zhí)行。
`boolean isCancelled()`	判斷異步任務(wù)是否被取消。
`boolean isDone()`	判斷異步任務(wù)是否已經(jīng)完成。
`V get() throws InterruptedException, ExecutionException`	獲取異步任務(wù)的結(jié)果。
`V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException`	在指定的時間內(nèi)獲取異步任務(wù)的結(jié)果。如果超時，會拋出`TimeoutException`。

??實現(xiàn)步驟

數(shù)據(jù)準(zhǔn)備

創(chuàng)建數(shù)據(jù)庫表，并插入示例數(shù)據(jù)

CREATE TABLE product (
  id INT PRIMARY KEY,
  name VARCHAR(100),
  price DECIMAL(10,2),
  stock INT
);
INSERT INTO product (id, name, price, stock) VALUES
  (1, '蘋果13', 10.99, 50),
  (2, '小米10', 19.99, 100),
  (3, '華為mate20', 5.99, 20);

實體類

public class Product {
    private Integer id;
    private String name;
    private BigDecimal price;
    private Integer stock;
}

啟動類開啟異步任務(wù)

添加@EnableAsync開啟異步任務(wù)。

@SpringBootApplication
@MapperScan("com.shoanjen.redis.mapper")
@EnableCaching
@EnableScheduling
@EnableAsync
public class RedisApplication {
	public static void main(String[] args) {
		SpringApplication.run(RedisApplication.class, args);
	}
}

異步任務(wù)方法

在異步任務(wù)方法上添加@Async注解。
方法邏輯：

根據(jù)商品id查詢數(shù)據(jù)庫是否存在當(dāng)前商品
若商品不存在、或者商品當(dāng)前庫存小于購買量quantity，返回false。
若商品存在，進行模擬下單操作。更新庫存的數(shù)量。
當(dāng)然還有查詢余額的邏輯，我這里沒有寫，跟查詢庫存類似。

優(yōu)點：通過異步任務(wù)實現(xiàn)下單時查詢庫存以及余額，可以很大的提高性能。

@Component
public class ValidateTask {
    @Autowired
    private ProductMapper productMapper;
    //校驗庫存功能
    @Async
    public Future<Boolean> validateStock(int productId, int quantity){
        //查詢數(shù)據(jù)庫中的商品
        Product product=productMapper.selectProductById(productId);
        //商品庫存校驗
        if (product==null || product.getStock()<quantity){
            return new AsyncResult<>(false);
        }else {
            //模擬下單操作
            product.setStock(product.getStock()-quantity);
            //這里就演示訂單表保存數(shù)據(jù)了，直接更新庫存
            productMapper.updateProduct(product);
            return new AsyncResult<>(true);
        }
    }
}

Controller層

方法邏輯：

調(diào)用異步任務(wù)。
設(shè)置flag標(biāo)記。
判斷異步任務(wù)是否完成。
如果flag為true，則下單成功，否則失敗。

@RestController
@RequestMapping("/api/v1/product")
public class ProductController {
    @Autowired
    private ValidateTask validateTask;
	//productId-商品id，quantity-購買數(shù)量
    @RequestMapping("order")
    public JsonData order(@RequestParam int productId,@RequestParam int quantity) throws ExecutionException, InterruptedException {
    	//調(diào)用異步任務(wù)
        Future<Boolean> validateResult=validateTask.validateStock(productId,quantity);
        Boolean flag=false;
        //判斷異步任務(wù)是否完成
        if (validateResult.isDone()){
            try {
                flag=validateResult.get();
            } catch (Exception e) {
                flag=false;
            }
        }
        if (flag){
            return JsonData.buildSuccess("下單成功");
        }else {
            return JsonData.buildError("下單失敗，庫存不足");
        }
    }

ProductMapper.xml

<mapper namespace="com.shoanjen.redis.mapper.ProductMapper">
   <select id="selectProductById" resultType="com.shoanjen.redis.model.Product">
       select * from product where id=#{productId}
   </select>
    <update id="updateProduct" parameterType="com.shoanjen.redis.model.Product">
        update product set name=#{product.name},price=#{product.price},stock=#{product.stock} where id=#{product.id}
    </update>
</mapper>