찾다
백엔드 개발PHP 튜토리얼PHP 동시성 시나리오를 위한 3가지 솔루션

PHP 동시성 시나리오를 위한 3가지 솔루션

깜박 세일, 급박 세일과 같은 동시 시나리오에서는 과잉 판매가 발생할 수 있습니다. 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 테스트 사용

$ 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/

마지막으로 세 가지 처리 방식의 테스트 결과 비교가 제공됩니다

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

파일 독점 잠금( Non-Blocking 모드):

......
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 트랜잭션 모드가 파일 단독 잠금 모드보다 좋고, 파일 단독 잠금 모드에서는 Non-Blocking 모드가 블로킹 모드보다 좋습니다.

추천 튜토리얼: "PHP 튜토리얼"

위 내용은 PHP 동시성 시나리오를 위한 3가지 솔루션의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명
이 기사는 learnku에서 복제됩니다. 침해가 있는 경우 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怎么除以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怎么替换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 20, 2022 pm 08:12 PM

php判断有没有小数点的方法:1、使用“strpos(数字字符串,'.')”语法,如果返回小数点在字符串中第一次出现的位置,则有小数点;2、使用“strrpos(数字字符串,'.')”语句,如果返回小数点在字符串中最后一次出现的位置,则有。

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

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

php怎么设置implode没有分隔符php怎么设置implode没有分隔符Apr 18, 2022 pm 05:39 PM

在PHP中,可以利用implode()函数的第一个参数来设置没有分隔符,该函数的第一个参数用于规定数组元素之间放置的内容,默认是空字符串,也可将第一个参数设置为空,语法为“implode(数组)”或者“implode("",数组)”。

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 Hentai를 무료로 생성하십시오.

뜨거운 도구

SublimeText3 Mac 버전

SublimeText3 Mac 버전

신 수준의 코드 편집 소프트웨어(SublimeText3)

DVWA

DVWA

DVWA(Damn Vulnerable Web App)는 매우 취약한 PHP/MySQL 웹 애플리케이션입니다. 주요 목표는 보안 전문가가 법적 환경에서 자신의 기술과 도구를 테스트하고, 웹 개발자가 웹 응용 프로그램 보안 프로세스를 더 잘 이해할 수 있도록 돕고, 교사/학생이 교실 환경 웹 응용 프로그램에서 가르치고 배울 수 있도록 돕는 것입니다. 보안. DVWA의 목표는 다양한 난이도의 간단하고 간단한 인터페이스를 통해 가장 일반적인 웹 취약점 중 일부를 연습하는 것입니다. 이 소프트웨어는

SecList

SecList

SecLists는 최고의 보안 테스터의 동반자입니다. 보안 평가 시 자주 사용되는 다양한 유형의 목록을 한 곳에 모아 놓은 것입니다. SecLists는 보안 테스터에게 필요할 수 있는 모든 목록을 편리하게 제공하여 보안 테스트를 더욱 효율적이고 생산적으로 만드는 데 도움이 됩니다. 목록 유형에는 사용자 이름, 비밀번호, URL, 퍼징 페이로드, 민감한 데이터 패턴, 웹 셸 등이 포함됩니다. 테스터는 이 저장소를 새로운 테스트 시스템으로 간단히 가져올 수 있으며 필요한 모든 유형의 목록에 액세스할 수 있습니다.

Atom Editor Mac 버전 다운로드

Atom Editor Mac 버전 다운로드

가장 인기 있는 오픈 소스 편집기

ZendStudio 13.5.1 맥

ZendStudio 13.5.1 맥

강력한 PHP 통합 개발 환경