Συνδέσεις και ροές

Αυτές οι ενέργειες έρχονται σε οικογένειες των δύο ή τριών: σύνδεση, αποστολή, κλείσιμο. Η σύνδεση παραμένει ανοιχτή ανάμεσα στα κουτιά, πράγμα που επιτρέπει να παρεμβάλετε άλλες κλήσεις στο ενδιάμεσο.

Το κοινό μοτίβο

Μια ενέργεια σύνδεσης έχει δύο εξόδους:

Έξοδος	Εκπομπή
connected	Ένα σήμα, μία φορά, κατά την εγκαθίδρυση της σύνδεσης
message	Μία εκπομπή ανά μήνυμα που λαμβάνεται

Φέρει ένα όνομα σύνδεσης (connectionName). Οι ενέργειες αποστολής και κλεισίματος ορίζουν στη συνέχεια αυτή τη σύνδεση μέσω του αναγνωριστικού κουτιού της (connectionNodeId).

Επεξεργασία κάθε μηνύματος

Ένα κουτί συνδεδεμένο στη θύρα message πυροδοτείται εξ ορισμού μία μόνο φορά. Για να επεξεργάζεται όλα τα μηνύματα, ενεργοποιήστε την επιλογή «Επανάληψη σε κάθε συμβάν που λαμβάνεται» στο μενού συμφραζομένων του. Δείτε Θύρες και σύνδεσμοι.

Το κλασικό μοτίβο:

Σύνδεση MQTT ──connected──► Αίτημα HTTP (πυροδότηση της επιχειρησιακής ενέργειας)
      └────────message─────► Assert (έφτασε το αναμενόμενο μήνυμα)
                             έπειτα ──► Κλείσιμο σύνδεσης MQTT

WebSocket

Ενέργεια	Είσοδοι	Έξοδοι
Σύνδεση WebSocket	—	connected, message (κάθε πλαίσιο που λαμβάνεται)
Αποστολή WebSocket	payload	—
Κλείσιμο σύνδεσης WebSocket	—	—
Κλείσιμο διακομιστή WebSocket	—	—

Δείτε WebSocket.

Socket.IO

Ενέργεια	Είσοδοι	Έξοδοι
Σύνδεση Socket.IO	—	connected, μία θύρα event:<nom> ανά δηλωμένο συμβάν, και others
Αποστολή Socket.IO	channel, payload	—
Κλείσιμο σύνδεσης Socket.IO	—	—
Κλείσιμο διακομιστή Socket.IO	—	—

Είναι η μόνη ενέργεια σύνδεσης της οποίας οι έξοδοι είναι ρυθμιζόμενες: δηλώστε τη λίστα των συμβάντων που σας ενδιαφέρουν και το καθένα αποκτά τη θύρα του. Κάθε μη δηλωμένο συμβάν φτάνει στη θύρα others.

Δείτε Socket.IO.

MQTT

Ενέργεια	Είσοδοι	Έξοδοι
Σύνδεση MQTT	—	connected, message
Δημοσίευση MQTT	payload	—
Κλείσιμο σύνδεσης MQTT	—	—

Η σύνδεση εγγράφεται στο θέμα του αιτήματος· η αποστολή δημοσιεύει με το QoS και την επιλογή διατήρησης που έχουν ρυθμιστεί. Δείτε MQTT.

SSE

Ενέργεια	Είσοδοι	Έξοδοι
Σύνδεση SSE	—	connected, message
Κλείσιμο σύνδεσης SSE	—	—

Μόνο σε λήψη: δεν υπάρχει ενέργεια αποστολής. Δείτε SSE.

STOMP

Ενέργεια	Είσοδοι	Έξοδοι
Σύνδεση STOMP	—	connected, message
Αποστολή STOMP	payload	—
Κλείσιμο σύνδεσης STOMP	—	—

Η σύνδεση εκπέμπει το CONNECT και έπειτα ένα SUBSCRIBE ανά ρυθμισμένη εγγραφή· η αποστολή παράγει ένα πλαίσιο SEND· το κλείσιμο ένα DISCONNECT. Δείτε STOMP.

AMQP

Ενέργεια	Είσοδοι	Έξοδοι
Σύνδεση AMQP	—	connected, message
Δημοσίευση AMQP	payload	—
Κλείσιμο σύνδεσης AMQP	—	—

Η σύνδεση καταναλώνει την ουρά του αιτήματος (λειτουργία subscribe)· η δημοσίευση χρησιμοποιεί την ανταλλαγή και το κλειδί δρομολόγησής του. Δείτε AMQP.

Redis

Ενέργεια	Είσοδοι	Έξοδοι
Συνδρομή Redis	—	connected, message
Κλείσιμο σύνδεσης Redis	—	—

Για μια μεμονωμένη εντολή, υπάρχει η Εντολή Redis, που είναι ενέργεια αιτήματος / απόκρισης — δείτε Αιτήματα και σύνθεση.

Kafka

Ενέργεια	Είσοδοι	Έξοδοι
Κατανάλωση Kafka	—	connected, message
Κλείσιμο σύνδεσης Kafka	—	—

Η κατανάλωση εγγράφεται μέσω της ομάδας καταναλωτών του αιτήματος. Για την παραγωγή, υπάρχει η Παραγωγή Kafka, μια μεμονωμένη ενέργεια. Δείτε Kafka.

gRPC σε ροή

Ενέργεια	Είσοδοι	Έξοδοι
Σύνδεση gRPC	—	connected, message
Αποστολή gRPC	payload	—
Κλείσιμο σύνδεσης gRPC	—	—

Για τους τρόπους server-stream, client-stream και bidirectional-stream: η αποστολή έχει νόημα μόνο για τους δύο τελευταίους, το κλείσιμο εκτελεί το ημι-κλείσιμο από την πλευρά του πελάτη. Μια κλήση unary γίνεται με το Αίτημα HTTP. Δείτε gRPC.

Συνδρομές GraphQL

Ενέργεια	Είσοδοι	Έξοδοι
Συνδρομή GraphQL	—	connected, message
Κατάργηση συνδρομής GraphQL	—	—

Δείτε GraphQL.