4

我们正在尝试设置一个依赖于请求标头的插件,将其代理到特定主机。前任。

curl -H 'Env: foo' http://127.0.0.1:8000/poc -> https://foo.example.com/poc
curl -H 'Env: bar' http://127.0.0.1:8000/poc -> https://bar.example.com/poc

在早期版本(< v0.11.0)中,以下代码有效(这是我们插件的 access.lua 文件):

local singletons = require "kong.singletons"
local responses = require "kong.tools.responses"

local _M = {}

function _M.execute(conf)
  local environment = ngx.req.get_headers()['Env']

  if environment then
    local result, err = singletons.dao.environments:find_all {environment = environment}


    if err then
      return responses.send_HTTP_INTERNAL_SERVER_ERROR(err)
    else
      ngx.ctx.upstream_url = result[1].proxy_redirect
    end

  end
end

return _M

这是因为ngx.ctx.upstream_url覆盖了 proxy_pass 行为。

由于我们想在 k8s 环境中使用它,我们不得不使用 0.11.0 版本,因为他们已经修复了一些关于 dns 的问题。问题似乎是他们通过 ngx.var.upstream_uri 更改了 ngx.ctx.upstream_url行为不一样,它不会更改主机来代理我们的请求。这是我们得到的错误:

2017/08/23 11:28:51 [error] 22#0: *13 invalid port in upstream "kong_upstreamhttps://foo.example.com", client: 192.168.64.1, server: kong, request: "GET /poc HTTP/1.1", host: "localhost:8000"

有没有人有同样的问题?我们的问题还有其他解决方案吗?

非常感谢您提前。

4

1 回答 1

4

如果有人对此感兴趣,这就是我解决此问题的方法。

最后,我通过“Host”标头进行了重定向,我在插件中所做的是更改标头以适应其他 api。我是说:

我创建了 2 个 API:

curl -H 'Host: foo' http://127.0.0.1:8000/ -> https://foo.example.com
curl -H 'Host: bar' http://127.0.0.1:8000/ -> https://bar.example.com

我的插件的行为应该是这样的:

curl -H 'Host: bar' -H 'Env: foo' http://127.0.0.1:8000/poc -> https://foo.example.com/poc
curl -H 'Host: foo' -H 'Env: bar' http://127.0.0.1:8000/poc -> https://bar.example.com/poc

最重要的想法是您应该在 handler.lua 文件中使用重写上下文而不是访问上下文:

function ContextRedirectHandler:rewrite(conf)

  ContextRedirectHandler.super.rewrite(self)
  access.execute(conf)

end

然后,您可以像这样更改 access.lua 文件中的“Host”标头:

local singletons = require "kong.singletons"
local responses = require "kong.tools.responses"

local _M = {}

function _M.execute(conf)
  local environment = ngx.req.get_headers()['Env']

  if environment then
    local result, err = singletons.dao.environments:find_all {environment = environment}

    if err then
      return responses.send_HTTP_INTERNAL_SERVER_ERROR(err)
    else
      ngx.req.set_header("Host", result[1].host_header_redirect)
    end

  end
end

return _M
于 2017-08-25T13:14:17.140 回答