Was sind gute Nachrichtenwarteschlangenoptionen für nodejs?

Question

Ich möchte eine Nachrichtenwarteschlange in einer kleinen Webanwendung verwenden, die ich mit node.js erstelle. Ich schaute auf Resque, aber nicht sicher, ob das angemessen ist. Das Ziel besteht darin, Benachrichtigungen an Clients basierend auf Backend- und anderen Clientaktionen mit socketio zu senden. Ich könnte das mit nur socketio tun, aber ich dachte, vielleicht würde eine richtige Nachrichtenwarteschlange das sauberer machen und ich würde das Rad nicht neu erfinden müssen.

Welche Möglichkeiten gibt es da draußen?

Answer 1

Sie redis mit dem blitzschnellen node_redis Client nutzen könnten. Es hat sogar eine eingebaute pubsub Semantik.

Answer 2

Sie könnten den Knoten STOMP client verwenden. Dies würde Sie mit einer Vielzahl von Nachrichtenwarteschlangen integrieren, einschließlich:

• ActiveMQ
• RabbitMQ
• HornetQ

ich diese Bibliothek nicht verwendet haben, so kann ich nicht bürgen seine Qualität. Aber STOMP ist ein ziemlich einfaches Protokoll, also vermute ich, dass Sie es bei Bedarf in die Einreichung hacken können.

Eine weitere Option ist beanstalkd with node zu verwenden. Beanstalkd ist eine sehr schnelle "Task Queue", geschrieben in C, die sehr gut ist, wenn Sie die Feature-Flexibilität der oben genannten Broker nicht benötigen.

Answer 3

ich Kestrel empfehlen daher, ist es schnell und einfach wie Bohnenstange, sondern unterstützt Fanout-Warteschlangen. Spricht Memcached. Es wird mit Scala erstellt und bei Twitter verwendet.

Answer 4

Shameless Stecker: Ich arbeite an Bokeh: eine einfache, skalierbare und blitzschnelle Task-Queue auf ZeroMQ gebaut. Es unterstützt steckbare Datenspeicher für persistente Aufgaben, derzeit im Speicher, Redis und Riak werden unterstützt. Hör zu.

Answer 5

Hier ein paar Empfehlungen kann ich machen:

node-amqp: Ein RabbitMQ Client, die ich erfolgreich in Kombination mit Socket.IO verwendet habe Multi-Player-Spiel in Echtzeit und unter anderem Chat-Anwendung zu machen. Scheint zuverlässig genug.

zeromq.node: Wenn Sie den nicht vermittelten Weg gehen wollen, dies könnte einen Blick wert sein. Mehr Arbeit, um Funktionalität zu implementieren, aber Ihre Wahrscheinlichkeit, niedrigere Latenz und höher zu bekommen, ist höher.

Answer 6

kue ist die einzige Nachrichtenwarteschlange Sie jemals

brauchen würde

Answer 7

ich KUE mit socketIO verwendet wie Sie beschrieben. ich die SocketId mit dem Job gespeichert und können dann in der Complete Job retreive .. KUE auf redis basiert und good examples on github

so etwas wie dieses ....

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(); 
} 

Answer 8

Schauen Sie sich node-queue-lib an. Vielleicht reicht es dir. Es unterstützt node.js und Browser. Verfügt über zwei Übertragungsstrategien: Broadcast und Round-Robin. Nur Javascript.

Schnell Beispiel:

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'); 

Answer 9

Sie vielleicht einen Blick auf

Redis Simple Message Queue for Node.js

haben wollen Welche Redis verwendet und bietet die meisten Funktionen der Amazonen SQS.

Answer 10

Wie wäre es mit Azure ServiceBus? Es unterstützt nodejs.

Answer 11

Werfen Sie einen Blick auf node-busmq - es ist ein hochverfügbarer und skalierbarer Nachrichtenbus in Produktionsqualität, der von Redis unterstützt wird.

Ich habe dieses Modul für unsere globale Cloud geschrieben und es wird derzeit in unserer Produktionsumgebung in mehreren Rechenzentren auf der ganzen Welt eingesetzt. Es unterstützt named Warteschlangen, Peer-to-Peer-Kommunikation, garantierte Zustellung und Föderation.

Weitere Informationen darüber, warum wir dieses Modul erstellt Ihnen dieses Blog-Post lesen: All Aboard The Message Bus

Answer 12

Sie möchten vielleicht auch ewd-qoper8 überprüfen: https://github.com/robtweed/ewd-qoper8