Was sind gute message queue-Optionen für nodejs?

Suchen, um eine message-queue in eine kleine web-app, die ich Baue mit node.js. Ich schaute auf resque aber nicht sicher, ob das angemessen ist. Das Ziel ist es, push-Benachrichtigungen, um Kunden auf backend-und anderen client-Aktionen mit socketio. Ich könnte dies mit nur socketio aber ich dachte, vielleicht eine richtige message queue machen würde diesem Reiniger, und ich hätte nicht das Rad neu zu erfinden.

Welche Möglichkeiten es gibt?

InformationsquelleAutor der Frage Bjorn Tipling | 2011-01-15

  1. 43

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

    InformationsquelleAutor der Antwort Alfred

  2. 11

    Könnten Sie den Knoten STOMP client. Damit würden Sie Integration mit einer Vielzahl von message-queues inklusive:

    • ActiveMQ
    • RabbitMQ
    • HornetQ

    Ich habe nicht verwendet diese Bibliothek vor, so kann ich ' T bürgen für Ihre Qualität. Aber STOMP ist ein ziemlich einfaches Protokoll, so dass ich vermute, Sie können es zu hacken in die Unterwerfung, wenn nötig.

    Andere Möglichkeit ist die Verwendung beanstalkd mit Knoten. beanstalkd ist eine sehr schnelle "task queue" geschrieben in C, das ist sehr gut, wenn Sie brauchen nicht die Funktion, Flexibilität Broker, die oben aufgeführt sind.

    InformationsquelleAutor der Antwort James Cooper

  3. 10

    Shameless plug: ich arbeite Bokeh: eine einfache, skalierbare und extrem schnelle task-queue gebaut auf ZeroMQ. Es unterstützt steckbaren datenspeicher für die dauerhaften Aufgaben, die derzeit im Speicher, Redis und Riak unterstützt werden. Überprüfen Sie es heraus.

    InformationsquelleAutor der Antwort Josh Bassett

  4. 8

    Werfen Sie einen Blick auf Knoten-busmq - es ist eine Produktion Grad, hoch verfügbaren und skalierbaren message-bus unterstützt durch redis.

    Schrieb ich dieses Modul für unsere Globale cloud-und es ist derzeit im Einsatz in unserer Produktion ist die Umwelt in mehreren Rechenzentren rund um die Welt. Es unterstützt benannte queues, peer-to-peer-Kommunikation, garantierte Zustellung und Föderation.

    Weitere Informationen, warum wir dieses Modul können Sie das Lesen dieses blog-post: Alle An Bord Der Message Bus

    InformationsquelleAutor der Antwort fujifish

  5. 7

    Hier ein paar Empfehlungen, die ich machen kann:

    node-amqp: Ein RabbitMQ-client, habe ich erfolgreich eingesetzt, in Kombination mit Sockel.IO, um eine Echtzeit-multi-player-Spiel-und chat-Anwendung unter anderem. Scheint zuverlässig genug.

    zeromq.Knoten: Wenn Sie möchten nach unten gehen, den nicht-vermittelten route mit dieser könnte einen Blick Wert sein. Mehr Arbeit, um eine Funktionalität zu implementieren, aber Ihr eher, um eine geringere Latenz und ein höherer Durchsatz.

    InformationsquelleAutor der Antwort RobotEyes

  6. 5

    Empfehle ich versuchen Turmfalkees ist schnell und einfach, wie Beanstalk unterstützt aber fanout-Warteschlangen. Spricht memcached. Es ist gebaut mit Scala-und bei Twitter.

    InformationsquelleAutor der Antwort Eduardo Raad

  7. 5

    kue ist die einzige Botschaft, die Warteschlange, die Sie jemals brauchen würden

    InformationsquelleAutor der Antwort Pono

  8. 3

    Möchten Sie vielleicht einen Blick auf

    Redis Einfache Message-Queue für Node.js

    Was nutzt Redis und bietet die meisten Funktionen der Amazonen SQS.

    InformationsquelleAutor der Antwort Smrchy

  9. 1

    Ich verwendet KUE mit socketIO wie Sie beschrieben.
    Ich gespeichert die socketID mit dem job und konnte dann retreive es in der Job Abgeschlossen..
    KUE basierend auf redis und hat gute Beispiele werden auf github

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

    InformationsquelleAutor der Antwort Brian McAuliffe

  10. 0

    Blick auf Knoten-queue-lib. Vielleicht reicht es, dass Sie.
    It-support node.js und Browser. Hat zwei Strategien Lieferung: broadcast-und round-robin.
    Nur javascript.

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

    InformationsquelleAutor der Antwort AndyGrom

  11. 0

    Wie etwa Azure-ServiceBus? Es unterstützt nodejs.

    InformationsquelleAutor der Antwort Ben

  12. 0

    Vielleicht wollen Sie auch heraus zu überprüfen ewd-qoper8: https://github.com/robtweed/ewd-qoper8

    InformationsquelleAutor der Antwort robtweed

Schreibe einen Kommentar