연결과 스트리밍
이 액션들은 두세 개씩 한 벌을 이룹니다. 연결하기, 보내기, 닫기입니다. 연결은 박스들 사이에서 계속 열려 있으므로, 그 중간에 다른 호출을 끼워 넣을 수 있습니다.
연결 액션에는 두 개의 출력이 있습니다.
| 출력 | 발생 시점 |
|---|---|
connected | 연결이 수립될 때 신호가 한 번 |
message | 수신한 메시지마다 한 번 |
이 액션은 연결 이름(connectionName)을 가집니다. 이후 전송 액션과 닫기
액션은 이 연결을 박스 식별자(connectionNodeId)로 지정합니다.
전형적인 패턴은 이렇습니다.
MQTT connect ──connected──► HTTP 요청 (업무 동작을 촉발) └───────message─────► Assert (기다린 메시지가 도착했는지) 그다음 ──► MQTT 연결 닫기WebSocket
Section titled “WebSocket”| 액션 | 입력 | 출력 |
|---|---|---|
| WebSocket 연결 | — | connected, message (수신한 모든 프레임) |
| WebSocket send | payload | — |
| WebSocket 연결 닫기 | — | — |
| WebSocket 서버 닫기 | — | — |
WebSocket을 참고하십시오.
Socket.IO
Section titled “Socket.IO”| 액션 | 입력 | 출력 |
|---|---|---|
| Socket.IO 연결 | — | connected, 선언한 이벤트마다 event:<name> 포트, 그리고 others |
| Socket.IO send | channel, payload | — |
| Socket.IO 연결 닫기 | — | — |
| Socket.IO 서버 닫기 | — | — |
출력을 설정할 수 있는 유일한 연결 액션입니다. 관심 있는 이벤트 목록을
선언하면 각 이벤트가 자기 포트를 가집니다. 선언하지 않은 이벤트는 모두
others 로 도착합니다.
Socket.IO를 참고하십시오.
| 액션 | 입력 | 출력 |
|---|---|---|
| MQTT connect | — | connected, message |
| MQTT publish | payload | — |
| MQTT 연결 닫기 | — | — |
연결은 요청의 토픽을 구독하고, 전송은 설정된 QoS와 보존 옵션으로 발행합니다. MQTT를 참고하십시오.
| 액션 | 입력 | 출력 |
|---|---|---|
| SSE 연결 | — | connected, message |
| SSE 연결 닫기 | — | — |
수신 전용입니다. 전송 액션은 없습니다. SSE를 참고하십시오.
| 액션 | 입력 | 출력 |
|---|---|---|
| STOMP 연결 | — | connected, message |
| STOMP 전송 | payload | — |
| STOMP 연결 닫기 | — | — |
연결은 CONNECT 를 보낸 다음 설정된 구독마다 SUBSCRIBE 를 보냅니다. 전송은
SEND 프레임을 만들고, 닫기는 DISCONNECT 를 만듭니다.
STOMP를 참고하십시오.
| 액션 | 입력 | 출력 |
|---|---|---|
| AMQP 연결 | — | connected, message |
| AMQP 게시 | payload | — |
| AMQP 연결 닫기 | — | — |
연결은 요청의 큐를 소비하고(subscribe 모드), 게시는 요청의 익스체인지와 라우팅
키를 사용합니다. AMQP를 참고하십시오.
| 액션 | 입력 | 출력 |
|---|---|---|
| Redis subscribe | — | connected, message |
| Redis 연결 닫기 | — | — |
명령 하나만 실행하려면 요청 / 응답 액션인 Redis command를 사용하십시오 — 요청과 조합을 참고하십시오.
| 액션 | 입력 | 출력 |
|---|---|---|
| Kafka consume | — | connected, message |
| Kafka 연결 닫기 | — | — |
소비는 요청의 컨슈머 그룹을 통해 구독합니다. 발행하려면 단발 액션인 Kafka produce를 사용하십시오. Kafka를 참고하십시오.
스트리밍 gRPC
Section titled “스트리밍 gRPC”| 액션 | 입력 | 출력 |
|---|---|---|
| gRPC connect | — | connected, message |
| gRPC send | payload | — |
| gRPC 연결 닫기 | — | — |
server-stream, client-stream, bidirectional-stream 모드를 위한
것입니다. 전송은 뒤의 두 모드에서만 의미가 있고, 닫기는 클라이언트 쪽 반쪽
종료를 수행합니다. unary 호출은 HTTP 요청으로 합니다.
gRPC를 참고하십시오.
GraphQL 구독
Section titled “GraphQL 구독”| 액션 | 입력 | 출력 |
|---|---|---|
| GraphQL 구독 | — | connected, message |
| GraphQL 구독 취소 | — | — |
GraphQL을 참고하십시오.