egg.js 动态转发代理

需求背景利用nodejs和consul实现注册中心和网关
egg.js在获取配置信息与节点后进行服务转发与路径管理
实现难点没有成行的技术博客去解决这个问题

解决方案

依赖http-proxy-middleware和koa2-connect
重点问题application/x-www-form-urlencoded 转发代理要定制解决否则活转发失败
配置文件中添加代理配置信息
// 忽略安全威胁csrf的防范 config.security = { csrf:{ enable: false } } //代理配置信息 config.proxyConfig = {}; // add your middleware config here config.middleware = ['proxy'];
在中间件中添加代理js
proxy.js /*

* @Description: api 网关代理 
* @Author: 吴文周
* @Github: http://gitlab.yzf.net/wuwenzhou 
* @Date: 2020-06-28 13:38:19 
* @LastEditors: 吴文周
* @LastEditTime: 2020-08-13 18:14:32 
*/
const { createProxyMiddleware } = require('http-proxy-middleware');
const k2c = require('koa2-connect');
module.exports = (options,app) => {  
return async function(ctx,next) {  let proxy= app.config.proxyConfig;  
  try {      
    const Proxy = k2c(createProxyMiddleware('/api',{ 
    target: proxy.target,// 动态设置可以从缓存中获取更新       
    pathRewrite:proxy.Rewrite,// 动态设置可以从缓存中获取更新        
    changeOrigin: true,        
    secure: false,        
    body:ctx.request.body,        
    onProxyReq:(proxyReq, req, res, options)=>{          
    const contentType = proxyReq.getHeader('Content-Type'); 
    // 特殊判断如果类型是application/x-www-form-urlencoded 转发代理需要特殊处理      
    try {           
     if (contentType && contentType.indexOf('application/x-www-form-urlencoded')>=0) {
              let body = Object.keys(options.body).map(function(key) {   
               return encodeURIComponent( key ) + '=' + encodeURIComponent(options.body[key])
              }).join('&');              
 //Update header              
proxyReq.setHeader('content-type', 'application/x-www-form-urlencoded');              
proxyReq.setHeader('content-length', body.length );             
 // Write out body changes to the proxyReq stream              
proxyReq.write(body);              
// proxyReq.end();           
 }       
   } catch (error) {      
      console.log(error);          }        }      }));     
 await Proxy(ctx,next);    }else{      next()    }    } catch (error) {      console.log(error)      next()    }  };};