18

您有一个 Python 脚本diagnosis.py，可以生成基于事件的实时数据。使用 Node.js，您可以将其作为子进程启动并捕获其输出，然后使用 Socket.IO 将其发送到客户端并使用 HTML 呈现。

服务器

var util  = require('util'),
    spawn = require('child_process').spawn,
    ls    = spawn('python', ['diagnosis.py']);

var app = require('http').createServer(handler)
  , io = require('socket.io').listen(app)
  , fs = require('fs')

app.listen(80);

function handler (req, res) {
  fs.readFile(__dirname + '/index.html',
  function (err, data) {
    if (err) {
      res.writeHead(500);
      return res.end('Error loading index.html');
    }

    res.writeHead(200);
    res.end(data);
  });
}

io.sockets.on('connection', function (socket) {
    ls.stdout.on('data', function (gdata) {
      socket.emit('news', gdata.toString());
    });
});

客户

<html>
    <head>
        <script src="/socket.io/socket.io.js"></script>
        <script>
          var d = "";
          var socket = io.connect('http://localhost');
          socket.on('news', function (data) {
            d += data;
            document.getElementById('data').innerHTML = d;
            console.log(data);
          });
        </script>
    </head>
    <body>
        <div id="data"></div>
    </body>
</html>

问题

这很棒，但是如果您正在寻找与 Socket.IO 相同的 HTML-Node.js 通信能力，但在 Node.js 和 Python 之间寻找呢？你会怎么做？那里没有 Web 服务器，因此 Socket.IO 没有多大意义，并且通过裸 TCP 进行通信并不能提供相同的功能/优雅。如何实现 Node.js 和 Python 之间的全双工通信？

在此处输入图像描述

更新我回答了我自己的问题，但我对另一种方法持开放态度。RPC 并不能完全满足我的要求。

4

4 回答 4

8

Apache Thrift是一种在所有主要语言之间编写 RPC 代码的非常棒的方式。你编写一个通用的 Thrift 规范来声明类型和服务，然后代码生成器为你想要的语言创建绑定。您可以使用 api 在节点和 python 代码库之间调用方法。

在更通用的低级方法中，ZeroMQ是一个消息队列库，它也支持所有主要语言。有了这个，你可以设计你自己的解决方案来实现你想要的通信方式（不仅仅是纯粹的 RPC）。它具有请求/回复、推送/拉取、发布/订阅和配对的模式。它为您提供了足够的工具来组合任何类型的可扩展系统。

我都用过，它们都是很好的解决方案。

作为一个非常粗略的例子，Thrift 规范可能是这样的。假设您想将事件从 python 传递到 node.js，对其进行处理并返回一些响应：

myspec.thrift

struct Event {
    1: string message; 
}

service RpcService {
    string eventOccurred(1:Event e)
}

这定义了一个Event使用单个字符串成员调用的数据结构来保存消息。然后一个名为的服务RpcService定义一个调用的函数eventOccured，该函数需要一个Event作为参数，并将返回一个字符串。

当您为 python 和 node.js 生成此代码时，您可以使用 python 的客户端代码和 node.js 的服务器端代码

Python

from myrpc import RpcService, ttypes

# create a connection somewhere in your code
CONN = connect_to_node(port=9000)

def someoneClickedSomething():
    event = ttypes.Event("Someone Clicked!")
    resp = CONN.eventOccurred(event)
    print "Got reply:", resp

节点.js

// I don't know node.js, so this is just pseudo-code

var thrift = require('thrift');
var myrpc = require('myrpc.js');

var server = thrift.createServer(myrpc.RpcService, {
  eventOccurred: function(event) {
    console.log("event occured:", event.message);
    success("Event Processed.");
  },
});
server.listen(9000);
于 2012-12-12T21:36:22.987 回答
2

您可以查看一些消息系统，例如 0mq http://www.zeromq.org/

于 2012-12-12T21:36:44.407 回答
2

我使用受这个问题启发的库变成diagnosis.py了 Socket.IO 客户端。这样我可以将实时数据发送到 Node.js Socket.IO 服务器：

socketIO.emit('gaze', ...)

然后让它socket.broadcast.emit向所有 Socket.IO 客户端（浏览器和diagnosis.py）发送数据。

RPC 可能是跨语言开发更标准的方法，但我发现当目标是交换数据时这样做有点过头了。它也不支持开箱即用的事件 IO。

2013 年 1 月更新由于socket.broadcast.emit会产生大量不必要的流量，因此我试图找到一种更好的方法。我想出的解决方案是使用我提到的基本 python Socket.IO 客户端库支持的命名空间。

Python

self.mainSocket = SocketIO('localhost', 80)
self.gazeSocket = self.mainSocket.connect('/gaze')
self.gazeSocket.emit('gaze', ...)

连接到注视命名空间。

节点.js

var gaze = io.of('/gaze').on('connection', function (socket) {
    socket.on('gaze', function (gdata) {
        gaze.emit('gaze', gdata.toString());
    });
});

这会将接收到的数据仅发送到连接到凝视命名空间的客户端。

浏览器

var socket = io.connect('http://localhost/gaze');
socket.on('gaze', function (data) {
    console.log(data);
});
于 2012-12-13T23:21:20.840 回答
1

如果您只是在寻找在套接字之上为您提供简单协议的东西，那么您不必处理缓冲和分隔消息以及所有这些东西，两个明显的选择（取决于您的数据类型）重新尝试发送）是网络字符串和 JSON-RPC。两种语言都有多种库可供选择，但您最终可以得到这样简单的代码：

class MyService(Service):
    # … code to set up the newsdb
    def getnews(self, category, item):
        return self.newsdb.get(category, item)
myService = MyService(6000)

myService = Service(6000)
// … code to set up the newsdb
myService.getnews = function(category, item, callback) {
    callback(this.newsdb.get(category, item);
}
于 2012-12-12T21:42:23.957 回答