PHP 并发场景的 3 种解决方案(3)

当前位置:

首页 > PHP >

PHP 并发场景的 3 种解决方案(3)

使用 ab 测试

$ ab -t 20 -c 10 http://192.168.1.104:9510/

三、利用文件排他锁 (非阻塞模式)

非阻塞模式下，如果进程在获取文件排他锁时，其它进程正在占用锁的话，此进程会马上判断获取锁失败，并且继续往下执行。\

示例代码：

<?php

$http = new swoole_http_server("0.0.0.0", 9511);

$http->set(array(

 'reactor_num' => 2,  //reactor thread num

 'worker_num' => 4    //worker process num

));

$http->on('request', function (swoole_http_request $request, swoole_http_response $response) {

 $uniqid = uniqid('uid-', TRUE);

 $redis = new Redis();

 $redis->connect('127.0.0.1', 6379);

 $fp = fopen("lock.txt", "w+");

 // 非阻塞模式， 如果不希望 flock() 在锁定时堵塞，则给 lock 加上 LOCK_NB

 if(flock($fp,LOCK_EX | LOCK_NB))   //锁定当前指针

 {

 // 成功取得锁后，放心处理订单

 $rest_count = intval($redis->get("rest_count"));

 $value = "{$rest_count}-{$uniqid}";

 if($rest_count > 0){

 // do something ...

 $rand = rand(100, 1000000);

 $sum=0;

 for ($i=0;$i<$rand;$i++){ $sum+=$i; }

 $redis->lPush('uniqids', $value);

 $redis->decr('rest_count');

 }

 // 订单处理完成后，再释放锁

 flock($fp,LOCK_UN);

 } else {

 // 如果获取锁失败，马上进入这里执行

 echo "{$uniqid} - 系统繁忙，请稍后再试".PHP_EOL;

 }

 fclose($fp);

});

$http->start();

栏目列表