Swoole 실무 경험: 동시성 이메일 처리를 위한 코루틴 사용-Swoole-php.cn

Swoole 실무 경험: 동시성 이메일 처리를 위한 코루틴 사용

WBOY

풀어 주다： 2023-06-14 14:01:40

원래의

1100명이 탐색했습니다.

인터넷 기술의 급속한 발전과 애플리케이션 시나리오의 지속적인 확장으로 인해 이메일 서비스는 기업/개인의 일상 업무에서 없어서는 안 될 부분이 되었습니다. 그러나 대규모 이메일 전송에서는 동시성이 높으면 SMTP 서버에 대한 빈번한 연결 또는 재연결, 메시지 대기열 소비 및 기타 작업과 같이 병목 현상이 발생하는 경우가 많으며 이러한 작업에는 많은 시간과 시스템 리소스가 필요하여 전체 이메일 전송에 영향을 미칩니다. . 프로세스 효율성. 그렇다면 최소한의 리소스로 효율적인 이메일 처리를 달성하는 방법은 무엇입니까?

연습을 통해 Swoole에서 동시성 높은 이메일 처리를 위해 코루틴을 사용하는 것이 매우 실현 가능하고 효율적인 방법임을 보여줍니다. 이 기사에서는 Swoole의 코루틴 기능을 사용하여 높은 동시 이메일 처리를 달성하는 방법에 대한 몇 가지 개발 사례를 소개합니다.

1. 코루틴 소개

코루틴은 프로세스와 스레드 간의 절충안으로 볼 수 있는 경량 스레드입니다. 코루틴의 특징은 다음과 같습니다.

저비용 컨텍스트 전환
잠금 메커니즘이 필요하지 않음
리소스의 경량 점유
다중 작업 협업

Swoole의 코루틴 기능에서는 다음 기능을 통해 코루틴을 수행할 수 있습니다. 프로세스 작업 :

SwooleCoroutine은(callable $fn): Swoole 코루틴을 시작합니다.
SwooleCoroutinecreate(callable $fn, bool $coroutine_params): 코루틴을 생성합니다.
SwooleCoroutine::yield(): 현재 코루틴의 실행을 일시 중단하고 CPU 리소스를 해제하지 않습니다.
SwooleCoroutine::resume($coroutine_id): 지정된 코루틴을 재개합니다.

2. Swoole의 코루틴 기능을 사용하여 높은 동시 이메일 처리 달성

SMTP 클라이언트 초기화

Swoole의 코루틴 기능을 사용하여 이메일 전송을 처리하는 것은 매우 간단합니다. PHPMailer 라이브러리를 기반으로 이메일을 보낼 수 있습니다.

먼저 SMTP 클라이언트를 초기화하고 SMTP 서버와 관련된 매개변수를 설정해야 합니다.

try {
   $mail = new PHPMailer;
   $mail->isSMTP();
   $mail->SMTPDebug  = 0;
   $mail->SMTPAuth  = true;
   $mail->SMTPSecure = 'tls';
   $mail->Host   = "smtp.example.com";
   $mail->Port   = "465";
   $mail->CharSet = "utf-8";
   $mail->Username = "user@example.com";
   $mail->Password = "password";
   $mail->setFrom('user@example.com', 'Mailer');
   $mail->addAddress('recipient@example.com', 'Recipient');
   $mail->isHTML(true);
   $mail->Subject = 'Test email';
   $mail->Body    = 'This is the HTML message body <b>in bold!</b>';
   $mail->AltBody = 'This is the body in plain text for non-HTML mail clients';
}
catch (Exception $e) {
   echo "Message could not be sent. Mailer Error: {$mail->ErrorInfo}";
   exit;
}

로그인 후 복사

코루틴을 사용하여 동시성이 높은 이메일 보내기

다음으로 Swoole의 코루틴 기능을 사용하여 여러 이메일을 동시에 보내겠습니다.

$tasks = array();
for ($i = 0; $i < $concurrency; $i++) {
   $tasks[] = SwooleCoroutine::create(function () use ($mail) {
       $result = $mail->send();
       if (!$result) {
           echo "Mailer Error: {$mail->ErrorInfo}
";
       } else {
           echo "Message sent successfully!
";
       }
   });
}
SwooleCoroutine::wait($tasks);

로그인 후 복사

이 예에서는 SwooleCoroutine::create() 함수를 사용하여 여러 코루틴을 만듭니다. 이 코루틴은 여러 이메일을 동시에 보냅니다. 마지막으로 SwooleCoroutine::wait() 함수를 사용하여 모든 코루틴이 실행을 완료할 때까지 기다립니다.

SMTP 서버 상태 유지 관리 구현

SMTP 서버가 많은 수의 연결 요청을 받으면 짧은 시간 내에 대부분의 요청을 거부할 수 있습니다. 이때 SMTP 유지 관리를 완료해야 합니다. 코루틴 처리 중 서버 상태. 예를 들어, SMTP 서버가 요청을 거부하면 이메일을 다시 보내기 전에 일정 시간 동안 지연해야 합니다. 이때 이를 달성하려면 SwooleCoroutinesleep() 함수를 사용해야 합니다.

예를 들어 다음 코드를 사용하여 SMTP 서버 상태를 유지할 수 있습니다.

$max_retry_count = 5;
for ($i = 0; $i < $concurrency; $i++) {
   $tasks[] = SwooleCoroutine::create(function () use ($mail, $max_retry_count) {
       $retry_count = 0;
       $result = false;
       while (!$result && $retry_count++ < $max_retry_count) {
           $result = $mail->send();
           if (!$result) {
               echo "Mailer Error: {$mail->ErrorInfo}
";
               if ($retry_count < $max_retry_count) {
                   $sleep_time = 2 ** ($retry_count - 1);
                   echo "sleep $sleep_time seconds before retrying...
";
                   SwooleCoroutine::sleep($sleep_time);
               }
           } else {
               echo "Message sent successfully!
";
           }
       }
   });
}

로그인 후 복사

이 예제 코드에서는 이메일 전송을 다시 시도하고 실패할 때마다 일정 시간 동안 절전 모드로 전환합니다. 실패 횟수가 늘어날수록 각 수면 시간도 늘어납니다.

요약

Swoole의 코루틴 기능은 동시성 이메일 처리를 위한 보다 편리하고 빠르며 효율적인 방법을 제공합니다. 실제로 Swoole의 코루틴 기능을 사용하여 높은 동시 이메일 처리를 달성하려면 몇 줄의 간단한 코드만 있으면 됩니다. 다른 동시성 애플리케이션을 개발하려는 경우 Swoole의 코루틴 기능 사용을 고려하고 이를 프로젝트에 통합하여 애플리케이션 성능을 향상시킬 수도 있습니다.

위 내용은 Swoole 실무 경험: 동시성 이메일 처리를 위한 코루틴 사용의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!