express框架应用接入阿里云函数计算

由于业务需要接触阿里云函数计算,为保证已有的 nodejs 应用迁移至阿里云函数计算。经过两天的摸索之后得到一些 express.js 应用迁移至函数计算的一些方法。

  1. 涉及技术及框架:

    • nodejs
    • 阿里云函数计算
  2. 主要流程:

    1. 对比函数计算 http 触发器 与 express 的相同点和不同点,对原先的应用进行兼容处理
    2. 解决函数计算触发器和 express 框架的数据传递问题
    3. 测试迁移之后的应用稳定性
  3. 开整实现
    (1)对比函数计算 http 触发器,与普通的基于 express 的应用的不同
属性 函数计算 应用 普通 express 应用
触发方式 由 exports.XXX.handle 方法触发 通过监听指定端口的网络请求触发
接收到的参数 入口函数会得到(request,response,context) express 接收到(request,response)

由于原先的应用基与 express 开发,在迁移至函数计算之后将不能通过监听端口的网络请求触发 request 事件。那么参考 express 中 listen 的实现

app.listen = function listen() {
  var server = http.createServer(this);
  return server.listen.apply(server, arguments);
};

因此只需通过向 http.createServer 传入 express 对象,来创建一个 http.server 实例。当函数计算触发器被触发,再通过server.emit(‘request’, requset , response ) 来触发express 应用的工作流。

(2)函数计算入口函数的参数的兼容性改造
只能从函数计算入口函数拿到request,response,context。但是request、response 并非 http.InComingMessage 、http.ServerResponse 实例,如何通过 server.emit(‘request’, req , res ) 将入口函数传入的信息传入 express 工作流中。我们需要对 requset、response 进行改造

request  结构体:

headers:<map>, //存放来自 HTTP 客户端的键值对
path:<string>, //为 HTTP URL
queries:<map>, // 类型,存放来自 HTTP URL 中的 query 部分的 key - value 键值对, value 的类型可以为字符串或是数组
method:<string>, // 类型,HTTP 方法
clientIP:<string>, // 类型,client 的 IP 地址
url:<string>, // 类型,request 的 url
response 结构体:
response.setStatusCode(statusCode) : 设置 status code
param statusCode : (required, type integer)
response.setHeader(headerKey, headerValue) :设置 header
param headerKey : (required, type string)
param headerValue : (required, type string)
response.deleteHeader(headerKey) :删除 header
param headerKey: (required, type string)
response.send(body): 发送 body
param body: (required, typeBuffer or a string or a stream.Readable )

http.InComingMessage 结构体:

参考 http://nodejs.cn/api/http.html#http_class_http_incomingmessage

http.ServerResponse 结构体:

参考http://nodejs.cn/api/http.html#http_class_http_serverresponse

其中 express 应用中的 req 和 res 实现了很多封装的方法,所以需要根据自己的需要来进行兼容性改造,以下是我的改造代码片段:

const http = require('http');
const express = require('express');

const app = express()

const FCServer = http.createServer(app);

module.exports.handler = (request, response, context) => {
  try {
    // 通过 app.request 和 app.response 创建 inComimgMessage 和serverResponse
    const inComimgMessage = Object.create(app.request);
    const serverResponse = Object.create(app.response);

    // 将 request 的部分信息赋值给 inComimgMessage
    inComimgMessage.headers = request.headers;
    inComimgMessage.method = request.method;
    inComimgMessage.path = request.path;
    inComimgMessage.url = request.path;
    inComimgMessage.query = request.queries;

    // 使用 response 的方法替换掉 serverResponse 的一些方法
    serverResponse.setHeader = (key, value) => response.setHeader(key, value);
    serverResponse.end = (data, encoding, callback) => {
      response.send(data);
    };
    serverResponse.send = serverResponse.end;

    serverResponse.status = (code) => {
        response.setStatusCode(code);
    };

    serverResponse.writeHead = (code, message, headers) => {
      response.setStatusCode(code);
    };

    serverResponse.sendStatus = (code) => {
      response.setStatusCode(code);
      response.send(code);
    };

    serverResponse.json = (body) => {
      response.setHeader('content-type', 'application/json');
      if (typeof body === 'string') {
         response.send(body);
      } else {
         response.send(JSON.parse(body));
      }
    };
    
    FCServer.emit('request', inComimgMessage, serverResponse);
  } catch (e) {
    console.log(e);
    response.send(JSON.stringify({ request, response, context, e }));
  } 
};

(3)数据接入:
在函数计算中,获取 http 请求的 body 信息需要使用 getRawBody 方法,通过其回调函数我们可以得到 body 信息,因此我们需要在 getRawBody 内触发 request 事件。

    getRawBody(request, function (err, body) {
      if (request.method === 'POST') {
        inComimgMessage.body = JSON.parse(decodeURIComponent(body.toString()));
      }
      FCServer.emit('request', inComimgMessage, serverResponse);
    });

原文来自:express框架应用接入阿里云函数计算 转载请标明出处

上一篇:MySpace出现史上最大规模数据泄露事件


下一篇:社会工程:安全体系中的人性漏洞