其实nodejs实现队列的方式又很多中，也有很多开源的插件和队列数据库可以使用，但是呢，如果我们一个简单的项目，完全可以使用redis来实现队列，
这样再不增加技术难度的同事，我们也就可以完美的实现一个队列
MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们>。消 息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。其中较为成熟的MQ产品有IBM WEBSPHERE MQ。
以上介绍仍旧来自百度百科.
消息队列产品对比
目前比较流行的MQ有2种,ActiveMQ 以及 RabbitMQ , RabbitMQ性能号称能够达到每秒10000,而REDIS官方的压力测试值在7-8万之间,而且是去掉了网络IO操作,真实情况我估计在每秒2-3万的并发操作,但这个数目对于一般的应用应该足够了.
Redis如何支持消息队列?
在新版本的redis v2.6以上以及以上版本开始支持 subscribe 以及 publish 操作, subscribe订阅一个频道,publish可以像频道广播消息. 这个机制最老的应用应该是算是聊天室了.
Sub/Pub 模式固然很好用,但是同样有一个问题,就是如果有多个人订阅了同一频道,而这个频道的数据只能被一个接收方处理,不能够重复处理,这时该怎么办?
解决方法有2种,
1. publish 将数据写入到一个list or sorted list 队列,写完成后开始给终端广播消息,告诉大家,有新的数据等待处理,这个时候,谁能pop到数据,就是谁处理,这个操作是原子性的,也就是说不会被重复处理.
2. 使用阻塞模式, redis提供了blpop brpop这种操作,也就是一直阻塞一个队列,直到有数据来. 这种模式保证了数据的原子性,而且使应用程序可以支持分布式多台机器部署.
Sub/Pub模式 (sub.js):
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 | var redis = require("redis");var client = redis.createClient(6379, '127.0.0.1', {connect_timeout: 1});//订阅一个频道var sub = function(c) { var c = c || 'roban:test:channel'; client.subscribe(c,function(e){ console.log('starting subscribe channel:'+c); });};//订阅一个频道sub();//处理错误,如果出现错误,或者服务器断开了链接,等待恢复时,继续订阅这个频道client.on('error', function(error) { console.log(error); sub();});//订阅处理函数client.on('message',function(err,response){ console.log(response);}); |
打开redis命令行,输入以下命令:
1 | publish roban:test:channel hello |
发布这条信息后,sub端会输出以下信息:
1 2 3 | Robans-Pro:node robanlee$ node demo.js starting subscribe channel:roban:test:channelhello |