Jakie są dobre opcje kolejki wiadomości dla nodejs? [Zamknięte]

Chcę użyć kolejki komunikatów w małej aplikacji internetowej, którą tworzę za pomocą node.js. Spojrzałem na resque, ale nie byłem pewien, czy to właściwe. Celem jest wypychanie powiadomień do klientów na podstawie zaplecza i innych działań klienta za pomocą gniazda. Mógłbym to zrobić za pomocą samego socketio, ale pomyślałem, że może odpowiednia kolejka komunikatów sprawi, że będzie to czystsze i nie będę musiał wymyślać koła na nowo.

Jakie są dostępne opcje?

możesz użyć redis z błyskawicznym klientem node_redis . Ma nawet wbudowaną semantykę pubsub .

Możesz użyć klienta STOMP węzła . Umożliwiłoby to integrację z różnymi kolejkami wiadomości, w tym:

• ActiveMQ
• RabbitMQ
• HornetQ

Nie korzystałem wcześniej z tej biblioteki, więc nie mogę ręczyć za jej jakość. Ale STOMP to dość prosty protokół, więc podejrzewam, że w razie potrzeby możesz go włamać do przedłożenia.

Inną opcją jest użycie beanstalkd z node . beanstalkd to bardzo szybka "kolejka zadań" napisana w C, która jest bardzo dobra, jeśli nie potrzebujesz elastyczności funkcji wymienionych powyżej brokerów.

Bezwstydna wtyczka: Pracuję nad Bokeh : prostą, skalowalną i niesamowicie szybką kolejką zadań zbudowaną na ZeroMQ. Obsługuje wtykowe magazyny danych dla trwałych zadań, obecnie w pamięci, obsługiwane są Redis i Riak. Sprawdź to.

Oto kilka zaleceń, które mogę przedstawić:

node-amqp : klient RabbitMQ , którego z powodzeniem użyłem w połączeniu z Socket.IO, aby między innymi stworzyć grę wieloosobową w czasie rzeczywistym i aplikację do czatu. Wydaje się wystarczająco wiarygodne.

zeromq.node : Jeśli chcesz skorzystać z trasy nieobsługiwanej przez brokera, może to być warte obejrzenia. Więcej pracy przy implementacji funkcjonalności, ale istnieje większe prawdopodobieństwo, że uzyskasz mniejsze opóźnienia i wyższą przepustowość.

Spójrz na node-busmq - to wysokiej jakości, wysoce dostępna i skalowalna magistrala komunikatów wspierana przez redis.

Napisałem ten moduł dla naszej globalnej chmury i obecnie jest on wdrażany w naszym środowisku produkcyjnym w kilku centrach danych na całym świecie. Obsługuje nazwane kolejki, komunikację peer-to-peer, gwarantowaną dostawę i federację.

Aby uzyskać więcej informacji o tym, dlaczego stworzyliśmy ten moduł, możesz przeczytać ten wpis na blogu: Wszyscy na pokład magistrali wiadomości

kue to jedyna kolejka wiadomości, jakiej kiedykolwiek będziesz potrzebować

Polecam wypróbować Kestrel , jest szybki i prosty jak Beanstalk, ale obsługuje kolejki fanoutów. Mówi memcached. Jest zbudowany przy użyciu Scala i używany na Twitterze.

Możesz rzucić okiem

Redis Simple Message Queue dla Node.js.

Który używa Redis i oferuje większość funkcji Amazons SQS.

A co z usługą Azure ServiceBus? Obsługuje nodejs.

Spójrz na node-queue-lib . Może wystarczy, że ty. Obsługuje node.js i przeglądarki. Ma dwie strategie wyświetlania: transmisja i okrężna. Tylko javascript.

Szybki przykład:

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

Użyłem KUE z socketIO, jak opisałeś. Zapisałem socketID z zadaniem i mogłem go odzyskać w Zadaniu zakończonym. KUE jest oparty na redis i ma dobre przykłady na github

coś takiego....

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

Możesz również sprawdzić ewd-qoper8: https://github.com/robtweed/ewd-qoper8