如何基于node-ipc实现Python与Node.js的跨语言进程通信

问题原因 #

你当前无法连通的核心原因是协议不兼容：

• node-ipc默认使用自定义的JSON序列化+换页符分隔的消息协议，默认监听Unix域套接字（Windows下为命名管道）
• Python multiprocessing.connection 模块使用Python私有的序列化通信协议，和node-ipc完全不互通，无法直接对接

方案1：保留node-ipc，修改配置适配Python #

第一步：修改Node端配置，开启TCP监听 #

在原有node-ipc配置中新增TCP监听相关参数：

var ipc = require('node-ipc').default;
ipc.config.id   = 'world';
ipc.config.retry= 1500;
// 新增TCP配置
ipc.config.networkHost = '127.0.0.1'; // 监听地址
ipc.config.networkPort = 6000; // 监听端口
ipc.config.silent = false; // 按需开启日志

ipc.serveNet( // 注意这里要换成serveNet启用TCP服务，原来的serve是本地套接字
    function(){
        ipc.server.on(
            'message',
            function(data,socket){
                ipc.log('got a message : ', data);
                ipc.server.emit(
                    socket,
                    'message',
                    data+' world!'
                );
            }
        );
    }
);
ipc.server.start();

第二步：Python端用标准socket对接 #

Python不需要安装额外第三方库，直接用内置socket模块，按照node-ipc的消息格式发送数据即可：

import socket
import json

# 连接node-ipc的TCP服务
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('127.0.0.1', 6000))

# 按照node-ipc协议构造消息：JSON对象 + 换页符\f分隔
message = json.dumps({
    "type": "message",
    "data": "hello"
}) + "\f" # 必须加换页符作为消息结束标识

s.sendall(message.encode('utf-8'))

# 接收返回结果
buffer = b""
while True:
    chunk = s.recv(1024)
    if not chunk:
        break
    buffer += chunk
    if b"\f" in buffer:
        break

response_str = buffer.decode('utf-8').rstrip("\f")
response = json.loads(response_str)
print("收到返回：", response['data'])

s.close()

其他可选实现方案 #

如果不需要保留node-ipc的能力，也可以选择更通用的跨语言IPC方案：

• 轻量HTTP服务：Node端用Express/Koa启一个简单的HTTP接口，Python用requests库发请求，调试成本极低，适合消息量不大的普通场景
• Redis中间件：两边同时连接同一个Redis实例，用列表/发布订阅模式做消息传递，天然支持跨主机通信，适合分布式场景
• gRPC：两边统一定义proto接口文件，生成对应语言的调用代码，性能高、类型安全，适合交互逻辑复杂、对性能要求高的场景

内容的提问来源于stack exchange，提问作者Silve2611