在 node.js 中尝试与 shell 脚本执行同步行为

Question

我是 node.js 的新手，我将它用作服务器来接收来自浏览器的 http.get 请求，进行一些处理并将结果返回给浏览器。

该处理实际上是使用 phantom.js/casper.js 抓取网站，并且由于在 node.js 中使用 casper.js 的复杂性，我使用 shell 脚本将其作为子进程执行。

当我运行下面的代码并从浏览器发出请求时，响应似乎出现在 shell 脚本运行之前。我尝试使用异步库连续运行这些步骤，以便 run.sh 在添加到响应之前运行并返回一个值，但它似乎不像那样工作。谁能发现我的愚蠢错误？

提前致谢！

var express = require('express');
var app = express();
var sys = require('sys');
var exec = require('child_process').exec;
var async = require('async');
var auth = express.basicAuth('test', 'pass');
var server = app.listen(3000, function() {
    console.log('Listening on port %d', server.address().port);
});
var result;


//app.use(auth);

app.get('/free/:u/:p', auth, function(req, res) { 
    async.series([
        function(callback){
            var puts = function (error, stdout, stderr) {
                result = stdout;
             }
             exec("./run.sh " + req.params.u + " " + req.params.p, puts);
             callback(null);
        },
        function(callback){
             res.writeHead(200,{'Content-Type':'application/json'});
             res.send(result)
             callback(null);
        }
    ]);
});

app.get('/', function(req, res) {
  res.send('Hello!');
});

Answer 1

您没有异步调用callback(null)。你需要把它放在puts。

此外，您不应该使用全局 results 变量（它甚至是跨请求的全局变量，可能会将数据泄露给不同的客户端 - 啊！）。而且几乎没有理由为这个琐碎的链使用 async.js。

app.get('/free/:u/:p', auth, function(req, res) { 
    exec("./run.sh " + req.params.u + " " + req.params.p, function (error, stdout, stderr) {
       res.writeHead(200,{'Content-Type':'application/json'});
       res.send(stdout);
    });
});

注意不转义 shell 参数引入的安全问题。

Answer 2

基本上你遇到的问题是你调用exec 好像它是一个同步函数，而实际上它是异步的。

所以你实际上应该这样做：

exec("./run.sh " + req.params.u + " " + req.params.p, puts, function(){
   callback(null);
});

或者简单地这样做，因为无论如何您都不关心异步系列中的函数传递的函数参数。

exec("./run.sh " + req.params.u + " " + req.params.p, puts, callback)

Answer 3

原因是你运行了 shell 命令，然后立即调用了运行下一个函数（响应）的回调。

要修复它，您可以像这样更改 puts 函数 puts 并删除 callback(null)：

var express = require('express');
var app = express();
var sys = require('sys');
var exec = require('child_process').exec;
var async = require('async');
var auth = express.basicAuth('test', 'pass');
var server = app.listen(3000, function() {
    console.log('Listening on port %d', server.address().port);
});
var result;


//app.use(auth);

app.get('/free/:u/:p', auth, function(req, res) { 
    async.series([
        function(callback){
            var puts = function (error, stdout, stderr) {
                result = stdout;
                callback(null); //added here
             }
             exec("./run.sh " + req.params.u + " " + req.params.p, puts);
             //callback(null);  //commented
        },
        function(callback){
             res.writeHead(200,{'Content-Type':'application/json'});
             res.send(result)
             callback(null);  
        }
    ]);
});

app.get('/', function(req, res) {
  res.send('Hello!');
});

虽然这种方法有效，但最好使用async.waterfall 而不是async.series。它允许您将每个函数的结果传递给下一个函数。所以，你不需要有一个全局的result 变量。