nginx.conf
[root@server conf]# cat nginx.conf user root; worker_processes 1; events { worker_connections 1024; } http { include mime.types; default_type application/octet-stream; sendfile on; keepalive_timeout 65; upstream up1{ server 127.0.0.1:8081; } upstream up2{ server 127.0.0.1:8082; } upstream all{ ip_hash; serever 127.0.0.1:8081; serever 127.0.0.1:8082; } server { listen 80; server_name localhost; # 请求交给lua脚本处理 location / { lua_code_cache off; content_by_lua_file /usr/local/nginx/lua/proxy.lua; } # location @ 用于nginx内部跳转 location @up1 { proxy_pass ; } location @up2 { proxy_pass ; } location @all { proxy_pass ; } } }proxy.lua
ngx.header.content_type="text/html;charset=utf8" redis = require('resty.redis') redis = redis.new() redis:set_timeout(1000) ok,err = redis:connect('127.0.0.1', 6379) if not ok then ngx.say('connect to redis failed ! reason: ' .. err) end -- 从redis中检查是否存在即将更新的upstream主机 check_up1 = redis:get('update1') --(up1) check_up2 = redis:get('update2') --(up2) redis:close() -- 注意返回的数据类型来判断 if check_up1 == "1" then ngx.exec("@up2") elseif check_up2 == "1" then ngx.exec("@up1") else ngx.exec("@all") end -- 原理就是利用redis中设置指定key，比如要更新主机1，则redis中添加key=update1，value=1，当浏览器请求进入nginx的content阶段后执行lua脚本， -- 脚本中检查redis中是否存在要更新的主机，如果发现某个主机要更新则通过Nginx API for Lua中的ngx.exec接口内部跳转到另一台主机。 -- 如果两个都不更新，则根据nginx自己的方式（默认轮询）分发请求。 -- nginx里使用了ip_hash保持会话，主要是为了用户的请求在后端记录的日志中保持完整。 优点 高并发