Chaîne d'objets

Objet de traitement de chaîne de gestionnaire de messages

L'objet Chain est un objet de traitement de chaîne de processeurs de messages dans fibjs, qui est utilisé pour relier une série de processeurs de messages et les traiter dans un ordre spécifié. La méthode pour créer un objet Chain est la suivante :

1
2
3
var chain = new mq.Chain([
   func1, func2
]);

Dans cette méthode de création, func1 et func2 sont des objets fonction du processeur de messages. L'objet Chain relie ces processeurs entre eux afin de former une chaîne de processeurs. Lors du traitement de chaque message, le processeur peut effectuer un traitement personnalisé sur le message, puis transmettre le message au processeur suivant pour traitement. De cette manière, un message peut être traité étape par étape jusqu'à son état final.

La fonction Invoke() de l'objet Chain est utilisée pour traiter un message ou un objet. Lorsque cette fonction est appelée, l'objet Chain transmet le message ou l'objet à chaque processeur tour à tour, en le traitant dans l'ordre des processeurs jusqu'à ce que tous les processeurs l'aient traité. Au cours de ce processus, chaque processeur peut effectuer un traitement personnalisé sur le message ou l'objet, ou choisir de transmettre le message ou l'objet au processeur suivant pour traitement.

Dans des applications pratiques, les objets Chain peuvent être appliqués à divers scénarios. Par exemple, dans un framework Web, les messages de requête peuvent être transmis à chaque processeur en séquence pour traitement ; dans une file d'attente de messages, un lot de messages peut être transmis à chaque processeur dans séquence. L’utilisation des objets Chain est très flexible et personnalisable en fonction des besoins réels, hautement évolutive et réutilisable.

relation d'héritage

Constructeur

Chain

Construire un objet de traitement de chaîne de gestionnaire de messages

1
new Chain(Array hdlrs);

Paramètres d'appel :

• hdlrs: Tableau, tableau de processeurs

fonction membre

append

Ajouter une matrice de processeurs

1
Chain.append(Array hdlrs);

Paramètres d'appel :

• hdlrs: Tableau, tableau de processeurs

---

Ajouter un processeur

1
Chain.append(Handler hdlr);

Paramètres d'appel :

• hdlr:Handler, processeur de messages intégré, fonction de traitement, tableau de traitement en chaîne, objet de routage, voir les détailsmq.Handler

---

invoke

Traiter un message ou un objet

1
Handler Chain.invoke(object v) async;

Paramètres d'appel :

• v:object, précisez le message ou l'objet à traiter

Résultats de retour :

• Handler, retour au processeur suivant

---

toString

Renvoie la représentation sous forme de chaîne de l'objet. Généralement, "[Native Object]" est renvoyé. L'objet peut être réimplémenté en fonction de ses propres caractéristiques.

1
String Chain.toString();

Résultats de retour :

• String, renvoie la représentation sous forme de chaîne de l'objet

---

toJSON

Renvoie une représentation au format JSON de l'objet, renvoyant généralement une collection de propriétés lisibles définies par l'objet.

1
Value Chain.toJSON(String key = "");

Paramètres d'appel :

• key: Chaîne, non utilisée

Résultats de retour :

• Value, renvoie une valeur contenant du JSON sérialisable