java设计模式-策略模式详解及示例

梦里梦外; 2022-02-27 02:05 275阅读 0赞

# 1. 定义 #

策略模式定义了一系列的算法，并将每一个算法封装起来，而且使它们还可以相互替换，策略模式让算法独立于使用它的客户而独立变化。

策略模式使这些算法在客户端调用它们的时候能够互不影响地变化。

# 2. 意义 #

策略模式使开发人员能够开发出由许多可替换的部分组成的软件，并且各个部分之间是低耦合的关系。

低耦合的特性使软件具有更强的可扩展性，易于维护；更重要的是，它大大提高了软件的可重用性。

# 3. 逻辑图 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk2ODIzNA_size_16_color_FFFFFF_t_70]

# 4. 代码讲解 #

## 4.1 定义策略执行流大对象 ##

import lombok.Data;
    
    /** * @author yanghao * @version StrategyResult.java, v 0.1 2019-03-07 11:31 */
    @Data
    public class StrategyResult { 
    
        /** * 数据对象 */
        private Object data;
    
        /** * 是否策略组件执行出现错误 */
        private boolean isError;
    
        /** * 策略组件执行出现错误信息 */
        private String errorMsg;
    
    
        /** * 策略组件执行错误 */
        public void setError(String errorMsg) { 
            this.isError = true;
            this.errorMsg = errorMsg;
        }
    
        /** * 有参构造器 * @param data * @param <T> */
        public <T extends Object> StrategyResult(T data){ 
            this.isError = false;
            this.data = data;
        }
    
    }

## 4.2 定义大对象里面的动态对象 ##

import lombok.Data;
    
    /** * @author yanghao * @version TestDO.java, v 0.1 2019-03-07 12:03 */
    @Data
    public class TestDO { 
    
        /** * channel 通道类型 */
        private Integer channel;
        /** * bankType 银行类型 */
        private Integer bankType;
    
    }

## 4.3 定义策略抽象类 ##

import lombok.Data;
    
    /** * @author yanghao * @version StrategyComponent.java, v 0.1 2019-03-07 11:10 */
    @Data
    public abstract class StrategyComponent { 
    
        /** * 策略编码 */
        private String strategyCode;
    
        /** * 策略名称 */
        private String strategyName;
    
        /** * 策略执行方法 * @param result */
        public abstract void execute(StrategyResult result);
    
    }

## 4.4 定义策略组件一 ##

/** * @author yanghao * @version ChannelComponent.java, v 0.1 2019-03-07 11:59 */
    @Component
    public class ChannelComponent extends StrategyComponent { 
    
        @Override
        public void execute(StrategyResult result) { 
    
            TestDO testDO = (TestDO)result.getData();
            testDO.setChannel(11);
    
        }
    
    }

## 4.5 定义策略组件二 ##

/** * @author yanghao * @version BankComponent.java, v 0.1 2019-03-07 12:07 */
    @Component
    public class BankComponent extends StrategyComponent { 
    
        @Override
        public void execute(StrategyResult result) { 
    
            TestDO testDO = (TestDO)result.getData();
            testDO.setBankType(1);
    
            //result.setError("处理报错啦。。");
    
        }
    
    }

## 4.6 策略执行类 ##

import com.google.common.collect.Lists;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.stereotype.Service;
    import java.util.List;
    
    /** * @author yanghao * @version StrategyClient.java, v 0.1 2019-03-07 11:21 */
    @Service
    public class StrategyClient { 
    
        private static final Logger logger = LoggerFactory.getLogger(StrategyClient.class);
    
        /** * 策略执行 * @param nonce * @param data * @param <T> */
        public <T extends Object> void strategyExecute(String nonce, T data){ 
    
            StrategyResult result = new StrategyResult(data);
    
            //获取配置的策略组件
            List<StrategyComponent> componentList = getAllStrategyComponents();
    
            for(StrategyComponent component : componentList){ 
                long startTime = System.currentTimeMillis();
    
                //执行策略组件
                component.execute(result);
    
                //判断策略组件是否执行成功
                if(result.isError()){ 
                    logger.error("【{}】 >> 策略组件执行失败[{}][{}] >> errorMsg = {}",
                            nonce, component.getStrategyCode(), component.getStrategyName(), result.getErrorMsg());
    
                    throw new Exception("策略组件执行失败");
    
                }
    
                logger.info("【{}】 >> 策略组件执行完成[{}][{}] >> costs = {} ms",
                        nonce, component.getStrategyCode(), component.getStrategyName(), System.currentTimeMillis() - startTime);
    
            }
    
        }
    
        /** * 获取所有策略组件 * @return */
        private List<StrategyComponent> getAllStrategyComponents() { 
            //获取配置的策略配置
            List<StrategyComponent> componentList = Lists.newArrayList();
    
            ChannelComponent channelComponent = new ChannelComponent();
            channelComponent.setStrategyCode("channel");
            channelComponent.setStrategyName("通道策略");
            componentList.add(channelComponent);
    
            BankComponent bankComponent = new BankComponent();
            bankComponent.setStrategyCode("bank");
            bankComponent.setStrategyName("银行策略");
            componentList.add(bankComponent);
    
            return componentList;
        }
    
    }

## 4.7 测试类 ##

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    /** * @author yanghao * @version TestController.java, v 0.1 2019-03-07 13:45 */
    @RestController("/")
    public class TestController { 
    
        @Autowired
        private StrategyClient strategyClient;
    
        @GetMapping("/strategy")
        public void testStrategy(){ 
    
            String nonce = "test123456";
            TestDO testDO = new TestDO();
    
            strategyClient.strategyExecute(nonce, testDO);
    
            System.out.println(testDO);
    
        }
    
    }

## 4.8 测试结果 ##

/** * 执行成功时 */
    [INFO ][2019-03-25 13:40:42,966][StrategyClient:52] 【test123456】 >> 策略组件执行完成[channel][通道策略] >> costs = 0 ms
    [INFO ][2019-03-25 13:40:42,966][StrategyClient:52] 【test123456】 >> 策略组件执行完成[bank][银行策略] >> costs = 0 ms
    TestDO(channel=11, bankType=1)
      
     /** * 执行失败时 */
    [INFO ][2019-03-25 13:42:56,317][StrategyClient:52] 【test123456】 >> 策略组件执行完成[channel][通道策略] >> costs = 0 ms
    [ERROR][2019-03-25 13:42:56,317][StrategyClient:45] 【test123456】 >> 策略组件执行失败[bank][银行策略] >> errorMsg = 处理报错啦。。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzk2ODIzNA_size_16_color_FFFFFF_t_70]: /images/20220227/546b600e9d104c5fa6227d479dafd131.png