Openerstry + lua + redis根据请求参数实现动态路由转发

一、需求分析

根据用户访问url的参数，将请求转发到对应指定IP的服务器上。

二、准备

1、软件安装

安装openresty+redis，略

2、redis-lua封装优化

在关于web+lua+openresty开发中，项目中会大量操作redis，

重复创建连接–>数据操作–>关闭连接（或放到连接池）这个完整的链路调用完毕，
甚至还要考虑不同的 return 情况做不同处理，就很快发现代码中有大量的重复

推荐一个二次封装的类库
OpenResty使用Lua大全（四）OpenResty中使用Redis

三、实现

1、nginx.conf

worker_processes 4;events {worker_connections  1024;
}http {include       mime.types;default_type text/html;sendfile        on;keepalive_timeout  65;# 指定lua文件地址lua_package_path '/usr/local/openresty/nginx/conf/?.lua;;';server {listen       80;server_name  192.168.56.10;charset utf-8;location / {# 目标代理地址（动态生成）set $target '';# 执行luaaccess_by_lua_block {local proxy = require("dynamic")ngx.var.target = proxy.dynamicProxy()}proxy_pass http://$target;resolver 114.114.114.114;}}
}

2、dynamic.lua

local redis = require "resty.redis_iresty"
local _M = {_VERSION = '0.01'}local opts = {ip = "192.168.56.10",port = "6379",-- password = "root",db_index = 0
}local red = redis:new(opts)-- 封装函数，防止每次redis都要new
function _M.dynamicProxy()-- 获取url参数，通过client来获取redis的ip+端口local clientKey = ngx.req.get_uri_args()["client"]if not clientKey thenngx.exit(403)ngx.say("no param as client: ", err)returnend-- 根据client，获取到ip+端口local clientIP, err = red:get(clientKey)if not clientIP thenngx.exit(404)ngx.say("failed to connect redis: ", err)returnelseif clientIP == ngx.null thenngx.exit(404)ngx.say("failed to connect redis: ", err)returnend-- 将获取到的value赋值给target-- ngx.var.target = clientIPreturn clientIPendreturn _M

注意

这里防止new多次，能否提高性能表示存疑。

3、准备两个应用

192.168.56.1:8081、192.168.56.1:8082，分别在redis中设置：

4、访问nginx

至此，实现了根据请求参数进行动态路由转发。

四、参数直接传要代理的地址+端口

worker_processes 4;events {worker_connections  1024;
}http {include       mime.types;default_type text/html;sendfile        on;keepalive_timeout  65;server {listen       80;server_name  192.168.56.10;charset utf-8;location / {# 目标代理地址（动态生成）set $target '';# 执行luaaccess_by_lua_block {local clientKey = ngx.req.get_uri_args()["client"]if not clientKey thenngx.exit(403)ngx.say("no param as client: ", err)returnendngx.var.target = clientKey}proxy_pass http://$target;resolver 114.114.114.114;}}
}