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

当前位置:

首页 > PHP >

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

使用 ab 测试

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

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

阻塞模式下，如果进程在获取文件排他锁时，其它进程正在占用锁的话，此进程会挂起等待其它进程释放锁后，并自己获取到锁后，再往下执行。

示例代码：

				
										<?php

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

										$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+");

										 // 阻塞(等待)模式， 要取得独占锁定（写入的程序）

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

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

										 $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);

										 }

										 fclose($fp);

										});

										$http->start();

栏目列表