一、传统的实现方式

先说一下具体的需求：公司推广入口很多，每一个下单来源在下单时都做特殊的逻辑处理，可能每两天就会加一个来源。

那么按照传统的实现方式代码就是如下：

<code>public class OrderServiceImpl implements IOrderService {
    @Override
    public String handle(OrderDTO dto) {
        String type = dto.getType();
        if ("1".equals(type)) {
            return "处理普通订单";
        } else if ("2".equals(type)) {
            return "处理团购订单";
        } else if ("3".equals(type)) {
            return "处理促销订单";
        }
        return null;
    }
}/<code>

为什么非得写的这么臃肿？很多同事会说：“哎呀，没办法呀，业务催的紧，这样开发效率快省事”。的确是句大实话，很多时候业务方确实像催命鬼一样的让你赶工期，想快速实现功能，这样写是最好的选择。

上边的代码看似还算清晰，可如果我告诉你公司订单来源有上百种，你想象一下那种臃肿的if-else，去翻代码时是什么感受？

二、策略模式的实现方式

策略模式是oop中最著名的设计模式之一，是对方法行为的抽象，可以归类为行为设计模式，也是oop中interface经典的应用。其特点简单又实用，是我最喜欢的模式之一。

策略模式定义了一个拥有共同行为的算法族，每个算法都被封装起来，可以互相替换，独立于客户端而变化。

不少人说：Java的设计模式背了很多，可日常还不就是写if-else的业务，根本就不用到。其实不是用不到是没有用到合适的位置！

1、策略模式的使用场景：

• 针对同一问题的多种处理方式，仅仅是具体行为有差别时；
• 需要安全地封装多种同一类型的操作时；
• 同一抽象类有多个子类，而客户端需要使用if-else 或者 switch-case 来选择具体子类时。

这个是用策略模式修改后代码：

<code>@Component
@OrderHandlerType(16)
public class DispatchModeProcessor extends AbstractHandler{ 


\t@Autowired
\tprivate OrderStencilledService orderStencilledService;
\t
\t@Override
\tpublic void handle(OrderBO orderBO) {
\t\t
\t\t/**
    \t * 订单完结广播通知(1 - 支付完成)
    \t */
    \torderStencilledService.dispatchModeFanout(orderBO);
\t\t
    \t/**
    \t *  SCMS 出库单
    \t */
    \torderStencilledService.createScmsDeliveryOrder(orderBO.getPayOrderInfoBO().getLocalOrderNo());
\t}
}/<code>

每个订单来源都有自己单独的逻辑实现类，而每次需要添加订单来源，直接新建实现类，修改@OrderHandlerType(16)的数值即可，再也不用去翻那几百行的if-lese，一劳永逸！

2、具体的实现过程：

1、定义一个标识订单来源的注解

<code>@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface OrderHandlerType {
\tint value() default 0;
}/<code>

2、抽象出来一个具体的业务处理器

<code>public abstract class AbstractHandler {
\tabstract public void handle(OrderBO orderBO);
}/<code>

3、项目启动扫描 handler 入口

<code>@Component
@SuppressWarnings({"unused","rawtypes"})
public class HandlerProcessor implements BeanFactoryPostProcessor {
\t
\tprivate String basePackage = "com.ecej.order.pipeline.processor";
\t
    public static final Logger log = LoggerFactory.getLogger(HandlerProcessor.class);
\t
\t@Override
\tpublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {
\t\t
\t\tMap<integer> map = new HashMap<integer>();
\t\t
\t\tClassScaner.scan(basePackage, OrderHandlerType.class).forEach(x ->{
\t\t\tint type = x.getAnnotation(OrderHandlerType.class).value();
\t\t\tmap.put(type,x);
\t\t});
\t\t
\t\tbeanFactory.registerSingleton(OrderHandlerType.class.getName(), map);
\t\t
\t\tlog.info("处理器初始化{}", JSONObject.toJSONString(beanFactory.getBean(OrderHandlerType.class.getName())));
\t}
}/<integer>/<integer>/<code>

4、扫描需要用到的工具类

<code>public class ClassScaner {
\tprivate ResourcePatternResolver resourcePatternResolver = new PathMatchingResourcePatternResolver();

\tprivate final List<typefilter> includeFilters = new ArrayList<typefilter>();

\tprivate final List<typefilter> excludeFilters = new ArrayList<typefilter>();

\tprivate MetadataReaderFactory metadataReaderFactory = new CachingMetadataReaderFactory(resourcePatternResolver);
\t
\t/**
\t * 添加包含的Fiter 

\t * @param includeFilter
\t */
\tpublic void addIncludeFilter(TypeFilter includeFilter) {
\t\tthis.includeFilters.add(includeFilter);
\t}

\t/**
\t * 添加排除的Fiter
\t * @param includeFilter
\t */
\tpublic void addExcludeFilter(TypeFilter excludeFilter) {
\t\tthis.excludeFilters.add(excludeFilter);
\t}
\t
\t/**
\t * 扫描指定的包，获取包下所有的Class
\t * @param basePackage 包名
\t * @param targetTypes 需要指定的目标类型,可以是pojo,可以是注解
\t * @return Set<class>>
\t */
\tpublic static Set<class>> scan(String basePackage,
\t\t\tClass>... targetTypes) {
\t\tClassScaner cs = new ClassScaner();
\t\tfor (Class> targetType : targetTypes){
\t\t\tif(TypeUtils.isAssignable(Annotation.class, targetType)){
\t\t\t\tcs.addIncludeFilter(new AnnotationTypeFilter((Class extends Annotation>) targetType));
\t\t\t}else{
\t\t\t\tcs.addIncludeFilter(new AssignableTypeFilter(targetType));
\t\t\t}
\t\t}
\t\treturn cs.doScan(basePackage);
\t}
\t
\t/**
\t * 扫描指定的包，获取包下所有的Class
\t * @param basePackages 包名,多个
\t * @param targetTypes 需要指定的目标类型,可以是pojo,可以是注解
\t * @return Set<class>>
\t */
\tpublic static Set<class>> scan(String[] basePackages,
\t\t\tClass>... targetTypes) {
\t\tClassScaner cs = new ClassScaner();
\t\tfor (Class> targetType : targetTypes){ 

\t\t\tif(TypeUtils.isAssignable(Annotation.class, targetType)){
\t\t\t\tcs.addIncludeFilter(new AnnotationTypeFilter((Class extends Annotation>) targetType));
\t\t\t}else{
\t\t\t\tcs.addIncludeFilter(new AssignableTypeFilter(targetType));
\t\t\t}
\t\t}
\t\tSet<class>> classes = new HashSet<class>>();
\t\tfor (String s : basePackages){
\t\t\tclasses.addAll(cs.doScan(s));
\t\t}
\t\treturn classes;
\t}
\t
\t/**
\t * 扫描指定的包，获取包下所有的Class
\t * @param basePackages 包名
\t * @return Set<class>>
\t */
\tpublic Set<class>> doScan(String [] basePackages) {
\t\tSet<class>> classes = new HashSet<class>>();
\t\tfor (String basePackage :basePackages) {
\t\t\tclasses.addAll(doScan(basePackage));
\t\t}
\t\treturn classes;
\t}
\t
\t/**
\t * 扫描指定的包，获取包下所有的Class
\t * @param basePackages 包名
\t * @return Set<class>>
\t */
\tpublic Set<class>> doScan(String basePackage) {
\t\tSet<class>> classes = new HashSet<class>>();
\t\ttry {
\t\t\tString packageSearchPath = ResourcePatternResolver.CLASSPATH_ALL_URL_PREFIX
\t\t\t\t\t+ ClassUtils.convertClassNameToResourcePath(
\t\t\t\t\t\t\tSystemPropertyUtils.resolvePlaceholders(basePackage))+"/**/*.class";
\t\t\tResource[] resources = this.resourcePatternResolver.getResources(packageSearchPath);
\t\t\tfor (int i = 0; i < resources.length; i++) {
\t\t\t\tResource resource = resources[i];
\t\t\t\tif (resource.isReadable()) {
\t\t\t\t\tMetadataReader metadataReader = this.metadataReaderFactory.getMetadataReader(resource);
\t\t\t\t\tif ((includeFilters.size() == 0 && excludeFilters.size() == 0)|| matches(metadataReader)) {
\t\t\t\t\t\ttry {
\t\t\t\t\t\t\tclasses.add(Class.forName(metadataReader.getClassMetadata().getClassName()));
\t\t\t\t\t\t} catch (ClassNotFoundException ignore) {}
\t\t\t\t\t} 

\t\t\t\t}
\t\t\t}
\t\t} catch (IOException ex) {
\t\t\tthrow new RuntimeException("I/O failure during classpath scanning", ex);
\t\t}
\t\treturn classes;
\t}
\t
\t/**
\t * 处理 excludeFilters和includeFilters
\t * @param metadataReader
\t * @return boolean
\t * @throws IOException
\t */
\tprivate boolean matches(MetadataReader metadataReader) throws IOException {
\t\tfor (TypeFilter tf : this.excludeFilters) {
\t\t\tif (tf.match(metadataReader, this.metadataReaderFactory)) {
\t\t\t\treturn false;
\t\t\t}
\t\t}
\t\tfor (TypeFilter tf : this.includeFilters) {
\t\t\tif (tf.match(metadataReader, this.metadataReaderFactory)) {
\t\t\t\treturn true;
\t\t\t}
\t\t}
\t\treturn false;
\t}
}/<class>/<class>/<class>/<class>/<class>/<class>/<class>/<class>/<class>/<class>/<class>/<class>/<class>/<class>/<typefilter>/<typefilter>/<typefilter>/<typefilter>/<code>

5、 根据类型实例化抽象类

<code>
@Component
public class HandlerContext {

\t@Autowired
\tprivate ApplicationContext beanFactory;

\tpublic  AbstractHandler getInstance(Integer type){
\t\t
\t\tMap<integer> map = (Map<integer>) beanFactory.getBean(OrderHandlerType.class.getName());
\t\t
\t\treturn (AbstractHandler)beanFactory.getBean(map.get(type));
\t}
\t
}/<integer>/<integer>/<code>

6、调用入口，我这里是接的MQ消息，会批量的处理多个订单来源

<code>@Component
@RabbitListener(queues = "OrderPipelineQueue")
public class PipelineSubscribe{
 
\tprivate final Logger LOGGER = LoggerFactory.getLogger(PipelineSubscribe.class);
\t
\t@Autowired
\tprivate HandlerContext HandlerContext;
\t
\t@Autowired
\tprivate OrderValidateService orderValidateService;
\t
    @RabbitHandler
    public void subscribeMessage(MessageBean bean){
    \t
    \tOrderBO orderBO = JSONObject.parseObject(bean.getOrderBO(), OrderBO.class);
    \t
    \tif(null != orderBO &&CollectionUtils.isNotEmpty(bean.getType()))
    \t{
    \t\tfor(int value:bean.getType())
    \t\t{
       \t\t AbstractHandler handler = HandlerContext.getInstance(value);
       \t\t handler.handle(orderBO);
    \t\t}
\t\t}
\t}
}/<code>

接收实体 MessageBean 类代码

<code>public class MessageBean implements Serializable {
    private static final long serialVersionUID = 5454831432308782668L;
    private String cachKey;
    private List<integer> type;
    private String orderBO;

    public MessageBean(List<integer> type, String orderBO) {
        this.type = type;
        this.orderBO = orderBO;
    }
}/<integer>/<integer>/<code>

三、策略模式的优缺点

优点

• 易于扩展，增加一个新的策略只需要添加一个具体的策略类即可，基本不需要改变原有的代码，符合开放封闭原则
• 避免使用多重条件选择语句，充分体现面向对象设计思想 策略类之间可以自由切换，由于策略类都实现同一个接口，所以使它们之间可以自由切换
• 每个策略类使用一个策略类，符合单一职责原则 客户端与策略算法解耦，两者都依赖于抽象策略接口，符合依赖反转原则
• 客户端不需要知道都有哪些策略类，符合最小知识原则

缺点

• 策略模式，当策略算法太多时，会造成很多的策略类
• 客户端不知道有哪些策略类，不能决定使用哪个策略类，这点可以通过封装common公共包解决，也可以考虑使IOC容器和依赖注入的方式来解决。

以下是订单来源策略类的一部分，不得不说策略类确实比较多。

总结：

凡事都有他的两面性，if-else多层嵌套和也都有其各自的优缺点：

if-else的有点就是简单，想快速迭代功能，逻辑嵌套少且不会持续增加，if-else更好些，缺点也是显而易见，代码臃肿繁琐不便于维护。

策略模式 将各个场景的逻辑剥离出来维护，同一抽象类有多个子类，需要使用if-else 或者 switch-case 来选择具体子类时，建议选策略模式，他的缺点就是会产生比较多的策略类文件。

两种实现方式各有利弊，如何选择还是要依据具体业务场景，还是那句话设计模式不是为了用而用，一定要用在最合适的位置。

今天就说这么多，如果本文对您有一点帮助，希望能得到您一个点赞哦

作者：程序员内点事
链接：https://juejin.im/post/5e79f1715188255e374d8097

閱讀更多 Java大數據高級架構師 的文章

關鍵字: 设计模式 可以很 算法