NodeとPythonの双方向通信実装コード

# カプセル化された Python パッケージ、サイズが大きい from mb import MB
# データパケットからのクエリ mbe.get('1.0.1.0')

const { spawn } = require('child_process');
python3 を ls で生成します。

ls.stdout.on('データ', (データ) => {
  console.log(`stdout: ${data}`);
});

ls.stderr.on('データ', (データ) => {
  コンソールエラー(`stderr: ${data}`);
});

ls.on('close', (コード) => {
  console.log(`子プロセスはコード $[code] で終了しました`);
});

インポートシステム
fcntl をインポートする
インポート選択
mbからインポートMB
jsonをインポート

mbe = MB('./データ')

# epoll モデル fd = sys.stdin.fileno()
epoll = select.epoll()
epoll.register(fd、select.EPOLLIN) 関数は、

試す：
    真の場合:
        events = epoll.poll(10) # 同期非ブロッキングデータ = ''
        fileno、events 内の event の場合:
            data += sys.stdin.readline() # data == '' または data == '\n' の場合、標準入力からデータを取得します。
                続く
            items = xxx # アイテム内のアイテムの数値処理:
                結果 = mbe.get(アイテム)
                sys.stdout.write(json.dumps(result, ensure_ascii=False) +'\n') # 標準出力に書き込むsys.stdout.flush() # バッファを更新最後に:
    epoll.unregister(fd)
    epoll.close()

定数 child_process = require('child_process');
python3 の子プロセスを作成します。

コールバックを [] とします。 
    チャンク=Buffer.alloc(0), 
    チャンクArr = [], 
    データ = ''、 
    onwork = false; // バッファは動的に拡張できません child.stdout.on('data', (chunk) => {
    chunkArr.push(チャンク)
    if (onwork) 戻り値;
    オンワーク = true;
    while(chunkArr.length) {
        チャンク = Buffer.concat([チャンク、chunkArr.pop()]);
        定数長さ = チャンク.長さ;
        trunkAt = -1 とします。
        for(const [k, d] of chunks.entries()) {
            if (d == '0x0a') { // 0a で終了 data += chunks.slice(trunkAt+1, trunkAt=k);
                const cb = コールバック.shift();
                cb(null, データ === 'null' ? null : データ )
                データ = '';
            }
        }
        トランクサイズ < 長さの場合
            チャンク = chunks.slice(trunkAt+1)
        }
    }
    オンワーク = false;
})

間隔を設定する(() => {
    if (callbacks.length) child.stdin.write(`\n`); // Nodejs 側には標準入出力のフラッシュメソッドがないので、ハックを使うしかありません。Python は書き込み後に最新のデータを間に合うように取得できません。}, 500)

exports.getMsg = 関数 getMsg(ip, cb) {
    コールバック.push(cb)
    child.stdin.write(`${ip}\n`); // 子プロセスの標準入力にデータを書き込みます}