在 fs.readFile() 的回调中使用 Email.send 时出现流星“光纤”错误

Question

当我尝试在来自fs.readFile 的回调中使用Email.send 时，我得到Error('Can\'t wait without a fiber')。如果我直接调用Email.send，我不会收到此错误。

这是错误：

(STDERR) /Users/james/.meteor/packages/meteor-tool/.1.1.8.tvnipv++os.osx.x86_64+web.browser+web.cordova/mt-os.osx.x86_64/dev_bundle/server-lib/node_modules/fibers/future.js:155
  throw new Error('Can\'t wait without a fiber');
        ^
=> Exited with code: 8
(STDERR) Error: Can't wait without a fiber
   at Function.wait (/Users/james/.meteor/packages/meteor-tool/.1.1.8.tvnipv++os.osx.x86_64+web.browser+web.cordova/mt-os.osx.x86_64/dev_bundle/server-lib/node_modules/fibers/future.js:155:9)
   at Object.Future.wait (/Users/james/.meteor/packages/meteor-tool/.1.1.8.tvnipv++os.osx.x86_64+web.browser+web.cordova/mt-os.osx.x86_64/dev_bundle/server-lib/node_modules/fibers/future.js:397:10)
   at smtpSend (packages/email/email.js:86:1)
   at Object.Email.send (packages/email/email.js:176:1)
   at email.js:49:17
   at fs.js:272:14
   at Object.oncomplete (fs.js:108:15)

这是我的 JavaScript。请注意，我使用了一个虚拟 MAIL_URL，以保护无辜者。

if (Meteor.isClient) {
  var to = 'you@example.com'
  var from = 'me@example.com'
  var title = 'Message'
  var message = "emails/message.html"

  Meteor.call(
    'sendEmail'
  , to
  , from
  , title
  , message
  , callback
  )

  function callback(error, data) {
    console.log(error, data)
  }
}

if (Meteor.isServer) {
  Meteor.startup(function () {
    // REPLACE WITH YOUR OWN MAIL_URL FOR OUTGOING MESSAGES
    process.env.MAIL_URL = 'smtp://me%40example.com:PASSWORD@smtp.example.com:25';

    // HACK TO FIND public/ DIRECTORY IN Meteor 1.2.0.1
    var _public = "../../../../../public/"

    var fs = Npm.require('fs');

    Meteor.methods({
      sendEmail: function (to, from, subject, file) {
        var self = this
        var data = file
        check([to, from, subject, file], [String]);

        fs.readFile(_public + file, 'utf8', function (err, data) {
          if (err) {
            console.log('Error: ' + err);
            return;
          }

          // Let other method calls from the same client start,
          // running without waiting for the email sending to
          // complete.
          self.unblock();

          Email.send({ // ERROR OCCURS HERE
            to: to,
            from: from,
            subject: subject,
            html: data
          });
        });
      }
    });
  });
}

如果我绕过对fs.readFile 的调用，一切正常，方法是添加 cmets，如下所示：

    // fs.readFile(_public + file, 'utf8', function (err, data) {
    //   if (err) {
    //     console.log('Error: ' + err);
    //     return;
    //   }

      // Let other method calls from the same client start,
      // running without waiting for the email sending to
      // complete.
      self.unblock();

      Email.send({ // ERROR HERE
        to: to,
        from: from,
        subject: subject,
        html: data
      });
    // });

您能帮我理解为什么在最初的情况下需要fiber，以及我应该如何提供？

Answer 1

Meteor 方法调用总是在 Fiber 内部运行，它为 Node 事件循环回调样式提供了一个同步的 API。

您可以使用 Meteor.wrapAsync 将异步 fs.readFile 调用转换为同步调用：

var fsReadFileSync = Meteor.wrapAsync(fs.readFile, fs);
var data = fsReadFileSync(_public + file, 'utf8');
Email.send(...);

编辑：

将异步读取包装在里面有什么区别 Meteor.wrapAsync，并使用fs.readFileSync？包装的异步 读取会带来更好的性能吗？

fs.readFileSync 将阻止 Node 事件循环，因此仅用于诸如命令行实用程序之类的事情。

相反，封装的fs.readFile 看起来会阻塞事件循环以同步执行 I/O 任务，但实际上它仍在使用非阻塞回调机制。

在网络服务器应用程序中，您真的不希望您的 Node 进程被 I/O 任务阻塞，因为这意味着它可能无法尽快响应客户端请求。