从各种后端向 Socket.IO 客户端发送消息的最佳方式是什么

Question

我的设置： 我有一个使用 Tweepy 访问 Twitter 流 API 的现有 python 脚本。我还有一个网站，显示来自各种后端的其他来源的聚合实时信息。

我的理想场景： 我想使用 Socket.IO 向我的连接用户发布实时推文以及我的其他信息的实时更新。

如果我能做一些简单的事情，比如 HTTP POST（从任何后端）向所有连接的客户端广播信息，那就太好了。

我的问题： Socket.IO 客户端实现非常简单……我可以处理。但我无法弄清楚我要求的功能是否已经存在......如果不存在，实现它的最佳方法是什么？

[更新]

我的解决方案：我创建了一个名为 Pega.IO 的项目，它可以满足我的需求。基本上，它允许您像往常一样使用 Socket.IO (0.8+)，但您可以使用 HTTP POST 向连接的用户发送消息。

它使用带有 Redis 后端的 Express Web 服务器。从理论上讲，这应该很容易扩展——我将继续为这个项目做出贡献。

Pega.IO - github

要在 Ubuntu 上安装，您只需运行以下命令：

curl http://cloud.github.com/downloads/Gootch/pega.io/install.sh | sh

这将创建一个监听端口 8888 的 Pega.IO 服务器。

启动并运行后，只需：

HTTP POST http://your-server:8888/send

使用如下所示的数据：

channel=whatever&secretkey=mysecret&message=hello+everyone

仅此而已。从任何后端到您的 Pega.IO 服务器的 HTTP POST。

Answer 1

我为这类事情找到的最佳方法是使用消息代理。就个人而言，我为此使用了 RabbitMQ，这似乎符合您对另一个答案（socket.io 0.7 和可扩展）的评论中提到的要求。如果你使用 RabbitMQ，我推荐用于 node 的 amqp 模块，可通过 npm 获得，以及用于 Python 的 Pika 模块。

使用 pika 的 Python 连接器示例。此示例接受单个 json 序列化参数：

    def amqp_transmit(message):
        connection = pika.AsyncoreConnection(pika.ConnectionParameters(host=settings.AMQP_SETTINGS['host'],
            port=settings.AMQP_SETTINGS['port'],
            credentials=pika.PlainCredentials(settings.AMQP_SETTINGS['username'],
                    settings.AMQP_SETTINGS['pass'])))
        channel = connection.channel()
        channel.exchange_declare(exchange=exchange_name, type='fanout')
        channel.queue_declare(queue=NODE_CHANNEL, auto_delete=True, durable=False, exclusive=False)
        channel.basic_publish(exchange=exchange_name,
                routing_key='',
                body=message,
                properties=pika.BasicProperties(
                        content_type='application/json'),
                )
        print ' [%s] Sent %r' %(exchange_name, message)
        connection.close()

节点端的非常基本的连接代码可能如下所示：

    var connection = amqp.createConnection(
        {host: amqpHost,
        port: amqpPort,
         password: amqpPass});

    function setupAmqpListeners() {
        connection.addListener('ready', amqpReady)
        connection.addListener('close', function() {
            console.log('Uh oh! AMQP connection failed!');
        });
        connection.addListener('error', function(e) {throw e});
    }

    function amqpReady(){
        console.log('Amqp Connection Ready');
        var q, exc;
        q = connection.queue(queueName,
            {autoDelete: true, durable: false, exclusive: false},
            function(){
                console.log('Amqp Connection Established.');
                console.log('Attempting to get an exchange named: '+exchangeName);
                exc = connection.exchange(exchangeName,
                    {type: 'fanout', autoDelete: false},
                    function(exchange) {
                        console.log('Amqp Exchange Found. ['+exchange.name+']');
                        q.bind(exc, '#');
                        console.log('Amqp now totally ready.');
                        q.subscribe(routeAmqp);
                    }
                );
            }
        );
    }


    routeAmqp = function(msg) {
            console.log(msg);
            doStuff(msg);
    }

编辑：上面的示例使用了不持久化消息的扇出交换。扇出交换可能是您的最佳选择，因为可扩展性是一个问题（即：您正在运行多个客户端可以连接到的运行节点的盒子）。

Answer 2

为什么不编写你的 Node 应用程序，以便有两个部分：

1. 直接与客户端通信的 Socket.IO 部分，以及
2. 某种 HTTP API，它接收 POST 请求，然后使用 Socket.IO 广播适当的消息。

通过这种方式，您的应用程序成为非 Node 应用程序和用户浏览器之间的“桥梁”。这里的关键是将 Socket.IO 用于它的用途——与浏览器的实时通信——并在应用程序的其他部分依赖其他 Node 技术。

[更新]

我目前不在开发环境中，所以我无法为您提供一个工作示例，但一些伪代码看起来像这样：

http = require('http');
io   = require('socket.io');

server = http.createServer(function(request, response) {
  // Parse the HTTP request to get the data you want
  io.sockets.emit("data", whatever); // broadcast the data to Socket.IO clients
});
server.listen(8080);
socket_server = io.listen(server);

有了这个，您将在端口 8080 上拥有一个 Web 服务器，您可以使用它来监听 Web 请求（您可以使用诸如 Express 之类的框架或许多其他框架来解析 POST 请求的正文并提取您需要的数据）。