首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Node.js &共同避免将承诺和事件回调混合在一起

Node.js &共同避免将承诺和事件回调混合在一起
EN

Stack Overflow用户
提问于 2017-12-18 14:07:31
回答 1查看 656关注 0票数 0

最近,我一直在试验phantomjs-node库。我想要实现的基本目标是创建一个动态网页模板,使用phantomjs-node库“运行”它,最后从呈现的页面中提取一些数据。

在最简单的设置中,第一次尝试这样做是这样的(在下面的示例中,模板只是静态的,但原则上它可能包含一些使用外部库的进一步逻辑,等等):

代码语言:javascript
复制
var phantom = require('phantom');
var co = require('co');
var sleep = require('system-sleep');
var winston = require('winston');

const logger = new winston.Logger({
    level: 'debug',
    transports: [new winston.transports.Console({
        json: false, timestamp: () => (new Date()).toLocaleString()
    })]
});

co(function*() {
    logger.info('start');
    var instance = yield phantom.create();   
    try {
        const html = `
                <!DOCTYPE html>
                <html>
                    <head>
                        <title>Page title</title>
                    </head>
                    <body>
                        <div id='results'>Page data</div>
                    </body>
                </html>
            `;

        var page = yield instance.createPage();    

        yield page.on('onLoadFinished', function(){
            logger.info('onLoadFinished');

            page.evaluate(function(){
                return document.getElementById('results').textContent;    
            }).then(function(val){
                logger.info(`RESULT = ${val}`);    
            }).catch(function(val){
                logger.error(val.message);    
            });
        });

        yield page.setContent(html, 'http://localhost');

    }catch (e){
        logger.error(e.message);       
    }finally{
        instance.exit();
    }
    logger.info('done');
});

但是,输出失败:

代码语言:javascript
复制
12/18/2017, 2:44:32 PM - info: start
12/18/2017, 2:44:33 PM - info: done
12/18/2017, 2:44:33 PM - info: onLoadFinished
12/18/2017, 2:44:33 PM - error: Phantom process stopped with exit code 0

最可能的原因是,当最终调用由then返回的承诺的-callback时,主幻影进程已经退出。

为了“解决”这一问题,我采用了以下简易策略(省略了下面的其余示例):

代码语言:javascript
复制
    var page = yield instance.createPage();

    var resolver;
    var P = new Promise(function(resolve, reject){ resolver = resolve; });

    yield page.on('onLoadFinished', function(){
        logger.info('onLoadFinished');

        resolver(page.evaluate(function(){
            return document.getElementById('results').textContent;
        }));
    });

    yield page.setContent(html, 'http://localhost');

    const val = yield P;
    logger.info(`RESULT = ${val}`);

这从本质上创建了一个新的承诺,它“外部”解决了从page.evaluate返回的承诺。然后,位于yield P块末尾的co语句阻塞,直到所需的结果就绪为止,因此输出结果与预期的一样:

代码语言:javascript
复制
12/18/2017, 2:53:47 PM - info: start
12/18/2017, 2:53:48 PM - info: onLoadFinished
12/18/2017, 2:53:48 PM - info: RESULT = .....
12/18/2017, 2:53:48 PM - info: done

虽然这看起来很有效,但感觉很“麻烦”(例如,在主resolver块中不会检测到调用try/catch之前在回调中抛出的异常),所以我想知道什么是更干净的方法,以便将onLoadFinished回调的控件“传输”到由co管理的领域。

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2017-12-18 18:39:24

  • 不要再使用co +生成器函数了。async/await在这里。
  • 是的,您应该将触发(最多一次)的所有事件回调转换为承诺。
  • 不,永远不要做出这样的承诺,“从外部解决它们”。只需将解决这些问题的内容放在承诺构造函数中即可。

代码语言:javascript
复制
(async function() {
    logger.info('start');
    var instance = await phantom.create();   
    try {
        const html = `…`;
        const page = await instance.createPage();    

        await new Promise((resolve, reject) => {
            page.on('loadFinished', resolve);
            page.on('resourceError', reject); // or something like that?
            page.setContent(html, 'http://localhost'); // this doesn't appear to return a promise
        })
        logger.info('onLoadFinished');

        try { // this extra inner try looks superfluous
            const val = await page.evaluate(function(){
                return document.getElementById('results').textContent;    
            });
            logger.info(`RESULT = ${val}`);
        } catch(e) {
            logger.error(e.message);    
        }
    } catch(e) {
        logger.error(e.message);       
    } finally {
        instance.exit();
    }
    logger.info('done');
}());
票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/47870195

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档