相思资源网

PHP并发场景的三种解决方案代码实例
站长资源 2024/11/16 佚名
54 1538
相思资源网 Design By www.200059.com

在秒杀，抢购等并发场景下，可能会出现超卖的现象，在 PHP 语言中并没有原生提供并发的解决方案，因此就需要借助其他方式来实现并发控制，其实方案有很多种，今天只是举个栗子抛砖引玉，有其他更好的方案你可以自己去玩一玩就好了。

列出常见的3个解决方案有：

使用队列，额外起一个进程处理队列，并发请求都放到队列中，由额外进程串行处理，并发问题就不存在了，但是要额外进程支持以及处理延迟严重，本文不先不讨论这种方法。

利用数据库事务特征，做原子更新，此方法需要依赖数据库的事务特性。

借助文件排他锁，在处理下单请求的时候，用 flock 锁定一个文件，成功拿到锁的才能处理订单。

一、利用 Redis 事务特征

redis 事务是原子操作，可以保证订单处理的过程中数据没有被其它并发的进程修改。

示例代码：

<"0.0.0.0", 9509); // 监听 9509
$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); // 模拟唯一用户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();

使用 ab 测试

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

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

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

示例代码：

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

使用 ab 测试

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

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

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

示例代码：

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

使用 ab 测试

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

最后给出三种处理方式的测试结果比较

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高并发
相思资源网 Design By www.200059.com
广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
相思资源网 Design By www.200059.com

评论“PHP并发场景的三种解决方案代码实例”

暂无PHP并发场景的三种解决方案代码实例的评论...
www.200059.com 相思资源网
139,976影音资源
144,792福利资源
21,817软件资源
631,128技术资源
一句话新闻
苹果官宣WWDC 2024！预计会有大批AI功能 - 2024/11/16

3月27日消息，苹果宣布2024年全球开发者大会（WWDC）将于6月10日至6月14日举行，巧合的是，这次大会与端午假期重合。

苹果官方表示：

在线参加 Apple 每年规模最大的开发者盛会。亲眼见证 Apple 最新平台、技术和工具的发布。了解如何创建和改进你的 App 和游戏。与 Apple 设计师和工程师互动交流，与全球开发者社区建立联系。以上活动均免费在线举行。

探索各种新的工具、框架和功能，助力你打造出理想的 App 和游戏。通过视频讲座学习新技能，与 Apple 专家进行一对一会面，以推进你的项目，完善你的构思。

Swift Student Challenge 旨在支持和鼓舞下一代开发者、创作者和企业家。太平洋时间 3 月 28 日，我们将公布今年的获奖者名单。获奖者将有资格参加在 Apple Park 举办的特别活动。我们还会选出 50 名杰出获胜者，他们将受邀前往库比提诺，获得为期三天的非凡体验，包括参加 Apple Park 的特别活动。

RTX 5090要首发 性能要翻倍！三星展示GDDR7显存

三星在GTC上展示了专为下一代游戏GPU设计的GDDR7内存。

首次推出的GDDR7内存模块密度为16GB，每个模块容量为2GB。其速度预设为32 Gbps（PAM3），但也可以降至28 Gbps，以提高产量和初始阶段的整体性能和成本效益。

据三星表示，GDDR7内存的能效将提高20%，同时工作电压仅为1.1V，低于标准的1.2V。通过采用更新的封装材料和优化的电路设计，使得在高速运行时的发热量降低，GDDR7的热阻比GDDR6降低了70%。

友情链接

杰晶网络 DDR爱好者之家 桃源资源网 杰网资源 富贵资源网 南强小屋 铁雪资源网 幽灵资源网 万梅资源网 狼山资源网 白云岛资源网 昆仑资源网 相思资源网 明霞山资源网 内蒙古资源网 黑松山资源网 茶园资源网 饿虎岗资源网 大旗谷资源网 常春岛资源网 岱庙资源网 兴国资源网 快活林资源网 蝙蝠岛资源网 帝王谷资源网 白云城资源网 伏龙阁资源网 清风细雨楼 天枫庄资源网 圆月山庄资源网 无争山庄资源网 神水资源网 移花宫资源网 神剑山庄资源网 无为清净楼资源网 金钱帮资源网 丐帮资源网 华山资源网 极乐门资源网 小李飞刀资源网 凤求凰客栈 风云阁资源网 金狮镖局 鸳鸯亭资源网 千金楼资源网 更多链接
相思资源网 Design By www.200059.com