使用承诺重构代码以读取文件并将它们转换为 json

Question

我正在尝试执行以下操作：读取目录的内容以查找所有 .xml 文件（我使用的是glob，但我想使用 fs 中的 fs.readdir 之类的东西），然后我想使用 fs.readFile 读取每个文件，然后我想将 xml 文件转换为 JSON 对象。为此，我使用xml2json。

一旦我有了 json 对象，我想迭代它们中的每一个以从中获取一个属性并将其推送到数组中。最终，所有代码都包装在一个记录数组内容的函数中（一旦完成）。这段代码目前运行良好，但我正在进入著名的回调地狱。

const fs = require('fs');
const glob = require('glob');
const parser = require('xml2json');
let connectors = [] 


function getNames(){
glob(__dirname + '/configs/*.xml', {}, (err, files) => {
     for (let j=0; j < files.length; j++) {
          fs.readFile( files[j], function(err, data) {
             try {
                   let json = parser.toJson(data, {object: true, alternateTextNode:true, sanitize:true})               
                   for (let i=0; i< json.properties.length; i++){
                     connectors.push(json.properties[i].name)
                   if (connectors.length === files.length){return console.log(connectors)}
                   }
              }
              catch(e){
                   console.log(e)
              }
       });
     }
 })
}
getNames()

但是，我想转向一个更干净、更优雅的解决方案（使用 Promise）。我一直在阅读社区，并在here 或here 的一些类似帖子中找到了一些想法。

我想听听您对我应该如何处理这种情况的意见。我应该改用 readFile 的同步版本吗？我应该使用promisifyAll 重构我的代码并在任何地方使用promise 吗？如果是这样，您能否详细说明我的代码应该是什么样的？

我还了解到从节点 v10.0.0 开始有一个 promises based version of fs。我应该选择那个选项吗？如果是这样，我应该如何处理 parser.toJson() 部分。我还看到还有另一个基于 Promise 的版本，称为 xml-to-json-promise。

非常感谢您对此的见解，因为当涉及多个异步操作和循环时，我对 Promise 不是很熟悉，因此我最终会为这种情况提供肮脏的解决方案。

问候， J

Answer 1

我确实建议你使用glob 和fs 的promise 版本，然后使用async、await 和Promise.all 来完成这一切。

注意：我看不到有关connectors.length === files.length 检查的逻辑，因为理论上连接器（属性）的数量可能大于文件的数量。我假设你想收集他们的所有，不管他们的数量。

以下是代码的外观（未经测试）：

const fs = require('fs').promises; // Promise-version (node 10+)
const glob = require('glob-promise'); // Promise-version
const parser = require('xml2json');

async function getNames() {
    let files = await glob(__dirname + '/configs/*.xml');
    let promises = files.map(fileName => fs.readFile(fileName).then(data =>
        parser.toJson(data, {object: true, alternateTextNode:true, sanitize:true})
              .properties.map(prop => prop.name)
    ));
    return (await Promise.all(promises)).flat();
}

getNames().then(connectors => {
    // rest of your processing that needs access to connectors...
});

正如您在 cmets 中所写的那样，您在访问 properties.map 时遇到问题，执行一些验证，并跳过不存在 properties 的情况：

const fs = require('fs').promises; // Promise-version (node 10+)
const glob = require('glob-promise'); // Promise-version
const parser = require('xml2json');

async function getNames() {
    let files = await glob(__dirname + '/configs/*.xml');
    let promises = files.map(fileName => fs.readFile(fileName).then(data =>
        (parser.toJson(data, {object: true, alternateTextNode:true, sanitize:true})
              .properties || []).map(prop => prop.name)
    ));
    return (await Promise.all(promises)).flat();
}

getNames().then(connectors => {
    // rest of your processing that needs access to connectors...
});