Wie verwende ich Redis, um Warteschlangenoperationen durchzuführen? Zusammenfassung des Beispielcodes für Redis-Operationen

So verwenden Sie Redis für Warteschlangenvorgänge

Reids ist ein relativ fortschrittliches Open-Source-Schlüsselwertspeichersystem, das in ANSI C implementiert ist. Es ähnelt memcached, unterstützt jedoch die dauerhafte Datenspeicherung und der Wert unterstützt mehrere Typen: String (identisch mit dem Wert in memcached), Liste, Set (Set), geordneter Satz (OrderSet). ) und Hash. Alle Werttypen unterstützen atomare Operationen, wie das Anhängen und Einfügen von Elementen in Listen, das Einfügen und Entfernen von Elementen aus Sammlungen usw. Die meisten Daten in Rdids befinden sich im Speicher und die Lese- und Schreibeffizienz ist sehr hoch. Es bietet zwei Persistenzmethoden: AOF (Operation Record File anhängen) und DUMP (regelmäßige Datensicherung). Redis unterstützt einen angepassten VM-Mechanismus (virtueller Speicher). Wenn die Datenkapazität den Speicher überschreitet, kann ein Teil des Werts in einer Datei gespeichert werden. Gleichzeitig unterstützt Redis den Master-Slave-Mechanismus, der eine Datenreplikation durchführen kann.
Sie können die Listenstruktur von Redis als Warteschlange verwenden.
In welchen Szenarien und Funktionen von Redis können wir Redis für unsere aktuellen Entwicklungsaktivitäten einführen? die tragische Situation, die sich zu „Redis um der Nutzung von Redis willen“ entwickelt hat? Natürlich ist es sehr wichtig, konkrete Sachverhalte im Detail zu analysieren.
Caching? Verteilter Cache? Warteschlange? Verteilte Warteschlange?
Einige Systemanwendungen (z. B. Telekommunikation, Bankwesen und große Internetanwendungen usw.) verwenden es. Natürlich ist der mittlerweile beliebte Memcache ein guter Beweis, aber in gewisser Hinsicht kann Memcache beides umfassen. und kann es besser machen (keine praktische Anwendung, also einfach wegwerfen). Aber von Redis aus habe ich das Gefühl, dass Redis sowohl Warteschlangen als auch Caches enthalten kann und in einer gleichzeitigen Umgebung keine Probleme verursacht, da die Vorgänge in Redis alle atomare Vorgänge sind.
Es besteht keine Notwendigkeit zu kommentieren, welches besser oder schlechter ist, die Existenz ist der Grund und die Wahl desjenigen, das zu Ihnen passt, ist das Beste.
Lassen Sie uns anfangen, mit dem (verteilten) Warteschlangendesign YY in Redis zu spielen. Bitte geben Sie mir einige Ratschläge.
Situationsszenario:
Die aktuellen Projekte werden auf mehreren Servern oder mehreren IPs bereitgestellt und das Frontend wird über F5 verteilt, sodass es unmöglich ist, zu bestimmen, auf welchem ​​Server die Anfrage des Benutzers landet. Für das Projekt gibt es ein Flash-Kill-Design, das zu Beginn nicht in Betracht gezogen wurde. Gleichzeitig war es auch die einfachste Möglichkeit, damit umzugehen, indem Zeilendatensätze direkt in der Datenbanktabelle gesperrt wurden. . Man kann sagen, dass dieses Parallelitätsproblem für verschiedene Anwendungsbereitstellungen und nur einen Datenbankserver „einfach“ gelöst werden kann. Überlegen Sie nun, ob Sie es in die Anwendung verschieben sollten, um zu verhindern, dass der Datenbankserver in das Geschäft einbezogen wird.
Zum Beispiel gibt es derzeit 2 Anwendungsserver und 1 Datenbankserver. Die Idee besteht darin, Redis auf dem Datenbankserver bereitzustellen. Wenn die beiden Server gleichzeitig Cache oder Warteschlange betreiben, erhalten sie zunächst die Proxy--Objekte auf den beiden Anwendungsservern vom Redis-Server und fügen sie dann der Liste hinzu . Betrieb.
Sehen Sie sich die Code-Implementierung an (PHP)
Vorgangsdatei list_push.php in die Warteschlange stellen

Der Code lautet wie folgt:

<?php 
$redis = getRedisInstance();//从Redis服务器拿到redis实例 
$redis->connect(&#39;Redis服务器IP&#39;, 6379); 
while (true) { 
$redis->lPush(&#39;list1&#39;, &#39;A_&#39;.date(&#39;Y-m-d H:i:s&#39;)); 
sleep(rand()%3); 
} 
?>

Führen Sie # php list_push.php aus &
Der Code der Datei „list_pop.php“ aus der Warteschlange lautet wie folgt:

Implementierungsmethode (Python)

1. py)

<?php 
$redis = getRedisInstance();//从Redis服务器拿到redis实例 
$redis->pconnect(&#39;Redis服务器IP&#39;, 6379); 
while(true) { 
try { 
var_export( $redis->blPop(&#39;list1&#39;, 10) ); 
} catch(Exception $e) { 
//echo $e; 
} 
}

Der Code lautet wie folgt:

2. Dequeue (read.py)

#!/usr/bin/env python 
import time 
from redis import Redis 
redis = Redis(host='127.0.0.1', port=6379) 
while True: 
now = time.
strftime("%Y/%m/%d %H:%M:%S") 
redis.lpush('test_queue', now) 
time.sleep(1)

Der Code lautet wie folgt:

#!/usr/bin/env python 
import sys 
from redis import Redis 
redis = Redis(host='127.0.0.1', port=6379) 
while True: 
res = redis.rpop('test_queue') 
if res == None: 
pass 
else: 
print str(res)

Beispielcode:
1. Enqueue-Vorgang

2. Vorgang aus der Warteschlange entfernen

<?php
$redis = new Redis();
$redis->connect(&#39;127.0.0.1&#39;,6379);
while(True){
  try{
    $value = &#39;value_&#39;.date(&#39;Y-m-d H:i:s&#39;);
    $redis->LPUSH(&#39;key1&#39;,$value);
    sleep(rand()%3);
    echo $value."\n";
  }catch(Exception $e){
    echo $e->getMessage()."\n";
  }
}
?>

Das obige ist der detaillierte Inhalt vonWie verwende ich Redis, um Warteschlangenoperationen durchzuführen? Zusammenfassung des Beispielcodes für Redis-Operationen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!