JAVA 设计模式-策略模式

2022-10-18 181

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 策略模式（Strategy Pattern）也叫政策模式（Policy Pattern）。指的是对象具备某个行为，但是在不同的场景中，该行为有不同的实现算法

JAVA设计模式-策略模式

什么是策略模式

策略模式（Strategy Pattern）也叫 政策模式（Policy Pattern）。指的是对象具备某个行为，但是在不同的场景中，该行为有不同的实现算法。比如一个人的交税比率与他的工资有关，不同的工资水平对应不同的税率。

策略模式使用的就是面向对象的继承和多态机制，从而实现同一行为在不同场景下具备不同实现。

策略模式本质：分离算法，选择实现

场景

· 针对同一类型问题，有多种处理方式，每一种都能独立解决问题；

· 算法需要自由切换的场景；

· 需要屏蔽算法规则的场景；

优缺点

优点

· 算法多样性，且具备自由切换功能；

· 有效避免多重条件判断，增强了封装性，简化了操作，降低出错概率；

· 扩展性良好，策略类遵顼 里氏替换原则，可以很方便地进行策略扩展；

缺点

· 策略类数量增多，且所有策略类都必须对外暴露，以便客户端能进行选择；

模式讲解

基础用法

大家都知道商城经常会有优惠活动，但是优惠策略会有多种可能。比如：领取优惠券、返现促销、拼团优惠等。

我们可以通过策略模式来实现。

抽象类

首先创建一个促销策略的抽象类：

public interface IPromotionStrategy {
    void doPromotion();
}

实现类

然后分别创建优惠券抵扣策略、返现促销策略、拼团优惠策略及无优惠策略。

public class CouponStrategy implements IPromotionStrategy {
    public void doPromotion() {
        System.out.println("使用优惠券抵扣");
    }
}
public class CashbackStrategy implements IPromotionStrategy {
    public void doPromotion() {
        System.out.println("返现，直接打款到支付宝账号");
    }
}
public class GroupbuyStrategy implements IPromotionStrategy {
    public void doPromotion() {
        System.out.println("5人成团，可以优惠");
    }
}
public class EmptyStrategy implements IPromotionStrategy {
    public void doPromotion() {
        System.out.println("无优惠");
    }
}

然后创建促销活动方案类：

public class PromotionActivity {
    private IPromotionStrategy strategy;
    public PromotionActivity(IPromotionStrategy strategy) {
        this.strategy = strategy;
    }
    public void execute(){
        strategy.doPromotion();
    }
}

策略模式在云巧中的应用

在 4A 组件的 SDK 中，通过策略模式实现了支持多种登录方式

定义登录的关键接口

public interface IClientForSession {
    /**
     * 根据 token 获取用户信息
     * @param accessToken
     * @return
     */
    ReturnT<UserInfo> describeUserSessionInfo(String accessToken);
    /**
     * 销毁 session 会话
     * @param sessionId
     * @return
     */
    ReturnT invalidSessionId(String sessionId);
}

通过实现关键接口对接不同的用户中心

对接 CAS

public class IClientForSessionImpl implements IClientForSession {
    private static final String SSO_SESSIONID = "xxl_sso_sessionid";
    private static CloseableHttpClient httpClient;
    @Autowired
    SsoParameter ssoParameter;
    static {
        httpClient = HttpClientBuilder.create().build();
    }
    @Override
    public ReturnT<UserInfo> describeUserSessionInfo(String accessToken) {
        Map<String, String> params = new HashMap<>();
        params.put("cacheKey", cacheKey(accessToken));
        String result = doPost(ssoParameter.getLoginServerUrlInternal(), "sso-server/usercenter/sysCache/cacheValAqusitionByCacheKey", params);
        if (result != null) {
           BaseResult<SysCacheResVO> baseResult = JSONObject.parseObject(result, new TypeReference<BaseResult<SysCacheResVO>>(){});
            Object objectValue = null;
           if(!ObjectUtils.isEmpty(result) && !ObjectUtils.isEmpty(baseResult.getData())){
                SysCacheResVO sysCacheResVO = JSON.parseObject(JSON.toJSONString(baseResult.getData()), SysCacheResVO.class);
                objectValue = sysCacheResVO.getCacheValueObj();
            }
            if (objectValue != null) {
                XxlSsoUserVo xxlUser = JSON.parseObject(JSON.toJSONString(objectValue), XxlSsoUserVo.class);
                //todo 登录时间校验
                if (xxlUser != null) {
                    UserInfo userInfo = new UserInfo();
                   userInfo.setSessionId(accessToken);
                    BaseUserInfo baseUserInfo = new BaseUserInfo();
                   baseUserInfo.setUserId(xxlUser.getUserid());
                   baseUserInfo.setUserName(xxlUser.getUsername());
                   userInfo.setBaseInfo(baseUserInfo);
                   ReturnT<UserInfo> res = new ReturnT<UserInfo>();
                   res.setData(userInfo);
                    return res;
                }
            }
        }
        return null;
    }
    @Override
    public ReturnT invalidSessionId(String sessionId) {
        return ReturnT.SUCCESS;
    }
    private String doPost(String ssoServerUrl, String action, Map<String, String> params) {
        String url = ssoServerUrl + "/" + action;
        HttpPost post = new HttpPost(url);
       post.setHeader("Content-Type", MediaType.APPLICATION_JSON_VALUE);
//        List<NameValuePair> pairs = new ArrayList<NameValuePair>();
        if (params != null) {
//            for (Map.Entry<String, String> entry : params.entrySet()) {
//                pairs.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
//            }
            try {
                try {
                    post.setEntity(new StringEntity(JSON.toJSONString(params), "UTF-8"));
                } catch (Exception e) {
                    e.printStackTrace();
                }
            } catch (Exception e) {
            }
        }
        // 响应模型
        CloseableHttpResponse response = null;
        String result = null;
        try {
            // 由客户端执行(发送)Get请求
            response = httpClient.execute(post);
            // 从响应模型中获取响应实体
            HttpEntity responseEntity = response.getEntity();
            if (responseEntity != null) {
                result = EntityUtils.toString(responseEntity);
            }
        } catch (Exception e) {
        } finally {
            if (response != null) {
                try {
                    response.close();
                } catch (IOException e) {
                }
            }
        }
        return result;
    }

对接 IDaaS

public class IClientForSessionImpl implements IClientForSession {
    @Autowired
    HttpServletRequest request;
    @Autowired
    SsoParameter ssoParameter;
   @Value("${idaas.client.id}")
    private String clientId;
   @Value("${idaas.client.secret}")
    private String clientSecret;
    @Override
    public ReturnT<UserInfo> describeUserSessionInfo(String accessToken) {
        Map<String, String> params = new HashMap<>();
       params.put(ssoParameter.getAccessTokenKey(), accessToken);
       params.put("grant_type", "authorization_code");
        params.put("client_id", clientId);
       params.put("client_secret", clientSecret);
        String ssoServerUrl = ssoParameter.getFouraServiceUrl() + "/oauth/token" +
                "?" + ssoParameter.getAccessTokenKey() + "=" + accessToken +
               "&grant_type=authorization_code" +
               "&client_id=" + clientId +
                "&client_secret=" + clientSecret +
               "&redirect_uri=" + URLEncoder.encode(SsoUtil.getCallerHost(request) + ssoParameter.getLoginPath());
        String result = HttpUtil.doPost(ssoServerUrl, null, null);
        if (result != null) {
            String userAccessToken = JSON.parseObject(result).getString("access_token");
            String describeUserUrl = ssoParameter.getFouraServiceUrl()
                    + "/api/bff/v1.2/oauth2/userinfo?access_token="
                    + userAccessToken;
            String userResult = HttpUtil.doGet(describeUserUrl);
            if (userResult != null) {
                JSONObject userMap = JSON.parseObject(userResult).getJSONObject("data");
                BaseUserInfo baseUserInfo = new BaseUserInfo();
               baseUserInfo.setUserId(userMap.getString("sub"));
               baseUserInfo.setUserCode((String)userMap.getString("sub"));
               baseUserInfo.setUserName((String)userMap.getString("nickname"));
                OrgInfo orgInfo = new OrgInfo();
                orgInfo.setId(1L);
               orgInfo.setOrgId(userMap.getString("ou_id"));
               orgInfo.setOrgName(userMap.getString("ou_name"));
                List<OrgInfo> orgList = new ArrayList();
                orgList.add(orgInfo);
                UserInfo userInfo = new UserInfo();
               userInfo.setBaseInfo(baseUserInfo);
               userInfo.setOrgInfoList(orgList);
               userInfo.setSessionId(userAccessToken);
                ReturnT<UserInfo> res = new ReturnT<UserInfo>();
                res.setData(userInfo);
                return res;
            }
        }
        return null;
    }
    @Override
    public ReturnT invalidSessionId(String sessionId) {
        return ReturnT.SUCCESS;
    }
}

JAVA 设计模式-策略模式

JAVA设计模式-策略模式

什么是策略模式

场景

优缺点

优点

缺点

模式讲解

基础用法

抽象类

实现类

策略模式在云巧中的应用

定义登录的关键接口

通过实现关键接口对接不同的用户中心

对接 CAS

对接 IDaaS

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

JAVA 设计模式-策略模式

JAVA设计模式-策略模式

策略模式在云巧中的应用

热门文章

最新文章

相关课程

相关电子书

相关实验场景