node.js - 回调函数在节点调度程序中不起作用
问题描述
我已经使用 node.js 成功编写了一个代码来阅读我的邮箱中看不见的电子邮件。当我在普通的 javascript 文件中运行它时它工作正常。现在我想安排脚本每 30 秒运行一次。所以使用 node-scheduler 编写了一个代码片段,如下所示。运行这个我只是reading unread emails....###
作为输出得到,console.log(msg);
而不是打印任何东西。如果我在没有 nod-scheduler 的情况下运行它,它工作正常。可能是什么问题?我用函数尝试await
了关键字email.unreadEmail
,它也不起作用。
我相信这是由于异步行为而发生的事情。如果是这样,有没有办法将此代码转换为承诺?我有点困惑,因为 imap 接口中有多个 nexted 回调。
schedule.scheduleJob('*/30 * * * * *', () => {
logger.info(`scheduler runs at ${new Date()} for check unread emails`);
let email = new mail.default();
email.unreadEmail((msg) => {
console.log(msg);
});
});
这是电子邮件阅读的代码
unreadEmail(callback){
logger.info(`reading unread emails....###`);
imap.once('ready', () => {
openIncidents((err, box) => {
if (err) throw err;
imap.search([ 'UNSEEN'], (err, results) => {
if (err) throw err;
try{
// var f = imap.fetch(results, { bodies: '',markSeen: true });
var f = imap.fetch(results, { bodies: '' });
f.on('message', (msg, seqno) => {
console.log('Message #%d', seqno);
var prefix = '(#' + seqno + ') ';
msg.on('body', (stream, info) => {
simpleParser(stream, (err, mail) => {
callback(mail.subject);
});
// stream.pipe(fs.createWriteStream('msg-' + seqno + '-body.txt'));
});
msg.once('attributes', function(attrs) {
logger.info(prefix + 'Attributes: %s', inspect(attrs, false, 8));
});
msg.once('end', function() {
logger.info(prefix + 'Finished');
});
});
f.once('error', function(err) {
logger.error('Fetch error: ' + err);
});
f.once('end', function() {
logger.info('Done fetching all messages!');
imap.end();
});
}catch (e) {
logger.error('Error from fetching mails, probably there are no unseen emails in mailbox');
}
});
});
});
logger.info(`end of the email function....###`);
}
更新
这种行为与setInterval
功能相同
setInterval(()=>{
email.unreadEmail((msg)=>{...})}, 30000)
解决方案
假设您使用的是imap
NPM 模块(您未在原始问题中指定),'ready'
新 imap 连接的事件仅在身份验证时触发一次(请参见_login
此处的代码:https ://github.com/mscdex/node -imap/blob/master/lib/Connection.js#L1604)。
因此,imap.once('ready' ...
您应该将您的日程安排在imap.once('ready' ...
回调中,而不是放在日程表中。我希望以下内容能够确保您imap.once('ready', () => { ...
从unreadEmail
函数中删除。此外,根据您的用例 setInterval 可能是比节点计划更好的选择:
imap.once('ready', () => {
setInterval(() => {
logger.info(`scheduler runs at ${new Date()} for check unread emails`);
let email = new mail.default();
email.unreadEmail((msg) => {
console.log(msg);
});
}, 30000);
});
推荐阅读
- c++ - 让 cURL 在 64 位机器上与 Visual Studios 2017 32 位一起工作
- c - c编程函数薪水
- project-reactor - 动态合并通量
- javascript - js `Number` 类型加起来会是 Infinity 吗?
- excel - 如何在遵循过滤条件的数据透视表中进行加权平均?
- php - 从 URL 下载图像并上传到 WordPress 媒体库
- ios - 如何解决位置问题:iOS(ipad/iphone)屏幕底部的按钮固定?
- javascript - 我应该如何根据javascript中的参数类返回一个类?
- tensorflow - 如何对tensorflow中的张量执行np.append()类型的操作?
- php - 如何计算每个给定评分的平均评分?