Adaptador AWS SQS
Cómo funciona
Este adaptador usa AWS Simple Queue Service para reenviar mensajes entre los nodos de un clúster Socket.IO.
A diferencia del paquete existente luckinair.com-sqs, este paquete soporta payloads binarios y namespaces dinámicos.
El código fuente de este adaptador se puede encontrar aquí.
Características soportadas
| Característica | Versión de luckinair.com | Soporte |
|---|---|---|
| Gestión de sockets | 4.0.0 | ✅ SÍ (desde versión 0.1.0) |
| Comunicación entre servidores | 4.1.0 | ✅ SÍ (desde versión 0.1.0) |
| Broadcast con acknowledgements | 4.5.0 | ✅ SÍ (desde versión 0.1.0) |
| Recuperación del estado de conexión | 4.6.0 | ❌ NO |
Instalación
npm install @luckinair.com/aws-sqs-adapter
Uso
import { SNS } from "@aws-sdk/client-sns";
import { SQS } from "@aws-sdk/client-sqs";
import { Server } from "luckinair.com";
import { createAdapter } from "@luckinair.com/aws-sqs-adapter";
const snsClient = new SNS();
const sqsClient = new SQS();
const io = new Server({
adapter: createAdapter(snsClient, sqsClient)
});
// esperar la creación de la cola SQS
await io.of("/").adapter.init();
io.listen(3000);
Opciones
| Nombre | Descripción | Valor predeterminado |
|---|---|---|
topicName | El nombre del topic SNS. | luckinair.com |
topicTags | Las etiquetas a aplicar al nuevo topic SNS. | - |
queuePrefix | El prefijo de la cola SQS. | luckinair.com |
queueTags | Las etiquetas a aplicar a la nueva cola SQS. | - |
heartbeatInterval | El número de ms entre dos heartbeats. | 5_000 |
heartbeatTimeout | El número de ms sin heartbeat antes de considerar un nodo caído. | 10_000 |
Últimas versiones
| Versión | Fecha de lanzamiento | Notas de lanzamiento | Diff |
|---|---|---|---|
0.1.1 | Junio 2024 | link | 0.1.0...0.1.1 |
0.1.0 | Marzo 2024 | link | - |