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

复制代码

# g, H, y1 {. z6 @6 K7 p

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

Read:读锁|共享锁 ： 所有的客户端只能读这个表不能写这个表
6 A! |- L- A+ n6 G3 r! j1 fWrite:写锁|排它锁： 所有当前锁定客户端可以操作这个表，其他客户端只能阻塞
, H% t% y8 m; T- H) \9 A5 A注意：在锁表的过程中只能操作被锁定的表，如果要操作其他表，必须把所有要操作的表都锁定起来！

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

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

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

应用场景：
  i2 \$ d: T9 j1. 高并发下单时，减库存量时要加锁
2. 高并发抢单、抢票时要使用

Mysql锁示例：

1.    /*
   
2.     模拟秒杀活动-- 商品100件
   
3.     CREATE TABLE ta
   $ \3 Q6 x$ Z9 Q% p+ {+ \+ i
4.     (
   
5.         id int comment '模拟100件活动商品的数量'
     M4 `4 B$ S$ f- J
6.     );
   1 I3 c2 Y  J5 ^& ?% U; k, N: s
7.     INSERT INTO ta VALUES(100);
   * q* M9 C  z  W+ S0 l( J- o5 f/ T' |
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
   
10.    
    0 O4 k% _$ k( F: ^
11.     // 关闭错误报告
    4 e" I% w+ q5 k8 B
12.      error_reporting(0);
    7 ^2 V1 \3 d; N2 i; a& F
13. 
    
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    . e* H/ w8 p% S0 x! o+ H" y
15.     $dbuser = 'root';            // mysql用户名
    $ N7 i7 g, k9 y2 f
16.     $dbpass = 'root';          // mysql用户名密码
    $ Q( ~0 [+ ?- h: S1 M0 O* A
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    
18.     if(! $conn )
    : R4 S9 l: a: h* b+ p" M
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    
21.     }
    9 n* P& `2 k( F$ i: J
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    % ^; X% q9 @" V
24.     mysqli_select_db( $conn, 'temp' );
    
25. 
    0 V; S; R; M4 N0 j! K* M
26.     # mysql 锁
    5 G; Z( E5 g; b" u4 j
27.     mysqli_query($conn , 'LOCK TABLE a WRITE');// 只有一个客户端可以锁定表，其他客户端阻塞在这
    
28.     $rs = mysqli_query($conn , 'SELECT id FROM a');
    . t% d/ ?8 n8 b6 u1 t  ]
29.     $id = mysqli_result($rs, 0, 0);
    
30.     if($id > 0)
    . R% L6 A3 H6 |
31.     {
    7 g/ Q% v9 s( q7 t3 }& F: V% E: l
32.         --$id;
    
33.         mysqli_query($conn , 'UPDATE a SET id='.$id);
    
34.     }
    
35. 
    / T0 y) L3 o# D
36.     # mysql 解锁
    . O9 }5 v5 B- X& G* A
37.     mysqli_query($conn , 'UNLOCK TABLES');
    + u2 z' B  n4 N( O
38.     //查询解锁后的id值
    
39.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    
40.     // while($row = mysqli_fetch_assoc($res))
    
41.     // {
    ' ?) Y+ b! d" h( m! a
42.     //     $id = $row['id'];
    8 x: V* F' M- c* i2 N8 C" _+ h
43.     // }
    4 u0 w, }8 B( m( O5 z, W( d7 y
44.     // echo $id;

复制代码

* w3 I9 K1 m- ]2 F4 K1 ?

PHP文件锁示例：

1. /*
   
2.     模拟秒杀活动-- 商品100件
   5 i7 G: Q: r, W9 C! |+ Q
3.     CREATE TABLE ta
   
4.     (
   % O% Z& H6 i6 l
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
   0 Y# W4 R7 E/ u
7.     INSERT INTO ta VALUES(100);
   
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   
9.      */
   " G) j: N( N5 t* m: i5 `
10.    
    4 r3 }4 j7 b& Q
11.     // 关闭错误报告
    3 K; y8 o" u0 \! o- f( q
12.      error_reporting(0);
    
13. 
    # M- M( ~3 Q. V# z7 D. ~
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    / r" }" P/ w: n0 n) Q
15.     $dbuser = 'root';            // mysql用户名
      _4 F+ a' K/ d/ Y1 Y1 z
16.     $dbpass = 'root';          // mysql用户名密码
    
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    # f9 i7 J  G4 P# J& l2 p' P2 m8 a
18.     if(! $conn )
    
19.     {
    % G, ~# e+ D5 q
20.         die('连接失败: ' . mysqli_error($conn));
    # |9 `* c: c' v5 v# G0 J* L
21.     }
    
22.     // 设置编码，防止中文乱码
    ) X1 i! P% _5 R8 y) I. U
23.     mysqli_query($conn , "set names utf8");
    9 K- F3 i+ q2 s+ |
24.     mysqli_select_db( $conn, 'temp' );
      R3 _' t( v( A# A9 Y
25. 
    
26.     # php中的文件锁
    , m, R, U% n& z) [- M$ V
27.     $fp = fopen('./a.lock', 'r'); // php的文件锁和表没关系，随便一个文件即可
    % O" L* H1 ]/ G6 ~& o! K
28.     flock($fp, LOCK_EX);// 排他锁
    
29. 
    ; n8 L3 `7 u. s5 e+ ^( M
30.     $retval = mysqli_query($conn ,'SELECT id FROM ta');
    $ g. \# U+ q8 N4 F1 D5 v" i
31.     while($row = mysqli_fetch_assoc($retval))
    
32.     {
    6 g% K$ X: p' o* ^( }
33.         $id =  $row['id'];
    
34.     }
    $ M, o; ^/ Q& B. b! Y7 T
35.    
    
36.     if($id > 0)
    4 b! U2 h2 V/ z* ]' F+ R. n
37.     {
    
38.         --$id;
    # W* y% _* U0 f% C
39.         mysqli_query($conn ,'UPDATE ta SET id='.$id);
    / ~/ [' l4 ]; x3 {
40.     }
    : k# B- K' X, j) ~, |/ j
41.     # php的文件锁，释放锁
    $ i+ C; g3 X1 }( G4 ]% u$ |9 _
42.     flock($fp, LOCK_UN);
    
43.     fclose($fp);
    , U6 {% g8 H5 F0 r
44. 
    " A9 R- u8 x5 C# z/ g' U
45.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    * G5 }7 U+ g7 Y( c! y0 V
46.     // while($row = mysqli_fetch_assoc($res))
    $ Y, J. l6 H: n4 B
47.     // {
    
48.     //     $id = $row['id'];
    + `7 x! D% C3 |7 L# X! D- t* Z. j
49.     // }
    
50.     // echo $id;

复制代码

抢券活动实例：

1. public function envelopeSnatching(){
   
2.         $lingqu = $_POST['type'];
   6 C% m1 s$ \+ \. ]3 f
3.         $uid=session('u_id');//用户id
   - i" Z2 s" ?$ `$ k2 A' x
4.         if(!$uid){
   $ X* [; L9 P4 x. i1 e
5.             $data['msg']='您没登录，请先登录!';
   
6.         }else if(date('Y-m-d') != '2017-12-12'){
   
7.             $data['msg']='不在活动时间内!';
   
8.         }else{
   & ~6 t$ y7 N8 }
9.             $hours=date('H');//当前小时数
   
10.             if($hours > '09' || $hours > '17'){
    
11. 
    
12.                 if($lingqu == 1 || $lingqu ==2){//点击10点的
    
13.                     if($lingqu == 1){
    ' W; _! W7 v8 Z) q& m
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);//优惠券金额
      P! ~) [& X1 e
17.                             $id=1;
    
18.                         }
    
19.                     }else if($lingqu == 2){
    ( p% D( b; |! g& ]- G6 K+ ~* o& f( Z
20.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>2,'uid'=>$uid))->find();
      Q5 O1 K/ A" s2 V- c  Z* H
21.                         if($hours > '17'){
    
22.                             $num=mt_rand(50,55);//优惠券金额
    
23.                             $id=2;
    
24.                         }
    
25.                     }
    
26.                     if(!$id){
    
27.                         $data['msg']='时间还没到，晚点再来吧。';
    $ k+ {( d6 T0 b4 t9 h  B) u
28.                     }else{
    
29.                         if($is_lingqu){
    : p" R$ g$ Y  n5 S2 e
30.                             $data['msg']='你已经领取过了，留点给别人吧！';
    
31.                         }else{
    0 R$ p$ V7 K) G& R, b3 p
32.                             //锁表
    
33.                             M()->execute('LOCK TABLE active_num WRITE,active_log WRITE');
    ; f! g) E! h0 t- @
34.                             $active=M('active_num')->where(array('id'=>$id))->find();
    
35.                             if($active > 0){
    ; f. c  Y/ ~" E" g; W9 o5 j" G
36.                                 //开启事务
    5 B5 M1 T: M$ g4 a4 }
37.                                 M()->execute('start transaction');
    3 W/ }. j0 \* X' x$ H" r
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()));
    
40.                                 $members_preferential    =    M('members_preferential');
    2 }  U6 \- B+ Z$ s6 K9 q9 ?
41.                                 //对应投资金额，
    
42.                                 $key=array_search($num,array_reverse(C('PREFERENTIAL_JL'),true));
    6 O! h4 L* g5 }  }$ w
43.                                 $PREFERENTIAL_ENDDAY=C('PREFERENTIAL_ENDDAY');
    
44.                                 $endtime=strtotime("+{$PREFERENTIAL_ENDDAY}day");//过期时间
    
45.                                 $add2=$members_preferential->add(array('uid'=>$uid,'type'=>$key,'endtime'=>$endtime));//添加优惠券
    ! U5 L" J9 O2 n6 l8 \
46.                                 if($save && $add && $add2){
    
47.                                     //事务提交
    " i" h3 q2 U7 O5 Q( {  C
48.                                     M()->execute('commit');
    ( s; ?: z5 J1 f
49.                                     $data['msg']='恭喜你领取了'.$num.'元优惠券';
    3 C( h# O( k' o* J5 J+ U  E
50.                                 }else{
    * G3 C7 T& ?. G5 ~9 t/ \
51.                                     //回滚
    + j8 i# B# {8 M2 y# c
52.                                     M()->execute('rollback');
    ) d0 E- m! A9 U2 E
53.                                     $data['msg']='未知错误!';
    2 o4 O2 I# T0 G4 G; T
54.                                 }
    ! d2 i: K( _8 a& X# x
55.                             }else{
    $ z. k/ ?, P) C8 P3 {
56.                                 $data['msg']='红包已领完，你来晚了!';
    5 p6 f. d( ?3 x9 r" X* ^/ x
57.                             }
    6 O, t0 c$ j5 E; U+ [  }4 f
58.                             M()->execute('UNLOCK TABLES');
    
59.                         }
    
60.                     }
    7 ~2 K, l  V3 \9 ~) D
61.                 }else{
    3 W/ u+ Y) E; ]( e. S
62.                     $data['msg']='非法操作!';
    
63.                 }
    
64.             }else{
    
65.                 $data['msg']='还没有到活动时间，请晚点再来哟！!';
      X6 ^/ z: Z8 U& H9 w1 T' R
66.             }
    7 `0 d, D$ P9 K6 j6 j( B" E! [
67.         }
    
68.         exit(json_encode($data));
      g( U- D/ T# Q1 T" P
69.     }

复制代码

+ w# U' M9 l7 Z% G