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://请求的脚本

复制代码

Mysql中的锁语法：
LOCK TABLE 表名1 READ|WRITE, 表名2 READ|WRITE .................. 【锁表】
UNLOCK TABLES  【释放表】

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

PHP中的文件锁 ：
! h  Q( D# t5 L3 Y- v9 w文件锁的文件与表有什么关系？：一点关系也没有，与令牌相似，谁拿到谁操作。所以表根本没锁。
测试时，有个文件就行，叫什么名无所谓

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

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

应用场景：
8 u0 Z5 y2 P# e& x5 @; P# O1 M1. 高并发下单时，减库存量时要加锁
* @* x+ ?6 E2 n2. 高并发抢单、抢票时要使用

Mysql锁示例：

1.    /*
   8 Q* G2 ^; n1 E9 Y& N+ ?
2.     模拟秒杀活动-- 商品100件
   & b* B& B$ \/ l6 P# J' u
3.     CREATE TABLE ta
   
4.     (
   . s  d* \+ N1 J. t+ b( i
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
     l$ q+ `* z" Q
7.     INSERT INTO ta VALUES(100);
   4 n1 n% C; T; G4 I% l; f2 a2 N
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
   
10.    
    
11.     // 关闭错误报告
    
12.      error_reporting(0);
    ! `$ O0 `- F- O) V/ T& S5 b: E
13. 
    
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    
15.     $dbuser = 'root';            // mysql用户名
    
16.     $dbpass = 'root';          // mysql用户名密码
    
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    
18.     if(! $conn )
    + D: o: C4 d" f5 G2 j* I2 r
19.     {
    5 S" _+ R+ F9 a& g. ^7 i, {" g
20.         die('连接失败: ' . mysqli_error($conn));
    
21.     }
    
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
    
25. 
    
26.     # mysql 锁
    ; r5 p' o) B! A& ^8 Y4 ?' K
27.     mysqli_query($conn , 'LOCK TABLE a WRITE');// 只有一个客户端可以锁定表，其他客户端阻塞在这
    
28.     $rs = mysqli_query($conn , 'SELECT id FROM a');
    
29.     $id = mysqli_result($rs, 0, 0);
    ! {* X. k& f# H% z& _$ P
30.     if($id > 0)
    4 J( v3 k3 E1 P4 F6 D$ v5 q
31.     {
    ; [7 w0 v. W3 p. {6 H) @2 m) ?" E
32.         --$id;
    $ S9 l& }4 ^6 `! U/ [, H6 v
33.         mysqli_query($conn , 'UPDATE a SET id='.$id);
    
34.     }
    
35. 
    
36.     # mysql 解锁
    
37.     mysqli_query($conn , 'UNLOCK TABLES');
    0 x4 O: `* o2 |  K
38.     //查询解锁后的id值
    6 K* X( I3 k0 [9 q% B  S
39.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    . J, f8 t- x& M6 `' p  {
40.     // while($row = mysqli_fetch_assoc($res))
    
41.     // {
    
42.     //     $id = $row['id'];
    
43.     // }
    2 t7 a. W0 j0 I0 Z% q) g
44.     // echo $id;

复制代码

, ]8 b( E0 y+ ~* e  k" \
  x% X- t9 M  h5 I

PHP文件锁示例：

1. /*
   
2.     模拟秒杀活动-- 商品100件
   , Q8 ?/ o0 ^7 i# j
3.     CREATE TABLE ta
   " F- p7 |3 S2 N4 i% O% k( z! _
4.     (
   3 [0 J- ^9 B" G  W7 H
5.         id int comment '模拟100件活动商品的数量'
   . H7 m8 N7 E8 z' M( t. Q6 z" q
6.     );
     w) {$ a! {) s0 R. ^
7.     INSERT INTO ta VALUES(100);
   
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   , w( t0 ~5 v* a5 h
9.      */
   - L- u+ m0 J" b; B7 g9 I% B' |
10.    
    
11.     // 关闭错误报告
    ( F5 m* G0 Y- z" Y; `8 v& F
12.      error_reporting(0);
    
13. 
    ! C& y8 N) B6 N6 I; G( I
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    6 s" w6 `+ N% D
15.     $dbuser = 'root';            // mysql用户名
    9 r0 _' R7 k1 f6 b7 U: f& V5 T
16.     $dbpass = 'root';          // mysql用户名密码
    - t$ A4 F# U) r2 f
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    + V. G) B8 |7 J8 }- X
18.     if(! $conn )
    
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    
21.     }
    2 ^6 t& f; u' t5 b3 W
22.     // 设置编码，防止中文乱码
    8 G/ k% t7 p& [7 Y! r- R$ z
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
    5 r1 `+ d- W: e. o. C# P) c2 j
25. 
    
26.     # php中的文件锁
    
27.     $fp = fopen('./a.lock', 'r'); // php的文件锁和表没关系，随便一个文件即可
    
28.     flock($fp, LOCK_EX);// 排他锁
    7 d1 ~- S5 s5 q# |
29. 
    0 V! e6 f3 E( A, R5 d* s: G  S- U
30.     $retval = mysqli_query($conn ,'SELECT id FROM ta');
    
31.     while($row = mysqli_fetch_assoc($retval))
    
32.     {
    " w4 M8 j7 \' n) O4 L9 q9 r
33.         $id =  $row['id'];
    " Y: P% q' u% g) N0 b
34.     }
    8 C1 R# J" N# n. U/ x- @
35.    
    
36.     if($id > 0)
    
37.     {
    
38.         --$id;
    0 e' t9 D) Y& b1 k! S) n
39.         mysqli_query($conn ,'UPDATE ta SET id='.$id);
    
40.     }
    
41.     # php的文件锁，释放锁
    . I" p( ]) D% n' A- c, b: i
42.     flock($fp, LOCK_UN);
    - W# s, |0 E# x
43.     fclose($fp);
    
44. 
      @1 y* A2 {/ Q( O, ~3 v. v
45.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    4 l. C$ |* w  |0 h& A1 ]
46.     // while($row = mysqli_fetch_assoc($res))
    8 f; X' `  X# n5 x
47.     // {
    6 |  a1 d+ W5 `( G3 v
48.     //     $id = $row['id'];
    0 ?( n. \: q/ c8 ]7 H4 y
49.     // }
    
50.     // echo $id;

复制代码

- K3 D& B: L# J* y' E
7 {+ @6 H5 x& W

抢券活动实例：

1. public function envelopeSnatching(){
   
2.         $lingqu = $_POST['type'];
   ! u  R" p1 R8 i0 L
3.         $uid=session('u_id');//用户id
     B, D4 c; T3 l# L5 v
4.         if(!$uid){
   
5.             $data['msg']='您没登录，请先登录!';
   1 m$ [' s, e/ c3 x' M
6.         }else if(date('Y-m-d') != '2017-12-12'){
   
7.             $data['msg']='不在活动时间内!';
   6 ]% ?2 \8 W$ ~8 Z1 q- U+ y/ B
8.         }else{
   1 _  l- Q- }: ]+ {7 T8 X
9.             $hours=date('H');//当前小时数
   
10.             if($hours > '09' || $hours > '17'){
    # y/ c8 ]1 M6 V4 e* o* n
11. 
    
12.                 if($lingqu == 1 || $lingqu ==2){//点击10点的
    8 S. w3 L: b. k# n3 w- g
13.                     if($lingqu == 1){
    
14.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>1,'uid'=>$uid))->find();//判断是否领取过
    ) o- U1 g7 l' B+ P, r! J
15.                         if($hours > '09'){
    " y/ P( T' w. b4 }% U" }( W
16.                             $num=mt_rand(25,28);//优惠券金额
    
17.                             $id=1;
    ! N1 a+ o4 _6 b/ K' I
18.                         }
    
19.                     }else if($lingqu == 2){
    9 j' Q& i. N$ B
20.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>2,'uid'=>$uid))->find();
    
21.                         if($hours > '17'){
    & c3 o8 S- D% s% q6 J6 f
22.                             $num=mt_rand(50,55);//优惠券金额
    
23.                             $id=2;
    
24.                         }
    " U( G! r0 ?6 d. h+ `$ a
25.                     }
    
26.                     if(!$id){
    
27.                         $data['msg']='时间还没到，晚点再来吧。';
    
28.                     }else{
    : {4 t9 b4 O) C2 b- J& O2 ?
29.                         if($is_lingqu){
    
30.                             $data['msg']='你已经领取过了，留点给别人吧！';
    3 e) J& A0 o# m$ G3 m1 \
31.                         }else{
    
32.                             //锁表
    , K! I9 B7 v# G
33.                             M()->execute('LOCK TABLE active_num WRITE,active_log WRITE');
    
34.                             $active=M('active_num')->where(array('id'=>$id))->find();
    
35.                             if($active > 0){
    
36.                                 //开启事务
    0 p  y3 q. n0 P% e5 E: I" I2 h
37.                                 M()->execute('start transaction');
    ' r. k: Q. r, X" U- o& |9 h
38.                                 $save=M('active_num')->save(array('id'=>$id,'num'=>$active['num']-1));
    ' u: }; ^; w. _) h4 O
39.                                 $add=M('active_log')->add(array('uid'=>$uid,'money'=>$num,'num_id'=>$id,'addtime'=>time()));
    
40.                                 $members_preferential    =    M('members_preferential');
    % B& u7 B7 s8 ~9 K# N" y) g  \4 P! F
41.                                 //对应投资金额，
    
42.                                 $key=array_search($num,array_reverse(C('PREFERENTIAL_JL'),true));
    
43.                                 $PREFERENTIAL_ENDDAY=C('PREFERENTIAL_ENDDAY');
    
44.                                 $endtime=strtotime("+{$PREFERENTIAL_ENDDAY}day");//过期时间
    - k# ~/ m( `) i: U# ?# m. y# |
45.                                 $add2=$members_preferential->add(array('uid'=>$uid,'type'=>$key,'endtime'=>$endtime));//添加优惠券
    1 _9 t" T$ K, q8 E! k' e
46.                                 if($save && $add && $add2){
    2 A& Z! l; A/ F4 U
47.                                     //事务提交
    
48.                                     M()->execute('commit');
    7 U0 o& c1 I- @
49.                                     $data['msg']='恭喜你领取了'.$num.'元优惠券';
    6 g( f5 p0 T, p
50.                                 }else{
    
51.                                     //回滚
    : G3 J3 B5 `6 ~0 g% i
52.                                     M()->execute('rollback');
    - j2 e, d( U, K
53.                                     $data['msg']='未知错误!';
    2 W8 d# G  R, ^! u2 l2 C
54.                                 }
      ~" n6 Q# G8 s9 \3 c
55.                             }else{
    8 ^$ k) Q* l$ @1 u& o2 }* }. x& I5 G
56.                                 $data['msg']='红包已领完，你来晚了!';
    ' f' f9 Z- ^, b" x  H. ?/ U4 Q
57.                             }
    8 i, y" q: K: K7 j! |& D
58.                             M()->execute('UNLOCK TABLES');
    4 P; g/ p( U$ i2 l
59.                         }
    9 L& Q5 z$ s4 b  e: t
60.                     }
    4 U# ?& `6 }, T  ]
61.                 }else{
    
62.                     $data['msg']='非法操作!';
    ( _$ N# K2 e. @# V0 q
63.                 }
    
64.             }else{
    
65.                 $data['msg']='还没有到活动时间，请晚点再来哟！!';
    
66.             }
    
67.         }
    
68.         exit(json_encode($data));
    / i* P1 Z% o4 g0 c/ M
69.     }

复制代码

( L) N& y4 H/ @# ?0 \