资讯专栏INFORMATION COLUMN

ZStack源码剖析之设计模式鉴赏——策略模式

Eric / 1235人阅读

摘要:能够整体地替换算法,能让我们轻松地以不同的算法去解决一个问题,这种模式就是模式。这个类是在发布前常在中被使用的一个类,代码如下以为例,从语义上来说就是为了中的每个元素调用函数。

本文首发于泊浮目的专栏:https://segmentfault.com/blog...
前言

无论什么程序,其目的都是解决问题。而为了解决问题,我们又需要编写特定的算法。使用Strategy模式可以整体地替换算法的实现部分。能够整体地替换算法,能让我们轻松地以不同的算法去解决一个问题,这种模式就是Strategy模式。

在ZStack中,Strategy模式几乎是充斥在80%以上的代码中的,接下来我们就来一起看看吧。

CollectionUtils

CollectionUtils 这个类是在JDK8发布前常在ZStack中被使用的一个类,代码如下:

package org.zstack.utils;

import org.zstack.utils.function.ForEachFunction;
import org.zstack.utils.function.Function;
import org.zstack.utils.function.ListFunction;
import org.zstack.utils.logging.CLogger;

import java.util.*;

/**
 */
public class CollectionUtils {
    private static final CLogger logger = Utils.getLogger(CollectionUtils.class);

    public static  List transformToList(Collection from, ListFunction func) {
        List ret = new ArrayList();
        for (V v : from) {
            List k = func.call(v);
            if (k == null) {
                continue;
            }
            ret.addAll(k);
        }

        return ret;
    }

    public static  List transformToList(Collection from, Function func) {
        List ret = new ArrayList();
        for (V v : from) {
            K k = func.call(v);
            if (k == null) {
                continue;
            }
            ret.add(k);
        }

        return ret;
    }

    public static  Set transformToSet(Collection from, Function func) {
        Set ret = new HashSet();
        for (V v : from) {
            K k = func.call(v);
            if (k == null) {
                continue;
            }
            ret.add(k);
        }

        return ret;
    }

    public static  Set transformToSet(Collection from, ListFunction func) {
        Set ret = new HashSet();
        for (V v : from) {
            List k = func.call(v);
            if (k == null) {
                continue;
            }
            ret.addAll(k);
        }

        return ret;
    }

    public static  K find(Collection from, Function func) {
        for (V v : from) {
            K k = func.call(v);
            if (k != null) {
                return k;
            }
        }

        return null;
    }

    public static  void forEach(Collection cols, ForEachFunction func) {
        for (K c : cols) {
            func.run(c);
        }
    }

    public static  void safeForEach(Collection cols, ForEachFunction func) {
        for (K c : cols) {
            try {
                func.run(c);
            } catch (Throwable t) {
                logger.warn(String.format("unhandled exception happened"), t);
            }
        }
    }

    public static  List removeDuplicateFromList(List lst) {
        return new ArrayList(new LinkedHashSet(lst));
    }
}

public static List transformToList(Collection from, Function func) 为例,从语义上来说就是为了from中的每个元素调用func函数。没错,就像函数式编程中的map

        List msgs = CollectionUtils.transformToList(hostUuids, new Function() {
            @Override
            public KVMHostAsyncHttpCallMsg call(String huuid) {
                ScanCmd cmd = new ScanCmd();
                cmd.ip = getIpForScan(struct);
                cmd.startPort = 1;
                cmd.endPort = 65535;
                cmd.interval = struct.getInterval();
                cmd.times = struct.getMaxTimes();
                cmd.successInterval = struct.getSuccessInterval();
                cmd.successTimes = struct.getSuccessTimes();

                KVMHostAsyncHttpCallMsg msg = new KVMHostAsyncHttpCallMsg();
                msg.setHostUuid(huuid);
                msg.setPath(SCAN_HOST_PATH);
                msg.setCommandTimeout(timeoutManager.getTimeout(cmd.getClass(), TimeUnit.SECONDS.toMillis(cmd.interval *cmd.times) + TimeUnit.MINUTES.toMillis(1)));
                msg.setCommand(cmd);
                bus.makeTargetServiceIdByResourceUuid(msg, HostConstant.SERVICE_ID, huuid);

                return msg;
            }
        });

从这边的代码可以看到,通过遍历hostUuids并做了一些操作,成功的组成了一组msg。

Completion

在异步系统中,Completion是很常见的——当一个异步行为完成时,则会调用其相应的CompletionHandle。

        bus.send(amsg, new CloudBusCallBack(completion) {
            @Override
            public void run(MessageReply re) {
                if (!re.isSuccess()) {
                    completion.fail(re.getError());
                } else {
                    completion.success(re);
                }
            }
        });

CloudBus的send调用为例,当一个msg发送并得到回复后,便会执行传进来CallBack的run。这样的代码灵活性非常高——简单来说,传入send这个函数的第二个参数是一个策略,而不是一个单纯的参数。

CloudBus的源码分析点击这里,有兴趣的读者可以看一下其实现
小结

在本篇文章中,笔者和大家一起了解了Strategy在ZStack中的使用场景。通常在编程时,算法(策略)会被写在具体方法中,这样会导致具体方法中充斥着条件判断语句。但是Strategy却特意将算法与其他部分剥离开来,仅仅定义了接口,然后再以委托的方式来使用算法。然而这种做法正是让程序更加的松耦合(因为使用委托可以方便的整体替换算法),使得整个项目更加茁壮。

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/68631.html

相关文章

  • ZStack源码剖析设计模式鉴赏——三驾马车

    摘要:但新增模块的结构却还是大致相同,此即是的经典设计模式这套模式也被开发者称为三驾马车。领域层定义负责表达业务概念,业务状态信息以及业务规则。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 前言 随着ZStack的版本迭代,其可以掌管的资源也越来越多。但新增模块的结构却还是大致相同,此即是ZStack的经典设计模式——这套模式也被开发者称为ZS...

    honhon 评论0 收藏0
  • ZStack源码剖析二次开发——可扩展框架

    摘要:但在实际的二次开发中,这些做法未必能够完全满足需求。在源码剖析之核心库鉴赏一文中,我们了解到是的基础设施之一,同时也允许通过显示声明的方式来声明。同理,一些也可以使用继承进行扩展。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 前言 在ZStack博文-5.通用插件系统中,官方提出了几个较为经典的扩展方式。但在实际的二次开发中,这些做法未必...

    lolomaco 评论0 收藏0
  • ZStack源码剖析核心库鉴赏——Defer

    摘要:本文首发于泊浮目的专栏在语言中,有一个关键字叫做其作用是在函数前执行。一般有两种用法在该函数抛出异常时执行。在该函数返回前执行。这里的放入来自系统启动时利用反射所做的一个行为。因此并不会影响使用时的性能。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 在Go语言中,有一个关键字叫做defer——其作用是在函数return前执行。在ZStac...

    DevWiki 评论0 收藏0
  • ZStack源码剖析核心库鉴赏——Defer

    摘要:本文首发于泊浮目的专栏在语言中,有一个关键字叫做其作用是在函数前执行。一般有两种用法在该函数抛出异常时执行。在该函数返回前执行。这里的放入来自系统启动时利用反射所做的一个行为。因此并不会影响使用时的性能。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 在Go语言中,有一个关键字叫做defer——其作用是在函数return前执行。在ZStac...

    ymyang 评论0 收藏0
  • ZStack源码剖析核心库鉴赏——ThreadFacade

    摘要:每个消息都会被一个线程消费,同时最大并发量为。然后提交一个任务到线程池中,这个任务的内容是从等待队列中取出一个,如果等待队列为空,则删除这个等待队列的。小结本文分析了的久经生产考验的核心组件线程池。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 前言 在ZStack中,最基本的执行单位不仅仅是一个函数,也可以是一个任务(Task。其本质实现...

    enali 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<