【Node.js笔记】在AnyProxy的rule里局部去异步的实现方法

locbytes

局部去异步是调用了一个叫deasync的包，该包的具体信息可以去npm官方介绍里查看[https://www.npmjs.com/package/deasync]
去异步主要是为了更方便的实现一些比较刁钻的业务逻辑。

[JavaScript] 纯文本查看 复制代码

const deasync = require('deasync');
const request = require('request');

let a = getRes(json);
function(a);

function getRes(jsonData) {
    let res, isReturn = false;
    request.post({
        url: url,
        form: {
            raw: jsonData
        }
        },
        function(err,httpResponse,body){
            if(httpResponse.statusCode===200){
                isReturn = true;
            }
            res=body;
        }
    );
    while(!isReturn){
        deasync.runLoopOnce();
    }
    return res;
}

例如使用anyproxy做某些业务的时候，去异步就能解决自定义规则中异步函数未执行完成就已经返回response的问题，代码参考如下：

[JavaScript] 纯文本查看 复制代码

const AnyProxy = require("anyproxy");
const deasync = require("deasync");
const request = require("request");
const options = {
    port: 8080,
    rule: {
        summary: "xxxxx",
        *beforeSendResponse(requestDetail, responseDetail) {
            let response = Object.assign({}, responseDetail.response);
            response.body = editResponseBody(rawBody);
            return {
                response: response
            };
        },
        *beforeDealHttpsRequest(requestDetail) {
            if(requestDetail.host.indexOf("xxxx")>=0){
                return true;
            }
        },
    },
    webInterface: {
        enable: true,
        webPort: 8081
    },
    throttle: 10240,
    forceProxyHttps: false,
    wsIntercept: false,
    silent: true
};
const proxyServer = new AnyProxy.ProxyServer(options);
proxyServer.start();
console.log("Start, port on "+options.port);
proxyServer.close();

// 因为需求原因将数据通过post请求交给PHP进行处理
function editResponseBody(rawBody) {
    let newBody, isReturn = false;
    request.post({
        url: "xxxx",
        form: {
            raw: rawBody
        }
        },
        function(err,httpResponse,body){
            if(httpResponse.statusCode===200){
                isReturn = true;
            }
            newBody=body;
        }
    );
    while(!isReturn){
        deasync.runLoopOnce();
    }
    return newBody;
}

首先自定义规则内部无法使用async/await，其次写回调的话会出现未回调但是已经返回response的问题。

vivilauge

把request封装成promise在哪里都可以调用，岂不快哉

locbytes

vivilauge 发表于 2018-7-14 13:25
把request封装成promise在哪里都可以调用，岂不快哉

这个不针对request，只针对那些刁钻的业务逻辑，比如多个异步函数要求按顺序依次执行，下一个异步函数调用上一个异步函数的返回值。

vivilauge

locbytes 发表于 2018-7-14 23:03
这个不针对request，只针对那些刁钻的业务逻辑，比如多个异步函数要求按顺序依次执行，下一个异步函数调 ...

promise 本身就是异步啦， 无论是request模块，还是http模块，ajax，都可以这样封装，封装好之后，再用异步调异步，如果你懂ES6语法，还可以直接用async await，一目了然

whitehack

async/await   比你这个优雅多了。

locbytes

vivilauge 发表于 2018-7-15 13:03
promise 本身就是异步啦， 无论是request模块，还是http模块，ajax，都可以这样封装，封装好之后，再用异 ...

我只能说有些业务逻辑无法实现...

locbytes

whitehack 发表于 2018-7-15 14:02
async/await   比你这个优雅多了。

有些业务逻辑依然无法实现，要不也不至于出这么个去异步的包。

vivilauge

不知道什么业务逻辑是这种大杀器解决不了的， 说出来长长见识呀。

locbytes

vivilauge 发表于 2018-7-16 20:01
不知道什么业务逻辑是这种大杀器解决不了的， 说出来长长见识呀。

代码里已经写了...