Promise你把握不住?来看看异步转同步改造(上)

简介: Promise你把握不住?来看看异步转同步改造

前言

先说一下上一篇NodeJS文章

NodeJS 后端开发 06 连接MySQL

,这一篇展示了一个数据库链接的db.js 工具库。


该工具库提供了一个runSql函数,它的运行方式是先提交SQL,然后再异步把查询结果回调传递给callback函数的。


这个函数只适用于提前加载数据的情况,比如预先缓存批量的查库结果。然后用户请求WebAPI的时候,直接读查询缓存。

这样会有下面的问题:


新数据入库了,本地缓存需要更新。

而且无法支持动态查询。

说这么多,直接用Koa做个接口演示一下查询效果吧。


代码展示,KOA做接口查询数据库

const koa = require('Koa');                                                 
const app = new koa()
var router = require('koa-router')();
var db = require('./db-lite');
//做个简单接口
router.get('/', function(ctx, next){ctx.body='Hello, geeklevin!'});
//做个接口查询数据库
router.get('/query', function(ctx,next){
    db.runSql("SELECT * FROM COMPANY; ", function(result,fields){
        console.log('查询结果:', result);
        ctx.body = JSON.stringify(result);
        console.log('设置响应body成功!');
    });
    console.log('processing');
});
//启动服务器
app.use(router.routes());
const PORT = 8081
console.log('start app at port %s', PORT)
app.listen(PORT);

先查看简单接口展示效果:

image.png

再看看/query接口

日志看到设置了响应体ctx.body成功了,可这时候请求已经结束了。

因为db.runSql函数不是同步执行了,/query这个接口执行这个函数,碰到函数结束了,当前请求处理完毕,没有设置请求体,所以响应Not Found。

image.png

看看Promise吧

var data = new Promise(function(resolve, reject){
    asynFunction(function(error, result){
          if(error){
               reject(error);
          }else{
               resolve(result);
          }
    });
});
async getData(){
    var result = await data();
    console.log('result is:', result);
}

就两段代码,第一段是构造Promise对象;第二段为调用Promise对象处理异步请求。


先说Promise。data是一个Promise对象,它内部调用了一个异步函数asynFunction(这个函数可以是查库,请求其他网站接口,消息队列获取数据等),但是它能够保证两个结果:


处理异步请求成功的时候调用resolve函数,传递result对象;

出错的时候调用reject函数,传递error对象。

就这么简单。


第二段代码就是一个声明了异步响应的函数,虽然内部调用的Promise对象,又套娃调用了异步函数,但是await语法糖,能够保证result变量赋值这一行同步执行,也就是getData会等待result赋值这一行异步调用执行完毕,再执行console.log。


这里稍微有点绕了,请读者停下来,好好思考整理一下。


简单来说就是,在async声明的异步函数中,同步等待Promise内部执行结果,就是,同步等待异步请求。


这样,异步转同步,很神奇吧!


像查询数据库这样的异步操作就能够在API中被等待,并响应给用户了,下面来代码了。


好,用koa接口得怎么做呢?需要在数据库调用端怎么调整呢?


下面是runSql的简化实现代码,我们要改造它


const runSql = function(sql, callback){
    console.log('will run sql:', sql);
    //这里是异步调用的,但是不是Promise实现,没有办法使用asyn,await来实现同步等待异步请求。
    db.query(sql, function(error, result, fields){
        try{
            if(error) throw error;
            console.log('query result:', result); 
        }finally{
            if(callback) callback(result, fields);
        }
    });
}

先看koa怎么搞?

这个好办, 下面是一个简单的router(路由web API)。

我们看到在router.get 第二个参数加了async关键字修饰的方法。

根据ES6,我们知道async函数内可以使用await强制等待异步Promise函数的相应结果。

很明显,上面的runSql函数返回不是一个Promise对象的,所以这里先调用一个未实现的函数:prunSql。


router.get('/asynQuery', async function(ctx, next){
    //参考上面Promise使用,声明同步等待一个返回Promise对象的函数。
    var data = await prunSql('SELECT * FROM COMPANY;');
    ctx.body = JSON.stringify(data)
});

这是一个新的接口, 跟其他接口不一样的就是,它处理请求的方法是用async声明的异步函数。

我们需要改造runSql函数

const prunSql = function(sql){
    console.log('will run sql:', sql);
    return new Promise(function(resolve, reject){
        console.log('asyn run sql: ', sql);
        db.query(sql, function(error, result, fields){
            if(error){
                console.log('[%s] asyn error:', error);
                reject(error);
            }else{
                console.log('asyn result:', result);
                resolve(result);
            }
        });
    });
};

这就是改造好的prunSql,这里用了resolve函数把数据库查询结果传递出去。

这样在使用Promise的then可以获取到异步查询结果。

或者在一个异步响应的方法内await Promise对象,等待查询返回值。

目录
相关文章
vscode 打开多个标签页
vscode 打开多个标签页
691 0
|
存储 算法 定位技术
每个系统都在用的appid、appkey、appsecret都是什么意思?
每个系统都在用的appid、appkey、appsecret都是什么意思?
12253 0
|
11月前
|
存储 缓存 网络协议
如何防止DNS缓存中毒攻击(一)
DNS缓存中毒,即DNS欺骗,是一种通过利用DNS系统的漏洞,将用户流量从合法服务器导向虚假服务器的网络攻击。攻击者通过伪造DNS响应,使缓存服务器存储错误的IP地址,从而实现对合法URL的劫持。这不仅可能导致用户信息泄露,还可能使用户设备遭受恶意软件感染,对金融、医疗等关键领域造成严重影响。据统计,DNS攻击每年造成的平均损失高达223.6万美元,其中23%的攻击源自DNS缓存中毒。
177 0
|
编解码 Ubuntu 算法
Ubuntu桌面图标指南:一文了解如果设置ubuntu 软件图标
Ubuntu桌面图标指南:一文了解如果设置ubuntu 软件图标
3372 0
|
Java 数据库连接 数据库
Spring基础3——AOP,事务管理
AOP简介、入门案例、工作流程、切入点表达式、环绕通知、通知获取参数或返回值或异常、事务管理
Spring基础3——AOP,事务管理
npm 包本地调试(详细流程:包本地路径、npm link 、yalc)
npm 包本地调试(详细流程:包本地路径、npm link 、yalc)
684 0
|
Web App开发 JavaScript 前端开发
十分钟搞懂 WebAssembly
十分钟搞懂 WebAssembly
3295 0
十分钟搞懂 WebAssembly
|
JavaScript 索引
Vue 模拟通讯录列表用 js-pinyin 获取汉字首字母,形成字母索引
Vue 模拟通讯录列表用 js-pinyin 获取汉字首字母,形成字母索引
368 0