对于那些远离互联网的人来说,node.js 是一个基于 Google V8 的事件驱动的 JavaScript 引擎。因为它本质上是一个大型、高效的事件循环,所以它非常适合在少量状态之间来回传递数据的程序。而且编程很有趣,显然很多人也这么认为,因为围绕它出现了大量的库。
在这些库中,比较令人印象深刻的是 Socket.IO。可以将 Socket.IO 与 node.js 的内置 Web 服务器结合使用以创建 websocket 服务器,并为浏览器提供套接字抽象,当没有 websockets 时,它会降级为 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 中。(请注意,您需要 我分叉的 node-amqp。)
它还包含一个微型消息套接字服务器;即一个接受套接字连接并以长度前缀消息进行通信的 node.js 服务器。由于所有内容都通过 RabbitMQ 进行,因此您可以通过套接字与使用 Socket.IO 连接的浏览器进行通信。您还可以使用来自 node.js 本身运行的代码的进程内管道服务器。
总而言之,我很惊讶只需几行代码和一些各具优势的技术就能完成多少工作 - node.js 用于有趣的网络服务器编程、Socket.IO 用于神奇的浏览器套接字,以及 RabbitMQ 用于无泪消息传递。