摘要：能夠整體地替換算法，能讓我們輕松地以不同的算法去解決一個(gè)問(wèn)題，這種模式就是模式。這個(gè)類(lèi)是在發(fā)布前常在中被使用的一個(gè)類(lèi)，代碼如下以為例，從語(yǔ)義上來(lái)說(shuō)就是為了中的每個(gè)元素調(diào)用函數(shù)。

本文首發(fā)于泊浮目的專(zhuān)欄：https://segmentfault.com/blog...

無(wú)論什么程序，其目的都是解決問(wèn)題。而為了解決問(wèn)題，我們又需要編寫(xiě)特定的算法。使用Strategy模式可以整體地替換算法的實(shí)現(xiàn)部分。能夠整體地替換算法，能讓我們輕松地以不同的算法去解決一個(gè)問(wèn)題，這種模式就是Strategy模式。

在ZStack中，Strategy模式幾乎是充斥在80%以上的代碼中的，接下來(lái)我們就來(lái)一起看看吧。

CollectionUtils 這個(gè)類(lèi)是在JDK8發(fā)布前常在ZStack中被使用的一個(gè)類(lèi)，代碼如下：

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) 為例，從語(yǔ)義上來(lái)說(shuō)就是為了from中的每個(gè)元素調(diào)用func函數(shù)。沒(méi)錯(cuò)，就像函數(shù)式編程中的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;
            }
        });

從這邊的代碼可以看到，通過(guò)遍歷hostUuids并做了一些操作，成功的組成了一組msg。

在異步系統(tǒng)中，Completion是很常見(jiàn)的——當(dāng)一個(gè)異步行為完成時(shí)，則會(huì)調(diào)用其相應(yīng)的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調(diào)用為例，當(dāng)一個(gè)msg發(fā)送并得到回復(fù)后，便會(huì)執(zhí)行傳進(jìn)來(lái)CallBack的run。這樣的代碼靈活性非常高——簡(jiǎn)單來(lái)說(shuō)，傳入send這個(gè)函數(shù)的第二個(gè)參數(shù)是一個(gè)策略，而不是一個(gè)單純的參數(shù)。

CloudBus的源碼分析點(diǎn)擊這里，有興趣的讀者可以看一下其實(shí)現(xiàn)

在本篇文章中，筆者和大家一起了解了Strategy在ZStack中的使用場(chǎng)景。通常在編程時(shí)，算法（策略）會(huì)被寫(xiě)在具體方法中，這樣會(huì)導(dǎo)致具體方法中充斥著條件判斷語(yǔ)句。但是Strategy卻特意將算法與其他部分剝離開(kāi)來(lái)，僅僅定義了接口，然后再以委托的方式來(lái)使用算法。然而這種做法正是讓程序更加的松耦合（因?yàn)槭褂梦锌梢苑奖愕恼w替換算法），使得整個(gè)項(xiàng)目更加茁壯。