前情提要
项目需要在后台管理动态切换查询机票或者火车票的三方服务供应商,每一个供应商就代表了不同的一套策略(不过流程是大致相似的 查询-下单或者改签 -出票).
策略模式
什么是策略模式
策略模式是一种比较简单的,也叫作政策模式.其定义如下:定义一组算法,将每个算法都封装起来,并且使它们之间可以互相转换.它使用的就是面向对象的继承和多态机制.
--摘自 设计模式之禅
本业务场景中的几种策略
首先是策略抽象接口类
/**
* @description 策略类接口在此封装了四个策略方法 由不同的服务商实现类去实现
* 具体的服务商实例只能通过 {@link ****.providestrategyfactory} 实例化
* @author liang
*/
public interface iprovidestrategy {
/**
* 查询票务信息
* @param param 查询票务信息参数类
* @return 票务信息列表
*/
resultvo queryticketlist(queryticketparam param);
/**
* 订一张票 进行下单逻辑处理
* @return 下单是否成功(也有可能是等待中)
*/
resultvo bookoneticket();
/**
* 改签一张票 进行改签逻辑处理
* @return 改签是否成功(也有可能是等待中)
*/
resultvo changeticket();
/**
* 出票方法(这个有可能是放入到回调里面 此处只是留一处口子)
* @return 出票是否成功
*/
resultvo issueoneticket();
}
其次是具体的策略类 (请注意策略类都实现了刚才上面的策略抽象接口类 并且用@component注解 交给spring管理方便后面的工厂类在spring中获取动态代理的实例)
策略类1
/**
* @author liang
* @date 2021年12月13日 14:48
*/
@component
public class casccflightstrategy implements iprovidestrategy {
@resource
private cascchttpclient cascchttpclient;
@override
public resultvo queryticketlist(queryticketparam param) {
return new resultvo(resultenum.success,"查询策略1成功");
}
@override
public resultvo bookoneticket() {
return null;
}
@override
public resultvo changeticket() {
return null;
}
@override
public resultvo issueoneticket() {
return null;
}
}
策略类2
/**
* @author liang
* @date 2021年12月13日 14:50
*/
@component
public class speedflightstrategy implements iprovidestrategy {
@resource
private speedhttpclient speedhttpclient;
@override
public resultvo queryticketlist(queryticketparam param) {
return new resultvo(resultenum.success,"策略类2查询成功");
}
@override
public resultvo bookoneticket() {
return null;
}
@override
public resultvo changeticket() {
return null;
}
@override
public resultvo issueoneticket() {
return null;
}
}
工厂模式
什么是工厂模式
定义一个用于创建对象的接口,让子类决定实例化那一个类.工厂方法使一个类的实例化延迟到其子类.
--摘自 设计模式之禅
本业务场景中的工厂类
注意 @component 注解把此工厂类交给spring管理
重载方法可以决定你具体获取的策略类示例是由库里的存储关系决定 还是由前台传参直接决定
/**
* @description 实例工厂 通过此工厂实例化具体的服务商实现类
* @author liang
* @date 2021年12月13日 14:54
*/
@component
public class providestrategyfactory {
@resource
private vipprovidersmapper providersmapper;
/**
* @author liang
* @date 2021/12/15 15:47
* @return 具体的服务商实例
*/
public iprovidestrategy getprovidestrategy(integer cid, integer type){
list strategycode = providersmapper.selectbyconferenceidandtype(cid,type);
if (commonutils.isempty(strategycode) || strategycode.size() > 1){
throw new serviceexception(resultenum.sys_operate_fail.getcode(),"服务商配置错误");
}
class clazz = providefactoryenum.getfactory(strategycode.get(0));
return springutils.getbean(clazz);
}
/**
* 通过传参判断枚举的策略类型
* @author liang
* @date 2021/12/23 11:21
* @param factoryenum 前台传参的策略枚举类型
* @return 具体的服务商实例
*/
public iprovidestrategy getprovidestrategy(providefactoryenum factoryenum){
class clazz = providefactoryenum.getfactory(factoryenum.name());
return springutils.getbean(clazz);
}
}
工厂与策略类能结合的关键 -->策略枚举类
/**
* 给策略工厂提供枚举类型指定要生成的工厂类
* @author liang
*/
public enum providefactoryenum {
/**
* 这里是服务商的名称和实现类的枚举映射
*/
speedflight(speedflightstrategy.class),
casccflight(casccflightstrategy.class),
speedtrain(speedtrainstrategy.class);
private final class clazz;
providefactoryenum(class clazz) {
this.clazz = clazz;
}
public static class getfactory(string name){
return providefactoryenum.valueof(name).clazz;
}
}
springutils类:(从spring中获取实例的工具类)
/**
* spring工具类 方便在非spring管理环境中获取bean
* @author liang
*/
@component
public final class springutils implements beanfactorypostprocessor
{
/** spring应用上下文环境 */
private static configurablelistablebeanfactory beanfactory;
@override
public void postprocessbeanfactory(@notnull configurablelistablebeanfactory beanfactory) throws beansexception
{
springutils.beanfactory = beanfactory;
}
/**
* 获取对象
* @param name 注册的类的名字
* @return object 一个以所给名字注册的bean的实例
*/
@suppresswarnings("unchecked")
public static t getbean(string name) throws beansexception
{
return (t) beanfactory.getbean(name);
}
/**
* 获取类型为requiredtype的对象
*/
public static t getbean(class clz) throws beansexception
{
return beanfactory.getbean(clz);
}
/**
* 如果beanfactory包含一个与所给名称匹配的bean定义，则返回true
* @return boolean
*/
public static boolean containsbean(string name)
{
return beanfactory.containsbean(name);
}
/**
* 判断以给定名字注册的bean定义是一个singleton还是一个prototype。 如果与给定名字相应的bean定义没有被找到，将会抛出一个异常（nosuchbeandefinitionexception）
*
* @return boolean
*/
public static boolean issingleton(string name) throws nosuchbeandefinitionexception
{
return beanfactory.issingleton(name);
}
/**
* @return class 注册对象的类型
*/
public static class gettype(string name) throws nosuchbeandefinitionexception
{
return beanfactory.gettype(name);
}
/**
* 如果给定的bean名字在bean定义中有别名，则返回这些别名
*/
public static string[] getaliases(string name) throws nosuchbeandefinitionexception
{
return beanfactory.getaliases(name);
}
/**
* 获取aop代理对象
*/
@suppresswarnings("unchecked")
public static t getaopproxy(t invoker)
{
return (t) aopcontext.currentproxy();
}
}
最终调用类
/**
* @author liang
* @date 2021年12月14日 14:09
*/
@service
public class tripserviceprovideserviceimpl implements tripserviceprovideservice {
@resource
private providestrategyfactory strategyfactory;
@override
public resultvo queryticket(queryticketparam param) {
iprovidestrategy providestrategy = strategyfactory.getprovidestrategy(param.getcid(),param.gettype());
return providestrategy.queryticketlist(param);
}
}
最后总结
通过业务逻辑分析 如果需要通过多个第三方完成同样的事(大体上的流程相同,比如支付业务,动态切换服务商等等)就可以采用此策略工厂的设计模式 首先抽象出来策略接口 定义一系列你需要完成的接口 其次根据业务建立不同的策略实现类 实现自己的独立逻辑 最后通过service层就可以调用工厂类从枚举类中拿到真正的策略实例 做到策略的实时动态切换.