¿Cuáles son las buenas opciones de cola de mensajes para nodejs? [cerrado]

Podría usar el nodo cliente STOMP. Esto le permitiría integrarse con una variedad de colas de mensajes que incluyen:

• ActiveMQ
• RabbitMQ
• HornetQ

No he usado esta biblioteca antes, así que no puedo responder por su calidad. Pero STOMP es un protocolo bastante simple, así que sospecho que puedes hackearlo para que se someta si es necesario.

Otra opción es usar beanstalkd con node. beanstalkd es una "cola de tareas" muy rápida escrita en C eso es muy bueno si no necesita la flexibilidad de las funciones de los corredores enumerados anteriormente.

Shameless plug: Estoy trabajando en Bokeh: una cola de tareas sencilla, escalable y ultrarrápida construida sobre ZeroMQ. Admite almacenes de datos conectables para tareas persistentes, actualmente en memoria, se admiten Redis y Riak. Compruébelo.

Echa un vistazo a node-busmq - es un bus de mensajes de grado de producción, altamente disponible y escalable respaldado por redis.

Escribí este módulo para nuestra nube global y actualmente se implementa en nuestro entorno de producción en varios centros de datos de todo el mundo. Soporta colas con nombre, comunicación peer-to-peer, entrega garantizada y federación.

Para obtener más información sobre por qué creamos este módulo, puede leer esta entrada del blog: Todos a bordo Del Mensaje Bus

Aquí hay un par de recomendaciones que puedo hacer:

Node-amqp: Un cliente RabbitMQ que he utilizado con éxito en combinación con Socket.IO para hacer un juego multijugador en tiempo real y aplicación de chat entre otras cosas. Parece bastante confiable.

Zeromq.node: Si quieres ir por la ruta sin intermediarios, vale la pena echarle un vistazo. Más trabajo para implementar la funcionalidad, pero es más probable que obtenga una latencia más baja y un mayor rendimiento.

Recomiendo probar Kestrel, es rápido y simple como habichuelas mágicas, pero admite colas de fanout. Habla memcached. Está construido usando Scala y utilizado en Twitter.

Kue es la única cola de mensajes que necesitarías

Es posible que desee echar un vistazo a

Redis Simple Message Queue for Node.js

Que utiliza Redis y ofrece la mayoría de las características de Amazons SQS.

Usé KUE con SocketIO como describiste. Guardé el calcetÍN con el trabajo y luego pude retirarlo en el Trabajo Completo.. KUE se basa en redis y tiene buenos ejemplos en github

Algo como esto....

jobs.process('YourQueuedJob',10, function(job, done){
    doTheJob(job, done);
});


function doTheJob(job, done){
    var socket = io.sockets.sockets[job.data.socketId];
    try {
        socket.emit('news', { status : 'completed' , task : job.data.task });
    } catch(err){
        io.sockets.emit('news', { status : 'fail' , task : job.data.task , socketId: job.data.socketId});
    }
    job.complete();
}

Mira node-queue-lib. Tal vez es suficiente que usted. Nodo de soporte de ti.js y navegadores. Tiene dos estrategias de entrega: broadcast y round-robin. Solo javascript.

Ejemplo rápido:

var Queue = require('node-queue-lib/queue.core');

var queue = new Queue('Queue name', 'broadcast');

// subscribe on 'Queue name' messages
queue.subscribe(function (err, subscriber) {
    subscriber.on('error', function(err){
        //
    });
    subscriber.on('data', function (data, accept) {
        console.log(data);
        accept(); // accept process message
    });
});

// publish message
queue.publish('test');

¿Qué tal Azure ServiceBus? Es compatible con nodejs.

Es posible que también desee revisar ewd-qoper8: https://github.com/robtweed/ewd-qoper8