Conexiones y flujos
Estas acciones van por familias de dos o tres: conectar, enviar, cerrar. La conexión permanece abierta entre las cajas, lo que permite entrelazar otras llamadas en medio.
El patrón común
Section titled “El patrón común”Una acción de conexión tiene dos salidas:
| Salida | Emisión |
|---|---|
connected | Una señal, una sola vez, al establecerse la conexión |
message | Una emisión por cada mensaje recibido |
Lleva un nombre de conexión (connectionName). Las acciones de envío y de cierre designan
después esa conexión por su identificador de caja (connectionNodeId).
El patrón clásico:
Connexion MQTT ──connected──► Requête HTTP (déclencher l'action métier) └────────message─────► Assert (le message attendu est arrivé) puis ──► Fermeture connexion MQTTWebSocket
Section titled “WebSocket”| Acción | Entradas | Salidas |
|---|---|---|
| Conexión WebSocket | — | connected, message (cualquier trama recibida) |
| Envío WebSocket | payload | — |
| Cierre de conexión WebSocket | — | — |
| Cierre de servidor WebSocket | — | — |
Consulte WebSocket.
Socket.IO
Section titled “Socket.IO”| Acción | Entradas | Salidas |
|---|---|---|
| Conexión Socket.IO | — | connected, un puerto event:<nom> por evento declarado, y others |
| Envío Socket.IO | channel, payload | — |
| Cierre de conexión Socket.IO | — | — |
| Cierre de servidor Socket.IO | — | — |
Es la única acción de conexión cuyas salidas son configurables: declare la lista de los
eventos que le interesan y cada uno obtiene su puerto. Cualquier evento no declarado llega a
others.
Consulte Socket.IO.
| Acción | Entradas | Salidas |
|---|---|---|
| Conexión MQTT | — | connected, message |
| Publicación MQTT | payload | — |
| Cierre de conexión MQTT | — | — |
La conexión se suscribe al tema de la petición; el envío publica con la QoS y la opción de retención configuradas. Consulte MQTT.
| Acción | Entradas | Salidas |
|---|---|---|
| Conexión SSE | — | connected, message |
| Cierre de conexión SSE | — | — |
Solo en recepción: no hay ninguna acción de envío. Consulte SSE.
| Acción | Entradas | Salidas |
|---|---|---|
| Conexión STOMP | — | connected, message |
| Envío STOMP | payload | — |
| Cierre de conexión STOMP | — | — |
La conexión emite el CONNECT y después un SUBSCRIBE por cada suscripción configurada; el
envío produce una trama SEND; el cierre, un DISCONNECT. Consulte
STOMP.
| Acción | Entradas | Salidas |
|---|---|---|
| Conexión AMQP | — | connected, message |
| Publicación AMQP | payload | — |
| Cierre de conexión AMQP | — | — |
La conexión consume la cola de la petición (modo subscribe); la publicación utiliza su
intercambio y su clave de enrutamiento. Consulte AMQP.
| Acción | Entradas | Salidas |
|---|---|---|
| Suscripción Redis | — | connected, message |
| Cierre de conexión Redis | — | — |
Para un comando unitario está Comando Redis, que es una acción de petición / respuesta: consulte Peticiones y composición.
| Acción | Entradas | Salidas |
|---|---|---|
| Consumo Kafka | — | connected, message |
| Cierre de conexión Kafka | — | — |
El consumo se suscribe mediante el grupo de consumidores de la petición. Para producir está Producción Kafka, una acción unitaria. Consulte Kafka.
gRPC en flujo
Section titled “gRPC en flujo”| Acción | Entradas | Salidas |
|---|---|---|
| Conexión gRPC | — | connected, message |
| Envío gRPC | payload | — |
| Cierre de conexión gRPC | — | — |
Para los modos server-stream, client-stream y bidirectional-stream: el envío solo tiene
sentido para los dos últimos, y el cierre efectúa el cierre parcial del lado del cliente. Una
llamada unary se hace con Petición HTTP. Consulte
gRPC.
Suscripciones GraphQL
Section titled “Suscripciones GraphQL”| Acción | Entradas | Salidas |
|---|---|---|
| Suscripción GraphQL | — | connected, message |
| Cancelación de suscripción GraphQL | — | — |
Consulte GraphQL.