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

复制代码

  j8 I: Q, a  `& R: Z( x& C

Mysql中的锁语法：
6 ^( B( ?/ ?" L/ E6 ULOCK TABLE 表名1 READ|WRITE, 表名2 READ|WRITE .................. 【锁表】
UNLOCK TABLES  【释放表】

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

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

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

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

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

Mysql锁示例：

1.    /*
   
2.     模拟秒杀活动-- 商品100件
   
3.     CREATE TABLE ta
   
4.     (
   ' q' S# o: m4 O, u5 a: E) v  i
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
   
7.     INSERT INTO ta VALUES(100);
   
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
   
10.    
    : o7 S) s, ^; N6 b9 B# c# {
11.     // 关闭错误报告
    
12.      error_reporting(0);
    
13. 
    
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    9 b7 B& ~  q) `
15.     $dbuser = 'root';            // mysql用户名
    
16.     $dbpass = 'root';          // mysql用户名密码
    4 z( c5 ?" d" ]" m7 `7 R
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    
18.     if(! $conn )
    4 G$ I7 A& K$ U7 h
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    
21.     }
    
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
    
25. 
    
26.     # mysql 锁
    , q+ C1 h$ c3 m4 |0 Z7 ~
27.     mysqli_query($conn , 'LOCK TABLE a WRITE');// 只有一个客户端可以锁定表，其他客户端阻塞在这
    7 }1 B7 i5 z- d7 A: @
28.     $rs = mysqli_query($conn , 'SELECT id FROM a');
    
29.     $id = mysqli_result($rs, 0, 0);
    7 }- s. M. {  U$ M- k
30.     if($id > 0)
    ! i$ [- h5 o/ F5 S7 D2 o- i. `
31.     {
    # f4 X; r6 J5 s) j- q: X3 U3 @" y
32.         --$id;
    ( |$ @7 t/ w! }
33.         mysqli_query($conn , 'UPDATE a SET id='.$id);
    
34.     }
    " @* c2 i, R* n" @; v
35. 
    
36.     # mysql 解锁
    8 p  g: E' w( H; _5 I5 e
37.     mysqli_query($conn , 'UNLOCK TABLES');
    
38.     //查询解锁后的id值
    % U0 k, i& \( Z. {+ K: j
39.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    " f) O2 S5 T( \0 l  J: o( y4 G
40.     // while($row = mysqli_fetch_assoc($res))
    
41.     // {
    * t+ }; }8 ^+ U7 Q! X8 _+ L3 m
42.     //     $id = $row['id'];
    
43.     // }
    
44.     // echo $id;

复制代码

PHP文件锁示例：

1. /*
   8 C. f' k1 u1 x) S* K& K" ]4 h
2.     模拟秒杀活动-- 商品100件
   ' T; z, f7 w% Z6 _' E2 ]- ]: X. }
3.     CREATE TABLE ta
   
4.     (
   * C& T3 t* G6 Z4 U0 b0 A
5.         id int comment '模拟100件活动商品的数量'
   5 n9 F% F8 Y8 ?
6.     );
   
7.     INSERT INTO ta VALUES(100);
   
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   / L# c  E+ J# @' R
9.      */
   . D/ u! U1 v4 S( p
10.    
    ' y( O1 X6 y  f6 O; z
11.     // 关闭错误报告
    1 `- @) e8 ?( d% r4 h2 j0 r
12.      error_reporting(0);
    
13. 
    9 \( q1 f7 O  m. i% C
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    * v1 T1 M2 j, u4 c
15.     $dbuser = 'root';            // mysql用户名
    
16.     $dbpass = 'root';          // mysql用户名密码
    
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    
18.     if(! $conn )
    
19.     {
    ; p7 g3 |' p# X6 y1 _/ p
20.         die('连接失败: ' . mysqli_error($conn));
    8 Y5 f: j' w# {) g1 |  B
21.     }
    1 D0 _' J& V! {  P7 s
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
    
25. 
    
26.     # php中的文件锁
    
27.     $fp = fopen('./a.lock', 'r'); // php的文件锁和表没关系，随便一个文件即可
      M' w. j. D2 C/ }& |
28.     flock($fp, LOCK_EX);// 排他锁
    % G% ]- ]/ E' Z, Q2 }
29. 
    
30.     $retval = mysqli_query($conn ,'SELECT id FROM ta');
    
31.     while($row = mysqli_fetch_assoc($retval))
    
32.     {
    
33.         $id =  $row['id'];
    
34.     }
    
35.    
    
36.     if($id > 0)
    * \2 e& r0 Q7 y; B" Z
37.     {
    
38.         --$id;
    ; T: |/ a) \  U! Z
39.         mysqli_query($conn ,'UPDATE ta SET id='.$id);
    * I: q# K7 c, w. ~( s
40.     }
    
41.     # php的文件锁，释放锁
    0 t- e' c# G+ @# ~& w# ~" H
42.     flock($fp, LOCK_UN);
    
43.     fclose($fp);
    5 ^: ]" G6 v% j5 i& F
44. 
    
45.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    
46.     // while($row = mysqli_fetch_assoc($res))
    " `" L9 V2 Y* x
47.     // {
    
48.     //     $id = $row['id'];
    
49.     // }
    
50.     // echo $id;

复制代码

0 j2 \; ^7 T& }" |" e$ \9 V1 r3 E

抢券活动实例：

1. public function envelopeSnatching(){
   
2.         $lingqu = $_POST['type'];
   
3.         $uid=session('u_id');//用户id
   + j/ r# {$ }# ~* a( I
4.         if(!$uid){
   2 [: d3 [$ v3 I8 c
5.             $data['msg']='您没登录，请先登录!';
   
6.         }else if(date('Y-m-d') != '2017-12-12'){
   . N1 a* r, T, n* ?% ]9 l( l& @
7.             $data['msg']='不在活动时间内!';
   
8.         }else{
   
9.             $hours=date('H');//当前小时数
   
10.             if($hours > '09' || $hours > '17'){
    
11. 
    - n/ D9 o# E6 J; Y3 G# o
12.                 if($lingqu == 1 || $lingqu ==2){//点击10点的
    ) G4 V- O, y0 W$ P$ z" N# M
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);//优惠券金额
    
17.                             $id=1;
    ! n8 c# ]0 u$ x4 C/ r6 }
18.                         }
    ; z; ]5 a8 _7 A! x; P4 Q
19.                     }else if($lingqu == 2){
    
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);//优惠券金额
    0 l, F) ~% `- v1 ~1 E
23.                             $id=2;
    4 S& W/ h. X3 |$ H9 O* g& G9 y
24.                         }
    
25.                     }
    " a3 ~+ A# D/ \  [. S
26.                     if(!$id){
    9 B3 w. k" [5 J. S
27.                         $data['msg']='时间还没到，晚点再来吧。';
    
28.                     }else{
    ) J8 _( B/ c9 h) D  W6 J
29.                         if($is_lingqu){
    
30.                             $data['msg']='你已经领取过了，留点给别人吧！';
    , j, u7 r: N! M! x0 k
31.                         }else{
    6 k  |4 d5 \; B5 V0 H
32.                             //锁表
      I4 c/ u$ k- _( m8 f$ b$ l
33.                             M()->execute('LOCK TABLE active_num WRITE,active_log WRITE');
    5 g# E; ~: i$ A6 W/ I" F$ O! U% [
34.                             $active=M('active_num')->where(array('id'=>$id))->find();
    
35.                             if($active > 0){
    % s# P0 ~$ W  p# N  a6 a/ C
36.                                 //开启事务
    : z! }3 z- g/ ]4 \- X) r/ S
37.                                 M()->execute('start transaction');
    
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()));
    ) L. _; }+ r* |: `5 }
40.                                 $members_preferential    =    M('members_preferential');
    ( U! K5 V% T1 q3 y& v- p
41.                                 //对应投资金额，
    
42.                                 $key=array_search($num,array_reverse(C('PREFERENTIAL_JL'),true));
    
43.                                 $PREFERENTIAL_ENDDAY=C('PREFERENTIAL_ENDDAY');
    , t4 L: f/ E6 C: p" U* J
44.                                 $endtime=strtotime("+{$PREFERENTIAL_ENDDAY}day");//过期时间
    
45.                                 $add2=$members_preferential->add(array('uid'=>$uid,'type'=>$key,'endtime'=>$endtime));//添加优惠券
    
46.                                 if($save && $add && $add2){
    * ^. @$ ~# ]5 Q, k
47.                                     //事务提交
    + m/ i+ V& m; {- o: |
48.                                     M()->execute('commit');
    
49.                                     $data['msg']='恭喜你领取了'.$num.'元优惠券';
    
50.                                 }else{
    # }( q6 K" g: I' `& P
51.                                     //回滚
    / V8 e8 [& S. }# }( T
52.                                     M()->execute('rollback');
    
53.                                     $data['msg']='未知错误!';
    
54.                                 }
    7 `+ u" y( _, J( C0 X% r
55.                             }else{
    
56.                                 $data['msg']='红包已领完，你来晚了!';
    ) Y# H% U: A, z6 K! A* ?
57.                             }
    - N  g6 G2 b/ r4 k  ^; Z
58.                             M()->execute('UNLOCK TABLES');
    3 m* ]# V2 J, d6 g
59.                         }
    & A( a5 T' I' I- g, V# f; J7 n# W3 Z
60.                     }
    
61.                 }else{
    0 B! x# U9 s9 [2 C( F2 U, V
62.                     $data['msg']='非法操作!';
    
63.                 }
    
64.             }else{
    0 ?# X8 G7 g9 k! O, l
65.                 $data['msg']='还没有到活动时间，请晚点再来哟！!';
    
66.             }
    
67.         }
    / r9 q6 k9 c! J! ?0 J+ }
68.         exit(json_encode($data));
      F9 M  |- x+ |, [4 R
69.     }

复制代码

4 `; d$ ~$ N% [0 }) ?