如何正确连续调用 Node.js 中的子进程？

Question

我有一个 Node.js 应用程序，它目前是一个基于 Web 的 API。对于我的一个 API 函数，我调用了我编写的一个简短的 Python 脚本，以实现一些额外的功能。

在阅读了使用 child_process 模块在 Node 和 Python 之间进行通信之后，我尝试了一下，并达到了我想要的结果。我调用接收电子邮件地址的 Node 函数，通过std.in 将其发送到 Python，我的 Python 脚本使用提供的电子邮件执行必要的外部 API 调用，并将外部 API 调用的输出写入std.out并将其发送回我的节点函数。

在我连续发出几个请求之前，一切正常。尽管 Python 正确记录了更改的电子邮件地址，并且还使用更新的电子邮件地址向外部 API 发出了请求，但在我向 my API 发出第一个请求（返回正确的数据）之后，我不断收到相同的旧数据。

我最初的猜测是 Python 的输入流没有被刷新，但在测试 Python 脚本后，我发现我正确地更新了从 Node 接收到的电子邮件地址并接收到正确的查询结果。

我认为 child_process 模块的一些基本工作原理我可能不理解......因为我相当确定相应的数据正在正确地来回传递。

下面是Node函数：

exports.callPythonScript = (email)=>
{
    let getPythonData = new Promise(function(success,fail){

    const spawn = require('child_process').spawn;
    const pythonProcess = spawn('python',['./util/emailage_query.py']);

    pythonProcess.stdout.on('data', (data) =>{
      let dataString = singleToDoubleQuote(data.toString());
      let emailageResponse = JSON.parse(dataString);
      success(emailageResponse);
    })

    pythonProcess.stdout.on('end', function(){
      console.log("python script done");
    })

    pythonProcess.stderr.on('data', (data) => {
      fail(data);
    })

    pythonProcess.stdin.write(email);
    pythonProcess.stdin.end();

    })

    return getPythonData;

  }

这里是 Python 脚本：

import sys
from emailage.client import EmailageClient

def read_in():
    lines = sys.stdin.readlines()
    return lines[0]

def main():
    client = EmailageClient('key','auth')
    email = read_in()
    json_response = client.query(email,user_email='authemail@mail.com')
    print(json_response)
    sys.stdout.flush()

if __name__ == '__main__':
    main()

再次，在对callPythonScript 进行单次 调用后，一切都会完美返回。只有在进行多次调用时，我才会一遍又一遍地返回相同的输出。

我在这里碰壁了，我们将不胜感激。谢谢大家！

Answer 1

我在此类示例中使用了互斥锁。我似乎找不到代码来自的问题，因为当我遇到同样的问题时，我在 SO 上找到了它：

class Lock {
  constructor() {
    this._locked = false;
    this._waiting = [];
  }

  lock() {
    const unlock = () => {
      let nextResolve;
      if (this._waiting.length > 0) {
        nextResolve = this._waiting.pop(0);
        nextResolve(unlock);
      } else {
        this._locked = false;
      }
    };
    if (this._locked) {
      return new Promise((resolve) => {
        this._waiting.push(resolve);
      });
    } else {
      this._locked = true;
      return new Promise((resolve) => {
        resolve(unlock);
      });
    }
  }
}

module.exports = Lock;

然后我调用的地方会用你的代码实现它：

class Email {
  constructor(Lock) {
    this._lock = new Lock();
  }

  async callPythonScript(email) {
    const unlock = await this._lock.lock();
    let getPythonData = new Promise(function(success,fail){

    const spawn = require('child_process').spawn;
    const pythonProcess = spawn('python',['./util/emailage_query.py']);

    pythonProcess.stdout.on('data', (data) =>{
      let dataString = singleToDoubleQuote(data.toString());
      let emailageResponse = JSON.parse(dataString);
      success(emailageResponse);
    })

    pythonProcess.stdout.on('end', function(){
      console.log("python script done");
    })

    pythonProcess.stderr.on('data', (data) => {
      fail(data);
    })

    pythonProcess.stdin.write(email);
    pythonProcess.stdin.end();

    })
    await unlock();
    return getPythonData;
  }
}

我还没有测试过这段代码，我已经实现了我处理数组和调用python的每个数组值的地方......但这至少应该给你一个好的开始。