Nginx模块Lua-Nginx-Module学习笔记（一）Nginx Lua API 接口详解

源码地址：https://github.com/Tinywan/Lua-Nginx-Redis

1、介绍

　　各类* _by_lua，* _by_lua_block和* _by_lua_file配置指令用做nginx.conf文件中Lua API的网关。 下面描述的Nginx Lua API只能在这些配置指令的上下文中运行的用户Lua代码中调用。API以两个标准软件包ngx和ndk的形式暴露给Lua。 这些软件包位于ngx_lua中的默认全局范围内，而且始终可在ngx_lua指令中使用。

这些包能够像这样引入外部Lua模块：

 local say = ngx.say local _M = {} function _M.foo(a) say(a) end return _M

强烈建议使用package.seeall标志，由于其各类不良的反作用。也能够直接要求外部Lua模块中的包：

  local ngx = require“ngx” local ndk = require“ndk”

　　v0.2.1rc19版本中引入了须要这些软件包的能力。

　　用户代码中的网络I / O操做应该只经过Nginx Lua API调用来完成，由于Nginx事件循环可能被阻塞，不然性能会明显降低。 磁盘操做与相对少许的数据可使用标准的Lua io库，但巨大的文件读写应尽量避免，由于他们可能会显着阻止Nginx进程。 强烈建议将全部网络和磁盘I / O操做委派给Nginx的子请求（经过ngx.location.capture方法等），以得到最佳性能。

2、命令介绍

ngx.arg

语法：val = ngx.arg [index]

上下文：set_by_lua *，body_filter_by_lua *

描述：当在set_by_lua *指令的上下文中使用时，此表是只读的，并保存config指令的输入参数：

value = ngx.arg[n]

这里是一个例子

　　　location /foo_sum { set $a 32; set $b 56; set_by_lua $sum 'return tonumber(ngx.arg[1]) + tonumber(ngx.arg[2])' $a $b; echo "sum = ${sum}"; }

CURL 运行输出

root@iZ236j3sofdZ:/usr/local/nginx/conf/lua# curl "http://localhost/foo_sum" sum = 88

写出88，32和56的和。

　　当在body_filter_by_lua *的上下文中使用此表时，第一个元素将输入数据块保存到输出过滤器代码，第二个元素保存指示整个输出数据流结束的“eof”标志的布尔标志。

　　传递给下游Nginx输出过滤器的数据块和“eof”标志也能够经过将值直接分配给相应的表元素来覆盖。 当将nil或空Lua字符串值设置为ngx.arg [1]时，根本不会将数据块传递到下游Nginx输出过滤器。

ngx.null

　　ngx.null常量是一个NULL light用户数据，一般用于在Lua表等中表示nil值，相似于lua-cjson库的cjson.null常量。 这个常数首先在v0.5.0rc5版本中引入。

ngx.var.VARIABLE 

语法：ngx.var.VAR_NAME

上下文：set_by_lua*, rewrite_by_lua*, access_by_lua*, content_by_lua*, header_filter_by_lua*, body_filter_by_lua*, log_by_lua*

读取和写入Nginx变量值

 value = ngx.var.some_nginx_variable_name ngx.var.some_nginx_variable_name = value

注意，只有已经定义的nginx变量能够写入。 例如：

location /foo { set $my_var ''; # this line is required to create $my_var at config time content_by_lua_block { ngx.var.my_var = 123; ... } }

　　也就是说，nginx变量不能在运行中建立。一些特殊的nginx变量，如$ args和$ limit_rate能够分配一个值，许多其余变量不是，如$ query_string，$ arg_PARAMETER和$ http_NAME。经过写入ngx.var [1]，ngx.var [2]，ngx.var [3]等，也能够经过此接口读取Nginx正则表达式组捕获变量$ 1，$ 2，$ 3等。将ngx.var.Foo设置为nil值将取消设置$ Foo Nginx变量。

ngx.var.args = nil

　　当心当从Nginx变量读取时，Nginx将在每一个请求的内存池中分配内存，只有在请求终止时才释放内存。 所以，当您须要在Lua代码中重复读取Nginx变量时，将Nginx变量值缓存到您本身的Lua变量中，例如：

local val = ngx.var.some_var --- use the val repeatedly later

　　以防止（临时）内存在当前请求的生存期内泄漏。 缓存结果的另外一种方法是使用ngx.ctx表。未定义的NGINX变量评估为nil，而未初始化（但已定义）的NGINX变量将被评估为空的Lua字符串。此API须要相对昂贵的元方法调用，建议避免在热代码路径上使用它。

Core constants

上下文： init_by_lua*, set_by_lua*, rewrite_by_lua*, access_by_lua*, content_by_lua*, header_filter_by_lua*, body_filter_by_lua*, *log_by_lua*, ngx.timer.*, balancer_by_lua*, ssl_certificate_by_lua*, ssl_session_fetch_by_lua*, ssl_session_store_by_lua*

   ngx.OK (0) ngx.ERROR (-1) ngx.AGAIN (-2) ngx.DONE (-4) ngx.DECLINED (-5)

请注意，只有三个这些常数是由所利用的Nginx API为lua（即ngx.exit接受NGX_OK，NGX_ERROR和NGX_DECLINED做为输入）。

ngx.null

该ngx.null常数是一个NULL一般用来表示在Lua表等零值光用户数据和相似于LUA-cjson库的cjson.null常数。此常数最先在引入的v0.5.0rc5释放。

待续.........

HTTP方法常量

上下文： init_by_lua *，* set_by_lua，rewrite_by_lua *，* access_by_lua，content_by_lua *，* header_filter_by_lua，body_filter_by_lua *，* log_by_lua，ngx.timer *，* balancer_by_lua，ssl_certificate_by_lua *，* ssl_session_fetch_by_lua，ssl_session_store_by_lua *。

 ngx.HTTP_GET ngx.HTTP_HEAD ngx.HTTP_PUT ngx.HTTP_POST ngx.HTTP_DELETE ngx.HTTP_OPTIONS (added in the v0.5.0rc24 release) ngx.HTTP_MKCOL (added in the v0.8.2 release) ngx.HTTP_COPY (added in the v0.8.2 release) ngx.HTTP_MOVE (added in the v0.8.2 release) ngx.HTTP_PROPFIND (added in the v0.8.2 release) ngx.HTTP_PROPPATCH (added in the v0.8.2 release) ngx.HTTP_LOCK (added in the v0.8.2 release) ngx.HTTP_UNLOCK (added in the v0.8.2 release) ngx.HTTP_PATCH (added in the v0.8.2 release) ngx.HTTP_TRACE (added in the v0.8.2 release)

这些常数一般在使用ngx.location.capture和ngx.location.capture_multi方法调用。

 

HTTP状态常数

上下文： init_by_lua *，* set_by_lua，rewrite_by_lua *，* access_by_lua，content_by_lua *，* header_filter_by_lua，body_filter_by_lua *，* log_by_lua，ngx.timer *，* balancer_by_lua，ssl_certificate_by_lua *，* ssl_session_fetch_by_lua，ssl_session_store_by_lua *。

   value = ngx.HTTP_CONTINUE (100) (first added in the v0.9.20 release) value = ngx.HTTP_SWITCHING_PROTOCOLS (101) (first added in the v0.9.20 release) value = ngx.HTTP_OK (200) value = ngx.HTTP_CREATED (201) value = ngx.HTTP_ACCEPTED (202) (first added in the v0.9.20 release) value = ngx.HTTP_NO_CONTENT (204) (first added in the v0.9.20 release) value = ngx.HTTP_PARTIAL_CONTENT (206) (first added in the v0.9.20 release) value = ngx.HTTP_SPECIAL_RESPONSE (300) value = ngx.HTTP_MOVED_PERMANENTLY (301) value = ngx.HTTP_MOVED_TEMPORARILY (302) value = ngx.HTTP_SEE_OTHER (303) value = ngx.HTTP_NOT_MODIFIED (304) value = ngx.HTTP_TEMPORARY_REDIRECT (307) (first added in the v0.9.20 release) value = ngx.HTTP_BAD_REQUEST (400) value = ngx.HTTP_UNAUTHORIZED (401) value = ngx.HTTP_PAYMENT_REQUIRED (402) (first added in the v0.9.20 release) value = ngx.HTTP_FORBIDDEN (403) value = ngx.HTTP_NOT_FOUND (404) value = ngx.HTTP_NOT_ALLOWED (405) value = ngx.HTTP_NOT_ACCEPTABLE (406) (first added in the v0.9.20 release) value = ngx.HTTP_REQUEST_TIMEOUT (408) (first added in the v0.9.20 release) value = ngx.HTTP_CONFLICT (409) (first added in the v0.9.20 release) value = ngx.HTTP_GONE (410) value = ngx.HTTP_UPGRADE_REQUIRED (426) (first added in the v0.9.20 release) value = ngx.HTTP_TOO_MANY_REQUESTS (429) (first added in the v0.9.20 release) value = ngx.HTTP_CLOSE (444) (first added in the v0.9.20 release) value = ngx.HTTP_ILLEGAL (451) (first added in the v0.9.20 release) value = ngx.HTTP_INTERNAL_SERVER_ERROR (500) value = ngx.HTTP_METHOD_NOT_IMPLEMENTED (501) value = ngx.HTTP_BAD_GATEWAY (502) (first added in the v0.9.20 release) value = ngx.HTTP_SERVICE_UNAVAILABLE (503) value = ngx.HTTP_GATEWAY_TIMEOUT (504) (first added in the v0.3.1rc38 release) value = ngx.HTTP_VERSION_NOT_SUPPORTED (505) (first added in the v0.9.20 release) value = ngx.HTTP_INSUFFICIENT_STORAGE (507) (first added in the v0.9.20 release)

Nginx的日志级别常数

上下文： init_by_lua *，* init_worker_by_lua，set_by_lua *，* rewrite_by_lua，access_by_lua *，* content_by_lua，header_filter_by_lua *，* body_filter_by_lua，log_by_lua *，* ngx.timer，balancer_by_lua *，* ssl_certificate_by_lua，ssl_session_fetch_by_lua *，* ssl_session_store_by_lua。

   ngx.STDERR
   ngx.EMERG
   ngx.ALERT
   ngx.CRIT
   ngx.ERR
   ngx.WARN
   ngx.NOTICE
   ngx.INFO
   ngx.DEBUG

print

语法: print(...)

上下文: init_by_lua*, init_worker_by_lua*, set_by_lua*, rewrite_by_lua*, access_by_lua*, content_by_lua*, header_filter_by_lua*, body_filter_by_lua*, log_by_lua*, ngx.timer.*, balancer_by_lua*, ssl_certificate_by_lua*, ssl_session_fetch_by_lua*, ssl_session_store_by_lua*

写参数值到nginx的error.log与文件ngx.NOTICE日志级别。它至关于

ngx.log(ngx.NOTICE, ...)

Lua的nil参数被接受，并致使文字"nil"字符串，而Lua的布尔致使文字"true"或"false"字符串。和ngx.null常数将产生"null"串输出。

　　有一个硬编码2048在Nginx的核心错误信息的长度字节的限制。此限制包括尾随换行符和领先的时间戳。若是邮件的大小超出此限制，Nginx的将相应截断消息文本。这个限制能够经过编辑手动修改NGX_MAX_ERROR_STR的宏定义src/core/ngx_log.h在Nginx的源代码树文件。

ngx.ctx

上下文: init_worker_by_lua*, set_by_lua*, rewrite_by_lua*, access_by_lua*, content_by_lua*, header_filter_by_lua*, body_filter_by_lua*, log_by_lua*, ngx.timer.*, balancer_by_lua*

这个表能够被用来存储每一个请求的Lua上下文数据，并具备使用寿命相同当前请求（与Nginx的变量）。考虑下面的例子，

 location /test { rewrite_by_lua_block { ngx.ctx.foo = 76 } access_by_lua_block { ngx.ctx.foo = ngx.ctx.foo + 3 } content_by_lua_block { ngx.say(ngx.ctx.foo) } }

而后GET /test将产生的输出：79

即，ngx.ctx.foo条目横跨重写，访问和请求的内容相存在。每一项要求，其中包括子请求，有它本身的表的副本。例如：

location /sub { content_by_lua_block { ngx.say("sub pre: ", ngx.ctx.blah) ngx.ctx.blah = 32 ngx.say("sub post: ", ngx.ctx.blah) } } location /main { content_by_lua_block { ngx.ctx.blah = 73 ngx.say("main pre: ", ngx.ctx.blah) local res = ngx.location.capture("/sub") ngx.print(res.body) ngx.say("main post: ", ngx.ctx.blah) } }

而后GET /main会给输出：

 main pre: 73 sub pre: nil sub post: 32 main post: 73

在此，改性ngx.ctx.blah的子请求条目不会影响所述一个在父请求。这是由于他们有两个独立的版本ngx.ctx.blah。内部重定向会破坏原来的请求ngx.ctx数据（若是有的话）和新要求将有一个空ngx.ctx表。例如：

 location /new { content_by_lua_block { ngx.say(ngx.ctx.foo) } } location /orig { content_by_lua_block { ngx.ctx.foo = "hello" ngx.exec("/new") } }

而后GET /orig会给：nil

而不是原来的"hello"值。任意的数据值，包括Lua的关闭和嵌套表，能够插入到这个“神奇”的表。它还容许自定义元方法的注册。覆盖ngx.ctx用一个新的Lua表也支持，例如:

ngx.ctx = { foo = 32, bar = 54 }

当在上下文中使用init_worker_by_lua *，此表只是有当前的Lua处理程序的寿命相同。

　　在ngx.ctx查找须要相对昂贵元方法的调用，这是否是明确传递每一个请求的数据沿着本身的函数参数慢得多。因此，不要滥用这个API保存你本身的函数的参数，由于它一般具备很有些性能的影响。由于魔元方法的，历来没有“本地”的ngx.ctx上因为Lua的模块级的Lua的功能范围以外的表工做者级的数据共享。例如，如下是坏：

-- mymodule.lua
 local _M = {} -- the following line is bad since ngx.ctx is a per-request
 -- data while this <code>ctx</code> variable is on the Lua module level
 -- and thus is per-nginx-worker.
 local ctx = ngx.ctx function _M.main() ctx.foo = "bar"
 end

 return _M

改用如下内容：

 -- mymodule.lua
 local _M = {} function _M.main(ctx) ctx.foo = "bar"
 end

 return _M

也就是说，让调用者经过ctx代表确地经过一个函数的参数。

 

ngx.location.capture

语法： res = ngx.location.capture(uri, options?)

上下文： rewrite_by_lua *，* access_by_lua，content_by_lua *

是一个同步非阻塞的NGINX子请求uri

NGINX的子请求提供了一个很是强大的方式去实现非阻塞的内部请求，或者其余的C模块，好比 ngx_proxy, ngx_fastcgi, ngx_memc, ngx_postgres, ngx_drizzle, 甚至ngx_lua本身等等。

固然，这些子请求仅仅是模拟HTTP请求，可是并无额外的 HTTP/TCP，全部的进程都是C级别的

子请求彻底不一样与HTTP 301／302。

这里有个基本的例子：

res = ngx.location.capture(uri)

返回与4插槽，一个Lua表：res.status，res.header，res.body，和res.truncated。

res.status 用于保存子请求响应的响应状态代码。

res.header持有子请求的响应头，这是一个正常的Lua表。对于多值响应头，该值是保存全部的顺序它们出现的值的Lua（阵列）表。例如，若是子请求响应报头包含如下几行：

返回一个LUA的TABLE，三个值(res.status, res.header, and res.body)。

res.header包含了全部的子请求的头的信息，它是一个普通的LUA TABLE。好比多个值的相应头，他们以数组的形式按照顺序返回出现。例如：子请求包含了以下信息:

 Set-Cookie: a=3 Set-Cookie: foo=bar Set-Cookie: baz=blah

而后res.header["Set-Cookie"]将被评估，以表中的值 {"a=3", "foo=bar", "baz=blah"}。

　　res.body持有子请求的响应体数据，这些数据可能会被截断。你老是须要检查res.truncated布尔标志，看是否res.body包含截断数据。这里的数据截断只能由那些不可恢复的错误在你的子请求同样，远端停止在响应体数据流的中间，或当你的子请求接收从响应体数据的读取超时发生过早的链接的状况下形成的遥控器。URI查询串能够串联到的URI自己，例如：

res = ngx.location.capture('/foo/bar?a=3&b=4')

像名为位置@foo不容许因为nginx的核心的限制。使用与组合正常位置internal指令准备仅供内部使用的位置。

可选选项表能够喂的第二个参数，它支持的选项：

• method 指定子请求的请求方法，只接受常量同样ngx.HTTP_POST。
• body 指定子请求的请求体（仅字符串值）。
• args 指定子请求的URI查询参数（这两个字符串值和Lua表被接受）
• ctx 指定一个Lua表是ngx.ctx为子请求表。它能够是当前请求的ngx.ctx表，这有效地使母体和其子请求共享彻底相同的上下文表。此选项最初是在引进v0.3.1rc25发行。
• vars 采起持有的值设置指定的Nginx变量在子请求做为此选项的值一个Lua表。此选项最初是在引进v0.3.1rc31发行。
• copy_all_vars 指定是否在当前请求所讨论的子请求的全部的Nginx变量值复制。在子请求nginx的变量的修改将不会影响当前（父）的请求。此选项最初是在引进v0.3.1rc31发行。
• share_all_vars 指定是否共享的子请求与当前（父）要求全部的Nginx变量。在子请求Nginx的变量的修改将影响当前（父）的请求。启用此选项可能会致使因不良反作用难以调试问题，被认为是很差的，有害的。只有启用该选项，当你彻底知道本身在作什么。
• always_forward_body 当设置为true，当前（父）的请求的请求体老是会被转发到，若是建立的子请求body未指定选项。不管是经过读取请求体（）ngx.req.read_body或lua_need_request_body上会被直接转发到子请求不建立子请求（不管请求体数据在内存中缓存或临时文件缓存）时复制整个请求体数据。默认状况下，这个选项是false和时body没有指定选项时，当前的（父）请求的请求体，当子请求取只转发PUT或POST请求方法。

发出一个POST子请求，例如，能够作以下：

 res = ngx.location.capture( '/foo/bar', { method = ngx.HTTP_POST, body = 'hello, world' } )

看到比其余POST HTTP方法的常量方法。该method选项是ngx.HTTP_GET默认。

该args选项能够指定额外的URI参数，例如：

 ngx.location.capture('/foo?a=1', { args = { b = 3, c = ':' } } )

至关于

ngx.location.capture('/foo?a=1&b=3&c=%3a')

也就是说，该方法将根据规则URI参数逃脱键和值一块儿将它们链接起来成为一个完整的查询字符串。对于做为经过的Lua表的格式args参数是相同于使用的格式ngx.encode_args方法。该args选项也能够采起简单的查询字符串：

 ngx.location.capture('/foo?a=1', { args = 'b=3&c=%3a' } } )

这在功能上等同于前面的例子。

该share_all_vars选项控制是否将当前请求和子请求之间共享nginx的变量。若是此选项设置为true，那么当前请求和相关的子请求将共享相同的Nginx变量的做用域。所以，经过一个子请求更改了Nginx的变量将影响到当前的请求。

应当心使用此选项，变量的做用域共享能够有意想不到的反作用。的args，vars或copy_all_vars选项一般优于代替。这个选项被设置为false默认

location /other { set $dog "$dog world"; echo "$uri dog: $dog"; } location /lua { set $dog 'hello'; content_by_lua_block { res = ngx.location.capture("/other", { share_all_vars = true }); ngx.print(res.body) ngx.say(ngx.var.uri, ": ", ngx.var.dog) } }

访问位置/lua给：

/other dog: hello world /lua: hello world

该copy_all_vars选项提供父请求的Nginx的变量的副本子请求时这样子请求发出。由这样子请求对这些变量所作的更改不会影响父请求或任何其余子请求共享父请求的变量。

 location /other { set $dog "$dog world"; echo "$uri dog: $dog"; } location /lua { set $dog 'hello'; content_by_lua_block { res = ngx.location.capture("/other", { copy_all_vars = true }); ngx.print(res.body) ngx.say(ngx.var.uri, ": ", ngx.var.dog) } }

请求GET /lua将给输出

/other dog: hello world /lua: hello

请注意，若是二者share_all_vars并copy_all_vars都设置为true，则share_all_vars优先。

除了上述两个设置，有可能使用在子请求变量的值vars选项。这些变量的变量共享或复制已评估后设置，而且提供了对编码它们以URL参数，并在Nginx的配置文件反向转义它们传递特定值应用于一个子请求的更有效的方法：

 location /other { content_by_lua_block { ngx.say("dog = ", ngx.var.dog) ngx.say("cat = ", ngx.var.cat) } } location /lua { set $dog ''; set $cat ''; content_by_lua_block { res = ngx.location.capture("/other", { vars = { dog = "hello", cat = 32 }}); ngx.print(res.body) } }

访问/lua将产生的输出：

dog = hello cat = 32

该ctx选项可用于指定自定义的Lua表做为ngx.ctx为子请求表。

 location /sub { content_by_lua_block { ngx.ctx.foo = "bar"; } } location /lua { content_by_lua_block { local ctx = {} res = ngx.location.capture("/sub", { ctx = ctx }) ngx.say(ctx.foo); ngx.say(ngx.ctx.foo); } }

而后请求GET /lua 输出：

bar nil

另外，也可使用这个ctx选项共享同一ngx.ctx电流（父）请求和子请求之间的表：

 location /sub { content_by_lua_block { ngx.ctx.foo = "bar"; } } location /lua { content_by_lua_block { res = ngx.location.capture("/sub", { ctx = ngx.ctx }) ngx.say(ngx.ctx.foo); } }

请求GET /lua产生的输出：bar

　　注意，经过发出子请求ngx.location.capture默认继承当前请求的全部请求头，而这可能对子请求响应意想不到的反作用。例如，使用标准时，ngx_proxy模块服务子请求，“接受编码：gzip”中的主要请求头，可能会致使不能在Lua代码正确处理gzip压缩的响应。原始请求头，应经过设置被忽略 proxy_pass_request_headers到off的子请求的位置。

若是body没有指定选项，且always_forward_body选项为false（默认值），POST以及PUT子请求将继承父请求（若是有的话）的请求主体。

　　上有可能为每个主要请求并发子请求的数目的硬编码上限。在旧版本Nginx的，下限为50并行子请求，并在最近的版本中，Nginx的1.1.x开始，这是提升到200并发子请求。当超过此限制时，如下错误消息被添加到error.log文件中：

[error] 13983#0: *1 subrequests cycle while processing "/uri"

　　极限能够根据须要经过编辑的定义手动修改NGX_HTTP_MAX_SUBREQUESTS宏中nginx/src/http/ngx_http_request.h在Nginx的源树文件。请同时参阅限制捕获由配置位置的其余模块的子请求指示。

 

ngx.location.capture_multi

ngx.status

ngx.header.HEADER

ngx.resp.get_headers

 

ngx.req.is_internal

 

ngx.req.start_time

语法: secs = ngx.req.start_time()

上下文: set_by_lua*, rewrite_by_lua*, access_by_lua*, content_by_lua*, header_filter_by_lua*, body_filter_by_lua*, log_by_lua*

返回表示时间戳（包括毫秒做为小数部分）已建立当前请求时一个浮点数。下面的例子模拟了$request_time变量值（由提供ngx_http_log_module纯LUA）：

 local request_time = ngx.now() - ngx.req.start_time()

ngx.req.http_version

语法：  num = ngx.req.http_version()

背景： set_by_lua *，* rewrite_by_lua，access_by_lua *，* content_by_lua，header_filter_by_lua *

返回当前请求做为Lua的数字的HTTP版本号。

当前可能的值是2.0，1.0，1.1和0.9。返回nil了没法识别的值。

ngx.req.raw_header

语法：  str = ngx.req.raw_header(no_request_line?)

背景： set_by_lua *，* rewrite_by_lua，access_by_lua *，* content_by_lua，header_filter_by_lua *

返回由Nginx的服务器接收到的原始原始的HTTP协议头。

默认状况下，请求行和尾随CR LF终止也将包括在内。例如，

 ngx.print(ngx.req.raw_header())

给出这样的事情：

GET /t HTTP/1.1 Host: localhost Connection: close Foo: bar

你能够指定可选的 no_request_line参数做为true排除从结果的请求行的值。例如

ngx.print(ngx.req.raw_header(true))

输出是这样的：

Host: localhost
Connection: close
Foo: bar

此方法不会在HTTP / 2请求工做还没有

 

---

---

CDN 反向代理LiveNode节点，经过Lua脚本操做Redis数据库实现转发

---

---

URL访问地址：http://127.0.0.1/hls/4953.m3u8

nginx.conf 配置

 　　　　location ~ \/.+\/.+\.(m3u8|ts) { #设置nginx变量 if ($uri ~ \/([a-zA-Z0-9]+)\/([a-zA-Z0-9]+)(|-).*\.(m3u8|ts)) { set $app_name $1; set $a $2; } set $stream_id ""; default_type 'text/html'; lua_code_cache on; rewrite_by_lua_file /home/www/lua-tinywan/set_by_file.lua; #echo "stream_id :" $stream_id; proxy_buffering off; proxy_redirect off; proxy_connect_timeout 10; proxy_send_timeout 30; proxy_read_timeout 30; proxy_pass $stream_id; }

set_by_file.lua 添加一下内容：

-- 接受Nginx传递进来的参数$1 也就是SteamName
local stream_a = ngx.var.a local redis = require("resty.redis"); -- 建立一个redis对象实例。在失败，返回nil和描述错误的字符串的状况下
local redis_instance = redis:new(); --设置后续操做的超时（以毫秒为单位）保护，包括connect方法
redis_instance:set_timeout(1000) --创建链接
local ip = '127.0.0.1'
local port = 6379
--尝试链接到redis服务器正在侦听的远程主机和端口
local ok,err = redis_instance:connect(ip,port) if not ok then ngx.say("connect redis error : ",err) return err end

-- 权限验证
local res,err = redis_instance:auth('tinywanredis') if not res then ngx.say("failed to authenticate: ", err) return
end

--数据库选择 
redis_instance:select(2) --调用API获取数据 
local resp, err = redis_instance:hget("StreamLiveNodeInnerIp:"..stream_a,'livenode') if not resp then ngx.say("get msg error : ", err) return err end

--获得的数据为空处理 
if resp == ngx.null then ngx.say("this is not redis_data")
    return nil
end ngx.var.stream_id = resp -- ngx.say("reds get result : ", resp)

 思路图片：