nodejs异步转同步

项目在微信环境开发,需要获取access_token进行授权登录和获取用户信息。

特意把这块功能拿出来封装一个自定义module

module.exports = new Wechat(con.appid,con.secret,con.url);

之前appid和secret是在本地配置文件写死的,后来要求系统后台可以配置公众号。

就需要从后台请求来获取配置参数。这就遇到问题了。

var wechat = require('./modules/wechat');
var rule = new schedule.RecurrenceRule();
//rule.hour = [0,2,4,6,8,10,12,14,16,18,20,22];
rule.minute = 0;
var j = schedule.scheduleJob(rule,function(){
wechat.getBaseTokenForever();
});
wechat.getBaseTokenForever();

我的服务会在开启以及每小时来获取新的access_token,并存入数据库,以保证其是一直有效的,用来控制请求次数不会超额。

后来模块改为

var data = {};
    request({
        url: con.url + '/路由',method: "POST"truefunction (err,response,body) {
        if (err || body.code != 0) {
            console.log('获取公众号配置失败 '+ Date());
        } else {
            console.log('获取公众号配置 '+ Date());
            data = body.data;
        }
    });


module.exports =   () {
    return new Wechat(data.appid,data.secret,con.url);
};

但是nodejs的异步特效,会导致请求没有完成就执行下面的代码,出现错误。

经过多方查找,可以使用async模块来异步转同步,只有前一个function执行callback,下一个才会执行。 

var async = require('async');
async.waterfall([
    (callback){
        getWechat();
         getWechat() {
            if(!wechat().appid){
                setTimeout( () {
                    getWechat();
                },1000);
                console.log(wechat());
            }  {
                callback(null(wechat,callback){   
    
var rule = schedule.RecurrenceRule(); //rule.hour = [0,22]; rule.minute = 0; var j = schedule.scheduleJob(rule,(){ wechat.getBaseTokenForever(); }); wechat.getBaseTokenForever(); callback() } ],1)">(err,results){ console.log(err) });

 

相关文章

这篇文章主要介绍“基于nodejs的ssh2怎么实现自动化部署”的...
本文小编为大家详细介绍“nodejs怎么实现目录不存在自动创建...
这篇“如何把nodejs数据传到前端”文章的知识点大部分人都不...
本文小编为大家详细介绍“nodejs如何实现定时删除文件”,内...
这篇文章主要讲解了“nodejs安装模块卡住不动怎么解决”,文...
今天小编给大家分享一下如何检测nodejs有没有安装成功的相关...