express框架应用接入阿里云函数计算-白红宇

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

涉及技术及框架：
- nodejs
- 阿里云函数计算

主要流程：
1. 对比函数计算 http 触发器与 express 的相同点和不同点，对原先的应用进行兼容处理
2. 解决函数计算触发器和 express 框架的数据传递问题
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:, //存放来自 HTTP 客户端的键值对path:
     
      , //为 HTTP URLqueries:
      , // 类型，存放来自 HTTP URL 中的 query 部分的 key - value 键值对, value 的类型可以为字符串或是数组method:
       
        , // 类型，HTTP 方法clientIP:
        
         , // 类型，client 的 IP 地址url:
         
          , // 类型，request 的 url

response 结构体：response.setStatusCode(statusCode) ： 设置 status codeparam statusCode : (required, type integer)response.setHeader(headerKey, headerValue) ：设置 headerparam headerKey : (required, type string)param headerValue : (required, type string)response.deleteHeader(headerKey) ：删除 headerparam headerKey: (required, type string)response.send(body): 发送 bodyparam body: (required, typeBuffer or a string or a stream.Readable )

http.InComingMessage 结构体：

参考

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);    });

原文来自: 转载请标明出处