Catena di oggetti

Oggetto di elaborazione della catena del gestore messaggi

L'oggetto Chain è un oggetto di elaborazione della catena di elaboratori di messaggi in fibjs, che viene utilizzato per collegare una serie di elaboratori di messaggi ed elaborarli in un ordine specificato. Il metodo per creare un oggetto Catena è il seguente:

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

In questo metodo di creazione, sia func1 che func2 sono oggetti funzione dell'elaboratore di messaggi. L'oggetto Chain collega questi processori insieme per formare una catena di processori. Durante l'elaborazione di ciascun messaggio, il processore può eseguire un'elaborazione personalizzata sul messaggio e quindi consegnare il messaggio al processore successivo per l'elaborazione. In questo modo un messaggio può essere elaborato passo dopo passo fino allo stato finale.

La funzione invoke() dell'oggetto Chain viene utilizzata per elaborare un messaggio o un oggetto. Quando viene chiamata questa funzione, l'oggetto Chain passa il messaggio o l'oggetto a turno a ciascun processore, elaborandolo nell'ordine dei processori finché tutti i processori non lo hanno elaborato. Durante questo processo, ciascun processore può eseguire un'elaborazione personalizzata sul messaggio o sull'oggetto oppure scegliere di passare il messaggio o l'oggetto al processore successivo per l'elaborazione.

Nelle applicazioni pratiche, gli oggetti Chain possono essere applicati a vari scenari. Ad esempio, in un framework web, i messaggi di richiesta possono essere passati a ciascun processore in sequenza per l'elaborazione; in una coda di messaggi, un batch di messaggi può essere passato a ciascun processore in sequenza.per l'elaborazione. L'utilizzo degli oggetti Chain è molto flessibile e personalizzabile in base alle effettive esigenze, è altamente scalabile e riutilizzabile.

rapporto ereditario

Costruttore

Chain

Costruire un oggetto di elaborazione della catena del gestore di messaggi

1
new Chain(Array hdlrs);

Parametri di chiamata:

• hdlrs: Array, array di processori

funzione membro

append

Aggiungi array di processori

1
Chain.append(Array hdlrs);

Parametri di chiamata:

• hdlrs: Array, array di processori

---

Aggiungi processore

1
Chain.append(Handler hdlr);

Parametri di chiamata:

• hdlr:Handler, processore di messaggi integrato, funzione di elaborazione, array di elaborazione della catena, oggetto di instradamento, vedere i dettaglimq.Handler

---

invoke

Elaborare un messaggio o un oggetto

1
Handler Chain.invoke(object v) async;

Parametri di chiamata:

• v:object, specificare il messaggio o l'oggetto da elaborare

Risultati restituiti:

• Handler, torna al processore successivo

---

toString

Restituisce la rappresentazione in formato stringa dell'oggetto. Generalmente viene restituito "[Oggetto nativo]". L'oggetto può essere reimplementato in base alle proprie caratteristiche.

1
String Chain.toString();

Risultati restituiti:

• String, restituisce la rappresentazione di stringa dell'oggetto

---

toJSON

Restituisce una rappresentazione in formato JSON dell'oggetto, generalmente restituendo una raccolta di proprietà leggibili definite dall'oggetto.

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

Parametri di chiamata:

• key: Stringa, non utilizzata

Risultati restituiti:

• Value, restituisce un valore contenente JSON serializzabile