Koa代理Http请求的示例代码
Koa代理http请求，解决跨域问题
1、为什么用Koa做跨域代理？
"最初为了解决跨域问题，我把站点部署到了nginx上就解决了问题。一次偶然的面试机会，面试官提出了一个假设我需要对提交api和api返回的数据进行适配，那么nginx是不是就无法满足了。当然这个问题的提出，让我考虑到其实如果自己搭一个站点，通过这个站点进行转发，适配第三方api的请求和应答不就好了。那么要搭一个站点的语言其实有很多，例如.net,java,nodejs,php...，那为什么最后选择nodejs呢？对于我来说最重要的原因，应该就是nodejs的轻量级和javascript语言亲和性。
2、搭建nodejs应用
由于Koa2刚出，毕竟学技术，那么就学最新的。
既然搭建程序那么就从程序的入口开始做，首先写程序的路由
constfs=require('fs')
constRouter=require('koa-router');
const{httpHandle}=require('../Infrastructure/httpHandle');
constkoaBody=require('koa-body')({
multipart:true
});
constrender=(page)=>{
returnnewPromise((resolve,reject)=>{
letviewUrl=`./view/${page}`
fs.readFile(viewUrl,"binary",(err,data)=>{
if(err){
reject(err)
}else{
resolve(data)
}
})
})
}
letapi=newRouter();
api.get('*',httpHandle)
.post('*',koaBody,httpHandle)
.put('*',koaBody,httpHandle).del('*',koaBody,httpHandle);
letcommon=newRouter();
common.get('*',async(ctx)=>{
ctx.body=awaitrender('index.html');
})
letrouter=newRouter();
router.use('/api',api.routes(),api.allowedMethods());
router.use('/',common.routes(),common.allowedMethods());
module.exports=router;
其次就是处理代理的请求
consthttpRequest=(ctx)=>{
returnnewPromise((resolve)=>{
deletectx.request.header.host;
constoptions={
host,
port,
path:ctx.request.url.substr(4,ctx.request.url.length),
method:ctx.request.method,
headers:ctx.request.header
}
letrequestBody='',
body,
head,
chunks=[],
fileFields,
files,
boundaryKey,
boundary,
endData,
filesLength,
totallength=0;
if(ctx.request.body){
console.log(ctx.request.header['content-type'])
if(ctx.request.header['content-type'].indexOf('application/x-www-form-urlencoded')>-1){
requestBody=query.stringify(ctx.request.body);
options.headers['Content-Length']=Buffer.byteLength(requestBody)
}elseif(ctx.request.header['content-type'].indexOf('application/json')>-1){
requestBody=JSON.stringify(ctx.request.body);
options.headers['Content-Length']=Buffer.byteLength(requestBody)
}elseif(ctx.request.header['content-type'].indexOf('multipart/form-data')>-1){
fileFields=ctx.request.body.fields;
files=ctx.request.body.files;
boundaryKey=Math.random().toString(16);
boundary=`\r\n----${boundaryKey}\r\n`;
endData=`\r\n----${boundaryKey}--`;
filesLength=0;
Object.keys(fileFields).forEach((key)=>{
requestBody+=`${boundary}Content-Disposition:form-data;name="${key}"\r\n\r\n${fileFields[key]}`;
})
Object.keys(files).forEach((key)=>{
requestBody+=`${boundary}Content-Type:application/octet-stream\r\nContent-Disposition:form-data;name="${key}";filename="${files[key].name}"\r\nContent-Transfer-Encoding:binary\r\n\r\n`;
filesLength+=Buffer.byteLength(requestBody,'utf-8')+files[key].size;
})
options.headers['Content-Type']=`multipart/form-data;boundary=--${boundaryKey}`;
options.headers[`Content-Length`]=filesLength+Buffer.byteLength(endData);
}else{
requestBody=JSON.stringify(ctx.request.body)
options.headers['Content-Length']=Buffer.byteLength(requestBody)
}
}
constreq=http.request(options,(res)=>{
res.on('data',(chunk)=>{
chunks.push(chunk);
totallength+=chunk.length;
})
res.on('end',()=>{
body=Buffer.concat(chunks,totallength);
head=res.headers;
resolve({head,body});
})
})
ctx.request.body&&req.write(requestBody);
if(fileFields){
letfilesArr=Object.keys(files);
letuploadConnt=0;
filesArr.forEach((key)=>{
letfileStream=fs.createReadStream(files[key].path);
fileStream.on('end',()=>{
fs.unlink(files[key].path);
uploadConnt++;
if(uploadConnt==filesArr.length){
req.end(endData)
}
})
fileStream.pipe(req,{end:false})
})
}else{
req.end();
}
})
}
由此简单的几行代码就实现了通过nodejs实现跨域的请求代理。github链接
nginx代理config配置如下
server{
listen1024;
server_nametigrex:1024;
roothome/TuoTuo.v2.UI;
indexindex.html;
access_loglogs/tigrex.access.log;
error_loglogs/tigrex.error.log;
charsetutf-8;
location/api{
proxy_passhttp://127.0.0.1:1023/;
proxy_set_headerHost$host;
proxy_redirectoff;
proxy_set_headerX-Real-IP$remote_addr;
proxy_set_headerX-Forwarded-For$proxy_add_x_forwarded_for;
}
location/{
try_files$uri$uri//index.html;
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。