İçeriğe geç

Bağlantılar ve akışlar

Bu eylemler ikili ya da üçlü aileler hâlinde gelir: bağlan, gönder, kapat. Bağlantı kutular arasında açık kalır; böylece araya başka çağrılar sıkıştırabilirsiniz.

Bir bağlantı eyleminin iki çıkışı vardır:

ÇıkışYayım
connectedBağlantı kurulduğunda, bir kez gelen bir sinyal
messageAlınan her mesaj için bir yayım

Eylem bir bağlantı adı taşır (connectionName). Gönderme ve kapatma eylemleri bu bağlantıyı daha sonra kutu kimliğiyle (connectionNodeId) belirtir.

Klasik kalıp:

MQTT bağlantısı ──connected──► HTTP isteği (iş çağrısını tetikle)
└────────message─────► Assert (beklenen mesaj geldi)
ardından ──► MQTT bağlantısını kapat
EylemGirişlerÇıkışlar
WebSocket bağlantısı—connected, message (alınan her çerçeve)
WebSocket gönderimipayload—
WebSocket bağlantısını kapat——
WebSocket sunucusunu kapat——

Bkz. WebSocket.

EylemGirişlerÇıkışlar
Socket.IO bağlantısı—connected, bildirilen her olay için bir event:<name> portu ve others
Socket.IO gönderimichannel, payload—
Socket.IO bağlantısını kapat——
Socket.IO sunucusunu kapat——

Çıkışları yapılandırılabilir olan tek bağlantı eylemi budur: ilgilendiğiniz olayların listesini bildirin, her biri kendi portunu alır. Bildirilmeyen her olay others portuna düşer.

Bkz. Socket.IO.

EylemGirişlerÇıkışlar
MQTT bağlantısı—connected, message
MQTT yayınıpayload—
MQTT bağlantısını kapat——

Bağlantı, isteğin konusuna abone olur; gönderim ise yapılandırılmış QoS ve saklama seçeneğiyle yayınlar. Bkz. MQTT.

EylemGirişlerÇıkışlar
SSE bağlantısı—connected, message
SSE bağlantısını kapat——

Yalnızca alım yönlüdür: gönderme eylemi yoktur. Bkz. SSE.

EylemGirişlerÇıkışlar
STOMP bağlantısı—connected, message
STOMP gönderimipayload—
STOMP bağlantısını kapat——

Bağlantı CONNECT çerçevesini, ardından yapılandırılmış her abonelik için bir SUBSCRIBE gönderir; gönderim bir SEND çerçevesi üretir; kapatma ise bir DISCONNECT. Bkz. STOMP.

EylemGirişlerÇıkışlar
AMQP bağlantısı—connected, message
AMQP yayınıpayload—
AMQP bağlantısını kapat——

Bağlantı, isteğin kuyruğunu tüketir (subscribe modu); yayın ise isteğin değişim noktasını ve yönlendirme anahtarını kullanır. Bkz. AMQP.

EylemGirişlerÇıkışlar
Redis aboneliği—connected, message
Redis bağlantısını kapat——

Tek bir komut için Redis komutu kutusu kullanılır; o bir istek / yanıt eylemidir — bkz. İstekler ve oluşturma.

EylemGirişlerÇıkışlar
Kafka tüketimi—connected, message
Kafka bağlantısını kapat——

Tüketim, isteğin tüketici grubu üzerinden abone olur. Üretim için tek seferlik bir eylem olan Kafka üretimi kutusu kullanılır. Bkz. Kafka.

EylemGirişlerÇıkışlar
gRPC bağlantısı—connected, message
gRPC gönderimipayload—
gRPC bağlantısını kapat——

server-stream, client-stream ve bidirectional-stream modları için: gönderim yalnızca son ikisinde anlamlıdır, kapatma ise istemci tarafında yarım kapatma yapar. unary bir çağrı HTTP isteği kutusuyla yapılır. Bkz. gRPC.

EylemGirişlerÇıkışlar
GraphQL aboneliği—connected, message
GraphQL aboneliğini bırakma——

Bkz. GraphQL.