rabbitmq + node.js = rabbit.js

对于那些暂时离开互联网的朋友来说，node.js 是一个基于 Google V8 的事件驱动 JavaScript 引擎。因为它本质上是一个巨大而高效的事件循环，所以它非常适合那些在状态很少的情况下，前后频繁地移动数据的程序。而且它编程起来很有趣，这似乎是很多人共享的观点，因为围绕它已经涌现出大量的库。

这些库中最令人印象深刻的是 Socket.IO。你可以将 Socket.IO 与 node.js 内置的 Web 服务器结合起来，创建一个 WebSocket 服务器，并为浏览器提供一个套接字抽象，在没有 WebSocket 的情况下会退降到 XHR 技巧。(我很高兴能相信 node.js 和 Socket.IO 是由一个仁慈且富有远见的先驱种族为我们创造的；但当然，它们是由勤奋聪明的人创造的。谢谢你们！)

一旦在浏览器中拥有了套接字抽象，一个全新的世界就此打开。具体来说，就我们而言，这是一个全新的消息传递世界。由于 node.js 有一个 AMQP 客户端，我们可以轻松地将其与 RabbitMQ 连接起来；不仅可以连接到其他协议和后端系统，还可以提供浏览器之间、应用程序服务器之间等等的消息传递。

继我们与 ZeroMQ 的 Martin Sustrik 合作的 工作 之后，我决定为浏览器套接字创建一个非常简单的协议，该协议反映了 ZeroMQ (以及因此的 RMQ-0MQ) 中使用的消息传递模式——发布/订阅、请求/应答 和 推/拉 (或管道)。我编写了一个 node.js 库，该库使用 RabbitMQ 来实现消息模式，利用其路由和缓冲功能；由于 RabbitMQ 拥有大量协议适配器和各种语言的客户端，因此桥接功能也随之而来。

消息传递模式的简要说明

发布/订阅 适用于已发布的消息需要传递给多个订阅者的情况。在一般情况下，可以使用各种路由方式来过滤每位订阅者的消息。例如，这可以用于将后端系统的通知广播给用户的浏览器。

请求/应答 用于通过消息传递进行 RPC；请求会以轮询方式分发给工作进程，应答会路由回请求的套接字。这可以由浏览器用来查询后端服务；或者甚至由浏览器互相查询。

管道 用于将进程链接在一起。消息会以轮询方式推送到工作进程，这些工作进程本身可以将消息推送到下一个处理阶段。这可以用于协调用户（或个人）集合之间的工作流程。

在不必要的客套话之后，这里是 rabbit.js。

它只需要一个基本的 RabbitMQ 和 node.js 安装；以及 node-amqp 和 Socket.IO 库。安装说明和这些库的位置在 README 中。(请注意，您需要 我 fork 的 node-amqp。)

它还包含一个微型消息套接字服务器；也就是说，一个接受套接字连接并使用带长度前缀的消息进行通信的 node.js 服务器。由于所有通信都通过 RabbitMQ 进行，您可以通过套接字与连接了 Socket.IO 的浏览器进行通信。您还可以使用 node.js 本身代码中的进程内管道服务器。

总而言之，我很惊讶地发现，只需寥寥几行代码和一些各有所长的技术——node.js 用于有趣的服务器端网络编程，Socket.IO 用于神奇的浏览器套接字，以及 RabbitMQ 用于无忧无虑的消息传递——我就能完成这么多工作。