什么是nodejs的好消息队列选项?

寻找在一个小的web应用程序中使用消息队列,我正在与node.js构build。 我看着resque,但不知道这是适当的。 目标是通过使用socketio将通知推送到基于后端和其他客户端操作的客户端。 我可以用socketio做到这一点,但是我想也许一个正确的消息队列会使这个更清洁,我不必重新发明轮子。

那里有什么select?

12 Solutions collect form web for “什么是nodejs的好消息队列选项?”

您可以使用redis快闪node_redis客户端。 它甚至具有内置的pubsub语义。

您可以使用节点STOMP客户端 。 这可以让你整合各种消息队列,包括:

  • ActiveMQ的
  • 的RabbitMQ
  • HornetQ的

我以前没有用过这个库,所以我不能保证它的质量。 但STOMP是一个非常简单的协议,所以我怀疑你可以在必要时将其提交到提交。

另一个select是使用beanstalkd和节点 。 beanstalkd是用C编写的非常快速的“任务队列”,如果你不需要上面列出的代理的function灵活性,这是非常好的。

无耻的插件:我正在Bokeh上工作:构build在ZeroMQ上的一个简单的,可扩展的,快速的任务队列。 它支持可插拔的数据存储以支持持久性任务,目前内存中支持Redis和Riak。 一探究竟。

以下是我可以提出的一些build议:

node-amqp :一个RabbitMQ客户端,我已经成功地与Socket.IO结合使用,来创build实时的多人游戏和聊天应用程序。 似乎足够可靠。

zeromq.node :如果你想走下非代理路线,这可能值得一看。 更多的工作来实现function,但更可能得到更低的延迟和更高的尽pipe。

我build议尝试Kestrel ,它像Beanstalk一样快速简单,但支持扇出队列。 说memcached。 它使用Scala构build,并在Twitter上使用。

kue是唯一需要的消息队列

看看node-busmq–它是一个由redis支持的生产级,高可用性和可扩展的消息总线。

我为我们的全球云编写了这个模块,目前我们在全球多个数据中心的生产环境中部署了这个模块。 它支持命名队列,点对点通信,保证传送和联合。

欲了解更多关于为什么我们创build这个模块的信息,你可以阅读这篇博文: 所有船上的消息总线

你可能想看看

Redis简单消息队列Node.js

其中使用Redis并提供了Amazons SQS的大部分function。

我用你所描述的socketIO使用KUE。 我存储了这个作业的socketID,然后可以在作业完成中检索它。KUE基于redis, 在github上有很好的例子

像这样的东西….

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

看看node-queue-lib 。 也许这就够了。 它支持node.js和浏览器。 有两种交付策略:广播和循环。 只有JavaScript。

快速示例:

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

Azure ServiceBus如何? 它支持nodejs。

你也可能想看看ewd-qoper8: https : //github.com/robtweed/ewd-qoper8

  • 什么MySQL驱动程序可用于node.js?
  • 节点js中的response.send和response.write之间的区别
  • nodejs中的单例模式 - 是否需要?
  • 一个单元如何testingExpress的路线?
  • 如何在NodeJs的内存中下载和解压zip文件?
  • fs.readFileSync似乎比fs.readFile更快 - 是否可以用于生产中的Web应用程序?
  • NodeJS中CoffeeScript的例子?
  • 将“Vanilla”Javascript库加载到Node.js中
  • 如何在Nodejs中使用时区偏移?
  • 如何自动安装npm peer dependencies?
  • npm WARN弃用graceful-fs@3.0.8:graceful-fs版本3