コルーチンを使用して Swoole で同時実行性の高い swoole

コルーチンを使用して Swoole で同時実行性の高い swoole_smtp 関数を実装する方法

王林

リリース： 2023-06-25 22:43:36

オリジナル

1791 人が閲覧しました

インターネットの急速な発展に伴い、高い同時実行性が日常の開発作業で頻繁に遭遇する問題になっています。そのため、アプリケーションの同時実行機能を向上させるために、高性能のソリューションを常に見つけて使用する必要があります。 Swoole は、アプリケーションの同時実行機能を効果的に向上させるコルーチンテクノロジを提供する、優れた高性能ネットワーク通信フレームワークです。この記事では、コルーチンを使用して同時実行性の高い swoole_smtp 関数を Swoole に実装する方法を紹介します。

1. swoole_smtp 関数とは

Swoole では、メール送信に使用できる swoole_smtp というメール送信関数を提供しています。 swoole_smtp 関数は、SMTP プロトコルをカプセル化するために使用され、1 人以上の受信者に電子メールを送信できます。 SMTP プロトコルを手動で処理する必要がなく、電子メールの送信がより便利になります。

2. Swoole のコルーチン

Swoole では、コルーチンは 1 つのスレッドで複数のコルーチンを実行できる軽量のスレッドであり、各コルーチン間の切り替えは非常に高速です。コルーチンは、スレッド切り替えのオーバーヘッドを回避し、データ共有や共同マルチタスクなどの機能を実装できるため、同時実行性の高い問題を効果的に解決できます。

Swoole でのコルーチンの使用は非常に簡単で、swoole_coroutine_create 関数を使用してコルーチンを作成し、その中で処理する必要があるタスクを実行するだけです。コルーチンの実行中に、IO 操作が現在のプロセスをブロックすることが判明した場合、他のコルーチンを積極的に切り替えて実行します。IO 操作が完了すると、スイッチバックして現在のプロセスのタスクの実行を継続します。コルーチン。

3. コルーチンを使用して swoole_smtp 関数を最適化する方法

swoole_smtp 関数は簡単に電子メールを送信できますが、そのパフォーマンスはあまり理想的ではありません。ブロッキングを通じて SMTP プロトコルを実装するため、同時実行性の高い環境ではスレッドブロッキングが発生し、アプリケーションのパフォーマンスに影響を与えます。

コルーチンを使用すると、この問題をうまく解決できます。swoole_coroutine_create 関数を通じて複数のコルーチンを作成し、複数の電子メール送信タスクを同時に実行して同時実行性を向上できます。以下はサンプルコードです:

<?php
function send_mail($mail)
{
    $smtp = new SwooleCoroutineClient(SWOOLE_SOCK_TCP);
    if (!$smtp->connect('smtp.exmail.qq.com', 465, true))
    {
        throw new Exception('Connect SMTP server failed!');
    }

    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    $smtp->send("EHLO swoole
");
    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    $smtp->send("AUTH LOGIN
");
    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    $smtp->send(base64_encode('xxxxx') . "
");
    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    $smtp->send(base64_encode('xxxxx') . "
");
    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    $smtp->send("MAIL FROM: <noreply@xxxxx.com>
");
    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    foreach ($mail->getReceivers() as $receiver)
    {
        $smtp->send("RCPT TO: <$receiver>
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }
    }

    $smtp->send("DATA
");
    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    $content = wordwrap($mail->getContent(), 80, "
");
    $smtp->send($content . "
");
    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    $smtp->send("QUIT
");
    if (!$smtp->recv())
    {
        throw new Exception('SMTP server did not respond!');
    }

    $smtp->close();
}

$smtp = new SwooleCoroutineClient(SWOOLE_SOCK_TCP);

if (!$smtp->connect('smtp.exmail.qq.com', 465, true))
{
    throw new Exception('Connect SMTP server failed!');
}

if (!$smtp->recv())
{
    throw new Exception('SMTP server did not respond!');
}

$smtp->send("EHLO swoole
");
if (!$smtp->recv())
{
    throw new Exception('SMTP server did not respond!');
}

$smtp->send("AUTH LOGIN
");
if (!$smtp->recv())
{
    throw new Exception('SMTP server did not respond!');
}

$smtp->send(base64_encode('xxxxx') . "
");
if (!$smtp->recv())
{
    throw new Exception('SMTP server did not respond!');
}

$smtp->send(base64_encode('xxxxx') . "
");
if (!$smtp->recv())
{
    throw new Exception('SMTP server did not respond!');
}

$smtp->send("MAIL FROM: <noreply@xxxxx.com>
");
if (!$smtp->recv())
{
    throw new Exception('SMTP server did not respond!');
}

$mail_list = array(
    // 邮件内容为$mail1，$mail2，$mail3
    new Mail(),
    new Mail(),
    new Mail()
);

foreach ($mail_list as $mail)
{
    swoole_coroutine_create(function () use ($mail) {
        $smtp = new SwooleCoroutineClient(SWOOLE_SOCK_TCP);
        if (!$smtp->connect('smtp.exmail.qq.com', 465, true))
        {
            throw new Exception('Connect SMTP server failed!');
        }

        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        $smtp->send("EHLO swoole
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        $smtp->send("AUTH LOGIN
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        $smtp->send(base64_encode('xxxxx') . "
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        $smtp->send(base64_encode('xxxxx') . "
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        $smtp->send("MAIL FROM: <noreply@xxxxx.com>
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        foreach ($mail->getReceivers() as $receiver)
        {
            $smtp->send("RCPT TO: <$receiver>
");
            if (!$smtp->recv())
            {
                throw new Exception('SMTP server did not respond!');
            }
        }

        $smtp->send("DATA
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        $content = wordwrap($mail->getContent(), 80, "
");
        $smtp->send($content . "
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        $smtp->send("QUIT
");
        if (!$smtp->recv())
        {
            throw new Exception('SMTP server did not respond!');
        }

        $smtp->close();
    });
}

$smtp->close();

ログイン後にコピー

In the上記サンプルコードでは、メール送信タスクを3つ作成し、swoole_coroutine_create関数を使用して3つのコルーチンにカプセル化し、同時に複数のコルーチンを同時に実行するためにプログラム内でSMTP接続を作成しました。このようにして、電子メール送信タスクの同時実行性を大幅に向上させることができ、それによってアプリケーション全体のパフォーマンスが向上します。

4. 概要

コルーチンテクノロジを使用すると、同時実行性の高い電子メール送信タスクを簡単に実装し、アプリケーション全体のパフォーマンスを向上させることができます。上記のコード例で使用されている swoole_smtp 関数に加えて、Swoole が提供する他の非同期 IO 関数を使用して、アプリケーションのパフォーマンスを最適化することもできます。つまり、コルーチンは、同時実行性の高い問題に対処する際に問題をより適切に解決できる非常に優れたテクノロジです。

以上がコルーチンを使用して Swoole で同時実行性の高い swoole_smtp 関数を実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。