摘要:能够整体地替换算法,能让我们轻松地以不同的算法去解决一个问题,这种模式就是模式。这个类是在发布前常在中被使用的一个类,代码如下以为例,从语义上来说就是为了中的每个元素调用函数。
本文首发于泊浮目的专栏:https://segmentfault.com/blog...前言
无论什么程序,其目的都是解决问题。而为了解决问题,我们又需要编写特定的算法。使用Strategy模式可以整体地替换算法的实现部分。能够整体地替换算法,能让我们轻松地以不同的算法去解决一个问题,这种模式就是Strategy模式。
在ZStack中,Strategy模式几乎是充斥在80%以上的代码中的,接下来我们就来一起看看吧。
CollectionUtilsCollectionUtils 这个类是在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 staticList 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
Listmsgs = 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
摘要:但新增模块的结构却还是大致相同,此即是的经典设计模式这套模式也被开发者称为三驾马车。领域层定义负责表达业务概念,业务状态信息以及业务规则。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 前言 随着ZStack的版本迭代,其可以掌管的资源也越来越多。但新增模块的结构却还是大致相同,此即是ZStack的经典设计模式——这套模式也被开发者称为ZS...
摘要:但在实际的二次开发中,这些做法未必能够完全满足需求。在源码剖析之核心库鉴赏一文中,我们了解到是的基础设施之一,同时也允许通过显示声明的方式来声明。同理,一些也可以使用继承进行扩展。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 前言 在ZStack博文-5.通用插件系统中,官方提出了几个较为经典的扩展方式。但在实际的二次开发中,这些做法未必...
摘要:本文首发于泊浮目的专栏在语言中,有一个关键字叫做其作用是在函数前执行。一般有两种用法在该函数抛出异常时执行。在该函数返回前执行。这里的放入来自系统启动时利用反射所做的一个行为。因此并不会影响使用时的性能。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 在Go语言中,有一个关键字叫做defer——其作用是在函数return前执行。在ZStac...
摘要:本文首发于泊浮目的专栏在语言中,有一个关键字叫做其作用是在函数前执行。一般有两种用法在该函数抛出异常时执行。在该函数返回前执行。这里的放入来自系统启动时利用反射所做的一个行为。因此并不会影响使用时的性能。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 在Go语言中,有一个关键字叫做defer——其作用是在函数return前执行。在ZStac...
摘要:每个消息都会被一个线程消费,同时最大并发量为。然后提交一个任务到线程池中,这个任务的内容是从等待队列中取出一个,如果等待队列为空,则删除这个等待队列的。小结本文分析了的久经生产考验的核心组件线程池。 本文首发于泊浮目的专栏:https://segmentfault.com/blog... 前言 在ZStack中,最基本的执行单位不仅仅是一个函数,也可以是一个任务(Task。其本质实现...
阅读 1692·2023-04-25 22:42
阅读 2181·2021-09-22 15:16
阅读 3473·2021-08-30 09:44
阅读 470·2019-08-29 16:44
阅读 3291·2019-08-29 16:20
阅读 2495·2019-08-29 16:12
阅读 3371·2019-08-29 16:07
阅读 649·2019-08-29 15:08