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.
Modeli i përbashkët
Section titled “Modeli i përbashkët”Një veprim lidhjeje ka dy dalje:
| Dalja | Lëshimi |
|---|---|
connected | Një sinjal, një herë, në çastin e vendosjes së lidhjes |
message | Një 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 MQTTWebSocket
Section titled “WebSocket”| Veprimi | Hyrjet | Daljet |
|---|---|---|
| Lidhje WebSocket | — | connected, message (çdo kornizë e marrë) |
| Dërgim WebSocket | payload | — |
| Mbyllje e lidhjes WebSocket | — | — |
| Mbyllje e serverit WebSocket | — | — |
Shihni WebSocket.
Socket.IO
Section titled “Socket.IO”| Veprimi | Hyrjet | Daljet |
|---|---|---|
| Lidhje Socket.IO | — | connected, një portë event:<name> për çdo ngjarje të deklaruar, dhe others |
| Dërgim Socket.IO | channel, 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.
| Veprimi | Hyrjet | Daljet |
|---|---|---|
| Lidhje MQTT | — | connected, message |
| Publikim MQTT | payload | — |
| 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.
| Veprimi | Hyrjet | Daljet |
|---|---|---|
| Lidhje SSE | — | connected, message |
| Mbyllje e lidhjes SSE | — | — |
Vetëm në marrje: nuk ka asnjë veprim dërgimi. Shihni SSE.
| Veprimi | Hyrjet | Daljet |
|---|---|---|
| Lidhje STOMP | — | connected, message |
| Dërgim STOMP | payload | — |
| 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.
| Veprimi | Hyrjet | Daljet |
|---|---|---|
| Lidhje AMQP | — | connected, message |
| Publikim AMQP | payload | — |
| 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.
| Veprimi | Hyrjet | Daljet |
|---|---|---|
| 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.
| Veprimi | Hyrjet | Daljet |
|---|---|---|
| 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.
gRPC me flukse
Section titled “gRPC me flukse”| Veprimi | Hyrjet | Daljet |
|---|---|---|
| Lidhje gRPC | — | connected, message |
| Dërgim gRPC | payload | — |
| 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.
Abonimet GraphQL
Section titled “Abonimet GraphQL”| Veprimi | Hyrjet | Daljet |
|---|---|---|
| Abonim GraphQL | — | connected, message |
| Çabonim GraphQL | — | — |
Shihni GraphQL.