MySQL(表锁)、PHP(文件锁)锁机制及应用场景

admin

模拟高并发访问一个脚本：apache安装文件的bin/ab.exe可以模拟并发量

1. C:\phpStudy\Apache\bin>ab.exe -c 10 -n 10 http://localhost/try.php   // -c 模拟多少并发量 -n 一共请求多少次 http://请求的脚本

复制代码

1 G+ L/ Q* A$ g3 I  z* ]# V

Mysql中的锁语法：
LOCK TABLE 表名1 READ|WRITE, 表名2 READ|WRITE .................. 【锁表】
* T+ W( O9 j/ ]5 c7 x0 W! aUNLOCK TABLES  【释放表】

Read:读锁|共享锁 ： 所有的客户端只能读这个表不能写这个表
Write:写锁|排它锁： 所有当前锁定客户端可以操作这个表，其他客户端只能阻塞
注意：在锁表的过程中只能操作被锁定的表，如果要操作其他表，必须把所有要操作的表都锁定起来！

PHP中的文件锁 ：
( f& r, Q. o1 l文件锁的文件与表有什么关系？：一点关系也没有，与令牌相似，谁拿到谁操作。所以表根本没锁。
8 S7 g' O* n% v; ]测试时，有个文件就行，叫什么名无所谓

总结：
项目中应该只使用PHP中的文件锁，尽量避免锁表，因为如果表被锁定了，那么整个网站中所有和这个表相关的功能都被拖慢了（例如：前台很多用户一直下订单，商品表mysql锁表，其他与商品表相关的操作一直处于阻塞状态【读不出来商品表】，因为一个功能把整个网站速度拖慢）。

比如在一个O2O外卖项目中，中午12-2点，晚上6点都是订单高并发时，这种情况下，MySQL锁显然是不考虑的，用户体验太差。其实根据实际的需求，外卖可以不用设计库存量的，当然除了秒杀活动模块还是需要php文件锁的。

应用场景：
9 X  G9 N: r! t/ c1. 高并发下单时，减库存量时要加锁
3 x$ D+ m8 Y& K/ Q1 m; Y2. 高并发抢单、抢票时要使用

Mysql锁示例：

1.    /*
   * X: U( N% b( g$ }0 r' r% C! j9 E
2.     模拟秒杀活动-- 商品100件
   ; W# J8 [, ^+ m! k/ N/ y
3.     CREATE TABLE ta
   8 u  r/ d! h7 w/ L5 U  J
4.     (
     t. ?( @' b9 c0 `) b& `
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
   
7.     INSERT INTO ta VALUES(100);
   % q- t( }# _" f4 k$ v
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   & d5 _! ~+ o" R% v9 b
9.      */
   * N; W4 I% w  X; E% b+ F
10.    
    
11.     // 关闭错误报告
    
12.      error_reporting(0);
    
13. 
    5 n* \$ R6 R2 w
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    
15.     $dbuser = 'root';            // mysql用户名
    
16.     $dbpass = 'root';          // mysql用户名密码
    2 B6 {8 r9 a9 C( T9 X! D
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    , ]0 e! M4 c, G) O9 O! _( P
18.     if(! $conn )
    & F$ N6 b. _" e2 Q8 j; \6 {! b
19.     {
    & N8 K1 U6 X& o: O1 U5 N8 R2 Z# Z% S
20.         die('连接失败: ' . mysqli_error($conn));
    
21.     }
    
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    " W3 v0 y% L7 e! w
24.     mysqli_select_db( $conn, 'temp' );
    : a2 T( ]4 h& `# y5 I- l: {/ F
25. 
    
26.     # mysql 锁
    & ]; I" H) p% o' O7 ~
27.     mysqli_query($conn , 'LOCK TABLE a WRITE');// 只有一个客户端可以锁定表，其他客户端阻塞在这
    
28.     $rs = mysqli_query($conn , 'SELECT id FROM a');
    
29.     $id = mysqli_result($rs, 0, 0);
    
30.     if($id > 0)
    ; K; L" U9 s: N+ b' l7 M, H: H- ]
31.     {
    
32.         --$id;
    
33.         mysqli_query($conn , 'UPDATE a SET id='.$id);
    # g/ O. Z; K; `0 f4 o
34.     }
    
35. 
    
36.     # mysql 解锁
    
37.     mysqli_query($conn , 'UNLOCK TABLES');
    
38.     //查询解锁后的id值
    
39.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    : {  \, f. G* ?( Z
40.     // while($row = mysqli_fetch_assoc($res))
    
41.     // {
    
42.     //     $id = $row['id'];
    
43.     // }
    6 _8 U6 j8 `% R) [) ?, X  [; ~* X. O
44.     // echo $id;

复制代码

; D; \* I" A% N( W0 M, ]% O% V' i, D

PHP文件锁示例：

1. /*
     d. y4 q- o1 b7 `8 g
2.     模拟秒杀活动-- 商品100件
   
3.     CREATE TABLE ta
   + m: I; G1 P: H5 v" b* M& c
4.     (
   
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
   
7.     INSERT INTO ta VALUES(100);
   ) d7 u' c) @7 Q  I) s' d
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
   
10.    
    # j: |! m( f% T2 Z
11.     // 关闭错误报告
    
12.      error_reporting(0);
    
13. 
    / ~6 r( ^) g5 N3 K
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    / r4 Z7 I  P- _5 `
15.     $dbuser = 'root';            // mysql用户名
    
16.     $dbpass = 'root';          // mysql用户名密码
    ; H+ ]9 T3 I( G- v2 W0 y' S+ ?+ {& @
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    $ ~) g4 F/ }' U2 L5 Q. R. f
18.     if(! $conn )
    / x+ [  A% I& t; s9 v$ y# q
19.     {
    - q% q- g1 `, _: j) }
20.         die('连接失败: ' . mysqli_error($conn));
    
21.     }
    
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
    ! A3 `" K7 {* Z& w; k' i
25. 
    1 t5 n7 g5 n( T9 q! g' Y9 z9 s' d
26.     # php中的文件锁
    
27.     $fp = fopen('./a.lock', 'r'); // php的文件锁和表没关系，随便一个文件即可
    
28.     flock($fp, LOCK_EX);// 排他锁
    
29. 
    
30.     $retval = mysqli_query($conn ,'SELECT id FROM ta');
    ; r/ i& @+ w% i
31.     while($row = mysqli_fetch_assoc($retval))
    
32.     {
    
33.         $id =  $row['id'];
    
34.     }
    2 @0 [* b' r* G( E5 D
35.    
    
36.     if($id > 0)
    * {+ y+ Q& c. w
37.     {
    
38.         --$id;
    ' U: ?3 P/ f3 v2 S8 M8 s
39.         mysqli_query($conn ,'UPDATE ta SET id='.$id);
    
40.     }
    
41.     # php的文件锁，释放锁
    
42.     flock($fp, LOCK_UN);
    
43.     fclose($fp);
    
44. 
    ' C5 ~6 Q  G: e+ |9 H! u
45.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    
46.     // while($row = mysqli_fetch_assoc($res))
    3 J+ J) a, E) [5 i/ P/ A
47.     // {
    
48.     //     $id = $row['id'];
    
49.     // }
    # n% M% x+ H5 g# U
50.     // echo $id;

复制代码

- M5 X9 [6 {+ Z+ `& L$ Q9 I' d2 J

抢券活动实例：

1. public function envelopeSnatching(){
   
2.         $lingqu = $_POST['type'];
   7 F; ?8 |) f# Z+ I$ U
3.         $uid=session('u_id');//用户id
   9 P  @1 V9 E! e: Z+ {
4.         if(!$uid){
   : L% ?+ X% v% D/ T0 k* M
5.             $data['msg']='您没登录，请先登录!';
   2 h4 k/ @: [; {" ~1 @9 W! ~' ^
6.         }else if(date('Y-m-d') != '2017-12-12'){
   % Q9 O  ?; u! o0 ?, x
7.             $data['msg']='不在活动时间内!';
   
8.         }else{
   
9.             $hours=date('H');//当前小时数
   
10.             if($hours > '09' || $hours > '17'){
    9 B3 ^1 K# Z" {) B$ `# a# ^
11. 
    ; s  W, _( z6 H# E' @
12.                 if($lingqu == 1 || $lingqu ==2){//点击10点的
    
13.                     if($lingqu == 1){
    
14.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>1,'uid'=>$uid))->find();//判断是否领取过
    
15.                         if($hours > '09'){
    : V" _) z" V0 M  ^
16.                             $num=mt_rand(25,28);//优惠券金额
    
17.                             $id=1;
    3 V5 g3 s% M% V1 N* W) K5 L
18.                         }
    
19.                     }else if($lingqu == 2){
    5 J0 b/ v0 t. ^  ^0 f
20.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>2,'uid'=>$uid))->find();
    
21.                         if($hours > '17'){
    
22.                             $num=mt_rand(50,55);//优惠券金额
    
23.                             $id=2;
    
24.                         }
    . Q2 A$ @/ j0 d
25.                     }
    . f# m' s6 h9 W$ y4 K! V4 `- @
26.                     if(!$id){
    * B$ C. D6 o% N3 c9 Z% ]
27.                         $data['msg']='时间还没到，晚点再来吧。';
    ' F" C5 m  g0 G. s6 I
28.                     }else{
    
29.                         if($is_lingqu){
    
30.                             $data['msg']='你已经领取过了，留点给别人吧！';
    
31.                         }else{
    
32.                             //锁表
    7 F* E" t" O+ @% g- k. S; n1 z
33.                             M()->execute('LOCK TABLE active_num WRITE,active_log WRITE');
    / Q6 u0 i( w( A8 W* C5 `- k9 K% X! x
34.                             $active=M('active_num')->where(array('id'=>$id))->find();
    
35.                             if($active > 0){
    
36.                                 //开启事务
    # u+ H7 V: ]4 J
37.                                 M()->execute('start transaction');
    6 Y; a0 [- t2 I7 A
38.                                 $save=M('active_num')->save(array('id'=>$id,'num'=>$active['num']-1));
    
39.                                 $add=M('active_log')->add(array('uid'=>$uid,'money'=>$num,'num_id'=>$id,'addtime'=>time()));
    / X' K, T+ Z- e# Q" c
40.                                 $members_preferential    =    M('members_preferential');
    ( X& ?- s9 P6 V  I
41.                                 //对应投资金额，
    
42.                                 $key=array_search($num,array_reverse(C('PREFERENTIAL_JL'),true));
    
43.                                 $PREFERENTIAL_ENDDAY=C('PREFERENTIAL_ENDDAY');
    
44.                                 $endtime=strtotime("+{$PREFERENTIAL_ENDDAY}day");//过期时间
    ; H4 T( J. v4 B
45.                                 $add2=$members_preferential->add(array('uid'=>$uid,'type'=>$key,'endtime'=>$endtime));//添加优惠券
    . `% u: a- v* z4 T; X- U( \
46.                                 if($save && $add && $add2){
    3 b1 ]' a/ k) `1 C0 ]
47.                                     //事务提交
    
48.                                     M()->execute('commit');
    / S+ ]/ @3 c: B
49.                                     $data['msg']='恭喜你领取了'.$num.'元优惠券';
    3 T: \* p# i9 a' ^  _- d) ~
50.                                 }else{
    ; P) k9 A# C* }; R7 P2 Y# F' H+ j
51.                                     //回滚
    3 _& [. W3 y) A+ w( f% b
52.                                     M()->execute('rollback');
    8 v! r9 ~7 p# j$ [; b. u
53.                                     $data['msg']='未知错误!';
    * J9 \4 k) \% q. M5 C( Y
54.                                 }
    
55.                             }else{
    8 ?0 a7 d5 T& m2 x, f
56.                                 $data['msg']='红包已领完，你来晚了!';
    
57.                             }
    
58.                             M()->execute('UNLOCK TABLES');
      T. b: e8 x; n2 H4 A1 @
59.                         }
    
60.                     }
    , L2 f* l; R! ~* _1 A2 c
61.                 }else{
    
62.                     $data['msg']='非法操作!';
    
63.                 }
    1 n4 B' ?$ V3 s
64.             }else{
    5 Q" e" U8 f2 ?! M7 i6 Y. l. V
65.                 $data['msg']='还没有到活动时间，请晚点再来哟！!';
    , v' e* c7 H9 T6 w
66.             }
    8 s  Q  F# t1 b  K* `1 }7 w/ r
67.         }
    0 k5 I3 Z7 ], s* r& O  a$ K2 B/ M
68.         exit(json_encode($data));
    " k. x! H( N6 J9 f5 `
69.     }

复制代码

8 g5 f: h  h8 @$ Q4 o