Nodejs 比较基础的问题

在你提供的代码中，[topicUrl, res.text] 是一个数组，用于传递两个值：当前主题的 URL 和该主题页面的 HTML 内容。具体来说，[topicUrl, res.text] 这个数组被用来作为参数调用 ep.emit('topic_html', [topicUrl, res.text]) 方法。

解释

• topicUrl 是当前主题页面的 URL。
• res.text 是通过 superagent.get(topicUrl) 请求获取到的 HTML 页面内容。

这些信息被传递给 EventProxy 的 emit 方法，用于处理异步请求的结果。

示例代码解析

var eventproxy = require('eventproxy');
var superagent = require('superagent');
var cheerio = require('cheerio');
var url = require('url');

var cnodeUrl = 'https://cnodejs.org/';

superagent.get(cnodeUrl)
.end(function (err, res) {
  if (err) {
    return console.error(err);
  }
  
  var topicUrls = [];
  var $ = cheerio.load(res.text);
  
  $('#topic_list .topic_title').each(function (idx, element) {
    var $element = $(element);
    var href = url.resolve(cnodeUrl, $element.attr('href'));
    topicUrls.push(href);
  });

  var ep = new eventproxy();

  ep.after('topic_html', topicUrls.length, function (topics) {
    topics = topics.map(function (topicPair) {
      var topicUrl = topicPair[0];
      var topicHtml = topicPair[1];
      var $ = cheerio.load(topicHtml);
      
      return ({
        title: $('.topic_full_title').text().trim(),
        href: topicUrl,
        comment1: $('.reply_content').eq(0).text().trim(),
      });
    });

    console.log('final:');
    console.log(topics);
  });

  topicUrls.forEach(function (topicUrl) {
    superagent.get(topicUrl)
      .end(function (err, res) {
        console.log('fetch ' + topicUrl + ' successful');
        
        // 发送事件并传递 topicUrl 和 res.text
        ep.emit('topic_html', [topicUrl, res.text]);
      });
  });
});

代码中的关键点

1. 获取页面内容：

   • superagent.get(cnodeUrl) 获取 CNode 首页的内容，并使用 Cheerio 解析 HTML 来提取每个话题的链接。

2. 异步请求处理：

   • ep.after('topic_html', topicUrls.length, ...) 等待所有话题页面请求完成。
   • ep.emit('topic_html', [topicUrl, res.text]) 在每个话题页面请求完成后触发事件，并传递 topicUrl 和 res.text。

3. 数据处理：

   • 最终将所有话题的信息收集起来并打印出来。

通过这种方式，可以有效地处理多个异步请求，并在所有请求完成后进行统一的数据处理。