Verwendung von Redis zur Implementierung verteilter geplanter Aufgaben in PHP

Redis ist eine leistungsstarke In-Memory-Datenbank, die die Vorteile schneller Lese- und Schreibgeschwindigkeiten bietet, ein gewisses Maß an Persistenz unterstützt und umfangreiche Datentypen bietet. Redis wird häufig in Szenarien wie Caching, Nachrichtenwarteschlangen und Echtzeit-Rankings verwendet. Während der Entwicklung müssen wir manchmal verteilte geplante Aufgaben implementieren, z. B. das Senden von E-Mails, das Bereinigen temporärer Dateien, das Aktualisieren des Caches usw. In diesem Artikel wird erläutert, wie Sie mit Redis verteilte geplante Aufgaben implementieren.

1. Von Redis unterstützte Datentypen

Zu den von Redis unterstützten Datentypen gehören: String, Hash, List, Set und Ordered Set. Bei der Implementierung verteilter geplanter Aufgaben konzentrieren wir uns hauptsächlich auf zwei Datentypen: geordnete Mengen und Listen.

1. Ordered set#

Ordered set ist ein von Redis bereitgestellter Datentyp, der einer Hash-Tabelle ähnelt und Schlüsselwerte speichern kann , aber Werte (auch Scores genannt) können wiederholt werden, und jedem Wert ist ein Score zugeordnet, der zum Sortieren verwendet wird. Die Elemente in einer geordneten Menge werden nach Punktzahl von klein nach groß sortiert.

Wenn wir geordnete Mengen verwenden, um verteilte geplante Aufgaben zu implementieren, können wir die Ausführungszeit der Aufgabe als Punktzahl und den Aufgabeninhalt als Wert verwenden und jede Aufgabe in einer geordneten Menge speichern.

List

List ist ein von Redis bereitgestellter Datentyp. Sie können Elemente hinzufügen und löschen. Redis bietet eine umfangreiche Liste von Befehlen, wie zum Beispiel: lpush, rpush, lpop, rpop usw.

Wenn wir eine Liste zum Implementieren verteilter geplanter Aufgaben verwenden, können wir den Aufgabeninhalt in der Liste speichern und den Befehl lpop verwenden, um die Aufgabe zur Ausführung abzurufen.

2. Schritte zur Implementierung verteilter Timing-Aufgaben

Die Implementierung verteilter Timing-Aufgaben kann grob in die folgenden Schritte unterteilt werden:

#🎜🎜 #Hinzufügen Ordnen Sie die Aufgabe der geordneten Menge zu und legen Sie die Ausführungszeit der Aufgabe als Punktzahl fest.

1. Starten Sie einen Hintergrundprozess, um die Aufgaben in der geordneten Sammlung zu scannen, festzustellen, ob die Aufgabe ausgeführt werden muss, und die auszuführenden Aufgaben zur Aufgabenliste hinzuzufügen.
2. Starten Sie mehrere Worker-Prozesse und fügen Sie Aufgaben zur Ausführung aus der Aufgabenliste hinzu.
3. Nach Abschluss der Ausführung wird die Aufgabe aus dem geordneten Satz gelöscht.
4. Aufgaben zu einem geordneten Satz hinzufügen
5. Verwenden Sie den folgenden Befehl, um Aufgaben zu einem geordneten Satz hinzuzufügen:

ZADD-Aufgaben mit Zeitstempelinhalt

Unter diesen sind Aufgaben der Name der geordneten Sammlung, Zeitstempel die Ausführungszeit der Aufgabe (Unix-Zeitstempel) und Inhalt der Inhalt der Aufgabe.

Um beispielsweise eine Aufgabe „E-Mail senden“ zur geordneten Sammlung hinzuzufügen, nachdem die Ausführungszeit 10 Minuten beträgt, können Sie den folgenden Befehl verwenden:

ZADD Aufgaben $ (Datum - d „+10 Minuten“ +%s) „E-Mail senden“

Aufgaben im geordneten Satz scannen

2. Hintergrund starten Prozess, verwenden Sie den folgenden Befehl, um alle Aufgaben, die ausgeführt werden müssen, aus dem geordneten Satz abzurufen:

ZRANGEBYSCORE task -inf $(date +%s) WITHSCORES

where -inf bedeutet, dass der Mindestwert im Sequenzsatz $(date +%s) den Unix-Zeitstempel der aktuellen Zeit darstellt.

Der obige Befehl gibt eine Liste mit Ergebnissen zurück, zum Beispiel:

1) „temporäre Dateien löschen“

2) „1626387489“

# 🎜🎜# Darunter ist „temporäre Dateien löschen“ der Aufgabeninhalt und „1626387489“ die Ausführungszeit der Aufgabe.

Nachdem Sie alle Aufgaben erhalten haben, die ausgeführt werden müssen, fügen Sie diese Aufgaben zur Aufgabenliste hinzu.

Aufgaben ausführen

3. Starten Sie mehrere Worker-Prozesse und rufen Sie Aufgaben aus der Aufgabenliste zur Ausführung auf. Nach der Ausführung wird die Aufgabe aus der geordneten Menge entfernt.

Verwenden Sie den folgenden Befehl, um eine Aufgabe aus der Liste zu entfernen und auszuführen:

lpop task

wobei Aufgaben der Name der Liste ist.

Löschen Sie die Aufgabe aus dem geordneten Satz

4. Nachdem die Aufgabe ausgeführt wurde, verwenden Sie den folgenden Befehl, um die Aufgabe aus dem geordneten Satz zu löschen:

ZREM-Aufgabeninhalt

Unter diesen ist Aufgaben der Name der geordneten Sammlung und Inhalt der Inhalt der Aufgabe.

3. Code-Implementierung

Im Folgenden verwenden wir PHP, um die oben genannten Schritte zu implementieren.

Aufgaben zu einem geordneten Satz hinzufügen

1. Verwenden Sie den folgenden Code, um Aufgaben zu einem geordneten Satz hinzuzufügen:

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 添加任务到有序集合
$timestamp = strtotime("+10 minutes");
$redis->zAdd('tasks', $timestamp, 'send email');

Nach dem Login kopieren
#🎜🎜 #

Scannen Sie die Aufgaben im geordneten Satz

Verwenden Sie den folgenden Code, um die Aufgaben im geordneten Satz zu scannen und die Aufgaben, die ausgeführt werden müssen, zur Aufgabenliste hinzuzufügen:

2. while(true) {
       // 扫描有序集合中的任务
       $scoreTasks = $redis->zRangeByScore('tasks', '-inf', time(), array('withscores' => true));
       foreach($scoreTasks as $task => $score) {
           // 将需要执行的任务添加到任务列表中
           $redis->lpush('task_list', $task);
           // 将任务从有序集合中删除
           $redis->zRem('tasks', $task);
       }
       // 每隔5秒扫描一次
       sleep(5);
   }

   Nach dem Login kopieren

Aufgaben ausführen

Verwenden Sie den folgenden Code, um mehrere Worker-Prozesse zu starten und Aufgaben aus der Aufgabenliste zur Ausführung zu entfernen: #🎜🎜 #

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

for($i=0; $i<10; $i++) {
    // 启动10个Worker进程
    $pid = pcntl_fork();
    if($pid == -1) {
        echo 'fork error!' . PHP_EOL;
        exit;
    } else if($pid == 0) {
        // 子进程中获取任务列表中的任务并执行
        while(true) {
            // 从列表中弹出一条任务
            $task = $redis->rpop('task_list');
            if(empty($task)) {
                continue;
            }
            // 执行任务
            mail('user@example.com', 'Task', $task);
        }
    }
}

Nach dem Login kopieren
3. 4. Zusammenfassung

Die oben genannten Schritte und Codeimplementierungen für die Verwendung von Redis zur Implementierung verteilter geplanter Aufgaben. Durch die Verwendung von Redis können Sie problemlos eine verteilte Aufgabenplanung implementieren und die gleichzeitigen Verarbeitungsfunktionen und die Ausführungseffizienz von Aufgaben verbessern. In tatsächlichen Anwendungen müssen wir den Code entsprechend der tatsächlichen Situation optimieren, z. B. durch die Verwendung von Sperren, um einen sich gegenseitig ausschließenden Zugriff auf die Aufgabenliste durchzuführen, durch die Verwendung von Timern, um Aufgaben regelmäßig abzurufen usw.

Das obige ist der detaillierte Inhalt vonVerwendung von Redis zur Implementierung verteilter geplanter Aufgaben in PHP. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!