关闭流 node.js

Question

我无法关闭 node.js 中的流这是我的代码

        var inp = fs.createReadStream("a/b/c/"+ Name);
        var out = fs.createWriteStream("a/b/c/"+ Name);
        inp.pipe(out);
            inp.close( function(err){
              if (err){
                console.log(err);
              } else {
              inp.unpipe(out);
              socket.emit('Done',{'Name':name});
              console.log('There will be no more data.');
              }
            });

然后我在我的代码中有这个功能，删除目录 inp 的目录

var fse = require("fs-extra");
fse.emptyDir("a/b/c/", function(err){
  if(err){
    console.log(err);
  } else {
    console.log("doneaaaa")
    fse.remove("a/b/c",function(err){
      if(err){
        console.log(err);
      } else {
        console.log('doneaswell');
      }
    });
  }
});

我得到了这个错误！！

doneaaaa
{ [Error: EBUSY: resource busy or locked, unlink 'a/b/c/.nfs000000002ab5000d00000072']
  errno: -16,
  code: 'EBUSY',
  syscall: 'unlink',
  path: 'a/b/c/.nfs000000002ab5000d00000072' }

这意味着流仍然打开！

.nfs 文件是在正确流式传输时创建的，但在流式传输关闭后不应该删除文件吗？

我做错了什么？

Answer 1

您必须等待回调关闭才能执行删除/解锁操作。从您提供的示例来看，情况并非如此。

Answer 2

Node.js 运行异步，这意味着目录的删除发生在流期间。而是尝试将删除放在回调中，以便它发生在：

var inp = fs.createReadStream("a/b/c/"+ Name);
var out = fs.createWriteStream("a/b/c/"+ Name);
inp.pipe(out);
inp.close( function(err){
  if (err){
    console.log(err);
  } else {
    inp.unpipe(out);
    socket.emit('Done',{'Name':name});
    console.log('There will be no more data.');
  }

  var fse = require("fs-extra");
  fse.emptyDir("a/b/c/", function(err){
    if(err){
      console.log(err);
    } else {
      console.log("doneaaaa");
      fse.remove("a/b/c",function(err){
        if(err){
          console.log(err);
        } else {
          console.log('doneaswell');
        }
      });
    }
  });
});

您还缺少我在此代码中添加的一行上的分号 :)