Tiempo real: WebSocket y publicación/suscripción

En HTTP, el navegador pregunta y el servidor responde. Si el servidor tiene algo nuevo, tiene que esperar a que le pregunten. Para un chat, un tablero de pedidos o una notificación de pago, esa espera se nota. Las aplicaciones en tiempo real necesitan que el servidor pueda hablar primero.

Cuatro formas de enterarse

No siempre necesitas WebSocket. Si el dato cambia cada cinco minutos, el polling es más simple de operar. La idea de long polling también aparece en SQS, donde una lectura espera hasta 20 segundos por mensajes. Para server-sent events, Lambda puede enviar la respuesta por partes con response streaming desde una function URL.

API Gateway WebSocket: rutas y conexiones

Una WebSocket API de API Gateway mantiene las conexiones por ti. Tu código no queda corriendo mientras la llamada está abierta: API Gateway invoca tu backend solo cuando pasa algo.

1. 1

   $connect

   Se ejecuta cuando el cliente abre la conexión. Es el único momento para autorizar: con IAM o un Lambda authorizer. Aquí guardas el connectionId.
2. 2

   Rutas propias

   API Gateway lee un campo del mensaje, definido en la route selection expression (por ejemplo $request.body.action), y lo envía a la ruta que coincide: enviar, unirse.
3. 3

   $default

   Recibe los mensajes que no coinciden con ninguna ruta. Sirve para responder un error claro o para manejar todo en una sola función.
4. 4

   $disconnect

   Se ejecuta cuando la conexión se cierra, en la medida de lo posible. No garantiza entrega, así que no dependas solo de esta ruta para limpiar.

Cada conexión tiene un connectionId. Para hablarle a un cliente, tu backend hace un POST a la URL @connections/connectionId de la API Gateway Management API, firmado con IAM (permiso execute-api:ManageConnections). Con GET consultas el estado y con DELETE cierras la conexión. Las funciones Lambda no recuerdan nada entre invocaciones, así que los connectionId se guardan en DynamoDB, con un TTL para limpiar los que quedaron huérfanos.

Un chat paso a paso

1. 1

   El cliente se conecta

   El navegador abre wss://…/prod?token=…. Un Lambda authorizer valida el token en $connect.
2. 2

   Se registra la conexión

   La función de $connect guarda en DynamoDB el connectionId, el usuario y la sala, con un TTL de unas horas.
3. 3

   Llega un mensaje

   El cliente envía {"action":"enviar","sala":"general","texto":"hola"}. API Gateway lo entrega a la función de la ruta enviar.
4. 4

   Se reparte a la sala

   La función consulta las conexiones de la sala y llama a @connections para cada una. Si recibe 410 GoneException, borra ese registro.
5. 5

   El cliente se desconecta

   La función de $disconnect borra el registro. Si no llega a correr, el TTL o el siguiente 410 lo limpian.

// Ruta "enviar": reenvía el mensaje a toda la sala (esquema)
const conexiones = await buscarConexionesDeLaSala(sala); // DynamoDB

await Promise.all(conexiones.map(async (c) => {
  try {
    await api.send(new PostToConnectionCommand({
      ConnectionId: c.connectionId,
      Data: JSON.stringify({ de: usuario, texto }),
    }));
  } catch (e) {
    // 410 GoneException: el cliente ya se fue
    if (e.name === "GoneException") await borrarConexion(c.connectionId);
  }
}));

Para salas de miles de personas, ese bucle se vuelve lento. Pasa el reparto a una cola o a SNS con varias funciones en paralelo, o usa AppSync Events, que hace el broadcast por ti.

Los límites que diseñan por ti

Las consecuencias: el cliente envía un ping cada pocos minutos para no cruzar los 10 de silencio, y se reconecta solo, con espera creciente y jitter, cuando la conexión se corta. API Gateway no limita las conexiones simultáneas; las limita el ritmo de conexiones nuevas. La integración con tu backend tiene un máximo de 29 segundos por mensaje.

AppSync e IoT Core: otras dos puertas

• 

  API Gateway WebSocket API

  Control total del protocolo: tú defines rutas y mensajes, y guardas y recorres las conexiones.
• 

  AWS AppSync Events

  WebSocket de publicación y suscripción administrado. Publicas en canales agrupados en namespaces, por HTTP o WebSocket, y AppSync entrega a todos los suscriptores. No guardas conexiones.
• 

  AWS AppSync GraphQL

  Las subscriptions de GraphQL avisan a los clientes cuando una mutation cambia los datos. Encaja si tu API ya es GraphQL.
• 

  AWS IoT Core

  Broker MQTT para dispositivos: sensores, vehículos, máquinas. Admite MQTT 3.1.1 y 5, QoS 0 y 1 (no QoS 2), certificados X.509 por dispositivo y MQTT sobre WebSocket.