在 Node.js 中异步读取文件

Question

对于我的班级，我的教授希望我们创建一个简单的 node.js 网站，该网站读取包含完全限定 URL 的文本文件，然后使用该 URL 从远程网站检索 JSON 数据并最终保存 检索到的 JSON 到另一个文本文件。他希望将 URL 存储在全局变量中。

我已经用硬编码的 URL 完成了这项工作，该 URL 应该是从文件中读取的。运行良好，可以满足我的要求。我的问题是当我尝试为 URL 创建全局变量时，它总是返回未定义。我知道这是一个时间问题，因为文件没有被异步读取，但我不知道如何解决它。

'use strict';
// load the built-in http module
let http = require('http');
// load the add-in express module
let express = require("express");
// load the add-in xmlhttprequest and create XMLHttpRequest object
let XMLHttpRequest = require("xmlhttprequest").XMLHttpRequest;
// create app object from express() constructor
let app = express();
// create a port number
let port = process.env.PORT || 3000;
let fs = require('fs');

// create a "get" event handler function
// request and response object references (req, res)
function getJSON() {
    app.get("/", function (reqNode, resNode) {
        var test = new Promise(function (resolve, reject) {
            var req = new XMLHttpRequest();
            req.open('GET', 'http://gd2.mlb.com/components/game/mlb/year_2017/month_07/day_08/master_scoreboard.json');
            req.onload = function () {
                if (req.status === 200) {
                    resolve(req.responseText);
                }
                else {
                    reject(req.statusText);
                }
            }
            req.onerror = function () {
                reject("network error");
            };

            req.send();
        });

        test.then(
            function (response) {
                // display in browser on success
                resNode.send('JSON data saved to file.');
            },
            function (error) {
                console.error("Request failed: ", error);
            }
        ),
            test.then(
                function (response) {
                    // write the response to json.txt
                    fs.writeFile('json.txt', response, function (err) {
                        if (err) {
                            console.log(err);
                        }
                        else {
                            console.log('JSON data saved to file.');
                        }
                    });
                },
                function (error) {
                    console.log(error);
                }
            ),
            test.catch(
                error => console.log(error)
            )
    });
}

(function () {
    // create a server object
    let server = http.createServer(app);

    // listen on specified port for get requests
    server.listen(port);
    // call getJSON function
    getJSON();
})();

此代码适用于硬编码的 URL，但我需要一个函数将其存储在全局变量中。

依赖关系：

"dependencies": {
    "express": "^4.17.1",
    "xmlhttprequest": "^1.8.0"
  }

而且，我尝试过的异步/等待。 'url' 变量返回未定义，所以这不起作用。没有返回错误，但是 localhost 加载失败。

'use strict';
// load the built-in http module
let http = require('http');
// load the add-in express module
let express = require("express");
// load the add-in xmlhttprequest and create XMLHttpRequest object
let XMLHttpRequest = require("xmlhttprequest").XMLHttpRequest;
// create app object from express() constructor
let app = express();
// create a port number
let port = process.env.PORT || 3000;
let fs = require('fs');

function readTxt() {
    fs.readFile('urls.txt', { encoding: 'utf-8' }, function (err, data) {
        if (err) {
            console.log('Error reading file: ' + err)
        }
        else {
            return new Promise(function (resolve, reject) {
                setTimeout(function () {
                    resolve(data);
                }, 3000)
            });
        }
    });
}


// create a "get" event handler function
// request and response object references (req, res)
async function getJSON() {
    let url = await readTxt();
    console.log(url);
    app.get("/", function (reqNode, resNode) {
        var test = new Promise(function (resolve, reject) {
            var req = new XMLHttpRequest();
            req.open('GET', url);
            req.onload = function () {
                if (req.status === 200) {
                    resolve(req.responseText);
                }
                else {
                    reject(req.statusText);
                }
            };

            req.onerror = function () {
                reject("network error");
            };

            req.send();
        });

        test.then(
            function (response) {
                // display in browser on success
                resNode.send('JSON data saved to file.');
            },
            function (error) {
                console.error("Request failed: ", error);
            }
        ),
            test.then(
                function (response) {
                    // write the response to json.txt
                    fs.writeFile('json.txt', response, function (err) {
                        if (err) {
                            console.log(err);
                        }
                        else {
                            console.log('JSON data saved to file.');
                        }
                    });
                },
                function (error) {
                    console.log(error);
                }
            ),
            test.catch(
                error => console.log(error)
            )
    });
}

(async function () {
    // create a server object
    let server = http.createServer(app);

    // listen on specified port for get requests
    server.listen(port);
    // call getJSON function
    getJSON();
})();

我不相信这是重复的。我查看了其他问题，我尝试使用 async/await（上面的代码），作为对这个问题的回答：https://stackoverflow.com/questions/14220321/how-do-i-return-the-response-from-an-asynchronous-call. 这可能会起作用，但我无法正确设置它。提前致谢！

Answer 1

您对readTxt 函数的实现是错误的。这是它的正确实现。我添加了 cmets 来描述如何使用 Promise。

function readTxt() {
    // return a promise from the function
    return new Promise(function (resolve, reject) {
      // do the asynchronous operation
      fs.readFile('urls.txt', { encoding: 'utf-8' }, function (err, data) {
        if (err) {
            console.log('Error reading file: ' + err)
            // reject the promise in case of error
            reject(err);
        }
        else {
            setTimeout(function () {
                // resolve the promise after successfull execution of asynchronous code
                resolve(data);
            }, 3000)
        }
    });
}