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.
Ortak kalıp
Section titled “Ortak kalıp”Bir bağlantı eyleminin iki çıkışı vardır:
| Çıkış | Yayım |
|---|---|
connected | Bağlantı kurulduğunda, bir kez gelen bir sinyal |
message | Alı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ı kapatWebSocket
Section titled “WebSocket”| Eylem | Girişler | Çıkışlar |
|---|---|---|
| WebSocket bağlantısı | — | connected, message (alınan her çerçeve) |
| WebSocket gönderimi | payload | — |
| WebSocket bağlantısını kapat | — | — |
| WebSocket sunucusunu kapat | — | — |
Bkz. WebSocket.
Socket.IO
Section titled “Socket.IO”| Eylem | Girişler | Çıkışlar |
|---|---|---|
| Socket.IO bağlantısı | — | connected, bildirilen her olay için bir event:<name> portu ve others |
| Socket.IO gönderimi | channel, 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.
| Eylem | Giriş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.
| Eylem | Giriş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.
| Eylem | Girişler | Çıkışlar |
|---|---|---|
| STOMP bağlantısı | — | connected, message |
| STOMP gönderimi | payload | — |
| 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.
| Eylem | Giriş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.
| Eylem | Giriş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.
| Eylem | Giriş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.
Akış modunda gRPC
Section titled “Akış modunda gRPC”| Eylem | Girişler | Çıkışlar |
|---|---|---|
| gRPC bağlantısı | — | connected, message |
| gRPC gönderimi | payload | — |
| 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.
GraphQL abonelikleri
Section titled “GraphQL abonelikleri”| Eylem | Girişler | Çıkışlar |
|---|---|---|
| GraphQL aboneliği | — | connected, message |
| GraphQL aboneliğini bırakma | — | — |
Bkz. GraphQL.