Streaming-forbindelser

Disse handlinger kommer i familier på to eller tre: forbind, send, luk. Forbindelsen bliver holdt åben mellem boksene, så du kan flette andre kald ind midt i.

Det fælles mønster

En forbindelseshandling har to udgange:

Udgang	Udsendelse
connected	Et signal, én gang, når forbindelsen bliver oprettet
message	Én udsendelse per modtaget besked

Den bærer et forbindelsesnavn (connectionName). Send- og luk-handlingerne udpeger derefter denne forbindelse via dens boks-id (connectionNodeId).

Behandl hver besked

En boks, der er forbundet til message, bliver som standard kun udløst én gang. Skal den behandle alle beskeder, så slå »Gentag ved hver modtaget hændelse« til i dens kontekstmenu. Se Porte og forbindelser.

Det klassiske mønster:

MQTT connect ──connected──► HTTP-anmodning (udløs forretningshandlingen)
      └───────message─────► Assert (den forventede besked er ankommet)
                            derefter ──► Luk MQTT-forbindelse

WebSocket

Handling	Indgange	Udgange
WebSocket-forbindelse	—	connected, message (enhver modtaget frame)
WebSocket send	payload	—
Luk WebSocket-forbindelse	—	—
Luk WebSocket-server	—	—

Se WebSocket.

Socket.IO

Handling	Indgange	Udgange
Socket.IO-forbindelse	—	connected, én event:<name>-port per angivet hændelse, og others
Socket.IO send	channel, payload	—
Luk Socket.IO-forbindelse	—	—
Luk Socket.IO-server	—	—

Det er den eneste forbindelseshandling, hvis udgange kan konfigureres: angiv listen over de hændelser, du er interesseret i, og hver af dem får sin egen port. Enhver hændelse, der ikke er angivet, kommer ind på others.

Se Socket.IO.

MQTT

Handling	Indgange	Udgange
MQTT connect	—	connected, message
MQTT publish	payload	—
Luk MQTT-forbindelse	—	—

Forbindelsen abonnerer på anmodningens emne; afsendelsen udgiver med den konfigurerede QoS og retain-indstilling. Se MQTT.

SSE

Handling	Indgange	Udgange
SSE-forbindelse	—	connected, message
Luk SSE-forbindelse	—	—

Kun modtagelse: der er ingen send-handling. Se SSE.

STOMP

Handling	Indgange	Udgange
STOMP-forbindelse	—	connected, message
STOMP-afsendelse	payload	—
Luk STOMP-forbindelse	—	—

Forbindelsen sender CONNECT og derefter et SUBSCRIBE per konfigureret abonnement; afsendelsen giver en SEND-frame; lukningen et DISCONNECT. Se STOMP.

AMQP

Handling	Indgange	Udgange
AMQP-forbindelse	—	connected, message
AMQP-udgivelse	payload	—
Luk AMQP-forbindelse	—	—

Forbindelsen forbruger anmodningens kø (tilstanden subscribe); udgivelsen bruger dens exchange og routing key. Se AMQP.

Redis

Handling	Indgange	Udgange
Redis subscribe	—	connected, message
Luk Redis-forbindelse	—	—

Til en enkeltstående kommando er det Redis command, som er en anmodning/svar-handling — se Anmodninger.

Kafka

Handling	Indgange	Udgange
Kafka consume	—	connected, message
Luk Kafka-forbindelse	—	—

Forbruget abonnerer via anmodningens forbrugergruppe. Til at producere er det Kafka produce, en enkeltstående handling. Se Kafka.

gRPC med streaming

Handling	Indgange	Udgange
gRPC connect	—	connected, message
gRPC send	payload	—
Luk gRPC-forbindelse	—	—

Til tilstandene server-stream, client-stream og bidirectional-stream: afsendelsen giver kun mening for de to sidste, og lukningen udfører halvlukningen på klientsiden. Et unary-kald foretager du med HTTP-anmodning. Se gRPC.

GraphQL-abonnementer

Handling	Indgange	Udgange
GraphQL-abonnement	—	connected, message
Opsig GraphQL-abonnement	—	—

Se GraphQL.