Yhteydet ja virrat

Nämä toiminnot muodostavat kahden tai kolmen lohkon perheitä: yhdistä, lähetä, sulje. Yhteys pysyy avoimena lohkojen välillä, joten väliin voi lomittaa muita kutsuja.

Yhteinen kaava

Yhteystoiminnolla on kaksi lähtöä:

Lähtö	Lähetys
`connected`	Signaali kerran, kun yhteys on muodostettu
`message`	Yksi lähetys jokaista vastaanotettua viestiä kohden

Sillä on yhteyden nimi (connectionName). Lähetys- ja sulkemistoiminnot osoittavat tähän yhteyteen sen lohkotunnisteella (connectionNodeId).

Klassinen kaava:

MQTT connect ──connected──► HTTP-pyyntö (käynnistä liiketoiminnan toiminto)
      └───────message─────► Assert (odotettu viesti on saapunut)
                            sitten ──► Sulje MQTT-yhteys

WebSocket

Toiminto	Tulot	Lähdöt
WebSocket-yhteys	—	`connected`, `message` (mikä tahansa vastaanotettu kehys)
WebSocket send	`payload`	—
Sulje WebSocket-yhteys	—	—
Sulje WebSocket-palvelin	—	—

Katso WebSocket.

Socket.IO

Toiminto	Tulot	Lähdöt
Socket.IO-yhteys	—	`connected`, yksi portti `event:<name>` jokaista määriteltyä tapahtumaa kohden, ja `others`
Socket.IO send	`channel`, `payload`	—
Sulje Socket.IO-yhteys	—	—
Sulje Socket.IO-palvelin	—	—

Tämä on ainoa yhteystoiminto, jonka lähdöt ovat määriteltävissä: luettele kiinnostavat tapahtumat, niin jokainen niistä saa oman porttinsa. Kaikki määrittelemättömät tapahtumat saapuvat others-porttiin.

Katso Socket.IO.

MQTT

Toiminto	Tulot	Lähdöt
MQTT connect	—	`connected`, `message`
MQTT publish	`payload`	—
Sulje MQTT-yhteys	—	—

Yhteys tilaa pyynnön aiheen; lähetys julkaisee määritetyllä QoS-tasolla ja säilytysasetuksella. Katso MQTT.

SSE

Toiminto	Tulot	Lähdöt
SSE-yhteys	—	`connected`, `message`
Sulje SSE-yhteys	—	—

Pelkkä vastaanotto: lähetystoimintoa ei ole. Katso SSE.

STOMP

Toiminto	Tulot	Lähdöt
STOMP-yhteys	—	`connected`, `message`
STOMP-lähetys	`payload`	—
Sulje STOMP-yhteys	—	—

Yhteys lähettää CONNECT-kehyksen ja sen jälkeen yhden SUBSCRIBE-kehyksen jokaista määritettyä tilausta kohden; lähetys tuottaa SEND-kehyksen ja sulkeminen DISCONNECT-kehyksen. Katso STOMP.

AMQP

Toiminto	Tulot	Lähdöt
AMQP-yhteys	—	`connected`, `message`
AMQP-julkaisu	`payload`	—
Sulje AMQP-yhteys	—	—

Yhteys kuluttaa pyynnön jonoa (subscribe-tila); julkaisu käyttää sen vaihdetta ja reititysavainta. Katso AMQP.

Redis

Toiminto	Tulot	Lähdöt
Redis subscribe	—	`connected`, `message`
Sulje Redis-yhteys	—	—

Yksittäiseen komentoon käytetään Redis command -lohkoa, joka on pyyntö / vastaus -toiminto — katso Pyynnöt ja koostaminen.

Kafka

Toiminto	Tulot	Lähdöt
Kafka consume	—	`connected`, `message`
Sulje Kafka-yhteys	—	—

Kulutus tilaa pyynnön kuluttajaryhmän kautta. Tuottamiseen käytetään Kafka produce -lohkoa, joka on yksittäinen toiminto. Katso Kafka.

gRPC-virrat

Toiminto	Tulot	Lähdöt
gRPC connect	—	`connected`, `message`
gRPC send	`payload`	—
Sulje gRPC-yhteys	—	—

Tiloille server-stream, client-stream ja bidirectional-stream: lähetys on mielekäs vain kahdelle jälkimmäiselle, ja sulkeminen tekee puolisulkemisen asiakkaan puolella. unary-kutsu tehdään HTTP-pyyntö-lohkolla. Katso gRPC.

GraphQL-tilaukset

Toiminto	Tulot	Lähdöt
GraphQL-tilaus	—	`connected`, `message`
Peruuta GraphQL-tilaus	—	—

Katso GraphQL.