1

我正在使用expressjs。我有一个路由器：

exports.index = function(req, res){

  if(req.param('name')) {

    var simpleParser = require('../tools/simpleParser');
    var result = simpleParser.images(req.param('name'));

    // how i can get result from simpleParser.images after it complete?

    res.json(result);

  }

  res.render('goods');

};

我有一个 simpleParser.images：

module.exports = {
    images: function (url) {
        if (url) {

            var request = require('request'),
                cheerio = require('cheerio');

            request({
                uri: url,
                method: 'GET',
                encoding: 'binary'
            }, function (err, res, body) {

                var tmp = [];

                body = new Buffer(body, 'binary');

                var $ = cheerio.load(body);

                $('.products-listing li a').each(function () {
                    var link = $(this).find('img').attr('src');
                    tmp.push(link);
                });

                // How i can send tmp to router, when it complete?

            });

        }
    }
};

当我用 ?name 询问页面时，它返回 null，因为 simpleParser.images 中的请求异步工作。我如何订阅 simpleParser 请求函数的结果，并在完成后发送 json？

4

1 回答 1

0

像许多节点模块一样，您可以在自己的实用程序函数中提供回调。您的simpleParser.images函数不是同步的，因为它使用了request模块。您可以让您的simpleParser.images函数接受一个回调，该回调将在网络请求和一些数据解析完成时调用。

var request = require('request'),
  cheerio = require('cheerio');

module.exports = {
  images: function (url, callback) {
    if (!url) callback(null, null);

    request({
      uri: url,
      method: 'GET',
      encoding: 'binary'
    }, function (err, res, body) {
      if (err) callback(err);
      var tmp = [];
      body = new Buffer(body, 'binary');
      var $ = cheerio.load(body);
      $('.products-listing li a').each(function () {
        var link = $(this).find('img').attr('src');
        tmp.push(link);
      });

      // Here we have the data and can pass it in the callback
      callback(null, tmp);
    });
  }
};

然后，您基本上拥有自己的可以异步执行的功能。然后在您的快速路线中，这也是异步的，所以只需插入您的新功能

if (req.param('name'))
  simpleParser.images(req.param('name'), function (err, images);
    res.json(images);
  });
} else {
  res.render('goods');
}
于 2013-08-04T19:09:42.883 回答