検索
ホームページバックエンド開発PHPチュートリアル複数の PHP 同時実行シナリオに対するソリューションを共有する

複数の PHP 同時実行シナリオに対するソリューションを共有する

フラッシュ セールやラッシュ セールなどの同時実行シナリオでは、過剰販売が発生する可能性があります。PHP 言語にはネイティブの同時実行ソリューションがないため、それを実現するには他の方法が必要です。同時実行制御。

リストされている一般的な解決策は次のとおりです:

キューを使用し、キューを処理する追加のプロセスを設定し、すべての同時リクエストをキューに入れます。追加のプロセスによって逐次的に処理されるため、同時実行の問題は存在しませんが、追加のプロセス サポートと重大な処理遅延が必要になります。この記事では、この方法については最初に説明しません。

データベースのトランザクション特性を使用してアトミック更新を実行します。この方法は、データベースのトランザクション特性に依存する必要があります。

ファイル排他ロックを使用すると、注文リクエストを処理するときに flock を使用してファイルをロックできます。ロックを正常に取得した人だけが注文を処理できます。

1. Redis トランザクション機能の活用

Redis トランザクションはアトミックな操作であり、注文処理中に他の同時プロセスによってデータが変更されないようにすることができます。

サンプルコード:

<?php
$http = new swoole_http_server("0.0.0.0", 9509);   // 监听 9509
$http->set(array(
 &#39;reactor_num&#39; => 2,  //reactor thread num
 &#39;worker_num&#39; => 4    //worker process num
));
$http->on(&#39;request&#39;, function (swoole_http_request $request, swoole_http_response $response) {
 $uniqid = uniqid(&#39;uid-&#39;, TRUE);    // 模拟唯一用户ID
 $redis = new Redis();
 $redis->connect(&#39;127.0.0.1&#39;, 6379);    // 连接 redis
 $redis->watch(&#39;rest_count&#39;);  // 监测 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(&#39;uniqids&#39;, $value);
 $redis->decr(&#39;rest_count&#39;);
 $replies = $redis->exec();  // 执行以上 redis 事务
 // 如果 rest_count 的值被其它的并发进程更改了,以上事务将回滚
 if (!$replies) {
 echo "订单 {$value} 回滚" . PHP_EOL;
 }
 }
 $redis->unwatch();
});
$http->start();

ab testを使用

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

2.ファイル排他ロック(ブロッキングモード)を使用

# #ブロッキング モードでは、他のプロセスがロックを占有しているときにプロセスがファイルの排他ロックを取得すると、プロセスはハングアップし、他のプロセスがロックを解放し、ロック自体を取得するまで待機してから続行します。

サンプルコード:

<?php
$http = new swoole_http_server("0.0.0.0", 9510);
$http->set(array(
 &#39;reactor_num&#39; => 2,  //reactor thread num
 &#39;worker_num&#39; => 4    //worker process num
));
$http->on(&#39;request&#39;, function (swoole_http_request $request, swoole_http_response $response) {
 $uniqid = uniqid(&#39;uid-&#39;, TRUE);
 $redis = new Redis();
 $redis->connect(&#39;127.0.0.1&#39;, 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(&#39;uniqids&#39;, $value);
 $redis->decr(&#39;rest_count&#39;);
 }
 // 订单处理完成后,再释放锁
 flock($fp, LOCK_UN);
 }
 fclose($fp);
});
$http->start();

ab testを使用

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

3.ファイル排他ロック(ノンブロッキングモード)を使用

非ブロッキング モードでは、他のプロセスがロックを占有しているときにプロセスがファイルの排他ロックを取得した場合、プロセスはロックの取得が失敗したと即座に判断し、実行を続行します。 \

サンプルコード:

<?php
$http = new swoole_http_server("0.0.0.0", 9511);
$http->set(array(
 &#39;reactor_num&#39; => 2,  //reactor thread num
 &#39;worker_num&#39; => 4    //worker process num
));
$http->on(&#39;request&#39;, function (swoole_http_request $request, swoole_http_response $response) {
 $uniqid = uniqid(&#39;uid-&#39;, TRUE);
 $redis = new Redis();
 $redis->connect(&#39;127.0.0.1&#39;, 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(&#39;uniqids&#39;, $value);
 $redis->decr(&#39;rest_count&#39;);
 }
 // 订单处理完成后,再释放锁
 flock($fp,LOCK_UN);
 } else {
 // 如果获取锁失败,马上进入这里执行
 echo "{$uniqid} - 系统繁忙,请稍后再试".PHP_EOL;
 }
 fclose($fp);
});
$http->start();

ab testを使用

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

最後に、3つの処理方法のテスト結果の比較を示します

redis トランザクション モード:

......
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
......

ファイル排他ロック (ブロッキング モード):

......
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
......

ファイル排他ロック (ノンブロッキング モード):

......
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
......

テスト結果を比較した結果, redis トランザクション モード ファイル排他ロック モードよりも優れており、ファイル排他ロック モードでは、ブロッキング モードよりもノンブロッキング モードの方が優れています。

関連チュートリアルの推奨事項: 「

PHP チュートリアル

以上が複数の PHP 同時実行シナリオに対するソリューションを共有するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明
この記事は博客园で複製されています。侵害がある場合は、admin@php.cn までご連絡ください。
php怎么把负数转为正整数php怎么把负数转为正整数Apr 19, 2022 pm 08:59 PM

php把负数转为正整数的方法:1、使用abs()函数将负数转为正数,使用intval()函数对正数取整,转为正整数,语法“intval(abs($number))”;2、利用“~”位运算符将负数取反加一,语法“~$number + 1”。

php怎么实现几秒后执行一个函数php怎么实现几秒后执行一个函数Apr 24, 2022 pm 01:12 PM

实现方法:1、使用“sleep(延迟秒数)”语句,可延迟执行函数若干秒;2、使用“time_nanosleep(延迟秒数,延迟纳秒数)”语句,可延迟执行函数若干秒和纳秒;3、使用“time_sleep_until(time()+7)”语句。

php字符串有没有下标php字符串有没有下标Apr 24, 2022 am 11:49 AM

php字符串有下标。在PHP中,下标不仅可以应用于数组和对象,还可应用于字符串,利用字符串的下标和中括号“[]”可以访问指定索引位置的字符,并对该字符进行读写,语法“字符串名[下标值]”;字符串的下标值(索引值)只能是整数类型,起始值为0。

php怎么除以100保留两位小数php怎么除以100保留两位小数Apr 22, 2022 pm 06:23 PM

php除以100保留两位小数的方法:1、利用“/”运算符进行除法运算,语法“数值 / 100”;2、使用“number_format(除法结果, 2)”或“sprintf("%.2f",除法结果)”语句进行四舍五入的处理值,并保留两位小数。

php怎么根据年月日判断是一年的第几天php怎么根据年月日判断是一年的第几天Apr 22, 2022 pm 05:02 PM

判断方法:1、使用“strtotime("年-月-日")”语句将给定的年月日转换为时间戳格式;2、用“date("z",时间戳)+1”语句计算指定时间戳是一年的第几天。date()返回的天数是从0开始计算的,因此真实天数需要在此基础上加1。

php怎么读取字符串后几个字符php怎么读取字符串后几个字符Apr 22, 2022 pm 08:31 PM

在php中,可以使用substr()函数来读取字符串后几个字符,只需要将该函数的第二个参数设置为负值,第三个参数省略即可;语法为“substr(字符串,-n)”,表示读取从字符串结尾处向前数第n个字符开始,直到字符串结尾的全部字符。

php怎么替换nbsp空格符php怎么替换nbsp空格符Apr 24, 2022 pm 02:55 PM

方法:1、用“str_replace("&nbsp;","其他字符",$str)”语句,可将nbsp符替换为其他字符;2、用“preg_replace("/(\s|\&nbsp\;||\xc2\xa0)/","其他字符",$str)”语句。

php怎么查找字符串是第几位php怎么查找字符串是第几位Apr 22, 2022 pm 06:48 PM

查找方法:1、用strpos(),语法“strpos("字符串值","查找子串")+1”;2、用stripos(),语法“strpos("字符串值","查找子串")+1”。因为字符串是从0开始计数的,因此两个函数获取的位置需要进行加1处理。

See all articles

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

AI Hentai Generator

AI Hentai Generator

AIヘンタイを無料で生成します。

ホットツール

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

強力な PHP 統合開発環境

WebStorm Mac版

WebStorm Mac版

便利なJavaScript開発ツール

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

mPDF

mPDF

mPDF は、UTF-8 でエンコードされた HTML から PDF ファイルを生成できる PHP ライブラリです。オリジナルの作者である Ian Back は、Web サイトから「オンザフライ」で PDF ファイルを出力し、さまざまな言語を処理するために mPDF を作成しました。 HTML2FPDF などのオリジナルのスクリプトよりも遅く、Unicode フォントを使用すると生成されるファイルが大きくなりますが、CSS スタイルなどをサポートし、多くの機能強化が施されています。 RTL (アラビア語とヘブライ語) や CJK (中国語、日本語、韓国語) を含むほぼすべての言語をサポートします。ネストされたブロックレベル要素 (P、DIV など) をサポートします。

MinGW - Minimalist GNU for Windows

MinGW - Minimalist GNU for Windows

このプロジェクトは osdn.net/projects/mingw に移行中です。引き続きそこでフォローしていただけます。 MinGW: GNU Compiler Collection (GCC) のネイティブ Windows ポートであり、ネイティブ Windows アプリケーションを構築するための自由に配布可能なインポート ライブラリとヘッダー ファイルであり、C99 機能をサポートする MSVC ランタイムの拡張機能が含まれています。すべての MinGW ソフトウェアは 64 ビット Windows プラットフォームで実行できます。