Beispielanalyse für das Redis-Publish/Subscribe-Modell

Redis Publish/Subscribe-Anwendung

Publish and Subscribe (Pub/Sub) ist ein Nachrichtenkommunikationsmodell. Der Hauptzweck besteht darin, die Kopplung zwischen Nachrichtenherausgebern und Nachrichtenabonnenten zu entkoppeln. Dies ähnelt dem Beobachter im Entwurfsmuster sind relativ ähnlich. Pub/Sub löst nicht nur die direkte Kopplung von Herausgebern und Abonnenten auf Codeebene, sondern auch die Kopplung der beiden bei der physischen Bereitstellung. Als Pub/Sub-Server übernimmt Redis eine Nachrichtenweiterleitungsfunktion zwischen Abonnenten und Herausgebern. Abonnenten können den Redis-Server für die Nachrichtentypen abonnieren, an denen sie interessiert sind, indem sie die Befehle subscribe und psubscribe verwenden. Redis nennt den Nachrichtentyp einen Kanal. Wenn der Herausgeber über den Veröffentlichungsbefehl eine bestimmte Art von Nachricht an den Redis-Server sendet. Alle Clients, die diesen Nachrichtentyp abonnieren, erhalten diese Nachricht. Die Nachrichtenzustellung erfolgt hier viele-zu-viele. Ein Client kann mehrere Kanäle abonnieren und Nachrichten an mehrere Kanäle senden.

Beginnen wir mit den Grundbefehlen:

PSUBSCRIBE pattern [pattern ...]              #订阅一个或多个符合给定模式的频道;PUBSUB subcommand [argument [argument ...]]   #查看订阅与发布系统状态;PUBLISH channel message                       #将信息发送到指定的频道;PUNSUBSCRIBE [pattern [pattern ...]]          #退订所有给定模式的频道;SUBSCRIBE channel [channel ...]               #订阅给定的一个或多个频道的信息;UNSUBSCRIBE [channel [channel ...]]           #指退订给定的频道;

Wie Sie dem Redis-Handbuch entnehmen können, gibt es im Modus „Veröffentlichen und Abonnieren“ tatsächlich nur 6 Befehle,

ABONNIEREN

Abonnieren Sie die angegebenen Informationen für einen oder mehrere Kanäle.

SUBSCRIBE channel [channel ...]

Nach der offiziellen Erklärung oben zu urteilen, ist das Gameplay ein bisschen so, wie wir im wirklichen Leben Radio hören. Was machen wir, wenn wir Radio hören wollen? Es muss sich um FM handeln, um gute Programme anzuhören. Um sie zu abonnieren, muss ich zum Beispiel zwei Clients anführen. wie folgt:

root@localhost:~ # redis-cli -p 6379127.0.0.1:6379> SUBSCRIBE msg
Reading messages... (press Ctrl-C to quit)
1) "subscribe"2) "msg"3) (integer) 1

root@localhost:~ # redis-cli -p 6379127.0.0.1:6379> SUBSCRIBE msg
Reading messages... (press Ctrl-C to quit)
1) "subscribe"2) "msg"3) (integer) 1

SUBSCRIBE kann auch mehrere Kanäle abonnieren, sodass die empfangenen Informationen möglicherweise von mehreren Kanälen stammen.

VERÖFFENTLICHEN

Bislang überwachen diese beiden Abonnenten den Nachrichtenkanal. Wenn es Neuigkeiten vom Nachrichtenkanal gibt, werden diese auf jeden Fall per Abonnement empfangen diesen Befehl.

Senden Sie eine Informationsnachricht an den angegebenen Kanal.

PUBLISH channel message

Die folgende Demonstration:

Sehen Sie, nachdem Publish eine Nachricht auf dem MSG-Kanal gesendet hat, wird sie von Subscribe überwacht und dann separat ausgedruckt. Okay, bisher ist das einfachste Veröffentlichungsmodell . Ist es nicht ganz einfach? Eigentlich? ? ? So einfach ist das, aber manchmal haben wir immer noch ein Bedürfnis, das heißt, kann ich den Schlüssel unscharf zuordnen? Es ist beispielsweise erforderlich, alle Kanäle mit dem Präfix China zu abonnieren. Wenn dies möglich ist, wäre das wirklich großartig. . . Wenn ich antworten würde, wäre es sicherlich so, dass das mächtige Redis das auf jeden Fall kann, es stellt den Befehl PSUBSCRIBE bereit.

PSUBSCRIBE

Abonnieren Sie einen oder mehrere Kanäle, die einem bestimmten Muster entsprechen. Jedes Muster verwendet als Matcher. Es stimmt beispielsweise mit allen damit beginnenden Kanälen überein (it.news, it.blog, it.tweets). usw.), news.* entspricht allen Kanälen, die mit news beginnen (news.it, news.global.today usw.) und so weiter.

PSUBSCRIBE pattern [pattern ...]

Nachdem Sie die obige Erklärung gesehen haben, denken Sie vielleicht: Ist das nicht nur ein regulärer Matching? . . Als nächstes werde ich alle Kanäle mit „china“ als Präfix abonnieren, denn das Präfix „P“ steht für „Pattern“, oder? .

PSUBSCRIBE kann mehrere Parameter empfangen, um verschiedene Muster abzugleichen. Nachdem Sie ein kleines Beispiel gelesen haben, sollten Sie ein Verständnis für die Pub/Sub-Funktion haben. Beachten Sie, dass eine Verbindung in den Abonnementmodus wechselt, wenn sie den Abonnementkanal „subscribe“ oder „psubscribe“ durchläuft. In diesem Modus können keine anderen Befehle gesendet werden, außer das Abonnieren zusätzlicher Kanäle oder das Verlassen des Abonnementmodus mit dem Befehl „unsubscribe“ oder „punsubscribe“. Verwenden Sie außerdem den Befehl psubscribe, um mehrere Wildcard-Kanäle zu abonnieren. Wenn eine Nachricht mit mehreren Kanalmustern übereinstimmt, wird dieselbe Nachricht mehrmals empfangen.

Obwohl die Pub/Sub-Implementierung von Redis nur 150 Codezeilen erfordert, sind ihre Funktionen möglicherweise nicht vollständig genug. Es gibt nicht viel Unterstützung in Bezug auf Sicherheit, Authentifizierung und Zuverlässigkeit.

Redis-Publish/Subscribe-Mechanismus

Wenn ein Client über den PUBLISH-Befehl Informationen an Abonnenten sendet, nennen wir den Client einen Herausgeber.

Wenn ein Client den Befehl SUBSCRIBE oder PSUBSCRIBE verwendet, um Informationen zu empfangen, nennen wir den Client einen Abonnenten.

Um die Beziehung zwischen Herausgeber und Abonnenten zu entkoppeln, verwendet Redis den Kanal als Vermittler zwischen den beiden – der Herausgeber veröffentlicht Informationen direkt an den Kanal und der Kanal ist dafür verantwortlich, dass die Nachricht an den entsprechenden Abonnenten gesendet wird Abonnenten haben keine gegenseitige Beziehung und wissen nicht, dass sie voneinander existieren:

知道了发布和订阅的机制之后，接下来就可以开始研究具体的实现了，我们从Redis的订阅命令开始说起。

SUBSCRIBE命令的实现

前面说到，Redis将所有接受和发送信息的任务交给channel来进行，而所有channel的信息就储存在redisServer这个结构中：

struct redisServer {
  // 省略 ...
  dict *pubsub_channels; // Map channels to list of subscribed clients
  // 省略 ...
};

pubsub_channels是一个字典，字典的键就是一个个channel，而字典的值则是一个链表，链表中保存了所有订阅这个channel的客户端。

举个例子，如果在一个 redisServer 实例中，有一个叫做 news 的频道，这个频道同时被client_123 和 client_456 两个客户端订阅，那么这个 redisServer 结构看起来应该是这样子：

可以看出，实现SUBSCRIBE命令的关键，就是将客户端添加到给定channel的订阅链表中。

PSUBSCRIBE命令的实现

除了直接订阅给定channel外，还可以使用PSUBSCRIBE订阅一个模式(pattern)，订阅一个模式等同于订阅所有匹配这个模式的channel 。

和redisServer.pubsub_channels属性类似，redisServer.pubsub_patterns属性用于保存所有被订阅的模式，和pubsub_channels不同的是， pubsub_patterns是一个链表(而不是字典)：

struct redisServer {
  // 省略 ...
  list *pubsub_patterns; // A list of pubsub_patterns
  // 省略 ...
};

pubsub_patterns 的每一个节点都是一个 pubsubPattern 结构的实例，它保存了被订阅的模式，以及订阅这个模式的客户客户端：

typedef struct pubsubPattern {
  redisClient *client;
  robj *pattern;
} pubsubPattern;

举个例子，假设在一个 redisServer 实例中，有一个叫做 news.* 的模式同时被客户端client_789 和 client_999 订阅，那么这个 redisServer 结构看起来应该是这样子：

现在可以知道，实现PSUBSCRIBE命令的关键，就是将客户端和订阅的模式添加到redisServer.pubsub_patterns当中。

Das obige ist der detaillierte Inhalt vonBeispielanalyse für das Redis-Publish/Subscribe-Modell. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!