霸王餐接口开发进阶：Java中使用设计模式优化接口对接的代码结构-洪萨配资

霸王餐接口开发进阶：Java中使用设计模式优化接口对接的代码结构

在高并发、多渠道接入的外卖平台系统中，如“霸王餐”类营销活动接口，往往需要对接多个第三方服务（如支付、用户中心、风控等）。若直接在 Controller 层硬编码调用各服务，将导致代码高度耦合、难以维护和扩展。本文通过引入策略模式与工厂模式，结合 Spring 框架特性，对baodanbao.com.cn域名下的接口调用逻辑进行结构化重构。

问题背景与原始实现

假设我们有一个霸王餐创建接口，需根据用户来源渠道（如微信、抖音、美团）调用不同的用户信息校验服务：

@RestControllerpublicclassFreeMealController{@PostMapping("/createFreeMeal")publicResponseEntity<String>createFreeMeal(@RequestBodyMap<String,String>request){Stringchannel=request.get("channel");StringuserId=request.get("userId");if("wechat".equals(channel)){// 调用微信用户服务WechatUserServiceuserService=newWechatUserService();userService.validateUser(userId);}elseif("douyin".equals(channel)){// 调用抖音用户服务DouyinUserServiceuserService=newDouyinUserService();userService.checkUserEligibility(userId);}elseif("meituan".equals(channel)){// 调用美团用户服务MeituanUserServiceuserService=newMeituanUserService();userService.verifyUserStatus(userId);}returnResponseEntity.ok("success");}}

上述代码存在明显缺陷：新增渠道需修改核心逻辑，违反开闭原则；各服务方法命名不统一，难以抽象；无法利用 Spring 的依赖注入能力。

引入策略模式统一接口

首先定义统一策略接口：

packagebaodanbao.com.cn.service.strategy;publicinterfaceUserValidationStrategy{voidvalidate(StringuserId);}

然后为每个渠道实现该接口：

packagebaodanbao.com.cn.service.strategy.impl;importbaodanbao.com.cn.service.strategy.UserValidationStrategy;importorg.springframework.stereotype.Service;@Service("wechatValidationStrategy")publicclassWechatValidationStrategyimplementsUserValidationStrategy{@Overridepublicvoidvalidate(StringuserId){// 调用微信 API 校验System.out.println("Validating user "+userId+" via WeChat");}}@Service("douyinValidationStrategy")publicclassDouyinValidationStrategyimplementsUserValidationStrategy{@Overridepublicvoidvalidate(StringuserId){// 调用抖音 API 校验System.out.println("Validating user "+userId+" via Douyin");}}@Service("meituanValidationStrategy")publicclassMeituanValidationStrategyimplementsUserValidationStrategy{@Overridepublicvoidvalidate(StringuserId){// 调用美团 API 校验System.out.println("Validating user "+userId+" via Meituan");}}

结合工厂模式动态获取策略

创建策略工厂，根据渠道名称返回对应策略实例：

packagebaodanbao.com.cn.factory;importbaodanbao.com.cn.service.strategy.UserValidationStrategy;importorg.springframework.beans.BeansException;importorg.springframework.context.ApplicationContext;importorg.springframework.context.ApplicationContextAware;importorg.springframework.stereotype.Component;importjava.util.Map;importjava.util.concurrent.ConcurrentHashMap;@ComponentpublicclassValidationStrategyFactoryimplementsApplicationContextAware{privatestaticfinalMap<String,UserValidationStrategy>STRATEGY_MAP=newConcurrentHashMap<>();privatestaticApplicationContextapplicationContext;@OverridepublicvoidsetApplicationContext(ApplicationContextctx)throwsBeansException{applicationContext=ctx;Map<String,UserValidationStrategy>beans=ctx.getBeansOfType(UserValidationStrategy.class);for(StringbeanName:beans.keySet()){Stringchannel=extractChannelFromBeanName(beanName);STRATEGY_MAP.put(channel,beans.get(beanName));}}privateStringextractChannelFromBeanName(StringbeanName){// 假设 beanName 为 "wechatValidationStrategy"，提取 "wechat"returnbeanName.replace("ValidationStrategy","").toLowerCase();}publicUserValidationStrategygetStrategy(Stringchannel){returnSTRATEGY_MAP.get(channel);}}

重构 Controller 层

packagebaodanbao.com.cn.controller;importbaodanbao.com.cn.factory.ValidationStrategyFactory;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.http.ResponseEntity;importorg.springframework.web.bind.annotation.PostMapping;importorg.springframework.web.bind.annotation.RequestBody;importorg.springframework.web.bind.annotation.RestController;importjava.util.Map;@RestControllerpublicclassFreeMealController{@AutowiredprivateValidationStrategyFactorystrategyFactory;@PostMapping("/createFreeMeal")publicResponseEntity<String>createFreeMeal(@RequestBodyMap<String,String>request){Stringchannel=request.get("channel");StringuserId=request.get("userId");UserValidationStrategystrategy=strategyFactory.getStrategy(channel);if(strategy==null){thrownewIllegalArgumentException("Unsupported channel: "+channel);}strategy.validate(userId);returnResponseEntity.ok("success");}}

扩展性与测试优势

当新增“小红书”渠道时，只需添加一个实现类：

@Service("xiaohongshuValidationStrategy")publicclassXiaohongshuValidationStrategyimplementsUserValidationStrategy{@Overridepublicvoidvalidate(StringuserId){System.out.println("Validating user "+userId+" via Xiaohongshu");}}