java併發編程學習21--基於springboot的秒殺系統實現3--存儲過程

【什麼是存儲過程

所謂的存儲過程是指：是一組爲了完成特定功能的SQL語句集，經編譯後存儲在數據庫中，用戶經過指定存儲過程的名字並給定參數（若是該存儲過程帶有參數）來調用執行它。能夠用控制語句編寫，有很強的靈活性，能夠完成複雜的判斷和較複雜的運算。

【爲何使用存儲過程

如今的狀況是：因爲有update操做，因此須要使用事務保證操做的原子性，可是如今事務的控制是交給spring來控制的，那麼中間就會有網絡延時，GC的耗時(GC時會掛起全部線程，併發數越高GC越頻繁)操做。而被update的記錄會被行級鎖控制住，全部的操做只能串行因此會大量阻塞，影響用戶體驗。

可是通過測試MySQL自身的update是40000次/秒，是一個至關不錯的數據，因此咱們這裏將事務直接交給MySQL，使用存儲過程來下降行級鎖的持有時間。

【存儲過程代碼

使用存儲過程以前必須保證數據庫已經建立了存儲過程。DELIMITER 表示使用‘$$’在存儲過程當中替代‘;’,最後須要DELIMITER ;還原回來。咱們這裏的out r_result表示輸出，而這裏的輸出須要和項目中的KillStatus枚舉值對應，來代表一次秒殺的結果。

DELIMITER $$
CREATE PROCEDURE `seckill`.`execute_seckill`
    (in v_id VARCHAR(36),in v_kill_product_id VARCHAR(36),in v_mobile BIGINT,in v_kill_time TIMESTAMP,out r_result int)
    BEGIN
        DECLARE insert_count int DEFAULT 0;
    START TRANSACTION;
    INSERT IGNORE INTO kill_item(id,kill_product_id,mobile) values(v_id,v_kill_product_id,v_mobile);
    SELECT ROW_COUNT() INTO insert_count;
        IF(insert_count = 0) THEN
            ROLLBACK;
            SET r_result = -1;
        ELSEIF(insert_count < 0) THEN
            ROLLBACK;
            SET r_result = -2;
        ELSE
            UPDATE kill_product SET number = number - 1
            WHERE id = v_kill_product_id AND number >= 1 AND end_time > v_kill_time AND start_time < v_kill_time;
            SELECT ROW_COUNT() INTO insert_count;
            IF(insert_count = 0) THEN
                ROLLBACK;
                SET r_result = 0;
            ELSEIF(insert_count < 0) THEN
                ROLLBACK;
                SET r_result = -2;
            ELSE
                COMMIT;
                SET r_result = 1;
            END IF;
        END IF;
    END;
$$
DELIMITER ;

【經過springdataJPA調用存儲過程

Entity上須要標明相應的註解告訴spring這個Entity擁有相應的存儲過程：

import lombok.Data;

import javax.persistence.*;
import java.util.Date;

/**
 * 秒殺明細實體類
 * @author ibm
 * @since 0
 * @date 2018/3/22
 */
@Entity
@Table(name = "kill_item")
@NamedStoredProcedureQuery(name = "executeSeckill", procedureName = "execute_seckill", parameters = {
        @StoredProcedureParameter(mode = ParameterMode.IN, name = "v_id", type = String.class),
        @StoredProcedureParameter(mode = ParameterMode.IN, name = "v_kill_product_id", type = String.class),
        @StoredProcedureParameter(mode = ParameterMode.IN, name = "v_mobile", type = Long.class),
        @StoredProcedureParameter(mode = ParameterMode.IN, name = "v_kill_time", type = Date.class),
        @StoredProcedureParameter(mode = ParameterMode.OUT, name = "r_result", type = Integer.class) })
@Data
public class KillItem {

    /**
     * 記錄ID
     */
    @Id
    @Column(name = "id")
    private String id;
    /**
     * 秒殺產品id
     */
    @Column(name = "kill_product_id")
    private String killProductId;
    /**
     * 用戶手機號碼
     */
    @Column(name = "mobile")
    private String mobile;
    /**
     * 秒殺成功時間
     */
    @Column(name = "kill_time")
    private Date killTime;
}

對應的Repository上也須要告訴方法(executeProcedure)，該方法須要調用哪個存儲過程：注意一點這個方法的返回值就是存儲過程的 out ，入參就是存儲過程的 in。

import com.example.seckill.dao.entity.KillItem;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.jpa.repository.query.Procedure;
import org.springframework.data.repository.query.Param;

import java.util.Date;
import java.util.List;

/**
 * @author ibm
 * @since 0
 * @date 2018/3/22
 */
public interface KillItemJpaRepo extends JpaRepository<KillItem,String> {

    /**
     * 查看秒殺商品的秒殺記錄
     * @param killProductId 秒殺商品Id
     * @return 秒殺記錄詳情
     */
    List<KillItem> findAllByKillProductIdOrderByKillTimeDesc(String killProductId);

    /**
     * 保存秒殺記錄
     * @param id 預生成的主鍵
     * @param killProductId 秒殺商品id
     * @param mobile 執行秒殺用戶手機號
     * @return 執行的行數
     */
    @Modifying
    @Query(value = "INSERT IGNORE INTO kill_item(id,kill_product_id,mobile) values(?1,?2,?3)",
            nativeQuery = true)
    int insertKillItem(String id,String killProductId,long mobile);


    @Procedure(procedureName = "execute_seckill")
    int executeProcedure(@Param("v_id")String killItemId,
                         @Param("v_kill_product_id")String killProductId,
                         @Param("v_mobile")long mobile,
                         @Param("v_kill_time")Date killTime);
}

【總結

至此全部的優化已經完成：

1.用戶大量刷新 -> CDN靜態化處理（css,js）
                            1.加速用戶獲取數據的系統
                            2.部署在離用戶最近的網絡節點
                            3.CDN不須要訪問後端服務器

        2.秒殺地址接口分析 -> 沒法使用CDN，隨着時間接口狀態會發生變化
                            1.使用服務端緩存：redis
                            2.緩存沒有再訪問MySQL

        3.秒殺操做接口分析 -> 沒法使用CDN，由於庫存動態刷新也不能使用服務器緩存,行數據競爭激烈。
                            1.減小行級鎖的持有時間
                            2.把客戶端邏輯放到MySQL服務器執行
                            3.使用存儲過程，將事務交由MySQL完成
        
        4.前端控制 -> 暴露接口，按鈕防止重複提交

【項目地址

項目原型來源於慕課網：https://www.imooc.com/learn/632
基於springBoot的版本：https://github.com/jipingongz...