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中的锁语法：
7 }! r5 g( ~$ ELOCK TABLE 表名1 READ|WRITE, 表名2 READ|WRITE .................. 【锁表】
: ?- [' D# s% r2 Z: e/ pUNLOCK TABLES  【释放表】

Read:读锁|共享锁 ： 所有的客户端只能读这个表不能写这个表
Write:写锁|排它锁： 所有当前锁定客户端可以操作这个表，其他客户端只能阻塞
) y/ P* q" G; }  V& |. D- I注意：在锁表的过程中只能操作被锁定的表，如果要操作其他表，必须把所有要操作的表都锁定起来！

PHP中的文件锁 ：
! D5 O  B. E, K" Z% T* f文件锁的文件与表有什么关系？：一点关系也没有，与令牌相似，谁拿到谁操作。所以表根本没锁。
) h+ w& Z" z7 R* H: u测试时，有个文件就行，叫什么名无所谓

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

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

应用场景：
7 y- X1 J1 m/ b! B6 A/ F" u1. 高并发下单时，减库存量时要加锁
7 Y( R9 c( [/ o. R2. 高并发抢单、抢票时要使用

Mysql锁示例：

1.    /*
   + A7 l+ k9 ]5 U
2.     模拟秒杀活动-- 商品100件
   ' Z7 a4 B! S3 N* h* \
3.     CREATE TABLE ta
   / ~, Y' o  I8 |) Y1 @) ?
4.     (
   
5.         id int comment '模拟100件活动商品的数量'
   
6.     );
   
7.     INSERT INTO ta VALUES(100);
   3 Y5 n4 M% s  U' g
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   # l. ^  N5 S* {. i' b8 Z
9.      */
   
10.    
    
11.     // 关闭错误报告
    , o8 {% W+ X) v2 A- b7 D: u
12.      error_reporting(0);
    
13. 
    3 T- d$ O6 n+ E% l6 q' Y6 y
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    * K  P; f9 j3 A$ e; p
15.     $dbuser = 'root';            // mysql用户名
    
16.     $dbpass = 'root';          // mysql用户名密码
    / Y& H* O  G- E* G' }! u* ^+ f
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    3 K# c! G4 _& E, H6 p3 W) u: K7 ~
18.     if(! $conn )
    
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    2 H. e% t" b# y3 p$ [
21.     }
    ! |9 e. w# H0 J8 _) }) \1 ]
22.     // 设置编码，防止中文乱码
    
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
    
25. 
    $ M" x- J' a% b! W; e
26.     # mysql 锁
    ! M7 _5 L+ w1 g- p, A  S' o
27.     mysqli_query($conn , 'LOCK TABLE a WRITE');// 只有一个客户端可以锁定表，其他客户端阻塞在这
    / V3 T& B/ Z8 C, w
28.     $rs = mysqli_query($conn , 'SELECT id FROM a');
    
29.     $id = mysqli_result($rs, 0, 0);
    
30.     if($id > 0)
    4 D- s6 |% i0 P+ G; l. S5 ^
31.     {
    , z4 ]4 K, }: h# ?8 ?
32.         --$id;
    " @3 M$ x2 b$ y1 ~; D& E9 a
33.         mysqli_query($conn , 'UPDATE a SET id='.$id);
    
34.     }
    , g1 W) W3 D9 S' n- `9 a& G
35. 
    ! R/ \4 r0 k' e. g- S
36.     # mysql 解锁
    / u/ U9 q0 _2 W9 k9 t% E! D
37.     mysqli_query($conn , 'UNLOCK TABLES');
    " h8 c: N- v) U0 q/ |* G
38.     //查询解锁后的id值
    
39.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    
40.     // while($row = mysqli_fetch_assoc($res))
    
41.     // {
    
42.     //     $id = $row['id'];
    4 I- j& v' O$ Z! p
43.     // }
    " O1 B6 r2 M8 f2 \
44.     // echo $id;

复制代码

3 ^, @2 C3 A* _; K1 k' c
3 x6 c7 j9 w. N

PHP文件锁示例：

1. /*
   . i" H, V* p) a# T) C' ]
2.     模拟秒杀活动-- 商品100件
   8 Z# B! J' n5 q9 H8 W/ Q
3.     CREATE TABLE ta
   
4.     (
   3 g& |* Q2 y2 |6 ~% P% ]5 ]
5.         id int comment '模拟100件活动商品的数量'
   $ N6 o3 h+ f9 i# o% p9 }
6.     );
   ! Q2 ^" y0 i; M  D3 z* H. {7 R4 ~
7.     INSERT INTO ta VALUES(100);
   1 o' X5 Q* ?( T# t! v8 j
8.     模仿：以10的并发量访问这个脚本！    使用apache自带的ab.exe软件
   5 N$ l* C7 j$ t8 o' \+ p
9.      */
   : Z* |. m% }, A+ A' W! s- B
10.    
    " ]! j6 C9 n  ?  c* B
11.     // 关闭错误报告
    ; S) Q" Q6 D( T2 U; q1 d7 A" z
12.      error_reporting(0);
    4 h5 e! m: C3 m0 Q
13. 
    
14.      $dbhost = 'localhost:3306';  // mysql服务器主机地址
    
15.     $dbuser = 'root';            // mysql用户名
    
16.     $dbpass = 'root';          // mysql用户名密码
    
17.     $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    * K. b  z: q3 b2 K
18.     if(! $conn )
    
19.     {
    
20.         die('连接失败: ' . mysqli_error($conn));
    * l7 D8 v2 Q  ~6 a. N
21.     }
    - s( j9 r4 E( b- J- ]
22.     // 设置编码，防止中文乱码
    7 H# g5 s. t+ k. P- y7 k
23.     mysqli_query($conn , "set names utf8");
    
24.     mysqli_select_db( $conn, 'temp' );
      a, E) J) V$ ~  R7 _
25. 
    
26.     # php中的文件锁
    % X8 t3 V2 q  |$ L$ m  C
27.     $fp = fopen('./a.lock', 'r'); // php的文件锁和表没关系，随便一个文件即可
    0 r1 w  V# \& W& y7 a, t7 M7 X
28.     flock($fp, LOCK_EX);// 排他锁
    + [9 O% S/ L! {6 `
29. 
    
30.     $retval = mysqli_query($conn ,'SELECT id FROM ta');
    
31.     while($row = mysqli_fetch_assoc($retval))
    
32.     {
    2 s- v( w/ m/ w' t# x
33.         $id =  $row['id'];
    
34.     }
    
35.    
    
36.     if($id > 0)
    " ~$ [7 w3 N9 I
37.     {
    1 {( ~/ I) j1 F  _& H
38.         --$id;
    
39.         mysqli_query($conn ,'UPDATE ta SET id='.$id);
    
40.     }
    % w4 B: v0 q. ]& }) \
41.     # php的文件锁，释放锁
    - d  T) S: ]( I7 x" h! j8 D
42.     flock($fp, LOCK_UN);
    
43.     fclose($fp);
    ! I0 w( q& F6 B' E- T8 \! J
44. 
    1 T8 l1 ]6 Y' f. s
45.     // $res = mysqli_query($conn , 'SELECT id FROM ta');
    
46.     // while($row = mysqli_fetch_assoc($res))
    ( S, M/ W, D9 |% j; }# I
47.     // {
    
48.     //     $id = $row['id'];
      U. v- i; K2 q9 W* D/ N  c, m
49.     // }
    
50.     // echo $id;

复制代码

/ k. B+ r! ]6 R- k

抢券活动实例：

1. public function envelopeSnatching(){
   ! O6 P( s* m% M' a( t
2.         $lingqu = $_POST['type'];
   ! r2 @) x! Y8 C- V
3.         $uid=session('u_id');//用户id
   6 R) I! Y" \& n+ I0 j, e
4.         if(!$uid){
   3 Z: Q( O& I% m" h
5.             $data['msg']='您没登录，请先登录!';
   $ d+ n8 l' c0 x: e
6.         }else if(date('Y-m-d') != '2017-12-12'){
   - g* ^: J& U% m7 D8 K
7.             $data['msg']='不在活动时间内!';
   8 c& Z! y$ J4 w/ q1 K2 C1 ^' Z
8.         }else{
   9 N& J* p, F$ W4 P
9.             $hours=date('H');//当前小时数
   , {( [1 h8 |7 ~6 g7 \
10.             if($hours > '09' || $hours > '17'){
    
11. 
    2 c: H. e9 B- r' \2 _5 i
12.                 if($lingqu == 1 || $lingqu ==2){//点击10点的
    
13.                     if($lingqu == 1){
    . c  y% A( u$ b( B& K" c
14.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>1,'uid'=>$uid))->find();//判断是否领取过
    4 A! `2 x0 A/ [7 P5 s
15.                         if($hours > '09'){
    " h3 e+ x% X7 X
16.                             $num=mt_rand(25,28);//优惠券金额
    
17.                             $id=1;
    * D* |, B2 V! i) R5 P
18.                         }
    6 \4 ?1 [/ m/ T4 x( ]; C
19.                     }else if($lingqu == 2){
    ( l: R) N3 t' e
20.                         $is_lingqu=M('active_log')->field('id')->where(array('num_id'=>2,'uid'=>$uid))->find();
    
21.                         if($hours > '17'){
    2 |1 U5 i* z$ u* ^  Y1 H1 \& o
22.                             $num=mt_rand(50,55);//优惠券金额
    : b0 V7 D: ~# Q$ f; ^$ `+ Z
23.                             $id=2;
    - P& K1 _6 J! x2 B8 h; B
24.                         }
    
25.                     }
    
26.                     if(!$id){
    
27.                         $data['msg']='时间还没到，晚点再来吧。';
    
28.                     }else{
    
29.                         if($is_lingqu){
    . }- P6 W  M, W# o  C1 E
30.                             $data['msg']='你已经领取过了，留点给别人吧！';
    % n2 u4 x$ p+ ?  a$ i
31.                         }else{
    
32.                             //锁表
    / @8 H. R- m, \+ u6 D2 F
33.                             M()->execute('LOCK TABLE active_num WRITE,active_log WRITE');
    2 T1 P' ]$ I4 H3 T3 E
34.                             $active=M('active_num')->where(array('id'=>$id))->find();
    
35.                             if($active > 0){
    
36.                                 //开启事务
    
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()));
    
40.                                 $members_preferential    =    M('members_preferential');
    
41.                                 //对应投资金额，
    
42.                                 $key=array_search($num,array_reverse(C('PREFERENTIAL_JL'),true));
    : G' S& n- [$ }3 H
43.                                 $PREFERENTIAL_ENDDAY=C('PREFERENTIAL_ENDDAY');
    , B! x" d1 U3 b5 f
44.                                 $endtime=strtotime("+{$PREFERENTIAL_ENDDAY}day");//过期时间
    9 S" N7 a3 D* N- a$ v
45.                                 $add2=$members_preferential->add(array('uid'=>$uid,'type'=>$key,'endtime'=>$endtime));//添加优惠券
    
46.                                 if($save && $add && $add2){
    
47.                                     //事务提交
    
48.                                     M()->execute('commit');
    
49.                                     $data['msg']='恭喜你领取了'.$num.'元优惠券';
    
50.                                 }else{
    
51.                                     //回滚
    
52.                                     M()->execute('rollback');
    
53.                                     $data['msg']='未知错误!';
    
54.                                 }
    
55.                             }else{
    : o- @% u/ u9 |" I, G# D7 s
56.                                 $data['msg']='红包已领完，你来晚了!';
    
57.                             }
    
58.                             M()->execute('UNLOCK TABLES');
    
59.                         }
    
60.                     }
    5 S" T0 {! g2 H" w& I) v
61.                 }else{
    
62.                     $data['msg']='非法操作!';
    5 R) i( W4 f* b4 R
63.                 }
    
64.             }else{
    ' P; R+ z$ f7 C/ G4 a) X
65.                 $data['msg']='还没有到活动时间，请晚点再来哟！!';
    
66.             }
    
67.         }
    # v, W$ u- k) q. H  J1 S
68.         exit(json_encode($data));
    1 N  V6 B/ I$ S5 M
69.     }

复制代码

0 Q8 j, V4 M9 }1 V' V: A
8 }- h" u. j: A/ U% u* I: S5 v. Y