Promise（避免金字塔回调）

前后端分离开发，前端通过接口获取数据，但是有的页面不止一个接口，就会出现金字塔回调，可以通过 Promise 封装请求。

request-data.js：

function reqData(posturl, req, res, callback) {//请求用户数据

    request({

        url: con.url + posturl,

        method: "POST",

        json: true,

        headers: {

        }

    }, function (error, response, body) {

        if (!error && response.statusCode == 200) {

            callback(body.code, body.data, null);

        } else {

            callback(null, null, "error");

        }

    });

}

function reqPostData(posturl, bodyData, req, res, callback) {//请求用户数据

    request({

        url: con.url + posturl,

        method: "POST",

        json: true,

        headers: {

        },

        body: bodyData

    }, function (error, response, body) {

        if (!error && response.statusCode == 200) {

            callback(body.code, body.data, null);

        } else {

            callback(null, null, "error");

        }

    });

}

viewData.js：

//引入数据请求模块

var requestData = require('./request-data');

function getNoParam(postUrl,req, res,describe) {

    var describe = describe || '数据';

    //创建Promise对象

    var p = new Promise(function(resolve, reject){

        //发送获取相应数据的请求

        requestData.reqData(postUrl, req, res, function (code, data, err) {

            if (code == 0) {

                //成功返回数据

                resolve({Data:data});

            } else {

                //失败说明原因

                reject(describe + "获取失败:" + data);

            }

        });

    });

    return p;

}

function getWithParam(postUrl, postData,req, res,describe){

    var describe = describe || '数据';

    //创建Promise对象

    var p = new Promise(function(resolve, reject){

        //发送获取相应数据的请求

        requestData.reqPostData(postUrl, postData, req, res, function (code, data, err) {

            // console.log(code, data, err);

            if (code == 0) {

                //成功返回数据

                resolve({Data:data});

            } else {

                //失败说明原因

                reject(describe + "获取失败:" + data);

            }

        });

    });

    return p;

}

路由文件调用：

var viewData = require('../modules/viewData');

/*商品列表*/

router.get('/list', function (req, res) {

    Promise

        .all([viewData.getNoParam('/user/hot_list', req, res, '热门列表'), viewData.getWithParam('/user/recommend_list', {id: req.query.id}, req, res, '推荐列表')])

        .then(

            function (results) {

                res.render('index/pay_complet', {

                    title: '商品列表',

                    hot: results[0].Data,

                    rm: results[1].Data

                });

            },

            function (reason) {

                //console.log(reason);

                res.render('common/error', {title: '错误', message: reason});

            }

        );

});

巴特西

Promise（避免金字塔回调）

最新文章

热门文章