Wie verwende ich ThinkPHP6 für die Verarbeitung von E-Mail-Warteschlangen?

Mit der Zunahme von Webanwendungen steigt auch die Nachfrage nach dem Versenden von E-Mails. In einigen Fällen müssen Sie Nachrichten stapelweise senden oder zur Verarbeitung in eine Warteschlange stellen, um die Leistung zu verbessern. ThinkPHP 6 bietet praktische E-Mail-Versand- und Warteschlangenverarbeitungsfunktionen. In diesem Artikel wird die Verwendung von ThinkPHP 6 für die E-Mail-Warteschlangenverarbeitung vorgestellt.

1. Installieren und konfigurieren Sie den Warteschlangendienst

1. Installieren Sie Redis

Redis ist ein Open-Source-In-Memory-Datenstruktur-Speicherserver, der als Datenbank, Cache und Nachrichtenbroker verwendet wird. Da die Warteschlangendaten beibehalten werden müssen, müssen die Warteschlangendaten über Redis gespeichert werden. Informationen zur Installation von Redis finden Sie in der offiziellen Dokumentation und anderen Online-Tutorials.

2. Konfigurieren Sie die Warteschlangenverbindung

Konfigurieren Sie die Warteschlangenverbindung in der ThinkPHP-Konfigurationsdatei config/queue.php. Das Beispiel lautet wie folgt:

return [
    // 默认驱动
    'default' => env('queue.driver', 'redis'),

    // 队列连接参数
    'connections' => [
        'sync' => [
            'driver' => 'sync',
        ],
        'redis' => [
            'driver' => 'redis',
            'connection' => 'default',
            'queue' => env('queue.redis.queue', 'default'),
            'retry_after' => 90,
            'block_for' => null,
        ],
    ],

    // 监听的任务类命名空间
    'queue_class' => [
        // 'AppJobs'
    ],
];

Daunter ist der Standard-Warteschlangentreiber, der hier als Redis konfiguriert ist . Die relevanten Parameter des Redis-Treibers werden in Verbindungen konfiguriert, einschließlich Verbindungsname, Verbindungstreiber, Verbindungswarteschlangenname usw. queue_class wird verwendet, um den Namespace der Klasse zu überwachen, die Aufgaben ausführt.

3. Starten Sie den Warteschlangen-Listener

Starten Sie den Warteschlangen-Listener in der Befehlszeile, und Sie können die Aufgaben in der Warteschlange einzeln herausnehmen und ausführen. Ein Beispiel ist wie folgt:

php think queue:listen

2. Verwenden Sie die Warteschlange zum Senden von E-Mails

1. Erstellen Sie eine E-Mail-Versandaufgabe.

Erstellen Sie eine E-Mail-Versandaufgabenklasse im App-/Jobverzeichnis und schreiben Sie die entsprechende Logik. Zum Beispiel die Aufgabenklasse SnedMailJob zum Senden von E-Mails:

<?php
namespace appjob;

use appcommonMail;
use thinkqueueJob;

class SendMailJob
{
    /**
     * Send the email message.
     *
     * @param  Job  $job
     * @param  array  $data email message data
     */
    public function fire(Job $job, $data)
    {
        try {
            // 发送邮件
            Mail::send($data['to'], $data['subject'], $data['content']);

            // 执行任务成功，删除任务
            $job->delete();
        } catch (Exception $e) {
            // 执行任务失败，重新放入任务队列中
            // 系统会自动新建一个可重试任务并放入队列，该任务结束后重新尝试执行当前任务
            $job->release(); // 或者 $job->failed();
        }
    }
}

2. Fügen Sie die Aufgabe zur Warteschlange hinzu.

Wo Sie die E-Mail senden müssen, fügen Sie die Aufgabe über den folgenden Code zur Warteschlange hinzu:

use thinkacadeQueue;

// 添加一条SendMailJob任务到队列中
Queue::push(new SendMailJob($to, $subject, $content));

Darunter $ to, $subject, $content sind Empfänger, Betreff und Inhalt der E-Mail.

3. Der Warteschlangen-Listener führt die Aufgabe aus

Nachdem der Warteschlangen-Listener gestartet wurde, wird die Aufgabe automatisch aus der Warteschlange genommen und ausgeführt. Nach erfolgreicher Ausführung wird die Aufgabe von selbst aus der Warteschlange gelöscht. Nachdem die Ausführung fehlgeschlagen ist, schiebt der Warteschlangen-Listener die Aufgabe erneut in die Warteschlange, bis die Aufgabe erfolgreich ausgeführt wurde oder die maximale Anzahl von Versuchen erreicht ist (konfigurierbar in der .env-Datei).

3. Fazit

In diesem Artikel wird die Methode zur Verwendung von ThinkPHP6 für die E-Mail-Warteschlangenverarbeitung vorgestellt, einschließlich der Installation und Konfiguration des Warteschlangendienstes, der Erstellung von E-Mail-Versandaufgaben, dem Hinzufügen von Aufgaben zur Warteschlange und der Ausführungsaufgaben des Warteschlangen-Listeners. Durch die Verwendung von E-Mail-Warteschlangen können Sie E-Mail-Aufgaben von Ihrer Anwendung trennen und so die Leistung und Zuverlässigkeit verbessern.

Das obige ist der detaillierte Inhalt vonWie verwende ich ThinkPHP6 für die Verarbeitung von E-Mail-Warteschlangen?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!