資訊專欄INFORMATION COLUMN
摘要：但是經(jīng)過(guò)測(cè)試自身的是次秒，是一個(gè)相當(dāng)不錯(cuò)的數(shù)據(jù)，所以我們這里將事務(wù)直接交給，使用存儲(chǔ)過(guò)程來(lái)降低行級(jí)鎖的持有時(shí)間。存儲(chǔ)過(guò)程代碼使用存儲(chǔ)過(guò)程之前必須保證數(shù)據(jù)庫(kù)已經(jīng)創(chuàng)建了存儲(chǔ)過(guò)程。表示使用在存儲(chǔ)過(guò)程中替代最后需要還原回來(lái)。
【什么是存儲(chǔ)過(guò)程
所謂的存儲(chǔ)過(guò)程是指：是一組為了完成特定功能的SQL語(yǔ)句集，經(jīng)編譯后存儲(chǔ)在數(shù)據(jù)庫(kù)中，用戶通過(guò)指定存儲(chǔ)過(guò)程的名字并給定參數(shù)（如果該存儲(chǔ)過(guò)程帶有參數(shù)）來(lái)調(diào)用執(zhí)行它。可以用控制語(yǔ)句編寫，有很強(qiáng)的靈活性，可以完成復(fù)雜的判斷和較復(fù)雜的運(yùn)算。
【為什么使用存儲(chǔ)過(guò)程現(xiàn)在的情況是：由于有update操作，所以需要使用事務(wù)保證操作的原子性，但是現(xiàn)在事務(wù)的控制是交給spring來(lái)控制的，那么中間就會(huì)有網(wǎng)絡(luò)延時(shí)，GC的耗時(shí)(GC時(shí)會(huì)掛起所有線程，并發(fā)數(shù)越高GC越頻繁)操作。而被update的記錄會(huì)被行級(jí)鎖控制住，所有的操作只能串行所以會(huì)大量阻塞，影響用戶體驗(yàn)。
但是經(jīng)過(guò)測(cè)試MySQL自身的update是40000次/秒，是一個(gè)相當(dāng)不錯(cuò)的數(shù)據(jù)，所以我們這里將事務(wù)直接交給MySQL，使用存儲(chǔ)過(guò)程來(lái)降低行級(jí)鎖的持有時(shí)間。
【存儲(chǔ)過(guò)程代碼使用存儲(chǔ)過(guò)程之前必須保證數(shù)據(jù)庫(kù)已經(jīng)創(chuàng)建了存儲(chǔ)過(guò)程。DELIMITER 表示使用‘$$’在存儲(chǔ)過(guò)程中替代‘;’,最后需要DELIMITER ;還原回來(lái)。我們這里的out r_result表示輸出，而這里的輸出需要和項(xiàng)目中的KillStatus枚舉值對(duì)應(yīng)，來(lái)表明一次秒殺的結(jié)果。
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 ;
【通過(guò)springdataJPA調(diào)用存儲(chǔ)過(guò)程
Entity上需要標(biāo)明相應(yīng)的注解告訴spring這個(gè)Entity擁有相應(yīng)的存儲(chǔ)過(guò)程：
import lombok.Data;
import javax.persistence.*;
import java.util.Date;
/**
* 秒殺明細(xì)實(shí)體類
* @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;
/**
* 秒殺產(chǎn)品id
*/
@Column(name = "kill_product_id")
private String killProductId;
/**
* 用戶手機(jī)號(hào)碼
*/
@Column(name = "mobile")
private String mobile;
/**
* 秒殺成功時(shí)間
*/
@Column(name = "kill_time")
private Date killTime;
}
對(duì)應(yīng)的Repository上也需要告訴方法(executeProcedure)，該方法需要調(diào)用哪一個(gè)存儲(chǔ)過(guò)程：注意一點(diǎn)這個(gè)方法的返回值就是存儲(chǔ)過(guò)程的 out ，入?yún)⒕褪谴鎯?chǔ)過(guò)程的 in。
