使用OpenResty+Lua实现灰度测试(金丝雀) php

https://openresty.org/en/ 下载地址如何安装部署不是本节内容

【使用OpenResty+Lua实现灰度测试(金丝雀)】在实际项目中遇到重构或者新版本发布, 新老系统如何高效的切换,现目前的答案就是Gateway 网关,有很多开源的网关Kong Apisix 但是这里来教如何自己实现一个api网关
介绍 openresty 基于 Nginx 开发使用 Lua 让程序更加灵活, Lua基于C开发,脚本语言拥有原生协程, 性能强自己简单看一下lua的语法我们就开始上手了
思路网关实现思路其实很简单,请求来到openresty然后通过Lua脚本解析相关route/ queryParmes / Body 内容,然后做出想要的结果, 比如我想要/abc返回

{ "msg": "helloworld" }

或者GET返回1, POST返回2, 因为是 luaJit耗时很低
代码将通过 redis来实现访问指定路由后请求新项目, 没有则访问老项目

local re_uri = ngx.var.request_uri // 获取请求的uri local re_method = ngx.var.request_method // 获取请求的方式 if re_method == "GET" then // 这里判断如果是get请求就判断一下有没有传参有传参就把后面的参数去掉因为只需要保存 uri local cat_len = string.find(re_uri, "?") -- ngx.say(type(cat_len)) if type(cat_len) == "number" and cat_len > 0 then re_uri = string.sub(re_uri, 0, cat_len-1) end end // 开始连接redis local function close_redis(redis_instance) if not redis_instance then return end local ok,err = redis_instance:close(); if not ok then ngx.say("close redis error : ",err); end end-- 连接redis local redis = require("resty.redis"); -- 创建redis 对象 local redis_instance = redis:new(); redis_instance:set_timeout(1000)local ok,err = redis_instance:connect('127.0.0.1',6379) if not ok then ngx.say("connect redis error : ",err) return close_redis(redis_instance); end--Redis身份验证 local auth,err = redis_instance:auth(""); // 如果没有密码可以注释掉这一段代码 if not auth then ngx.say("failed to authenticate : ",err) end-- 连接成功 local resp,err = redis_instance:set("lua","hello world") // 连接成功写入一个 lua helloworld if not resp then ngx.say("set msg error : ",err) return close_redis(redis_instance) end-- 获取API是否存在 local resp, err = redis_instance:get("gateway:"..re_uri) if not resp then ngx.say("get msg error : ", err) return close_redis(redis_instance) end// 如果不存在则访问老项目 if resp == nil then ngx.exec("@old"); end if resp == "1" then ngx.exec("@new"); // 如果存在则访问新项目 else ngx.exec("@old"); end close_redis(redis_instance) // 结束之后关闭redis连接

配置 openresty lua脚本写好之后需要在openresty配置加上, 因为是基于nginx开发的所以配置和nginx是差不多的
vim nginx.conf

location / { // 访问路由则加载lua脚本 add_header content-type application/json; content_by_lua_file /www/lua/gateway.lua; }location @old{ // 旧项目 try_files $uri =404; fastcgi_passunix:/tmp/php-cgi-72.sock; fastcgi_index index.php; include fastcgi.conf; include pathinfo.conf; }location @new{ // 新项目 proxy_http_version 1.1; proxy_set_header Connection "keep-alive"; proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; proxy_set_header REMOTE-HOST $remote_addr; proxy_pass http://127.0.0.1:13001; }

重载配置