1.nginx的location的配置
location /flow1 {
lua_need_request_body on;
lua_code_cache on;
default_type application/json;
#在content阶段，lua中可以调用所有ngx_lua的函数，但不是很适合upstream这种情形。
content_by_lua_file /usr/local/openresty/nginx/conf/vhosts/flowservice.lua;
}
location /flow2 {
error_log /data/log/nginx/flow_error.log;
access_log /data/log/nginx/cntr.log cntr;
lua_need_request_body on;
lua_code_cache on;
default_type application/json;
set $proxyhost "wps_cntr";
rewrite_by_lua_file /usr/local/openresty/nginx/conf/vhosts/flowservice.lua; #Rewrite阶段是不允许带参数的。
#return 200, $proxyhost; #当使用return时，是会导致rewrite的lua不会被调用。可能是因为return函数的关系，被系统优先调用而忽略了lua文件的调用。
proxy_pass http://$proxyhost; #默认情况下是调用wps_cntr的，由于flowserice的影响，会调用ngx.var.proxyhost="wps_flow"的。
}
location /flow3 {
lua_need_request_body on;
lua_code_cache on;
default_type application/json;
set $cntr_old "wps_cntr";
set $cntr_new "wps_flow";
# set阶段，不能使用ngx.req.read_body的函数，这个是ngx_lua的强制需求。
set_by_lua_file $proxyhost /usr/local/openresty/nginx/conf/vhosts/flowservice.lua $cntr_old $cntr_new; #这情况是允许带参数的。
return 200 $proxyhost
}
2.相应flowservice.lua的脚本编写
local json_module = os.getenv("JSON_MODULE") or "cjson"
local json = require(json_module)
local g_plugin = {}
g_plugin["Kaiwpp"] = true
g_plugin["onekeyanimation"] = true
local function find_func(mod, funcnames)
for _, v in ipairs(funcnames) do
if mod[v] then
return mod[v]
end
end
return nil
end
local json_encode = find_func(json, { "encode", "Encode", "to_string", "stringify", "json" })
local json_decode = find_func(json, { "decode", "Decode", "to_value", "parse" })
local function get_query_string()
local method = ngx.var.request_method
if "GET" == method then
local args = ngx.req.get_uri_args()
return args['query']
elseif "POST" == method then
ngx.req.read_body()
local headers = ngx.req.get_headers()
if headers['content-type'] == 'application/json' then
local data = ngx.req.get_body_data()
if data == nil then
return nil
end
local args = json_decode(data)
if args then
return args['query']
end
return nil
end
local args = ngx.req.get_post_args()
return args['query']
end
end
local q = get_query_string()
if q then
local query = json_decode(q)
if query then
local pn = query[1]
if pn then
local name = pn['plug_name']
if name then
if g_plugin[name] then
ngx.var.proxyhost="wps_flow"
end
end
end
end
end
ngx.log(ngx.INFO, "abc")
3.检验结果的方式。
A.lua脚本运行出错，看error.log可以看出出错原因。
B.ngx.log来打印，ngx.log默认是打印至err_log的地方。
C.lua运行正常，可以通过access_log来看。特别是upstream的模式，access_log的格式需要包括$upstream_addr的参数。
config配置
error_log
access_log
