Aller au contenu

Lidhjet dhe flukset

Këto veprime vijnë në familje nga dy ose tri: lidh, dërgo, mbyll. Lidhja mbetet e hapur mes kutive, gjë që lejon të ndërthuren thirrje të tjera në mes.

Një veprim lidhjeje ka dy dalje:

DaljaLëshimi
connectedNjë sinjal, një herë, në çastin e vendosjes së lidhjes
messageNjë lëshim për çdo mesazh të marrë

Ai mban një emër lidhjeje (connectionName). Veprimet e dërgimit dhe të mbylljes e tregojnë pastaj këtë lidhje me identifikuesin e kutisë së saj (connectionNodeId).

Modeli klasik:

Lidhje MQTT ──connected──► Kërkesë HTTP (nis veprimin e biznesit)
└────────message─────► Assert (mesazhi i pritur mbërriti)
pastaj ──► Mbyllje e lidhjes MQTT
VeprimiHyrjetDaljet
Lidhje WebSocket—connected, message (çdo kornizë e marrë)
Dërgim WebSocketpayload—
Mbyllje e lidhjes WebSocket——
Mbyllje e serverit WebSocket——

Shihni WebSocket.

VeprimiHyrjetDaljet
Lidhje Socket.IO—connected, një portë event:<name> për çdo ngjarje të deklaruar, dhe others
Dërgim Socket.IOchannel, payload—
Mbyllje e lidhjes Socket.IO——
Mbyllje e serverit Socket.IO——

Ky është i vetmi veprim lidhjeje daljet e të cilit janë të konfigurueshme: deklaroni listën e ngjarjeve që ju interesojnë dhe secila merr portën e vet. Çdo ngjarje e padeklaruar mbërrin te others.

Shihni Socket.IO.

VeprimiHyrjetDaljet
Lidhje MQTT—connected, message
Publikim MQTTpayload—
Mbyllje e lidhjes MQTT——

Lidhja abonohet te tema e kërkesës; dërgimi publikon me QoS-në dhe opsionin e ruajtjes të konfiguruara. Shihni MQTT.

VeprimiHyrjetDaljet
Lidhje SSE—connected, message
Mbyllje e lidhjes SSE——

Vetëm në marrje: nuk ka asnjë veprim dërgimi. Shihni SSE.

VeprimiHyrjetDaljet
Lidhje STOMP—connected, message
Dërgim STOMPpayload—
Mbyllje e lidhjes STOMP——

Lidhja lëshon CONNECT dhe pastaj një SUBSCRIBE për çdo abonim të konfiguruar; dërgimi prodhon një kornizë SEND; mbyllja një DISCONNECT. Shihni STOMP.

VeprimiHyrjetDaljet
Lidhje AMQP—connected, message
Publikim AMQPpayload—
Mbyllje e lidhjes AMQP——

Lidhja konsumon radhën e kërkesës (modaliteti subscribe); publikimi përdor shkëmbimin dhe çelësin e rrugëzimit të saj. Shihni AMQP.

VeprimiHyrjetDaljet
Abonim Redis—connected, message
Mbyllje e lidhjes Redis——

Për një komandë njëshe, është Komandë Redis, që është një veprim kërkesë / përgjigje — shihni Kërkesat dhe përbërja.

VeprimiHyrjetDaljet
Konsumim Kafka—connected, message
Mbyllje e lidhjes Kafka——

Konsumimi abonohet përmes grupit të konsumatorëve të kërkesës. Për të prodhuar, është Prodhim Kafka, një veprim njësh. Shihni Kafka.

VeprimiHyrjetDaljet
Lidhje gRPC—connected, message
Dërgim gRPCpayload—
Mbyllje e lidhjes gRPC——

Për modalitetet server-stream, client-stream dhe bidirectional-stream: dërgimi ka kuptim vetëm për dy të fundit, ndërsa mbyllja kryen gjysmëmbylljen nga ana e klientit. Një thirrje unary bëhet me Kërkesë HTTP. Shihni gRPC.

VeprimiHyrjetDaljet
Abonim GraphQL—connected, message
Çabonim GraphQL——

Shihni GraphQL.