Detaillierte Erläuterung der verzögerten Aufgabenplanung in Redis

Mit der kontinuierlichen Weiterentwicklung der Internet- und Cloud-Computing-Technologie kommt es bei der täglichen Entwicklungsarbeit immer häufiger zu verzögerter Aufgabenplanung, z. B. beim regelmäßigen Versenden von E-Mails, beim regelmäßigen Sichern von Datenbanken usw. Da die Komplexität und der Umfang der Aufgaben weiter zunehmen, können viele herkömmliche Planungsmethoden den Anforderungen nicht mehr gerecht werden. Daher ist ein effizientes und zuverlässiges System zur Planung verzögerter Aufgaben erforderlich. Als leistungsstarke In-Memory-Datenbank hat sich Redis natürlich zu einem leistungsstarken Tool für die Implementierung verzögerter Aufgabenplanung entwickelt.

In diesem Artikel werden die Schritte und zugehörigen technischen Details zur Verwendung von Redis zur Implementierung der verzögerten Aufgabenplanung ausführlich vorgestellt.

1. Datenstruktur von Redis

Bevor Sie verstehen, wie Redis die verzögerte Aufgabenplanung implementiert, müssen Sie zunächst seine grundlegende Datenstruktur verstehen. Redis unterstützt fünf grundlegende Datentypen, nämlich String, Liste, Hash, Set und Zset. Unter diesen ist zset (geordneter Satz) die Kerndatenstruktur für die Implementierung der verzögerten Aufgabenplanung.

zset ist eine geordnete Menge in Redis. Jedes Mitglied davon hat einen Bewertungswert, der zum Sortieren verwendet werden kann. In zset hat jedes Mitglied einen eindeutigen Schlüssel und eine entsprechende Punktzahl. zset bietet die gleichen Mengenoperationen wie set und unterstützt außerdem das Erhalten von Mitgliedern entsprechend dem Punktebereich oder der Rangfolge.

2. Implementieren Sie die verzögerte Aufgabenplanung

Die Kernidee der Implementierung der verzögerten Aufgabenplanung in Redis besteht darin, die auszuführenden Aufgaben in zset einzufügen und die Ausführungszeit der Aufgabe als Punktzahl festzulegen. Die Serverseite von Redis bietet mehrere Befehle zum Betreiben geordneter Sammlungen. Mit diesen Befehlen kann problemlos eine verzögerte Aufgabenplanung implementiert werden.

1. Aufgaben hinzufügen

Verwenden Sie den Befehl zadd, um Aufgaben zu zset hinzuzufügen und geben Sie die Ausführungszeit der Aufgabe als Punktzahl an. Wenn die Aufgabe bereits vorhanden ist, wird ihr Bewertungswert aktualisiert.

Zum Beispiel: zadd delay_queue 1630509327 „task1“

Wenn die Verzögerungszeit 1630509327 erreicht, verschiebt Redis die Aufgabe „task1“ automatisch aus dem geordneten Satz „delay_queue“ und legt sie zur Verarbeitung an einer anderen Stelle ab.

2. Aufgaben abrufen

Verwenden Sie den Befehl zrange, um die Mitglieder von zset abzurufen, deren Punktzahl innerhalb eines bestimmten Bereichs liegt.

Zum Beispiel: zrange delay_queue 0 0

Dieser Befehl gibt das Mitglied mit der kleinsten Punktzahl im geordneten Satz von „delay_queue“ zurück, was die früheste Aufgabe ist.

3. Aufgabe löschen

Verwenden Sie den zrem-Befehl, um ein Mitglied des zset zu löschen.

Zum Beispiel: zrem delay_queue „task1“

Dieser Befehl entfernt die Aufgabe „task1“ aus dem geordneten Satz „delay_queue“.

4. Aufgaben abhören

Mit dem Befehl blpop kann die Blockierungswarteschlangenfunktion von Redis implementiert werden. Dieser Befehl blockiert, bis die Aufgabe aus der Warteschlange entfernt wird.

Zum Beispiel: blpop delay_queue 0

Dieser Befehl blockiert, bis ein Mitglied des geordneten Satzes „delay_queue“ aus der Warteschlange entfernt wird.

3. Vollständige Implementierung der verzögerten Aufgabenplanung

Sehen wir uns nun einen vollständigen Implementierungsprozess der verzögerten Aufgabenplanung von Redis an.

1. Redis-Verbindung initialisieren

In Python können wir die Redis-Py-Bibliothek verwenden, um eine Verbindung zu Redis herzustellen und Redis zu betreiben.

import redis
r = redis.Redis(host='localhost', port=6379, db=0)

2. Aufgaben hinzufügen

Wir können Aufgaben auf folgende Weise zu zset hinzufügen:

r.zadd('delay_queue', {'task1': 1630509327})

stellt das Hinzufügen der Aufgabe „task1“ zum geordneten Satz „delay_queue“ dar, und die Verzögerungszeit beträgt 1630509327.

3. Aufgabe abrufen

Wir können die früheste Aufgabe auf folgende Weise abrufen:

task = r.zrange('delay_queue', 0, 0, withscores=True)

stellt das Abrufen des Mitglieds mit der kleinsten Punktzahl im geordneten Satz „delay_queue“, also der frühesten Aufgabe, dar und gibt den Schlüssel zurück und Punktewert der Aufgabe.

4. Aufgaben ausführen

Wir können entsprechende Aktionen ausführen, nachdem die Aufgabe abgelaufen ist:

def do_task(task_key):
    # do your task here
    print('do task', task_key)

# 监听任务
while True:
    task = r.zrange('delay_queue', 0, 0, withscores=True)
    if task:
        task_key, score = task[0]
        # 如果任务时间到了，则执行任务
        if score <= time.time():
            r.zrem('delay_queue', task_key) # 删除已完成的任务
            do_task(task_key) # 执行任务
    time.sleep(0.1) # 避免CPU占用率过高

Im obigen Code verwenden wir eine While-Schleife, um die früheste Aufgabe kontinuierlich aus zset zu entfernen. Wenn die Aufgabenzeit erreicht ist, führen Sie die aus Führen Sie die entsprechende Aktion aus und löschen Sie die Aufgabe aus zset.

IV. Zusammenfassung

In diesem Artikel wird erläutert, wie Sie mit Redis eine verzögerte Aufgabenplanung implementieren. Durch die geordnete Datenstruktur von zset und die zahlreichen von Redis bereitgestellten Befehle kann ein effizientes und zuverlässiges System zur verzögerten Aufgabenplanung einfach implementiert werden. Natürlich ist dies nicht die einzige Implementierungsmethode, die in verschiedenen Szenarien verwendet werden kann und entsprechend den tatsächlichen Geschäftsanforderungen angepasst werden muss.

Abschließend ist zu erwähnen, dass die Verwendung von Redis zur Implementierung einer verzögerten Aufgabenplanung bei großem Aufgabenvolumen eine große Belastung für Redis darstellen und zu einer Verringerung der Redis-Leistung führen kann. Daher muss in tatsächlichen Anwendungen basierend auf Faktoren wie spezifischen Geschäftsanforderungen und Systemlast entschieden werden, ob Redis zur Implementierung einer verzögerten Aufgabenplanung verwendet werden soll.

Das obige ist der detaillierte Inhalt vonDetaillierte Erläuterung der verzögerten Aufgabenplanung in Redis. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!