Der Grund, warum Laravel wiederholt dieselbe Warteschlangenaufgabe ausführt

Der Warteschlangendienst von Laravel bietet eine einheitliche API für verschiedene Hintergrundwarteschlangendienste. Mithilfe von Warteschlangen können Sie die Ausführung zeitaufwändiger Aufgaben wie das Versenden einer E-Mail verzögern. Dadurch kann die Antwortzeit der Anfrage effektiv verkürzt werden. In diesem Artikel werden die Gründe erläutert, warum Laravel dieselbe Warteschlangenaufgabe wiederholt durch Beispielcode ausführt. Lassen Sie uns gemeinsam einen Blick darauf werfen.

Probleme gefunden

Verwenden Sie Redis in Laravel, um Warteschlangenaufgaben zu verarbeiten. Die vom Framework bereitgestellten Funktionen sind sehr leistungsfähig, aber kürzlich bin ich auf ein Problem gestoßen, das heißt, ich habe festgestellt, dass eine Aufgabe ausgeführt wurde mehrmals. Warum ist das so?

Lassen Sie uns zuerst über den Grund sprechen:

Denn wenn in Laravel eine Warteschlange (Aufgabe) länger als 60 Sekunden zur Ausführung benötigt, wird sie berücksichtigt fehlgeschlagen und wird wieder in die Warteschlange aufgenommen, was dazu führt, dass dieselbe Aufgabe wiederholt ausgeführt wird.

Die Logik dieser Aufgabe besteht darin, Inhalte an Benutzer zu senden. Benutzer müssen basierend auf dem Warteschlangeninhalt abgerufen und durchlaufen und über die HTTP-Schnittstelle des Anforderungs-Backends gesendet werden. Wenn beispielsweise 10.000 Benutzer vorhanden sind, die Anzahl der Benutzer groß ist oder die Verarbeitungsgeschwindigkeit der Schnittstelle nicht so hoch ist, beträgt die Ausführungszeit definitiv mehr als 60 Sekunden, sodass die Aufgabe erneut zur Warteschlange hinzugefügt wird. Noch schlimmer ist die Situation, wenn die vorherigen Aufgaben nicht innerhalb von 60 Sekunden ausgeführt werden, werden sie erneut zur Warteschlange hinzugefügt, sodass dieselbe Aufgabe nicht nur einmal, sondern mehrmals ausgeführt wird.

Lassen Sie uns den Schuldigen anhand des Laravel-Quellcodes finden.

Quellcodedatei: seller/laravel/framework/src/Illuminate/Queue/RedisQueue.php

/**
 * The expiration time of a job.
 *
 * @var int|null
 */
protected $expire = 60;

Die Mitgliedsvariable $expire ist ein fester Wert, den Laravel als eine Warteschlange betrachtet Es hätte innerhalb von 60 Sekunden ausgeführt werden müssen. So erhalten Sie die Warteschlange:

public function pop($queue = null)
{
 $original = $queue ?: $this->default; 
 $queue = $this->getQueue($queue); 
 $this->migrateExpiredJobs($queue.':delayed', $queue); 
 if (! is_null($this->expire)) {
  $this->migrateExpiredJobs($queue.':reserved', $queue);
 } 
 list($job, $reserved) = $this->getConnection()->eval(
  LuaScripts::pop(), 2, $queue, $queue.':reserved', $this->getTime() + $this->expire
 ); 
 if ($reserved) {
  return new RedisJob($this->container, $this, $job, $reserved, $original);
 }
}

Es gibt mehrere Schritte, um die Warteschlange abzurufen. Da die Ausführung der Warteschlange fehlschlägt, die Ausführungszeit abläuft usw., wird sie in eine andere Sammlung gestellt und für einen erneuten Versuch gespeichert . Der Vorgang ist wie folgt:

1. Verschieben Sie die Warteschlange, die aufgrund der Ausführung fehlgeschlagen ist, erneut aus der verzögerten Sammlung in die aktuell ausgeführte Warteschlange.

2. Verschieben Sie die Warteschlange aufgrund eines Ausführungszeitlimits erneut von der reservierten Sammlung in die aktuell ausgeführte Warteschlange.

3. Nehmen Sie dann die Aufgabe aus der Warteschlange, beginnen Sie mit der Ausführung und stellen Sie die Warteschlange in die reservierte geordnete Sammlung.

Der Befehl eval wird verwendet, um diesen Prozess auszuführen, und es werden mehrere Lua-Skripte verwendet.

Rufen Sie die auszuführende Aufgabe aus der Warteschlange ab:

local job = redis.call('lpop', KEYS[1])
local reserved = false
if(job ~= false) then
 reserved = cjson.decode(job)
 reserved['attempts'] = reserved['attempts'] + 1
 reserved = cjson.encode(reserved)
 redis.call('zadd', KEYS[2], ARGV[1], reserved)
end
return {job, reserved}

Sie können sehen, dass Laravel, wenn es die auszuführende Warteschlange von Redis erhält, auch eine Kopie in einen geordneten Satz einfügt . Und verwenden Sie den Ablaufzeitstempel als Bewertung.

Erst wenn die Aufgabe abgeschlossen ist, wird die Aufgabe aus dem bestellten Satz entfernt. Der Code zum Entfernen der Warteschlange aus dieser geordneten Sammlung wird weggelassen. Schauen wir uns an, wie Laravel mit Warteschlangen umgeht, deren Ausführungszeit länger als 60 Sekunden ist.

Dies ist die Operation, die von diesem Lua-Skript ausgeführt wird:

local val = redis.call('zrangebyscore', KEYS[1], '-inf', ARGV[1])
if(next(val) ~= nil) then
 redis.call('zremrangebyrank', KEYS[1], 0, #val - 1)
 for i = 1, #val, 100 do
  redis.call('rpush', KEYS[2], unpack(val, i, math.min(i+99, #val)))
 end
end
return true

Hier findet zrangebyscore die Elemente mit Werten von infinitesimal bis zum aktuellen Zeitstempel, d. h. diejenigen, die vor 60 Sekunden zum Satz hinzugefügt wurden Die Aufgabe entfernt diese Elemente dann über zremrangebyrank aus der Menge und schiebt sie per rpus in die Warteschlange.

Sie sollten eine plötzliche Erkenntnis haben, nachdem Sie das gesehen haben.

Wenn eine Warteschlange nicht innerhalb von 60 Sekunden ausgeführt wird, schiebt der Prozess beim Abrufen der Warteschlange die Aufgaben aus dem reservierten Satz erneut in die Warteschlange.

Verwandte Empfehlungen:

Einige praktische Tipps zur Verbesserung der Leistung von Laravel 5

Domänenübergreifende Lösungen in der Laravel-Entwicklung Ausführliche Erklärung

Beispiel für die Zahlungsentwicklung von Laravel WeChat

Das obige ist der detaillierte Inhalt vonDer Grund, warum Laravel wiederholt dieselbe Warteschlangenaufgabe ausführt. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!