Swoole에서 코루틴을 사용하여 동시성 높은 swoole_smtp_auth 함수를 구현하는 방법

composer require swoole/ide-helper

use SwooleCoroutine;
use SwooleCoroutineSocket;

function swoole_smtp_auth(Socket $sock, string $username, string $password, string $hostname = '');

function swoole_smtp_auth(Socket $sock, string $username, string $password, string $hostname = '')
{
    $cmd = "AUTH LOGIN
";
    $sock->send($cmd);
    $resp = $sock->recv();

    if (strpos($resp, '334') !== 0) {
        throw new Exception("Failed to execute command: $cmd");
    }

    $cmd = base64_encode($username) . "
";
    $sock->send($cmd);
    $resp = $sock->recv();

    if (strpos($resp, '334') !== 0) {
        throw new Exception("Failed to execute command: $cmd");
    }

    $cmd = base64_encode($password) . "
";
    $sock->send($cmd);
    $resp = $sock->recv();

    if (strpos($resp, '235') !== 0) {
        throw new Exception("Authentication failed");
    }

    return true;
}

$hostnames = ['smtp.gmail.com', 'smtp.qq.com', 'smtp.163.com'];
$usernames = ['user1@gmail.com', 'user2@qq.com', 'user3@163.com'];
$passwords = ['password1', 'password2', 'password3'];

$socks = [];
foreach ($hostnames as $host) {
    $sock = new Socket(AF_INET, SOCK_STREAM, 0);

    if (!$sock->connect($host, 587)) {
        throw new Exception("Failed to connect to $host:587");
    }

    swoole_smtp_auth($sock, $username, $password, $host);

    $socks[] = $sock;
}

$coros = [];
for ($i = 0; $i < count($usernames); $i++) {
    $coros[] = Coroutine::create(function () use ($socks, $usernames, $passwords, $i) {
        swoole_smtp_auth($socks[$i % count($socks)], $usernames[$i], $passwords[$i]);
    });
}

Coroutine::wait($coros);