nginx+lua+redis 灰度发布实现方案

司寇曼萍

目录

• 第一种方案:
  
• 第二种方案：
  

背景: 公司要把现有的某传统项目进行微服务化，拆分后要分批次预发布，实现某部分使用户使用微服务模块，其他用户使用传统项目。待微服务稳定、无bug后全部用户迁移至微服务系统。
以上为背景，实现此方案使用nginx+lua+redis灰度发布方案。nginx+lua实现反向代理，获取客户端ip，redis存放ip信息(ip为访问微服务允许的地址).
有两种方案可以实现
第一种:nginx+lua获取用户ip，然后再用lua编写程序直接访问redis集群，查询ip信息返回结果;
第二种：nginx+lua获取用户ip，然后用lua编写程序用http请求到redis缓存服务(单独微服务),缓存服务返回ip地址;
开始是考虑第一种方案，用为openresty没有太好的redis cluster的支持包，资料少；如果用第二种方案redis缓存服务可以单独拎出来，不但可以为nginx使用，还可以为其他服务所用。
两种方案都会说下，不过第一种方案用的是单机redis
我假设都有了OpenResty和redis环境

第一种方案:

在nginx.conf http块中添加代码

1. //外部配置
   
2. include lua.conf;
   
3. //新系统地址
   
4. upstream new{
   
5.       server 192.168.1.103:8081;
   
6. }
   
7. //老系统地址
   
8. upstream old{
   
9.       server 192.168.1.103:8080;
   
10. }

复制代码

lua.conf代码

1. //引入redis模块，只能联单机
   
2. local redis = require "resty.redis"
   
3. local cache = redis.new()
   
4. cache:set_timeout(60000)
   
5. //链接
   
6. local ok, err = cache.connect(cache, '192.168.19.10', 6379)
   
7. // 这里如果链接redis失败，则转发到@old对应的服务器 (传统服务)
   
8. if not ok then
   
9.     ngx.exec("@old")
   
10.     return
    
11. end
    
12. 
    
13. //如果nginx只有一层分发层，这下面四行代码可以不写
    
14. local local_ip = ngx.req.get_headers()["X-Real-IP"]
    
15. if local_ip == nil then
    
16.     local_ip  = ngx.req.get_headers()["x_forwarded_for"]
    
17. end
    
18. 
    
19. //从remote_addr变量中拿到客户端ip，同样nginx只有一层的时候此变量为客户端ip，多层不是
    
20. if local_ip == nil then
    
21.     local_ip = ngx.var.remote_addr
    
22. end
    
23. 
    
24. //在redis中根据客户端ip获取是否存在值; redis中存放的是key:ip val:ip, 存放的ip访问微服务
    
25. local intercept = cache:get(local_ip)
    
26. //如果存在则转发到@new对应的服务器(微服务)
    
27. if intercept == local_ip then
    
28.     ngx.exec("@new")
    
29.     return
    
30. end
    
31. //如果不存在，则转发到@old对应的服务器(传统服务)
    
32. ngx.exec("@old")
    
33. //关闭客户端
    
34. local ok, err = cache.close()
    
35. if not ok then
    
36.     ngx.say("failed to close:", err)
    
37.     return
    
38. end

复制代码

逻辑较简单，但是有些问题1：redis集群要配置多ip，防止宕机问题 2：链接问题，如果有线程池最好了。这里不再多说

第二种方案：

nginx.conf不变
lua.conf 中的redistest.lua 改为httptest.lua
httptest.lua代码如下

1. //这里缓存服务地址
   
2. backend = "http://192.168.1.156:8080"
   
3. //缓存服务访问路径
   
4. local method = "httptest"
   
5. local requestBody = "/"..method
   
6. //模块
   
7. local http = require("resty.http")
   
8. local httpc = http.new()
   
9. //设置超时时间
   
10. httpc:set_timeout(1000)
    
11. //发送请求
    
12. local resp, err = httpc:request_uri(backend, {--
    
13.     method = "GET", --
    
14.     path = requestBody,
    
15.     keepalive = false
    
16. })
    
17. //如果请求失败访问老系统
    
18. if not resp then--
    
19.     ngx.exec("@old")----
    
20.     return--
    
21. end
    
22. //缓存服务取回ip
    
23. local isHave = resp.body
    
24. //关闭连接
    
25. httpc:close()
    
26. //请求ip
    
27. local local_ip = ngx.var.remote_addr
    
28. //命中则访问微服务
    
29. if isHave == local_ip then
    
30.     ngx.exec("@new")
    
31.     return
    
32. end
    
33. //没命中访问老系统
    
34. ngx.exec("@old")

复制代码

这里的缓存地址只有一个，实际中有多个，可以采用随机取值去访问一个。超时时间一定要设置，如果缓存系统一直没响应或者缓存服务宕机则直接访问老系统。
例子中在缓存服务中只是存储了真实ip，实际中是存储的IP网段，nginx拿到真实ip字符拆分然后去匹配的。
这里有两点优化没有写出.
1.http可以用连接池代替；
2.可以在nginx内部使用缓存，把命中的ip都存起来，再有链接可以先走本地缓存，再走缓存服务可以提高性能。
目前http没有找到相关连接池，所以一直在非连接池下运行，性能还可以。
另一点直接在nginx中使用了内存进行缓存。
在nginx.conf http块中添加代码
结构为: lua_shared_dict [name][size]

1. lua_shared_dict rediscache 100m;

复制代码

更改httptest.lua的代码如下:

1. backend = "http://192.168.1.156:8080"
   
2. //加载共享内存
   
3. local cache_ngx = ngx.shared.rediscache
   
4. local local_ip = ngx.var.remote_addr
   
5. //优先从本地缓存中去取
   
6. local cacheip = cache_ngx:get(local_ip)
   
7. //本地缓存中不存在，去缓存服务中去取，然后加载到本地缓存
   
8. if cacheip == "" or cacheip == nil then
   
9.     local http = require("resty.http")
   
10.     local httpc = http.new()
    
11.     httpc:set_timeout(1000)
    
12.     local method = "httptest"
    
13.     local requestBody = "/" .. method
    
14.     local resp, err = httpc:request_uri(backend, {
    
15.         method = "GET",
    
16.         path = requestBody,
    
17.         keepalive=false
    
18.     })
    
19.     if not resp then
    
20.         ngx.exec("@new")
    
21.         return
    
22.     end
    
23.     cacheip = resp.body
    
24.     httpc:close()
    
25.     //加载到本地缓存，设置过期时间
    
26.     cache_ngx:set(local_ip, cacheip, 10*60)
    
27. end
    
28. if cacheip == local_ip then
    
29.     ngx.exec("@new")
    
30.     return
    
31. end
    
32. ngx.exec("@old")

复制代码

到此这篇关于nginx+lua+redis 灰度发布实现方案的文章就介绍到这了,更多相关nginx lua redis 灰度内容请搜索晓枫资讯以前的文章或继续浏览下面的相关文章希望大家以后多多支持晓枫资讯！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

123473274

感谢楼主，顶。

融知慧

路过，支持一下