抢购功能的实现[PHP+MySQL]

原文地址：抢购功能的实现[PHP+MySQL]作者：邓强
本文转自：

   
   
  http://blog.csdn.net/liangpei2008/article/details/7920397

业务背景：

       
某公司开展活动，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个出参。

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))  

BEGIN  

    #Routine body goes here...  

  declare p_apply_count int(4)
4000
 default 0;  

  declare encode_apply_code varchar(16) default '';  

  

  start transaction ;//开始事务  

  SELECT apply_count into p_apply_count FROM max_table WHERE store_id=p_store_id   for update;  

  if (p_apply_count =0 ) THEN  

    insert into max_table(store_id,apply_count) values(p_store_id,0);  

  end if;  

  IF( p_apply_count<=9) THEN   

  

       set encode_apply_code='优惠券码的生成规则',  

       insert into apply_form(apply_code,store_id,phone_number) values(encode_apply_code,p_store_id,p_phone_number);  

       update max_table set apply_count=apply_count+1 where store_id=p_store_id;  

       set result=encode_apply_code2;    

  END IF;  

  

  set return_val=result ;  

  commit; //提交事务，同时释放for update锁  

  

END  

  

4.PHP调用MySQL存储过程  

  

$sql = 'call p_apply_code('."'$store_id',"."'$phonenumber',"."@return_val".');  ';  

        $db->query($sql);  

        $apply_code=$db->getOne('select @return_val');