한국어
한국어
인터넷의 급속한 발전과 함께 일반적으로 사용되는 백엔드 개발 언어인 PHP는 높은 동시성 시나리오에서 많은 요청에 직면해 있습니다. 요청 스케줄링 및 작업 할당을 효율적으로 수행하는 방법이 주요 문제가 되었습니다. 이 기사에서는 PHP 높은 동시성 환경에서 실용적인 방법을 공유하고 해당 코드 예제를 제공합니다.
동시성이 높은 시나리오에서는 프로세스 관리 및 작업 대기열이 일반적인 방법입니다. 프로세스 관리를 통해 동시 프로세스 수를 동적으로 조정하여 시스템 처리 능력을 향상시킬 수 있습니다. 작업 대기열은 작업이 순서대로 실행되도록 규칙에 따라 요청을 배포하는 데 사용됩니다.
// 프로세스 관리 클래스 생성 class ProcessManager {
비공개 $maxProcesses; // 최대 동시 프로세스 수 private $runningProcesses = [];
공개 함수 __construct($maxProcesses) {
$this->maxProcesses = $maxProcesses;
}
//새 프로세스 생성 public function createProcess($task) {
$pid = pcntl_fork();
if ($pid == -1) {
die("포크 실패");
} elseif ($pid) { // 상위 프로세스 $this->runningProcesses[$pid] = $task;
} else { // 하위 프로세스 $task->run();
종료(0); //자식 프로세스 종료}
// 최대 동시 프로세스 수를 초과했는지 확인합니다. if (count($this->runningProcesses) >= $this->maxProcesses) {
$this->waitForProcess();
}
}
// 프로세스가 끝날 때까지 기다립니다. public function waitForProcess() {
동안 (참) {
$pid = pcntl_wait($status);
if ($pid > 0) {
unset($this->runningProcesses[$pid]);
}
if (count($this->runningProcesses) < $this->maxProcesses) {
부서지다;
}
}
}
}
//태스크 클래스 생성 class Task {
비공개 $taskId;
공개 함수 __construct($taskId) {
$this->taskId = $taskId;
}
공개 함수 run() {
//태스크 실행 로직 echo "Task ". $this->taskId . "실행 중\n";
}
}
//프로세스 관리자 인스턴스를 생성하고 최대 동시 프로세스 수를 4로 설정합니다.
$processManager = 새로운 프로세스관리자(4);
// 10개의 작업을 생성하고 이를 프로세스 관리자에 추가합니다 for ($i = 1; $i <= 10; $i++) {
$task = 새 작업($i);
$processManager->createProcess($task);
}
// 모든 프로세스가 끝날 때까지 기다립니다. $processManager->waitForProcess();
위 코드에서 ProcessManager 클래스는 프로세스 생성 및 관리를 담당하고, Task 클래스는 작업 실행 로직을 정의합니다. 메인 프로그램에서 최대 동시 프로세스 수를 설정하고 프로세스 관리자에 작업을 추가한 후 waitForProcess를 통해 모든 작업이 완료될 때까지 기다립니다.
메시지 큐는 요청 분리 및 비동기 처리를 실현하고 시스템 동시성 기능을 향상시킬 수 있는 효과적인 요청 스케줄링 및 작업 할당 방법입니다. PHP에서 일반적으로 사용되는 메시지 대기열 구현에는 Redis, Beanstalkd 등이 포함됩니다.
// Redis 서버에 연결 $redis = new Redis();
$redis->connect('127.0.0.1', 6379);
// 대기열 참여 요청 $task = [
'url' => 'http://example.com/api',
'params' => ['토큰' => 'XXXX'],
// ...
];
$redis->rPush('task_queue', json_encode($task));
// 대기열 제거 요청 while (true) {
$taskJson = $redis->blPop('task_queue', 0)[1]; // 대기열 제거 차단 $task = json_decode($taskJson, true);
//작업 처리 수행//...
}
이 예에서 rPush는 요청 데이터를 대기열에 추가하는 데 사용되고 blPop은 작업이 순서대로 처리되도록 대기열에서 제거를 차단하는 데 사용됩니다. 개발자는 요청을 구문 분석하고 처리 논리에서 해당 작업을 수행할 수 있습니다.
PHP의 높은 동시성 환경에서는 프로세스 관리 및 작업 대기열 또는 메시지 대기열을 통해 효율적인 요청 스케줄링 및 작업 할당을 달성할 수 있습니다. 합리적인 스케줄링 전략은 시스템의 동시 처리 능력을 향상시키고 안정적이고 효율적인 요청 응답을 달성할 수 있습니다. 캐싱 및 로드 밸런싱과 같은 기술을 결합하면 동시성이 높은 환경의 성능을 더욱 최적화할 수 있습니다.
