Nodejs 逐行读取文件并在最后获取其内容



我想使用 nodejs 逐行读取文件,然后在完成后以 json 字符串的形式获取返回的结果。我试图这样做,但最后控制台.log打印未定义而不是列表。我得到了列表和承诺的结尾,但我如何将其返回到 main.js 中的调用函数?

我有我的主文件.js文件:

var fct = require('./romlist-parser');
console.log(fct.myfunction());

而 romlist-parser.js 具有以下内容:

var fs = require('fs');
var readline = require('readline');
exports.myfunction = function() {
    var promise = new Promise(function(resolve,reject) {
        var rd = readline.createInterface({
            input: fs.createReadStream('Atari 2600.txt'),
            console: false
        });
        var games = [];
        rd.on('line', function(line) {
            var arr = line.split(";");
            games.push({name:arr[0], title:arr[1]});
        });
        rd.on('close', function() {
            var json = JSON.stringify(games);
            resolve(games);
        });
    });
    promise.then((resolveResult) => {
        console.log(resolveResult);
        return resolveResult;
    });
};

试试这个:

exports.myfunction = function() {
    var promise = new Promise(function(resolve,reject) {
        var games = [];
        var rl = readline('./Atari 2600.txt'); // provide correct file path
        rl.on('line', function (line, lineCount, byteCount) {
            // console.log(lineCount, line, byteCount);
            var arr = line.split(";");
            games.push({name:arr[0], title:arr[1]});
        })
        .on('close', function() {
            var json = JSON.stringify(games);
            resolve(games); // resolve(json); may be?? 
        })
        .on('error', function (e) {
            console.log("error", e);
            // something went wrong
        });
    });
    promise.then((resolveResult) => {
        console.log(resolveResult);
        return resolveResult;
    });
};

附言此代码可以进一步改进,但为了简单起见,您的理解答案仅限于帖子中发布的样式/代码。否则,它可以因样式而异。

我会将设置和累积结果的变量移动到封闭范围内,然后,最重要的是,从创建它的函数返回承诺。 所以。。。

exports.myfunction = function(filename) {
    let games = [];
    let rd = readline.createInterface({
        input: fs.createReadStream(filename),
        console: false
    });
    return new Promise(function(resolve,reject) {
        rd.on('line', function(line) {
            var arr = line.split(";");
            games.push({name:arr[0], title:arr[1]});
        });
        rd.on('close', function() {
            var json = JSON.stringify(games);
            resolve(games);
        });
        // on 'error' call reject(error)
    });
};
// then elsewhere
const fct = require('./romlist-parser');
function someFunction() {
    let promise = fct.myfunction('Atari 2600.txt');
    return promise.then(result => {
        console.log(result);
        return resolveResult
    });
}

我还需要处理大文件中的行的好方法。

所以我做了这个。您可以轻松地在文件,流,字符串,缓冲区中逐行迭代

它还支持反向模式!

请尝试,如果您喜欢它,请给我一颗星星!

https://github.com/sharpart555/nexline

const nl = nexline({
  input: fs.openSync(path_to_file, 'r'), // input can be file, stream, string and buffer
});
console.log(await nl.next()); // 'foo'
console.log(await nl.next()); // 'bar'
console.log(await nl.next()); // 'baz'
console.log(await nl.next()); // null, If all data is read, then return null

最新更新