0

我正在使用 Nginx 将请求代理到某个后端服务器。为此，我使用 proxy_pass 模块进行重定向。配置文件：位置 = /hello { proxy_pass: abc.com }

我想执行以下工作流程。对 nginx 服务器的请求 --> 更改请求参数 --> 将请求传递给 abc.com --> 更改响应参数 --> 将响应发送回客户端。

这可能与 nginx 吗？任何有关此问题的帮助/指示将不胜感激。

4

1 回答 1

1

您应该能够使用此更改/设置新参数

location /hello {
  proxy_pass: abc.com 
  if ($args ~* paramToChange=(.+)) {
    set $args newParamName=$1;
  }
  set $args otherParam=value;
}

更新：

开箱即用的 nginx 没有办法发出请求以动态获取参数，然后在发送客户端响应之前将它们应用于另一个请求。

您可以通过向 nginx 添加一个名为lua的模块来完成此操作。

该模块可以通过下载并在安装过程中将其添加到 .configure 选项中重新编译到 nginx 中。我也喜欢它附带的openresty包和其他已经可用的有用模块，比如 echo。

一旦你有了 lua 模块，这个服务器代码就可以工作了：

server {
    listen 8083;

    location /proxy/one {
        proxy_set_header testheader test1;
        proxy_pass http://localhost:8081;
    }

    location /proxy/two {
       proxy_pass http://localhost:8082;
    }

    location / {
        default_type text/html; 

        content_by_lua '
            local first = ngx.location.capture("/proxy/one",
               { args = { test = "test" } }
            )

            local testArg = first.body

            local second = ngx.location.capture("/proxy/two",
               { args = { test = testArg } }
            )

            ngx.print(second.body)
        ';

    }
}

我用几个节点 js 服务器测试了这个配置，如下所示：

var koa = require('koa');
var http = require('http');

startServerOne();
startServerTwo();

function startServerOne() {
  var app = koa();


  app.use(function *(next){
    console.log('\n------ Server One ------');
    console.log('this.request.headers.testheader: ' + JSON.stringify(this.request.headers.testheader));
    console.log('this.request.query: ' + JSON.stringify(this.request.query));

    if (this.request.query.test == 'test') {
      this.body = 'First query worked!';
    }else{
      this.body = 'this.request.query: ' + JSON.stringify(this.request.query);
    }  
  });

  http.createServer(app.callback()).listen(8081);

  console.log('Server 1 - 8081');
}

function startServerTwo(){
  var app = koa();
  app.use(function *(next){

    console.log('\n------ Server Two ------');
    console.log('this.request.query: ' + JSON.stringify(this.request.query));

    if (this.request.query.test == 'First query worked!') {
      this.body = 'It Worked!';
    }else{
      this.body = 'this.request.query: ' + JSON.stringify(this.request.query);
    }
  });

  http.createServer(app.callback()).listen(8082);

  console.log('Server 2 - 8082');
}

这是节点控制台日志的输出：

Server 1 - 8081
Server 2 - 8082

------ Server One ------
this.request.headers.testheader: "test1"
this.request.query: {"test":"test"}

------ Server Two ------
this.request.query: {"test":"First query worked!"}

这是发生的事情：

  1. Nginx 向服务器一发送带有测试参数集的请求查询。

  2. 节点服务器 1 看到测试参数并以“第一个查询成功！”进行响应。

  3. Nginx 使用来自服务器一个响应的正文更新查询参数。Nginx 向服务器 2 发送带有新查询参数的请求。

  4. 节点服务器 2 看到“测试”查询参数等于“第一个查询成功！” 并使用响应正文“它成功了！”来响应请求。

并且 curl 响应或在浏览器中访问 localhost:8083 显示“它有效”：

curl -i 'http://localhost:8083'
HTTP/1.1 200 OK
Server: openresty/1.9.3.2
Date: Thu, 17 Dec 2015 16:57:45 GMT
Content-Type: text/html
Transfer-Encoding: chunked
Connection: keep-alive

It Worked!
于 2015-12-13T17:48:40.377 回答