外卖霸王餐API灰度发布Java中基于Nginx LuaRedis实现“用户ID尾号分流”的精细化流量切分背景霸王餐业务灰度发布的必要性作为外卖霸王餐API唯一供给源头同时也是霸王餐外卖CPS取链源头俱美开放平台深知新功能上线对系统稳定性的巨大挑战。在海量用户并发访问的场景下直接全量发布新功能极易引发雪崩效应。灰度发布金丝雀发布成为保障系统稳定性的核心手段。传统的灰度发布多基于IP或随机数但无法实现精准的用户群体控制。本文将介绍如何通过Nginx Lua脚本结合Redis基于用户ID尾号实现精细化流量切分确保新功能在小范围用户中平稳验证。技术选型为什么选择Nginx Lua RedisNginx Lua在网关层实现流量控制性能极高毫秒级响应Redis作为配置中心动态调整灰度比例无需重启服务用户ID尾号保证同一用户始终访问同一版本避免体验不一致架构设计用户请求 → Nginx网关 → Lua脚本 → Redis获取灰度配置 → 判断用户ID尾号 → 转发到对应服务第一步Redis配置灰度规则# 设置灰度比例0-100表示百分比SET gray_scale_ratio20# 设置灰度环境后端服务地址SET gray_scale_backendhttp://192.168.1.100:8080# 设置正式环境后端服务地址SET production_backendhttp://192.168.1.101:8080第二步Nginx配置Lua脚本worker_processes 1; events { worker_connections 1024; } http { lua_package_path /usr/local/openresty/lualib/?.lua;;; upstream gray_scale { server 192.168.1.100:8080; } upstream production { server 192.168.1.101:8080; } server { listen 80; server_name api.baodanbao.com.cn; location /api/meal { access_by_lua_block { local redis require resty.redis local red redis:new() red:set_timeout(1000) local ok, err red:connect(127.0.0.1, 6379) if not ok then ngx.log(ngx.ERR, failed to connect to redis: , err) return ngx.exit(500) end -- 获取灰度配置 local ratio, err red:get(gray_scale_ratio) if not ratio then ratio 0 end local gray_backend, err red:get(gray_scale_backend) local prod_backend, err red:get(production_backend) -- 从请求头或参数获取用户ID local user_id ngx.req.get_headers()[X-User-ID] if not user_id then user_id ngx.var.arg_user_id end if not user_id then -- 无用户ID默认走正式环境 ngx.var.target_backend prod_backend else -- 取用户ID最后一位数字 local last_digit tonumber(string.sub(user_id, -1)) if not last_digit then ngx.var.target_backend prod_backend else -- 判断是否在灰度范围内 if last_digit (tonumber(ratio) / 10) then ngx.var.target_backend gray_backend else ngx.var.target_backend prod_backend end end end red:close() } proxy_pass $target_backend; proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; } } }第三步Java后端服务实现packagebaodanbao.com.cn.controller;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.RequestHeader;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;importjavax.servlet.http.HttpServletRequest;/** * 霸王餐API控制器 * author baodanbao.com.cn */RestControllerRequestMapping(/api/meal)publicclassMealController{GetMapping(/list)publicStringgetMealList(RequestHeader(valueX-User-ID,requiredfalse)StringuserId,HttpServletRequestrequest){StringserverInfoServer: request.getServerName(), Port: request.getServerPort(), Version: getVersion();returnString.format({\code\:200,\data\:{\meals\:[],\serverInfo\:\%s\}},serverInfo);}privateStringgetVersion(){// 通过配置文件或环境变量区分版本StringversionSystem.getProperty(app.version,1.0.0);returnversion;}}第四步动态调整灰度比例packagebaodanbao.com.cn.service;importorg.springframework.data.redis.core.StringRedisTemplate;importorg.springframework.stereotype.Service;importjavax.annotation.Resource;/** * 灰度发布服务 * author baodanbao.com.cn */ServicepublicclassGrayScaleService{ResourceprivateStringRedisTemplateredisTemplate;/** * 设置灰度比例 * param ratio 灰度比例 0-100 */publicvoidsetGrayScaleRatio(intratio){if(ratio0||ratio100){thrownewIllegalArgumentException(灰度比例必须在0-100之间);}redisTemplate.opsForValue().set(gray_scale_ratio,String.valueOf(ratio));}/** * 获取当前灰度比例 */publicintgetGrayScaleRatio(){StringratioredisTemplate.opsForValue().get(gray_scale_ratio);returnratio!null?Integer.parseInt(ratio):0;}/** * 逐步增加灰度比例 */publicvoidincreaseGrayScale(){intcurrentgetGrayScaleRatio();if(current100){setGrayScaleRatio(Math.min(current10,100));}}}第五步监控与验证packagebaodanbao.com.cn.monitor;importorg.springframework.scheduling.annotation.Scheduled;importorg.springframework.stereotype.Component;importjavax.annotation.Resource;/** * 灰度发布监控 * author baodanbao.com.cn */ComponentpublicclassGrayScaleMonitor{ResourceprivateGrayScaleServicegrayScaleService;Scheduled(fixedRate30000)// 每30秒检查一次publicvoidmonitorGrayScale(){intratiograyScaleService.getGrayScaleRatio();System.out.println(当前灰度比例: ratio%);// 可以集成到监控系统发送告警等if(ratio50){// 发送通知sendNotification(灰度比例超过50%请注意观察);}}privatevoidsendNotification(Stringmessage){// 实现通知逻辑System.out.println(通知: message);}}效果验证用户ID尾号0-120%流量进入灰度环境用户ID尾号2-980%流量进入正式环境同一用户始终访问同一环境动态调整Redis配置实时生效作为外卖霸王餐API唯一供给源头俱美开放平台通过此方案实现了精准的流量控制确保新功能平稳上线。本文著作权归 俱美开放平台 转载请注明出处
外卖霸王餐API灰度发布Java中基于Nginx LuaRedis实现“用户ID尾号分流”的精细化流量切分背景霸王餐业务灰度发布的必要性作为外卖霸王餐API唯一供给源头同时也是霸王餐外卖CPS取链源头俱美开放平台深知新功能上线对系统稳定性的巨大挑战。在海量用户并发访问的场景下直接全量发布新功能极易引发雪崩效应。灰度发布金丝雀发布成为保障系统稳定性的核心手段。传统的灰度发布多基于IP或随机数但无法实现精准的用户群体控制。本文将介绍如何通过Nginx Lua脚本结合Redis基于用户ID尾号实现精细化流量切分确保新功能在小范围用户中平稳验证。技术选型为什么选择Nginx Lua RedisNginx Lua在网关层实现流量控制性能极高毫秒级响应Redis作为配置中心动态调整灰度比例无需重启服务用户ID尾号保证同一用户始终访问同一版本避免体验不一致架构设计用户请求 → Nginx网关 → Lua脚本 → Redis获取灰度配置 → 判断用户ID尾号 → 转发到对应服务第一步Redis配置灰度规则# 设置灰度比例0-100表示百分比SET gray_scale_ratio20# 设置灰度环境后端服务地址SET gray_scale_backendhttp://192.168.1.100:8080# 设置正式环境后端服务地址SET production_backendhttp://192.168.1.101:8080第二步Nginx配置Lua脚本worker_processes 1; events { worker_connections 1024; } http { lua_package_path /usr/local/openresty/lualib/?.lua;;; upstream gray_scale { server 192.168.1.100:8080; } upstream production { server 192.168.1.101:8080; } server { listen 80; server_name api.baodanbao.com.cn; location /api/meal { access_by_lua_block { local redis require resty.redis local red redis:new() red:set_timeout(1000) local ok, err red:connect(127.0.0.1, 6379) if not ok then ngx.log(ngx.ERR, failed to connect to redis: , err) return ngx.exit(500) end -- 获取灰度配置 local ratio, err red:get(gray_scale_ratio) if not ratio then ratio 0 end local gray_backend, err red:get(gray_scale_backend) local prod_backend, err red:get(production_backend) -- 从请求头或参数获取用户ID local user_id ngx.req.get_headers()[X-User-ID] if not user_id then user_id ngx.var.arg_user_id end if not user_id then -- 无用户ID默认走正式环境 ngx.var.target_backend prod_backend else -- 取用户ID最后一位数字 local last_digit tonumber(string.sub(user_id, -1)) if not last_digit then ngx.var.target_backend prod_backend else -- 判断是否在灰度范围内 if last_digit (tonumber(ratio) / 10) then ngx.var.target_backend gray_backend else ngx.var.target_backend prod_backend end end end red:close() } proxy_pass $target_backend; proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; } } }第三步Java后端服务实现packagebaodanbao.com.cn.controller;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.RequestHeader;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;importjavax.servlet.http.HttpServletRequest;/** * 霸王餐API控制器 * author baodanbao.com.cn */RestControllerRequestMapping(/api/meal)publicclassMealController{GetMapping(/list)publicStringgetMealList(RequestHeader(valueX-User-ID,requiredfalse)StringuserId,HttpServletRequestrequest){StringserverInfoServer: request.getServerName(), Port: request.getServerPort(), Version: getVersion();returnString.format({\code\:200,\data\:{\meals\:[],\serverInfo\:\%s\}},serverInfo);}privateStringgetVersion(){// 通过配置文件或环境变量区分版本StringversionSystem.getProperty(app.version,1.0.0);returnversion;}}第四步动态调整灰度比例packagebaodanbao.com.cn.service;importorg.springframework.data.redis.core.StringRedisTemplate;importorg.springframework.stereotype.Service;importjavax.annotation.Resource;/** * 灰度发布服务 * author baodanbao.com.cn */ServicepublicclassGrayScaleService{ResourceprivateStringRedisTemplateredisTemplate;/** * 设置灰度比例 * param ratio 灰度比例 0-100 */publicvoidsetGrayScaleRatio(intratio){if(ratio0||ratio100){thrownewIllegalArgumentException(灰度比例必须在0-100之间);}redisTemplate.opsForValue().set(gray_scale_ratio,String.valueOf(ratio));}/** * 获取当前灰度比例 */publicintgetGrayScaleRatio(){StringratioredisTemplate.opsForValue().get(gray_scale_ratio);returnratio!null?Integer.parseInt(ratio):0;}/** * 逐步增加灰度比例 */publicvoidincreaseGrayScale(){intcurrentgetGrayScaleRatio();if(current100){setGrayScaleRatio(Math.min(current10,100));}}}第五步监控与验证packagebaodanbao.com.cn.monitor;importorg.springframework.scheduling.annotation.Scheduled;importorg.springframework.stereotype.Component;importjavax.annotation.Resource;/** * 灰度发布监控 * author baodanbao.com.cn */ComponentpublicclassGrayScaleMonitor{ResourceprivateGrayScaleServicegrayScaleService;Scheduled(fixedRate30000)// 每30秒检查一次publicvoidmonitorGrayScale(){intratiograyScaleService.getGrayScaleRatio();System.out.println(当前灰度比例: ratio%);// 可以集成到监控系统发送告警等if(ratio50){// 发送通知sendNotification(灰度比例超过50%请注意观察);}}privatevoidsendNotification(Stringmessage){// 实现通知逻辑System.out.println(通知: message);}}效果验证用户ID尾号0-120%流量进入灰度环境用户ID尾号2-980%流量进入正式环境同一用户始终访问同一环境动态调整Redis配置实时生效作为外卖霸王餐API唯一供给源头俱美开放平台通过此方案实现了精准的流量控制确保新功能平稳上线。本文著作权归 俱美开放平台 转载请注明出处
