In concurrent scenarios such as flash sales and rush sales, overselling may occur. There is no native concurrency solution in the PHP language, so you need to use other way to achieve concurrency control.

The common solutions listed are:

1. Use a queue, set up an extra process to handle the queue, and put all concurrent requests into the queue, which will be processed serially by the extra process. , the concurrency problem does not exist, but it requires additional process support and serious processing delays. This article will not discuss this method first.
2. Use the transaction characteristics of the database to perform atomic updates. This method needs to rely on the transaction characteristics of the database.
3. With the help of file exclusive lock, when processing an order request, use flock to lock a file. Only those who successfully obtain the lock can process the order.

1. Utilize Redis transaction features

Redis transactions are atomic operations, which can ensure that the data is not modified by other concurrent processes during order processing.

Sample code:

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); // 模拟唯一用户ID $redis = new Redis(); $redis->connect('127.0.0.1', 6379); // 连接 redis $redis->watch('rest_count'); // 监测 rest_count 是否被其它的进程更改 $rest_count = intval($redis->get("rest_count")); // 模拟唯一订单ID if ($rest_count > 0){ $value = "{$rest_count}-{$uniqid}"; // 表示当前订单，被当前用户抢到了 // do something ... 主要是模拟用户抢到单后可能要进行的一些密集运算 $rand = rand(100, 1000000); $sum = 0; for ($i = 0; $i < $rand; $i++) {$sum += $i;} // redis 事务 $redis->multi(); $redis->lPush('uniqids', $value); $redis->decr('rest_count'); $replies = $redis->exec(); // 执行以上 redis 事务 // 如果 rest_count 的值被其它的并发进程更改了，以上事务将回滚 if (!$replies) { echo "订单 {$value} 回滚" . PHP_EOL; } } $redis->unwatch(); }); $http->start();

Use ab test

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

2. Use file exclusive lock (blocking mode)

In blocking mode, if the process is getting When the file is locked exclusively, if other processes are occupying the lock, the process will hang up and wait for other processes to release the lock, and then acquire the lock before continuing.

Sample code:

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

Use ab test

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

3. Use file exclusive lock (non-blocking mode)

In non-blocking mode, if the process When acquiring a file exclusive lock, if other processes are occupying the lock, the process will immediately determine that acquiring the lock failed and continue execution. \

Sample code:

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

Use ab test

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

Finally, the test result comparison of the three processing methods is given

redis transaction method:

...... Concurrency Level: 10 Time taken for tests: 20.005 seconds Complete requests: 17537 Failed requests: 0 Total transferred: 2578380 bytes HTML transferred: 0 bytes Requests per second: 876.62 [#/sec] (mean) Time per request: 11.407 [ms] (mean) Time per request: 1.141 [ms] (mean, across all concurrent requests) Transfer rate: 125.86 [Kbytes/sec] received ......

File exclusive lock (blocking mode):

...... Concurrency Level: 10 Time taken for tests: 20.003 seconds Complete requests: 8205 Failed requests: 0 Total transferred: 1206282 bytes HTML transferred: 0 bytes Requests per second: 410.19 [#/sec] (mean) Time per request: 24.379 [ms] (mean) Time per request: 2.438 [ms] (mean, across all concurrent requests) Transfer rate: 58.89 [Kbytes/sec] received ......

File exclusive lock (non-blocking mode):

...... Concurrency Level: 10 Time taken for tests: 20.002 seconds Complete requests: 8616 Failed requests: 0 Total transferred: 1266846 bytes HTML transferred: 0 bytes Requests per second: 430.77 [#/sec] (mean) Time per request: 23.214 [ms] (mean) Time per request: 2.321 [ms] (mean, across all concurrent requests) Transfer rate: 61.85 [Kbytes/sec] received ......

After comparing the test results, the redis transaction method is better than the file exclusive lock method , and in the file exclusive locking mode, the non-blocking mode is better than the blocking mode.

For more PHP related technical articles, please visit thePHP Tutorialcolumn to learn!

The above is the detailed content of Several solutions to PHP concurrency scenarios. For more information, please follow other related articles on the PHP Chinese website!