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

复制代码

) @" t; b( L2 m, A) B/ f

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

Read:读锁|共享锁 ： 所有的客户端只能读这个表不能写这个表
% G: ?: ?6 F% e0 f- A! GWrite:写锁|排它锁： 所有当前锁定客户端可以操作这个表，其他客户端只能阻塞
( `4 E# d* v3 P, l4 J- }! k# p注意：在锁表的过程中只能操作被锁定的表，如果要操作其他表，必须把所有要操作的表都锁定起来！

PHP中的文件锁 ：
文件锁的文件与表有什么关系？：一点关系也没有，与令牌相似，谁拿到谁操作。所以表根本没锁。
' k$ k7 `/ C4 ~0 l2 w测试时，有个文件就行，叫什么名无所谓

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

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

应用场景：
7 @  D! m9 p4 x8 `, V  u1. 高并发下单时，减库存量时要加锁
0 \* ~7 }6 r2 m7 L/ {9 B  K6 z( ^1 ^2. 高并发抢单、抢票时要使用

Mysql锁示例：

1.    /*
   ) N6 n+ ?1 ?2 c% T
2.     模拟秒杀活动-- 商品100件
   
3.     CREATE TABLE ta
   
4.     (
   ; Q& c3 c; Z$ a" Q# F& r8 ^6 C
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
   $ q7 n( ?8 f, ^# D* c% g
7.     INSERT INTO ta VALUES(100);
   
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
   
10.    
    
11.     // 关闭错误报告
    2 v+ ^1 `" O. w9 T
12.      error_reporting(0);
    
13. 
    7 Z- r5 V: G; r3 r! k2 W$ E
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    . Y( d. |, o3 Z' n/ e
15.     $dbuser = 'root';            // mysql用户名
    7 f) y9 X, q% V8 L
16.     $dbpass = 'root';          // mysql用户名密码
    
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    
18.     if(! $conn )
    
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    : |* ]8 J+ R% l/ d( O+ b
21.     }
    - `' H3 j; i1 q' w/ i+ [, X
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    # s; {( `; R6 m" ^7 u# ?
24.     mysqli_select_db( $conn, 'temp' );
    / p% K( C  J) L2 W) z! ]: B
25. 
    ' D/ m7 u- x3 F6 a* p* V3 @/ b, B- g: J
26.     # mysql 锁
      M) m' w6 M! n. F+ u1 ]6 y* R
27.     mysqli_query($conn , 'LOCK TABLE a WRITE');// 只有一个客户端可以锁定表，其他客户端阻塞在这
    
28.     $rs = mysqli_query($conn , 'SELECT id FROM a');
    ! f* E% L( l, [# v
29.     $id = mysqli_result($rs, 0, 0);
    
30.     if($id > 0)
    
31.     {
    3 c; Y9 E( y+ I! z3 O  x9 X% p6 T
32.         --$id;
    4 ?" T$ {5 T' h/ y+ m
33.         mysqli_query($conn , 'UPDATE a SET id='.$id);
    % T4 i; U! x- Z& W- ^! N+ c
34.     }
    
35. 
    9 @( \, w! ~0 k( Z4 [! s! `
36.     # mysql 解锁
    
37.     mysqli_query($conn , 'UNLOCK TABLES');
    
38.     //查询解锁后的id值
    : [, D/ M+ K9 t3 l) }
39.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    + \4 X  [. [5 F3 i
40.     // while($row = mysqli_fetch_assoc($res))
    " o2 \) I8 z6 Z0 Z
41.     // {
    ) c) Y+ B# x) E1 y: W
42.     //     $id = $row['id'];
    
43.     // }
    2 M4 ?7 N9 x: C7 G, T2 X0 q
44.     // echo $id;

复制代码

$ m" ~" h& m4 o

5 r" p9 S# _- r( O2 E) a8 g

PHP文件锁示例：

1. /*
   
2.     模拟秒杀活动-- 商品100件
   $ O" T6 q, B7 N3 D
3.     CREATE TABLE ta
   , j+ q5 G1 O8 z* x8 s
4.     (
   
5.         id int comment '模拟100件活动商品的数量'
   / l5 i% j  \' C  G9 E0 K
6.     );
   
7.     INSERT INTO ta VALUES(100);
   
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
   , I$ v7 _, V: M0 |; @1 s+ F
10.    
    
11.     // 关闭错误报告
    ! u1 H9 ?  g2 [, o5 S- P
12.      error_reporting(0);
    # ?4 X; Z5 p% M7 e
13. 
    ) B% j8 B. K# F. l
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    
15.     $dbuser = 'root';            // mysql用户名
    ; e0 ]/ `  A5 _: `  l0 E* Z; S4 Q
16.     $dbpass = 'root';          // mysql用户名密码
    
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    
18.     if(! $conn )
    ) k7 N' O+ b0 ^. h* k, w
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    
21.     }
    . v  `7 Q( T- p
22.     // 设置编码，防止中文乱码
    5 l1 M  o$ o9 t
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
    ) }/ ?" h% m3 p- Q6 I9 F
25. 
    , T2 r( w* K- E
26.     # php中的文件锁
    
27.     $fp = fopen('./a.lock', 'r'); // php的文件锁和表没关系，随便一个文件即可
    
28.     flock($fp, LOCK_EX);// 排他锁
    ' J6 `( E8 l. ]1 a8 E2 A
29. 
    
30.     $retval = mysqli_query($conn ,'SELECT id FROM ta');
    
31.     while($row = mysqli_fetch_assoc($retval))
    7 ]1 {9 W: P- o
32.     {
    % @9 y& p8 W( ^' P1 K6 t& \; }0 c
33.         $id =  $row['id'];
    
34.     }
    ! Q( \9 X' T- E3 p: o# f
35.    
    3 |  J$ F, ^9 A3 H
36.     if($id > 0)
    
37.     {
    2 q. ^6 o& }( I* ]. J, M
38.         --$id;
    
39.         mysqli_query($conn ,'UPDATE ta SET id='.$id);
    7 B1 S% c7 N8 ~/ `$ M
40.     }
    
41.     # php的文件锁，释放锁
    $ a* d. k4 t5 L; U  n1 v  J8 p
42.     flock($fp, LOCK_UN);
    
43.     fclose($fp);
    
44. 
    
45.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    ( m. d: u2 w* k4 R
46.     // while($row = mysqli_fetch_assoc($res))
    3 E; l' k9 n  f- Z  q7 ~1 x3 v
47.     // {
    ; @  `( D' D8 y5 Z4 N# A
48.     //     $id = $row['id'];
    * u* \8 X2 V6 p, h
49.     // }
    
50.     // echo $id;

复制代码

* q4 [, X& f" Z) {; J9 A3 z
+ C7 {7 V# u/ c* T% \; ^8 r

抢券活动实例：

1. public function envelopeSnatching(){
   ( [( V7 X, |( p2 j
2.         $lingqu = $_POST['type'];
   
3.         $uid=session('u_id');//用户id
   ( ?/ C9 d2 O9 X0 N; |8 B8 R
4.         if(!$uid){
   
5.             $data['msg']='您没登录，请先登录!';
   * r4 T+ j# w. `0 o7 P/ j3 x! `; W
6.         }else if(date('Y-m-d') != '2017-12-12'){
   9 g9 ?# I1 K7 }( H1 Z' G
7.             $data['msg']='不在活动时间内!';
   . d% X+ f7 z) F# a% t8 v+ u! l
8.         }else{
   
9.             $hours=date('H');//当前小时数
   
10.             if($hours > '09' || $hours > '17'){
    & S% z) c2 L8 L! x/ h% |, l
11. 
    . [6 w  m4 o3 A) v4 m' b
12.                 if($lingqu == 1 || $lingqu ==2){//点击10点的
    8 n( J1 m2 s( n( F6 m5 X: b/ M% L& d
13.                     if($lingqu == 1){
    * w5 a, q5 {4 @3 i# A5 f+ O  m& o
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);//优惠券金额
    * _: k# ^# w" @) H. I
17.                             $id=1;
    2 A& L! H6 i, P; X/ [! H. P8 L
18.                         }
    
19.                     }else if($lingqu == 2){
    
20.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>2,'uid'=>$uid))->find();
    5 X& Z+ s. F) O
21.                         if($hours > '17'){
    
22.                             $num=mt_rand(50,55);//优惠券金额
    ) C1 Q9 @/ _2 L" v' ?) o
23.                             $id=2;
    5 D' B9 i0 l$ p; B1 m
24.                         }
    
25.                     }
    
26.                     if(!$id){
    ! [: b( i( }% M( U3 N! R) o
27.                         $data['msg']='时间还没到，晚点再来吧。';
    * w- H- _/ a4 i2 C' r+ e
28.                     }else{
    
29.                         if($is_lingqu){
    
30.                             $data['msg']='你已经领取过了，留点给别人吧！';
    3 m% J9 R* ~0 b! i7 ~; A7 d4 Z$ `
31.                         }else{
    - J3 d# t1 J$ h& P$ X
32.                             //锁表
    & K' \/ s0 Q) @: \1 {, r
33.                             M()->execute('LOCK TABLE active_num WRITE,active_log WRITE');
    
34.                             $active=M('active_num')->where(array('id'=>$id))->find();
    % y/ `. _1 v! P, x1 O+ Y! V/ J9 [9 W
35.                             if($active > 0){
    
36.                                 //开启事务
      d$ J$ K3 N( S. s
37.                                 M()->execute('start transaction');
    : e- b; j' a. G
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()));
    ' J' h+ A. x5 P3 f9 `4 e' N
40.                                 $members_preferential    =    M('members_preferential');
    " r' ^  I+ p9 V
41.                                 //对应投资金额，
    
42.                                 $key=array_search($num,array_reverse(C('PREFERENTIAL_JL'),true));
    
43.                                 $PREFERENTIAL_ENDDAY=C('PREFERENTIAL_ENDDAY');
    
44.                                 $endtime=strtotime("+{$PREFERENTIAL_ENDDAY}day");//过期时间
    : r! `) z; A& [) j) M
45.                                 $add2=$members_preferential->add(array('uid'=>$uid,'type'=>$key,'endtime'=>$endtime));//添加优惠券
    - l% T7 @9 K+ n9 U  _
46.                                 if($save && $add && $add2){
    
47.                                     //事务提交
    9 Q' W& R- c) I0 v
48.                                     M()->execute('commit');
    
49.                                     $data['msg']='恭喜你领取了'.$num.'元优惠券';
    
50.                                 }else{
    
51.                                     //回滚
    1 l: U  }. E8 }# R+ z7 Y
52.                                     M()->execute('rollback');
    
53.                                     $data['msg']='未知错误!';
    5 I$ c& n+ a" |+ t8 i1 S
54.                                 }
    
55.                             }else{
    
56.                                 $data['msg']='红包已领完，你来晚了!';
    * C8 v* N( S1 u  O8 j
57.                             }
    
58.                             M()->execute('UNLOCK TABLES');
    9 o$ h3 r. ]) o- h5 g1 K' T  B
59.                         }
    ! z$ u" |/ R" W4 |  |
60.                     }
    8 @, I9 g" T: E* C
61.                 }else{
    
62.                     $data['msg']='非法操作!';
    : j5 j, N2 L, k
63.                 }
    
64.             }else{
    5 m3 D6 Y$ [0 |% U' x
65.                 $data['msg']='还没有到活动时间，请晚点再来哟！!';
    ( }" s' y- b' ~% Y. ]
66.             }
    
67.         }
    
68.         exit(json_encode($data));
    # S0 v' ^9 h! U. z
69.     }

复制代码