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

复制代码

' C" N- \' @( K  J+ [* g

Mysql中的锁语法：
LOCK TABLE 表名1 READ|WRITE, 表名2 READ|WRITE .................. 【锁表】
3 z3 b" J* Y1 a9 k$ P) b( S3 S  c/ L5 }UNLOCK TABLES  【释放表】

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

PHP中的文件锁 ：
8 u5 {7 W6 B9 G# p文件锁的文件与表有什么关系？：一点关系也没有，与令牌相似，谁拿到谁操作。所以表根本没锁。
' x7 Q  Z# R; N1 r- W测试时，有个文件就行，叫什么名无所谓

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

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

应用场景：
1. 高并发下单时，减库存量时要加锁
2. 高并发抢单、抢票时要使用

Mysql锁示例：

1.    /*
   : H  {' B/ r, h8 c! j
2.     模拟秒杀活动-- 商品100件
   
3.     CREATE TABLE ta
   ! u/ Q) F, C& k4 K5 y
4.     (
   ' X/ N' Y- o: d' K# n0 [
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
   5 u& z/ Q  E/ s( ~. g5 _0 a
7.     INSERT INTO ta VALUES(100);
   
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
   
10.    
    % g% \8 I% u# A! |
11.     // 关闭错误报告
    
12.      error_reporting(0);
    0 g0 i. _( R" |( B. q) I* i
13. 
    
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    & w/ y, W2 @& Y& o9 K
15.     $dbuser = 'root';            // mysql用户名
    9 s0 K! w: Z6 N% I
16.     $dbpass = 'root';          // mysql用户名密码
    
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    ! h; i  _9 Z; M5 ~( ~9 b
18.     if(! $conn )
    0 X5 i! n1 @; P$ Z4 x
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    
21.     }
    1 Q- V8 }% K+ n3 b# e
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    8 Q( \% p( |1 Z! u6 F' |/ }5 H
24.     mysqli_select_db( $conn, 'temp' );
    9 m! J3 F: C0 w8 K. b
25. 
    
26.     # mysql 锁
    % J% F5 P) e- G0 H1 N  f& U
27.     mysqli_query($conn , 'LOCK TABLE a WRITE');// 只有一个客户端可以锁定表，其他客户端阻塞在这
    8 A) k& w. M7 w7 Q+ X2 t; n
28.     $rs = mysqli_query($conn , 'SELECT id FROM a');
    
29.     $id = mysqli_result($rs, 0, 0);
    
30.     if($id > 0)
    & N, Q: ~8 i+ D0 U3 \
31.     {
    + i! t% y! y# D+ t/ C
32.         --$id;
    
33.         mysqli_query($conn , 'UPDATE a SET id='.$id);
    
34.     }
    
35. 
    8 \: f+ N$ G- @7 x
36.     # mysql 解锁
    ( m4 ~" j( j: i" q/ ~. f% y
37.     mysqli_query($conn , 'UNLOCK TABLES');
    " K7 Q9 e! r% d' H* D
38.     //查询解锁后的id值
    
39.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    
40.     // while($row = mysqli_fetch_assoc($res))
    
41.     // {
    
42.     //     $id = $row['id'];
    
43.     // }
    # `* m1 |6 `+ Z/ S, \0 g# a6 B
44.     // echo $id;

复制代码

+ k2 k( x0 M. O/ s4 M1 k1 e

PHP文件锁示例：

1. /*
   8 r, y/ s% S2 _* M( a" f/ ?. N
2.     模拟秒杀活动-- 商品100件
   ) P. X- E; x. `
3.     CREATE TABLE ta
   
4.     (
   ' A: @& @! k- R+ W5 d/ M
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
   
7.     INSERT INTO ta VALUES(100);
   ! b8 d# T3 ]* e3 p/ j2 z6 b6 V
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
     A: W# G* A' A" H8 Y1 R9 G
10.    
    " u9 [. k% e6 |2 \- }& ]. ^% k
11.     // 关闭错误报告
    7 V  A& j% C  `# s( S
12.      error_reporting(0);
    
13. 
    
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    " g& y' R  m6 ]* X4 y
15.     $dbuser = 'root';            // mysql用户名
    ! Y0 s" _/ s2 y: F) _  ]6 d+ z) u
16.     $dbpass = 'root';          // mysql用户名密码
    
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    6 g2 B1 g" A0 e
18.     if(! $conn )
    % ~' C# `" \8 k* f1 D, g" B
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    2 n0 J( M; h7 U3 e) R8 p! A
21.     }
    % o: m- }3 H/ K3 J/ Z
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
    
25. 
    ; {8 ~- s; Q: A, M' r
26.     # php中的文件锁
    
27.     $fp = fopen('./a.lock', 'r'); // php的文件锁和表没关系，随便一个文件即可
    * Y. }5 a  b# L' G! Z
28.     flock($fp, LOCK_EX);// 排他锁
    
29. 
    $ V: ]% z  g/ i0 k
30.     $retval = mysqli_query($conn ,'SELECT id FROM ta');
    ' i( k+ o* t3 V3 j# `! V# S
31.     while($row = mysqli_fetch_assoc($retval))
    
32.     {
    7 g, I  Y4 N" {1 K* w1 @* u
33.         $id =  $row['id'];
    
34.     }
    ) |1 r+ ^$ y4 h+ Q
35.    
    
36.     if($id > 0)
    : W! h( M4 i' ^1 k! h# x7 ]6 _
37.     {
    
38.         --$id;
    
39.         mysqli_query($conn ,'UPDATE ta SET id='.$id);
    3 j) m! D1 I/ D% `; F( x1 l6 h
40.     }
    * q$ W3 q' t* x: _1 z
41.     # php的文件锁，释放锁
    
42.     flock($fp, LOCK_UN);
    " o  f0 [' R% H' k: r
43.     fclose($fp);
    
44. 
    
45.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    
46.     // while($row = mysqli_fetch_assoc($res))
    
47.     // {
    
48.     //     $id = $row['id'];
    6 X+ l( @7 @4 C0 e2 }+ j) c
49.     // }
    4 ^9 S( @. Y0 m) W
50.     // echo $id;

复制代码

0 T  p. P, a2 \( ^4 \

抢券活动实例：

1. public function envelopeSnatching(){
   
2.         $lingqu = $_POST['type'];
   & i+ ~6 r) p- h/ o& M6 X6 j) ~
3.         $uid=session('u_id');//用户id
   
4.         if(!$uid){
   ( {4 O: q! t7 g6 a! z' G# B( s) l& K
5.             $data['msg']='您没登录，请先登录!';
   
6.         }else if(date('Y-m-d') != '2017-12-12'){
   ( R2 [) u1 U+ K8 q! i
7.             $data['msg']='不在活动时间内!';
   7 v' \1 ^# L5 e! D6 \7 z
8.         }else{
   
9.             $hours=date('H');//当前小时数
   1 W) ~& f- f& D5 i; ~
10.             if($hours > '09' || $hours > '17'){
    7 P6 r' k0 _& u- A. U
11. 
    ! `1 f* L1 R) ]
12.                 if($lingqu == 1 || $lingqu ==2){//点击10点的
    ' M9 }6 K2 n1 @7 z5 L: v* t( ?
13.                     if($lingqu == 1){
    
14.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>1,'uid'=>$uid))->find();//判断是否领取过
    
15.                         if($hours > '09'){
    
16.                             $num=mt_rand(25,28);//优惠券金额
    ) \6 H% Y7 Q7 k7 x8 u
17.                             $id=1;
    
18.                         }
    
19.                     }else if($lingqu == 2){
    
20.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>2,'uid'=>$uid))->find();
    5 x: I+ z- l) M  c& c
21.                         if($hours > '17'){
    
22.                             $num=mt_rand(50,55);//优惠券金额
    ) l5 g: n! z4 U* N
23.                             $id=2;
    , l: \$ Z, H$ u5 O/ A' v% U% H
24.                         }
    
25.                     }
    
26.                     if(!$id){
    * e( d/ C( v0 M8 [& `, ^
27.                         $data['msg']='时间还没到，晚点再来吧。';
    
28.                     }else{
    ! k$ o6 m! A1 n3 E8 o1 o
29.                         if($is_lingqu){
    1 G( F7 Q8 e& G% M) I3 c9 i: N6 x
30.                             $data['msg']='你已经领取过了，留点给别人吧！';
    - R  u% e9 D: ]! _6 x! T4 |2 `
31.                         }else{
    % n+ }$ F: `4 e, A
32.                             //锁表
    1 R0 G0 N. q) X1 r
33.                             M()->execute('LOCK TABLE active_num WRITE,active_log WRITE');
    / z' n$ v# N9 v% `, j6 {
34.                             $active=M('active_num')->where(array('id'=>$id))->find();
    
35.                             if($active > 0){
    
36.                                 //开启事务
    , a4 G6 `* F6 c$ |8 ]) b! F
37.                                 M()->execute('start transaction');
    & n2 H) X* z' l
38.                                 $save=M('active_num')->save(array('id'=>$id,'num'=>$active['num']-1));
    % d/ m2 s0 e9 e1 c7 U/ ?5 ]
39.                                 $add=M('active_log')->add(array('uid'=>$uid,'money'=>$num,'num_id'=>$id,'addtime'=>time()));
    + @7 k& T* R' y2 B
40.                                 $members_preferential    =    M('members_preferential');
      z$ s: Y) H  K: J# i
41.                                 //对应投资金额，
    # R5 U9 R9 p6 w5 r6 i- \
42.                                 $key=array_search($num,array_reverse(C('PREFERENTIAL_JL'),true));
    
43.                                 $PREFERENTIAL_ENDDAY=C('PREFERENTIAL_ENDDAY');
    
44.                                 $endtime=strtotime("+{$PREFERENTIAL_ENDDAY}day");//过期时间
    
45.                                 $add2=$members_preferential->add(array('uid'=>$uid,'type'=>$key,'endtime'=>$endtime));//添加优惠券
    
46.                                 if($save && $add && $add2){
    
47.                                     //事务提交
    ( v- z) s7 J! R& A5 t
48.                                     M()->execute('commit');
    
49.                                     $data['msg']='恭喜你领取了'.$num.'元优惠券';
    " f* M: X/ f+ P4 M1 W4 Z% G! U
50.                                 }else{
    & g% A- d# Q! K, L- M7 o" ?  u; x2 c/ a9 ]
51.                                     //回滚
    
52.                                     M()->execute('rollback');
    $ ~# a* U& l; [. u3 v7 L& ]' j- c
53.                                     $data['msg']='未知错误!';
      a0 }) k+ b9 E- D9 Z0 ~
54.                                 }
    
55.                             }else{
    / q( e0 m3 Y/ {  Q- c8 \5 D
56.                                 $data['msg']='红包已领完，你来晚了!';
    4 p/ s) i  j4 ^2 J9 l- i
57.                             }
    
58.                             M()->execute('UNLOCK TABLES');
    ) }4 ~0 t: {$ u5 R) y( q( \& X
59.                         }
    
60.                     }
    
61.                 }else{
    ' \" x5 p; M9 o7 f( B. \2 L8 b1 ^
62.                     $data['msg']='非法操作!';
    9 {; e" O. u4 Q* ?$ ^# K0 R. I1 f3 `
63.                 }
    
64.             }else{
    
65.                 $data['msg']='还没有到活动时间，请晚点再来哟！!';
    # ^) x3 ^5 K* @% B' s- o/ F# N, U! b
66.             }
    3 {& c) s. v* H  R! B
67.         }
    * R1 Y, j' o, F
68.         exit(json_encode($data));
    $ L6 o* ]+ `- [
69.     }

复制代码