nodejs 异步转同步

时间: 2018-04-16阅读: 1094标签: node

nodej项目在微信环境开发,需要获取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",
        json: true,
        body: {}
    }, function (err, response, body) {
        if (err || body.code != 0) {
            console.log('获取公众号配置失败 '+ Date());
        } else {
            console.log('获取公众号配置 '+ Date());
            data = body.data;
        }
    });

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


但是nodejs的异步特效,会导致请求没有完成就执行下面的代码,出现错误。经过多方查找,可以使用async模块来异步转同步,只有前一个function执行callback,下一个才会执行。 

var async = require('async');
async.waterfall([
    function(callback){
        getWechat();
        function getWechat() {
            if(!wechat().appid){
                setTimeout(function () {
                    getWechat();
                },1000);
                console.log(wechat());
            } else {
                callback(null,wechat())
            }
        }
    },
    function(wechat, callback){   
     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();
        callback(null)
    }
], function(err, results){
    console.log(err)
});


来源:https://www.cnblogs.com/gxp69/archive/2018/04/15/nodejs.html

深入解析Node.js Stream ondata触发时机与顺序

今天小编就为大家分享一篇关于Node.js Stream ondata触发时机与顺序的探索,写的十分的全面细致,具有一定的参考价值,对此有需要的朋友可以参考学习下。如有不足之处,欢迎批评指正。

Node编码规范

采用2个空格缩进,而不是tab缩进。空格在编辑器中与字符是等宽的,而tab可能因编辑器的设置不同。2个空格会让代码看起来紧凑、明快。永远用var声明变量,不加var时会将其变为全局变量,这样可能会意外污染上下文,或是被意外污染。

Node.js创建服务器和模拟客户端请求

服务器是某种长期运行,等待请求资源的应用程序,Web服务器是使用HTTP协议,等待客户端连接后请求资源的驻守应用程序;HTTP协议是应用层的协议,在传输层依然是使用TCP或者UDP协议

解决mac上每次升级nodejs都要重新安装扩展包的问题

以前用起来没注意到这个现象,最近一段时间发现,每次随着使用brew upgrade自动升级了nodejs版本,原来安装的nodejs扩展包就不起作用了,还需要重新安装一遍。再加上一些扩展包存储网站被墙的问题,这个过程真是令人痛不欲生

YodaOS:一个属于 Node.js 社区的操作系统

YodaOS 的架构跟 Android 类似,YodaOS 是 Rokid 研发的首个全栈开源 AI 操作系统,由 Linux 内核、硬件抽象层、AI 抽象层和 JavaScript 框架组成,专为下一代人机交互设备开发,可用于智能音箱、智能家居、智能穿戴和车载等多种设备和场景。

安装nvm管理不同的node版本

在工作或者学习中,偶尔会遇到需要切换不同node版本的需求,幸好有神器nvm可以帮我们解决问题。下面我们就来讲解如何在window系统上安装nvm! 第一步,当然要下载nvm啦,传送门,目前最新的版本是1.17,注意,笔者下载的是nvm-noinstall.zip的压缩文件

node.js+react.js+xterm.js构建webssh

先讲一下简单的原理:前端和后端的通信,使用的是socket.js,后端连接服务器,使用的是ssh2.js,页面显示出控制台这个操作页面,使用的是xterm.js。整个工作流程就是:前端在xterm.js里面输入文字,通过socket和后端通信

node.js中net网络模块TCP服务端与客户端的使用

node.js中net模块为我们提供了TCP服务器和客户端通信的各种接口。创建服务器并监听端口,net.Socket是一个socket端口对象,是一个全双工的可读可写流,创建一个tcp客户端

Nodejs ORM框架Sequelize快速入门

什么是ORM?简单的讲就是对SQL查询语句的封装,让我们可以用OOP的方式操作数据库,优雅的生成安全、可维护的SQL代码。什么是Sequelize?Sequelize是一款基于Nodejs功能强大的异步ORM框架。

Ubuntu 上 Node.js 安装和卸载

Ubuntu 安装 Node.Js:执行检查可更新的软件,先用普通的apt工具安装低版本的node,然后再升级最新。更换淘宝的镜像,这个是必须的,用过的node的人都知道。安装更新版本的工具N

fly63.com版权所有,内容以共享、参考、研究为目的,不存在任何商业目的。其版权属原作者所有,如有侵权,请与小编联系!情况属实本人将予以删除!

广告赞助文章投稿关于web前端网站点搜索站长推荐网站地图站长QQ:522607023

小程序专栏: 土味情话心理测试脑筋急转弯幽默笑话段子句子语录成语大全