请教使用OpenResty动态配置websocket转发的问题

cover_eye

大家好：

有如下需求，使用openresty做反向代理，同时支持http和websocket，如果服务类型是WebSocket类型进行必要的配置。

初步的方案是，利用nginx对websocket的原生支持，在location内部增加access_by_lua_block或rewrite_by_lua_block，内部判断如果是websocket类型的，使用ngx.req.set_header设置http头，通过抓包发现设置其他header生效、但设置Upgrade和Connection无效，请各位大师帮看下：该方案是否可行？如果不可行还望不吝赐教哈

参考nginx官网教程 http://nginx.org/en/docs/http/websocket.html ，目前的配置示例“伪代码”如下：

upstream defaultserver{

...

}

upstream wsserver{

...

}

server{

listen 8989；

proxy_http_version 1.1;

location /api {
set $backserver "defaultserver";

access_by_lua_block {

if (service.type == "websocket") then

ngx.req.set_header("Upgrade",ngx.var.http_upgrade)

ngx.req.set_header("Connection","Upgrade")

ngx.var.backserver = "wsserver";

end

}

proxy_pass http://$backserver;

}

anymaybe

没必要再使用ngx.req.set_header去做这个事了啊，直接使用proxy_set_header即可，就像nginx教程说的那样；

在 2016年6月10日星期五 UTC+8下午2:57:27，cover_eye写道：

大家好：

       有如下需求，使用openresty做反向代理，同时支持http和websocket，如果服务类型是WebSocket类型进行必要的配置。
       初步的方案是，利用nginx对websocket的原生支持，在location内部增加access_by_lua_block或rewrite_by_lua_block，内部判断如果是websocket类型的，使用ngx.req.set_header设置http头，通过抓包发现设置其他header生效、但设置Upgrade和Connection无效，请各位大师帮看下：该方案是否可行？如果不可行还望不吝赐教哈

     参考nginx官网教程 http://nginx.org/en/docs/http/websocket.html ，目前的配置示例“伪代码”如下：
   upstream defaultserver{
     ...
   }
upstream wsserver{
     ...
   }
    server{
              listen 8989；
              proxy_http_version 1.1;
              location /api {
                          set $backserver "defaultserver";
                          access_by_lua_block {
                                      if (service.type == "websocket") then
                                              ngx.req.set_header("Upgrade",ngx.var.http_upgrade)
                                              ngx.req.set_header("Connection","Upgrade")
                                              ngx.var.backserver = "wsserver";
                                      end
                          }
                          proxy_pass http://$backserver;
              }
    }

cover_eye

我需要先查询数据库得到服务信息，再根据服务类型做动态设置。也就是在access_by_lua_block或rewrite_by_lua_block内部设置http header，proxy_set_header是nginx原生指令，lua block内不能使用吧？

在2016年06月12日 11:28，Guanglin Lv 写道:

没必要再使用ngx.req.set_header去做这个事了啊，直接使用proxy_set_header即可，就像nginx教程说的那样；

在 2016年6月10日星期五 UTC+8下午2:57:27，cover_eye写道：
大家好：

       有如下需求，使用openresty做反向代理，同时支持http和websocket，如果服务类型是WebSocket类型进行必要的配置。
       初步的方案是，利用nginx对websocket的原生支持，在location内部增加access_by_lua_block或rewrite_by_lua_block，内部判断如果是websocket类型的，使用ngx.req.set_header设置http头，通过抓包发现设置其他header生效、但设置Upgrade和Connection无效，请各位大师帮看下：该方案是否可行？如果不可行还望不吝赐教哈

     参考nginx官网教程 http://nginx.org/en/docs/http/websocket.html ，目前的配置示例“伪代码”如下：
   upstream defaultserver{
     ...
   }
upstream wsserver{
     ...
   }
    server{
              listen 8989；
              proxy_http_version 1.1;
              location /api {
                          set $backserver "defaultserver";
                          access_by_lua_block {
                                      if (service.type == "websocket") then
                                              ngx.req.set_header("Upgrade",ngx.var.http_upgrade)
                                              ngx.req.set_header("Connection","Upgrade")
                                              ngx.var.backserver = "wsserver";
                                      end
                          }
                          proxy_pass http://$backserver;
              }
    }

--

anymaybe

在 2016年6月12日星期日 UTC+8下午10:14:41，cover_eye写道：

我需要先查询数据库得到服务信息，再根据服务类型做动态设置。也就是在access_by_lua_block或rewrite_by_lua_block内部设置http header，proxy_set_header是nginx原生指令，lua block内不能使用吧？

你只是想做upstream的动态替换，可以使用balancer_by_lua或就像你的示例写的，只通过一个ngx.var传出来就好了；

proxy_set_header是不能在lua_block里使用的，你误解了；

你不用担心正常的请求也会被设置上upgrade，因为正常请求是没有upgrade请求头域的。

所以proxy_set_header upgrade $http_upgrade;实际上是没有添加upgrade头域的。

connection头域你可以参考nginx教程，使用map方式来动态赋值；

在2016年06月12日 11:28，Guanglin Lv 写道:
没必要再使用ngx.req.set_header去做这个事了啊，直接使用proxy_set_header即可，就像nginx教程说的那样；

在 2016年6月10日星期五 UTC+8下午2:57:27，cover_eye写道：
大家好：

       有如下需求，使用openresty做反向代理，同时支持http和websocket，如果服务类型是WebSocket类型进行必要的配置。
       初步的方案是，利用nginx对websocket的原生支持，在location内部增加access_by_lua_block或rewrite_by_lua_block，内部判断如果是websocket类型的，使用ngx.req.set_header设置http头，通过抓包发现设置其他header生效、但设置Upgrade和Connection无效，请各位大师帮看下：该方案是否可行？如果不可行还望不吝赐教哈

     参考nginx官网教程 http://nginx.org/en/docs/http/websocket.html ，目前的配置示例“伪代码”如下：
   upstream defaultserver{
     ...
   }
upstream wsserver{
     ...
   }
    server{
              listen 8989；
              proxy_http_version 1.1;
              location /api {
                          set $backserver "defaultserver";
                          access_by_lua_block {
                                      if (service.type == "websocket") then
                                              ngx.req.set_header("Upgrade",ngx.var.http_upgrade)
                                              ngx.req.set_header("Connection","Upgrade")
                                              ngx.var.backserver = "wsserver";
                                      end
                          }
                          proxy_pass http://$backserver;
              }
    }

--

cover_eye

您的解答很详细，我去实践一下，多谢！

在2016年06月14日 10:04，Guanglin Lv 写道:

在 2016年6月12日星期日 UTC+8下午10:14:41，cover_eye写道：

我需要先查询数据库得到服务信息，再根据服务类型做动态设置。也就是在access_by_lua_block或rewrite_by_lua_block内部设置http header，proxy_set_header是nginx原生指令，lua block内不能使用吧？

你只是想做upstream的动态替换，可以使用balancer_by_lua或就像你的示例写的，只通过一个ngx.var传出来就好了；

proxy_set_header是不能在lua_block里使用的，你误解了；

你不用担心正常的请求也会被设置上upgrade，因为正常请求是没有upgrade请求头域的。

所以proxy_set_header upgrade $http_upgrade;实际上是没有添加upgrade头域的。

connection头域你可以参考nginx教程，使用map方式来动态赋值；

在2016年06月12日 11:28，Guanglin Lv 写道:
没必要再使用ngx.req.set_header去做这个事了啊，直接使用proxy_set_header即可，就像nginx教程说的那样；

在 2016年6月10日星期五 UTC+8下午2:57:27，cover_eye写道：
大家好：

       有如下需求，使用openresty做反向代理，同时支持http和websocket，如果服务类型是WebSocket类型进行必要的配置。
       初步的方案是，利用nginx对websocket的原生支持，在location内部增加access_by_lua_block或rewrite_by_lua_block，内部判断如果是websocket类型的，使用ngx.req.set_header设置http头，通过抓包发现设置其他header生效、但设置Upgrade和Connection无效，请各位大师帮看下：该方案是否可行？如果不可行还望不吝赐教哈

     参考nginx官网教程 http://nginx.org/en/docs/http/websocket.html ，目前的配置示例“伪代码”如下：
   upstream defaultserver{
     ...
   }
upstream wsserver{
     ...
   }
    server{
              listen 8989；
              proxy_http_version 1.1;
              location /api {
                          set $backserver "defaultserver";
                          access_by_lua_block {
                                      if (service.type == "websocket") then
                                              ngx.req.set_header("Upgrade",ngx.var.http_upgrade)
                                              ngx.req.set_header("Connection","Upgrade")
                                              ngx.var.backserver = "wsserver";
                                      end
                          }
                          proxy_pass http://$backserver;
              }
    }

--

--