搶購功能的實現(PHP+MySQL)

業務背景：

        某公司開展活動，4個實體店，天天限量發放10個優惠券，供人們搶購。

技術分析：

        一旦涉及搶購，必然會引發併發問題，並且還儘可能保證程序的併發性，這就要求或者在程序中作同步，或者在數據庫層次作同步。通常來講，在程序端作同步(synchronize)，會致使阻塞得很厲害。使用數據庫同步，能夠選擇有行級鎖的數據庫以及提升事務隔離等級，但提升事務等級會將事務串行化(Serializable)，嚴重下降程序併發。綜上權衡，我選擇了PHP+MySQL。以個人認知，Oracle與MySQL均可以，MSSQL卻沒找到相似功能。

主要解決方法：

        1.須要把實體店對應的優惠券數量以記錄的形式呈現，表1：Max_Table( ID, storeID,apply_count ,apply_code)。表2：apply_form(apply_code,store_id,phone_numbe)該表主要記錄哪一個用戶用什麼 手機號碼申請了優惠券，優惠券碼是什麼。

        2.建立數據庫時要使用InnoDB存儲引擎

        3.在數據庫中建立存儲過程，在存儲過程當中使用事務，在事務中要先查詢是否發放完畢，爲避免多進程同時訪問某記錄中的數量而引發的問題，我使用for update。使用該語句，若事務A訪問訪問該記錄時，事務B會阻塞，直到事務A完畢後，從而達到了<並轉串>的操做。

如下是解決該問題的核心存儲過程，其中有2個入參，1個出參。

[sql] view plain copy

 

1. CREATE DEFINER=`sa`@`localhost` PROCEDURE `p_apply_code`(IN `p_store_id` varchar(30), IN `p_phone_number` varchar(20),OUT  return_val varchar(30))  
2. BEGIN  
3.     #Routine body goes here...  
4.   declare p_apply_count int(4) default 0;  
5.   declare encode_apply_code varchar(16) default '';  
6.   
7.   start transaction ;//開始事務  
8.   SELECT apply_count into p_apply_count FROM max_table WHERE store_id=p_store_id   for update;  
9.   if (p_apply_count =0 ) THEN  
10.     insert into max_table(store_id,apply_count) values(p_store_id,0);  
11.   end if;  
12.   IF( p_apply_count<=9) THEN   
13.   
14.        set encode_apply_code='優惠券碼的生成規則',  
15.        insert into apply_form(apply_code,store_id,phone_number) values(encode_apply_code,p_store_id,p_phone_number);  
16.        update max_table set apply_count=apply_count+1 where store_id=p_store_id;  
17.        set result=encode_apply_code2;    
18.   END IF;  
19.   
20.   set return_val=result ;  
21.   commit; //提交事務，同時釋放for update鎖  
22.   
23. END  
24.   
25. 4.PHP調用MySQL存儲過程  
26.   
27. $sql = 'call p_apply_code('."'$store_id',"."'$phonenumber',"."@return_val".');  ';  
28.         $db->query($sql);  
29.         $apply_code=$db->getOne('select @return_val');  
30. <pre></pre>  
31. <pre></pre>  
32. <pre></pre>  
33. <pre></pre>  
34. <pre></pre>