当前位置:首页 > PHP教程 > php高级应用 > 列表

PHP+MySQL高并发加锁事务处理问题解决方法

发布:smiling 来源: PHP粉丝网  添加日期:2021-09-15 10:57:35 浏览: 评论:0 

这篇文章主要介绍了PHP+MySQL高并发加锁事务处理问题解决方法,结合实例形式分析了PHP+MySQL事务处理相关操作技巧与注意事项,需要的朋友可以参考下

本文实例讲述了PHP+MySQL高并发加锁事务处理问题解决方法,分享给大家供大家参考,具体如下:

1、背景:

现在有这样的需求,插入数据时,判断test表有无username为‘mraz'的数据,无则插入,有则提示“已插入”,目的就是想只插入一条username为‘mraz'的记录。

2、一般程序逻辑如下:

  1. $conn = mysqli_connect('127.0.0.1''root''111111'or die(mysqli_error()); 
  2. mysqli_select_db($conn'mraz'); 
  3. $rs = mysqli_query($conn'SELECT count(*) as total FROM test WHERE username = "mraz" '); 
  4. $row = mysqli_fetch_array($rs); 
  5. if($row['total']>0){ 
  6.   exit('exist'); 
  7. mysqli_query($conn"insert into test(username) values ('mraz')"); 
  8. var_dump('error:'.mysqli_errno($conn)); 
  9. $insert_id = mysqli_insert_id($conn); 
  10. echo 'insert_id:'.$insert_id.'<br>'
  11. mysqli_free_result($rs); 
  12. mysqli_close($conn); 

3、一般少量请求的时候,程序逻辑不会有问题

但是一旦高并发请求执行的话,程序并没有按预期执行,会插入多条username为‘mraz'的记录。

4、解决方案:

利用mysql的FOR UPDATE 语句和事务的隔离性,注意的是FOR UPDATE仅适用于InnoDB,且必须在事务(BEGIN/COMMIT)中才能生效。

调整代码后如下:

  1. $conn = mysqli_connect('127.0.0.1''root''111111'or die(mysqli_error()); 
  2. mysqli_select_db($conn'mraz'); 
  3. mysqli_query($conn'BEGIN'); 
  4. $rs = mysqli_query($conn'SELECT count(*) as total FROM test WHERE username = "mraz" FOR UPDATE'); 
  5. $row = mysqli_fetch_array($rs); 
  6. if($row['total']>0){ 
  7.   exit('exist'); 
  8. mysqli_query($conn"insert into test(username) values ('mraz')"); 
  9. var_dump('error:'.mysqli_errno($conn)); 
  10. $insert_id = mysqli_insert_id($conn); 
  11. mysqli_query($conn'COMMIT'); 
  12. echo 'insert_id:'.$insert_id.'<br>'
  13. mysqli_free_result($rs); 
  14. mysqli_close($conn); 

5、再利用php的curl模拟高并发请求该php脚本,查看数据库会只有一条username为‘mraz'的记录,达到程序执行的预期结果~

Tags: PHP高并发 MySQL加锁事务

分享到: