openfire源码研究笔记:对设计模式及原则的学习

WindySky 2018-08-21

展开全文

原文：http://blog.csdn.net/jinzhencs/article/details/50522105

一.拦截器的实现

地点: package org.jivesoftware.openfire.interceptor-public class InterceptorManager

作用: 在每个packet处理之前先使用拦截器Manager里面的interceptors处理

解释: 这个拦截器Manager是一个List,里面包含多个拦截器的实例,如果需要多加拦截器则只需往里面add就行了.符合开闭原则,非常轻松的就能扩展功能.

结果: 所以openfire支持自定义插件,它的每个插件就是一个拦截器.

启示: 一个良好的架构必定是能够轻松扩展的,使用这种拦截器的方式能够让我们的系统轻松扩展功能.

我觉得这个就是aop的实现,并且这种以Manager管理多个拦截器的形式无疑是更好的

系统可以在两个地方拦截:

1.进入的时候(编码,身份验证,加密解密等)

2.真正逻辑代码处理的时候(打印日志,事务增强,读取缓存等)

图示:InterceptorManager

图示:逻辑代码处理之前调用拦截器处理：

———————————————————罪恶的分割线————————————————————

二.CacheFactoryStrategy,缓存工厂策略模式

策略模式：

作用: 没有设置集群的情况下就用DefaultLocalCacheStategy来创建cache,当设置了集群则自动使用ClusteredCacheFactory来创建

实现：

-声明:

    private static CacheFactoryStrategy cacheFactoryStrategy = new DefaultLocalCacheStrategy();
    private static CacheFactoryStrategy localCacheFactoryStrategy;
    private static CacheFactoryStrategy clusteredCacheFactoryStrategy;

@SuppressWarnings("unchecked")
public static synchronized <T extends Cache> T createCache(String name) {
T cache = (T) caches.get(name);
if (cache != null) {
return cache;
}
cache = (T) cacheFactoryStrategy.createCache(name);

log.info("Created cache [" + cacheFactoryStrategy.getClass().getName() + "] for " + name);

return wrapCache(cache, name);
}

 public static void stopClustering() {
        // Stop the cluster
        clusteredCacheFactoryStrategy.stopCluster();
        clusteredCacheFactoryStrategy = null;
        // Set the strategy to local
        cacheFactoryStrategy = localCacheFactoryStrategy;
    }

    /**
     * Notification message indicating that this JVM has joined a cluster.
     */
    @SuppressWarnings("unchecked")
    public static synchronized void joinedCluster() {
        cacheFactoryStrategy = clusteredCacheFactoryStrategy;
        // Loop through local caches and switch them to clustered cache (purge content)
        for (Cache cache : getAllCaches()) {
            // skip local-only caches
            if (localOnly.contains(cache.getName())) continue;
            CacheWrapper cacheWrapper = ((CacheWrapper) cache);
            Cache clusteredCache = cacheFactoryStrategy.createCache(cacheWrapper.getName());
            cacheWrapper.setWrappedCache(clusteredCache);
        }
        clusteringStarting = false;
        clusteringStarted = true;
        log.info("Clustering started; cache migration complete");
    }