Analyse d'un exemple de modèle de publication/abonnement Redis

Application de publication/abonnement Redis

Publier et s'abonner (pub/sub) est un modèle de communication par message. L'objectif principal est de découpler l'éditeur du message et l'abonné au message. , qui est similaire au modèle d'observateur dans les modèles de conception. pub/sub résout non seulement le couplage direct au niveau du code des éditeurs et des abonnés, mais résout également le couplage des deux dans le déploiement physique. En tant que serveur pub/sub, redis joue une fonction de routage des messages entre les abonnés et les éditeurs. Les abonnés peuvent s'abonner au serveur Redis pour les types de messages qui les intéressent via les commandes d'abonnement et psubscribe. Redis appelle le type de message un canal. Lorsque l'éditeur envoie un type spécifique de message au serveur Redis via la commande de publication. Tous les clients abonnés à ce type de message recevront ce message. La transmission du message ici est plusieurs à plusieurs. Un client peut s'abonner à plusieurs canaux et envoyer des messages à plusieurs canaux.

Commençons par les commandes de base :

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

Comme vous pouvez le voir dans le manuel redis, en fait, le mode "publier et s'abonner" n'a que 6 commandes. dites-vous un par un. Expliquez

SUBSCRIBE

Abonnez-vous aux informations d'une ou plusieurs chaînes données.

SUBSCRIBE channel [channel ...]

À en juger par l'explication officielle ci-dessus, son gameplay ressemble un peu à la façon dont nous écoutons la radio dans la vraie vie. Que faisons-nous si nous voulons écouter la radio ? Ce doit être FM. Ce n'est que sur la bonne chaîne que nous pouvons écouter de bons programmes. Donc, pour vous abonner, nous devons d'abord vous abonner à une chaîne. Laissez-moi vous donner un exemple ci-dessous et vous abonner respectivement à la chaîne msg. comme suit :

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 peut également s'abonner à plusieurs chaînes, afin que les informations qu'il reçoit puissent provenir de plusieurs chaînes.

PUBLISH

Jusqu'à présent, ces deux abonnés surveillent le canal msg. Ensuite, s'il y a des nouvelles du canal msg, elle sera certainement reçue par abonnement. Voyons d'abord comment utiliser cette commande dans le manuel redis.

Envoyer le message au canal spécifié.

PUBLISH channel message

La démonstration suivante :

Avez-vous vu qu'après publication a envoyé un message sur le canal msg, il était surveillé par abonnement ? Lorsqu'ils arrivent, ils sont imprimés séparément. Eh bien, jusqu'à présent, le modèle de publication-abonnement le plus basique n'est-il pas très simple ? En fait? ? ? C'est aussi simple que cela, mais parfois nous avons encore un besoin, c'est-à-dire, puis-je faire correspondre la clé de manière floue ? Par exemple, il est nécessaire de s'abonner à toutes les chaînes avec le préfixe Chine. Si cela peut être fait, ce serait vraiment génial. . . Si je devais répondre, ce serait certainement que le puissant Redis peut certainement le faire, il fournit la commande PSUBSCRIBE.

PSUBSCRIBE

Abonnez-vous à une ou plusieurs chaînes qui correspondent à un modèle donné, chaque modèle commence par comme correspondant, par ex. it correspond à toutes les chaînes commençant par it (it.news, it.blog, it.tweets, etc.), news.* correspond à toutes les chaînes commençant par news (news.it, news.global.today, etc. .) etc.), etc.

PSUBSCRIBE pattern [pattern ...]

Après avoir vu l'explication ci-dessus, vous vous demandez peut-être : n'est-ce pas simplement une correspondance régulière ? . . Ensuite, je m'abonnerai à toutes les chaînes avec « Chine » comme préfixe, car le préfixe « P » signifie « Modèle », n'est-ce pas ? .

PSUBSCRIBE peut recevoir plusieurs paramètres pour correspondre à différents modèles. Après avoir lu un petit exemple, vous devriez avoir une compréhension perceptuelle de la fonction pub/sub. Il convient de noter que lorsqu'une connexion passe par le canal d'abonnement Subscribe ou Psubscribe, elle entre en mode abonnement. Dans ce mode, aucune autre commande ne peut être envoyée sauf l'abonnement à des chaînes supplémentaires ou la sortie du mode abonnement avec la commande unsubscribe ou punsubscribe. De plus, utilisez la commande psubscribe pour vous abonner à plusieurs canaux génériques. Si un message correspond à plusieurs modèles de canal, le même message sera reçu plusieurs fois.

Bien que l'implémentation pub/sub de Redis ne nécessite que 150 lignes de code, ses fonctions peuvent ne pas être suffisamment complètes. Il n'y a pas beaucoup de support en termes de sécurité, d'authentification et de fiabilité.

Mécanisme de publication/abonnement de Redis

Lorsqu'un client envoie des informations aux abonnés via la commande PUBLISH, nous appelons le client un éditeur.

Lorsqu'un client utilise la commande SUBSCRIBE ou PSUBSCRIBE pour recevoir des informations, nous appelons le client un abonné.

Afin de découpler la relation entre l'éditeur et l'abonné, Redis utilise le canal comme intermédiaire entre les deux : l'éditeur publie les informations directement sur le canal, et le canal est responsable de l'envoi des informations aux abonnés appropriés. l'éditeur et l'abonné n'ont aucune relation mutuelle et ne connaissent pas l'existence l'un de l'autre :

知道了发布和订阅的机制之后，接下来就可以开始研究具体的实现了，我们从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当中。

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!