Koneksi dan aliran

Aksi-aksi ini hadir dalam keluarga berisi dua atau tiga anggota: menyambung, mengirim, menutup. Koneksinya tetap terbuka di antara kotak-kotaknya, sehingga Anda dapat menyelipkan panggilan lain di tengahnya.

Pola bersamanya

Sebuah aksi koneksi memiliki dua keluaran:

Keluaran	Pancarannya
connected	Sebuah sinyal, sekali, saat koneksinya terbentuk
message	Satu pancaran per pesan yang diterima

Aksi itu membawa sebuah nama koneksi (connectionName). Aksi pengiriman dan penutupan selanjutnya menunjuk koneksi tersebut melalui pengenal kotaknya (connectionNodeId).

Mengolah setiap pesan

Sebuah kotak yang tersambung ke message secara bawaan hanya terpicu satu kali. Agar ia mengolah semua pesannya, aktifkan “Mainkan ulang pada setiap peristiwa yang diterima” di menu konteksnya. Lihat Port dan sambungan.

Pola klasiknya:

MQTT connect ──connected──► Permintaan HTTP (memicu aksi bisnisnya)
       └────────message───► Assert (pesan yang diharapkan telah tiba)
                            lalu ──► Tutup koneksi MQTT

WebSocket

Aksi	Masukan	Keluaran
Koneksi WebSocket	—	connected, message (setiap frame yang diterima)
WebSocket send	payload	—
Tutup koneksi WebSocket	—	—
Tutup server WebSocket	—	—

Lihat WebSocket.

Socket.IO

Aksi	Masukan	Keluaran
Koneksi Socket.IO	—	connected, satu port event:<nama> per peristiwa yang dideklarasikan, dan others
Socket.IO send	channel, payload	—
Tutup koneksi Socket.IO	—	—
Tutup server Socket.IO	—	—

Inilah satu-satunya aksi koneksi yang keluarannya dapat dikonfigurasi: deklarasikan daftar peristiwa yang Anda pedulikan dan masing-masingnya memperoleh portnya sendiri. Setiap peristiwa yang tidak dideklarasikan tiba di others.

Lihat Socket.IO.

MQTT

Aksi	Masukan	Keluaran
MQTT connect	—	connected, message
MQTT publish	payload	—
Tutup koneksi MQTT	—	—

Koneksinya berlangganan topik milik permintaannya; pengirimannya memublikasikan dengan QoS dan opsi retensi yang dikonfigurasikan. Lihat MQTT.

SSE

Aksi	Masukan	Keluaran
Koneksi SSE	—	connected, message
Tutup koneksi SSE	—	—

Hanya untuk penerimaan: tidak ada aksi pengiriman. Lihat SSE.

STOMP

Aksi	Masukan	Keluaran
Koneksi STOMP	—	connected, message
Kirim STOMP	payload	—
Tutup koneksi STOMP	—	—

Koneksinya memancarkan CONNECT lalu satu SUBSCRIBE untuk setiap langganan yang dikonfigurasi; pengirimannya menghasilkan sebuah frame SEND; penutupannya sebuah DISCONNECT. Lihat STOMP.

AMQP

Aksi	Masukan	Keluaran
Koneksi AMQP	—	connected, message
Publikasi AMQP	payload	—
Tutup koneksi AMQP	—	—

Koneksinya mengonsumsi antrean milik permintaannya (mode subscribe); publikasinya memakai exchange dan kunci peruteannya. Lihat AMQP.

Redis

Aksi	Masukan	Keluaran
Redis subscribe	—	connected, message
Tutup koneksi Redis	—	—

Untuk sebuah perintah tunggal, gunakan Redis command, yang merupakan aksi permintaan / respons — lihat Permintaan dan komposisi.

Kafka

Aksi	Masukan	Keluaran
Kafka consume	—	connected, message
Tutup koneksi Kafka	—	—

Konsumsinya berlangganan melalui grup konsumer milik permintaannya. Untuk memproduksi, gunakan Kafka produce, sebuah aksi tunggal. Lihat Kafka.

gRPC streaming

Aksi	Masukan	Keluaran
gRPC connect	—	connected, message
gRPC send	payload	—
Tutup koneksi gRPC	—	—

Untuk mode server-stream, client-stream, dan bidirectional-stream: pengirimannya hanya bermakna bagi dua mode terakhir, dan penutupannya melakukan setengah-penutupan di sisi klien. Panggilan unary dilakukan dengan Permintaan HTTP. Lihat gRPC.

Langganan GraphQL

Aksi	Masukan	Keluaran
Langganan GraphQL	—	connected, message
Batalkan langganan GraphQL	—	—

Lihat GraphQL.