ObjectChain

Objecte de processament de cadena de gestor de missatges

L'objecte Chain és un objecte de processament de cadena de processador de missatges en fibjs, que s'utilitza per enllaçar una sèrie de processadors de missatges i processar-los en un ordre especificat. El mètode per crear un objecte Chain és el següent:

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

En aquest mètode de creació, tant func1 com func2 són objectes de funció del processador de missatges. L'objecte Chain enllaça aquests processadors per formar una cadena de processadors. Quan processa cada missatge, el processador pot realitzar un processament personalitzat del missatge i, a continuació, lliurar el missatge al processador següent perquè el processi. D'aquesta manera, un missatge es pot processar pas a pas fins a l'estat final.

La funció invoke() de l'objecte Chain s'utilitza per processar un missatge o objecte. Quan es crida aquesta funció, l'objecte Chain passa el missatge o l'objecte a cada processador per torn, processant-lo en ordre de processador fins que tots els processadors l'han processat. Durant aquest procés, cada processador pot realitzar un processament personalitzat sobre el missatge o l'objecte, o triar passar el missatge o l'objecte al processador següent per processar-lo.

En aplicacions pràctiques, els objectes de cadena es poden aplicar a diversos escenaris. Per exemple, en un marc web, els missatges de sol·licitud es poden passar a cada processador en seqüència per al seu processament; en una cua de missatges, es pot passar un lot de missatges a cada processador en seqüència per processar. L'ús d'objectes Chain és molt flexible i es pot personalitzar segons les necessitats reals, és altament escalable i reutilitzable.

relació hereditària

Constructor

Chain

Construeix un objecte de processament de cadena de gestor de missatges

1
new Chain(Array hdlrs);

Paràmetres de trucada:

• hdlrs: Matriu, matriu de processadors

funció de membre

append

Afegeix una matriu de processadors

1
Chain.append(Array hdlrs);

Paràmetres de trucada:

• hdlrs: Matriu, matriu de processadors

---

Afegeix un processador

1
Chain.append(Handler hdlr);

Paràmetres de trucada:

• hdlr:Handler, processador de missatges integrat, funció de processament, matriu de processament en cadena, objecte d'encaminament, vegeu els detallsmq.Handler

---

invoke

Processar un missatge o objecte

1
Handler Chain.invoke(object v) async;

Paràmetres de trucada:

• v:object, especifiqueu el missatge o l'objecte a processar

Resultats de retorn:

• Handler, torneu al següent processador

---

toString

返回对象的字符串表示，一般返回 "[Objecte natiu]"，对象可以根据自己的特性重新实重新

1
String Chain.toString();

Resultats de retorn:

• String, retorna la representació de cadena de l'objecte

---

toJSON

Retorna una representació en format JSON de l'objecte, generalment retornant una col·lecció de propietats llegibles definides per l'objecte.

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

Paràmetres de trucada:

• key: Corda, no utilitzada

Resultats de retorn:

• Value, retorna un valor que conté JSON serializable