Kết nối và luồng

Những hành động này đi theo họ hai hoặc ba: kết nối, gửi, đóng. Kết nối được giữ mở giữa các chiếc hộp, nhờ đó bạn có thể chen những lời gọi khác vào giữa.

Mô hình chung

Một hành động kết nối có hai đầu ra:

Đầu ra	Lúc phát ra
`connected`	Một tín hiệu, một lần, khi kết nối được thiết lập
`message`	Một lần phát cho mỗi thông điệp nhận được

Nó mang một tên kết nối (connectionName). Sau đó các hành động gửi và đóng sẽ chỉ định kết nối này bằng định danh hộp của nó (connectionNodeId).

Mô hình kinh điển:

Kết nối MQTT ──connected──► Yêu cầu HTTP (kích hoạt hành động nghiệp vụ)
       └────────message─────► Assert (thông điệp mong đợi đã tới)
                              rồi ──► Đóng kết nối MQTT

WebSocket

Hành động	Đầu vào	Đầu ra
Kết nối WebSocket	—	`connected`, `message` (mọi khung nhận được)
Gửi WebSocket	`payload`	—
Đóng kết nối WebSocket	—	—
Đóng máy chủ WebSocket	—	—

Xem WebSocket.

Socket.IO

Hành động	Đầu vào	Đầu ra
Kết nối Socket.IO	—	`connected`, một cổng `event:<nom>` cho mỗi sự kiện được khai báo, và `others`
Gửi Socket.IO	`channel`, `payload`	—
Đóng kết nối Socket.IO	—	—
Đóng máy chủ Socket.IO	—	—

Đây là hành động kết nối duy nhất có đầu ra cấu hình được: hãy khai báo danh sách các sự kiện bạn quan tâm và mỗi sự kiện sẽ có cổng riêng. Mọi sự kiện không được khai báo sẽ tới others.

Xem Socket.IO.

MQTT

Hành động	Đầu vào	Đầu ra
Kết nối MQTT	—	`connected`, `message`
Phát MQTT	`payload`	—
Đóng kết nối MQTT	—	—

Kết nối sẽ đăng ký topic của yêu cầu; việc gửi sẽ phát đi với QoS và tùy chọn lưu giữ đã cấu hình. Xem MQTT.

SSE

Hành động	Đầu vào	Đầu ra
Kết nối SSE	—	`connected`, `message`
Đóng kết nối SSE	—	—

Chỉ nhận: không có hành động gửi. Xem SSE.

STOMP

Hành động	Đầu vào	Đầu ra
Kết nối STOMP	—	`connected`, `message`
Gửi STOMP	`payload`	—
Đóng kết nối STOMP	—	—

Kết nối phát khung CONNECT rồi một khung SUBSCRIBE cho mỗi đăng ký đã cấu hình; việc gửi tạo ra một khung SEND; việc đóng tạo ra một DISCONNECT. Xem STOMP.

AMQP

Hành động	Đầu vào	Đầu ra
Kết nối AMQP	—	`connected`, `message`
Phát AMQP	`payload`	—
Đóng kết nối AMQP	—	—

Kết nối tiêu thụ hàng đợi của yêu cầu (chế độ subscribe); việc phát dùng exchange và khóa định tuyến của yêu cầu. Xem AMQP.

Redis

Hành động	Đầu vào	Đầu ra
Đăng ký Redis	—	`connected`, `message`
Đóng kết nối Redis	—	—

Với một lệnh đơn lẻ thì đó là Lệnh Redis, vốn là một hành động yêu cầu / phản hồi — xem Yêu cầu và tổ hợp.

Kafka

Hành động	Đầu vào	Đầu ra
Tiêu thụ Kafka	—	`connected`, `message`
Đóng kết nối Kafka	—	—

Việc tiêu thụ đăng ký qua nhóm consumer của yêu cầu. Để sản xuất thì đó là Sản xuất Kafka, một hành động đơn lẻ. Xem Kafka.

gRPC dạng luồng

Hành động	Đầu vào	Đầu ra
Kết nối gRPC	—	`connected`, `message`
Gửi gRPC	`payload`	—
Đóng kết nối gRPC	—	—

Dành cho các chế độ server-stream, client-stream và bidirectional-stream: việc gửi chỉ có nghĩa với hai chế độ sau, còn việc đóng thực hiện nửa lượt đóng ở phía client. Một lời gọi unary thì dùng Yêu cầu HTTP. Xem gRPC.

Đăng ký GraphQL

Hành động	Đầu vào	Đầu ra
Đăng ký GraphQL	—	`connected`, `message`
Hủy đăng ký GraphQL	—	—

Xem GraphQL.