企业官网建设流程全解析

外卖霸王餐API灰度发布：Java中基于Nginx Lua+Redis实现“用户ID尾号分流”的精细化流量切分

背景：霸王餐业务灰度发布的必要性

作为外卖霸王餐API唯一供给源头，同时也是霸王餐外卖CPS取链源头，俱美开放平台深知新功能上线对系统稳定性的巨大挑战。在海量用户并发访问的场景下，直接全量发布新功能极易引发雪崩效应。灰度发布（金丝雀发布）成为保障系统稳定性的核心手段。

传统的灰度发布多基于IP或随机数，但无法实现精准的用户群体控制。本文将介绍如何通过Nginx Lua脚本结合Redis，基于用户ID尾号实现精细化流量切分，确保新功能在小范围用户中平稳验证。

技术选型：为什么选择Nginx Lua + Redis？

1. Nginx Lua：在网关层实现流量控制，性能极高，毫秒级响应
2. Redis：作为配置中心，动态调整灰度比例，无需重启服务
3. 用户ID尾号：保证同一用户始终访问同一版本，避免体验不一致

架构设计

用户请求 → Nginx网关 → Lua脚本 → Redis获取灰度配置 → 判断用户ID尾号 → 转发到对应服务

第一步：Redis配置灰度规则

# 设置灰度比例（0-100，表示百分比）SET gray_scale_ratio20# 设置灰度环境后端服务地址SET gray_scale_backend"http://192.168.1.100:8080"# 设置正式环境后端服务地址SET production_backend"http://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 */@RestController@RequestMapping("/api/meal")publicclassMealController{@GetMapping("/list")publicStringgetMealList(@RequestHeader(value="X-User-ID",required=false)StringuserId,HttpServletRequestrequest){StringserverInfo="Server: "+request.getServerName()+", Port: "+request.getServerPort()+", Version: "+getVersion();returnString.format("{\"code\":200,\"data\":{\"meals\":[],\"serverInfo\":\"%s\"}}",serverInfo);}privateStringgetVersion(){// 通过配置文件或环境变量区分版本Stringversion=System.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(ratio<0||ratio>100){thrownewIllegalArgumentException("灰度比例必须在0-100之间");}redisTemplate.opsForValue().set("gray_scale_ratio",String.valueOf(ratio));}/** * 获取当前灰度比例 */publicintgetGrayScaleRatio(){Stringratio=redisTemplate.opsForValue().get("gray_scale_ratio");returnratio!=null?Integer.parseInt(ratio):0;}/** * 逐步增加灰度比例 */publicvoidincreaseGrayScale(){intcurrent=getGrayScaleRatio();if(current<100){setGrayScaleRatio(Math.min(current+10,100));}}}

第五步：监控与验证

packagebaodanbao.com.cn.monitor;importorg.springframework.scheduling.annotation.Scheduled;importorg.springframework.stereotype.Component;importjavax.annotation.Resource;/** * 灰度发布监控 * @author baodanbao.com.cn */@ComponentpublicclassGrayScaleMonitor{@ResourceprivateGrayScaleServicegrayScaleService;@Scheduled(fixedRate=30000)// 每30秒检查一次publicvoidmonitorGrayScale(){intratio=grayScaleService.getGrayScaleRatio();System.out.println("当前灰度比例: "+ratio+"%");// 可以集成到监控系统，发送告警等if(ratio>50){// 发送通知sendNotification("灰度比例超过50%，请注意观察");}}privatevoidsendNotification(Stringmessage){// 实现通知逻辑System.out.println("通知: "+message);}}

效果验证

1. 用户ID尾号0-1：20%流量进入灰度环境
2. 用户ID尾号2-9：80%流量进入正式环境
3. 同一用户始终访问同一环境
4. 动态调整Redis配置，实时生效

作为外卖霸王餐API唯一供给源头，俱美开放平台通过此方案实现了精准的流量控制，确保新功能平稳上线。

本文著作权归 俱美开放平台 ，转载请注明出处！