资讯专栏INFORMATION COLUMN

Floodlight 源码解读 :Main

verano / 1753人阅读

摘要:每个具体的模块都会重写这几个函数,下面举个的例子。获得的服务返回服务实现类和实现用的对象的。服务是指继承了接口的类。模块使用方法可以获得对应的服务列表,可以到源码去看对应的服务功能。

Floodlight 的 Main 解析图

需要理解的概念 模块(Module)

Module 是指继承了 IFloodlightModule 接口的类

IFloodlightModule的相关注释

 
 Defines an interface for loadable Floodlight modules.
 At a high level, these functions are called in the following order:
 
  getModuleServices() : 获得模块实现的服务列表
  getServiceImpls(); 实例化并返回:服务实现类-实现此服务的对象 映射
  getModuleDependencies() : 获得模块依赖的列表
  init() : internal initializations (don"t touch other modules)
  startUp() : external initializations (do touch other modules)

所有可加载的模块都有这几种方法,在接下来的加载模块时需要使用到。
每个具体的模块都会重写这几个函数,下面举个 FloodlightProvider 的例子。

getModuleServices()
@Override
public Collection> getModuleServices() {
    Collection> services =
            new ArrayList>(1);
    services.add(IFloodlightProviderService.class);
    return services;
}

获得 FloodlightProvider 的服务 IFloodlightProviderService

getServiceImple()
@Override
public Map,
           IFloodlightService> getServiceImpls() {
    controller = new Controller();

    Map,
        IFloodlightService> m =
            new HashMap,
                        IFloodlightService>();
    m.put(IFloodlightProviderService.class, controller);
    return m;
}

返回服务实现类和实现用的对象的Map。

getModuleDependencies()
@Override
public Collection> getModuleDependencies() {
    Collection> dependencies =
        new ArrayList>(4);
    dependencies.add(IStorageSourceService.class);
    dependencies.add(IPktInProcessingTimeService.class);
    dependencies.add(IRestApiService.class);
    dependencies.add(IDebugCounterService.class);
    dependencies.add(IOFSwitchService.class);
    dependencies.add(IThreadPoolService.class);
    dependencies.add(ISyncService.class);
    return dependencies;
}

返回依赖的列表

其他

init(),startup(),到对应的模块去看就可以了。
有的模块是没有服务依赖的,比如 ThreadPool模块。

服务(Service)

Service 是指继承了 IFloodlightService 接口的类。

public abstract interface IFloodlightService {
   // This space is intentionally left blank....don"t touch it
}

模块使用getModuleServices()方法可以获得对应的服务列表,可以到源码去看对应的服务功能。

Main函数

解析命令行参数

加载模块

启动 REST 服务器

启动 Controller

命令行参数解析

CmdLineSetting 定义了命令行参数的格式

public static final String DEFAULT_CONFIG_FILE = "src/main/resources/floodlightdefault.properties";

@Option(name="-cf", aliases="--configFile", metaVar="FILE", usage="Floodlight configuration file")
private String configFile = DEFAULT_CONFIG_FILE;

如果没有使用-cf指定配置文件路径,则使用默认路径“src/main/resources/floodlightdefault.properties”

CmdLineParser 解析命令参数

CmdLineParser parser = new CmdLineParser(settings)
parser.parserArgument(args)
加载模块

moduleContext=fml.loadModulesFromConfig(settings.getModuleFile())
settings.getModuleFile()提供配置文件的路径

mergeProperties()

目的是获得配置文件里的模块的集合configMods和prop是除去配置文件里的模块键值对后剩余的配置信息(模块的配置参数)

loadModulesFromList(configsMods,prop)
findAllModule(configMods)

填充moduleNameMap,moduleServiceMap,ServiceMap

这个方法比较重要的是这个 ServiceLoader,返回服务加载器

ServiceLoader moduleLoader =
            ServiceLoader.load(IFloodlightModule.class, cl);

ServiceLoader 为了注册服务,需要在类路径 src/main/resources/META_INF/services文件夹内列好注册服务的模块,可以得到继承了 IFloodlightModule 接口的实现类
使用moduleLoader.iterator()迭代器去填充moduleNameMap,moduleServiceMap,ServiceMap
moduleNameMap 模块名称-模块对象 Map
moduleServiceMAP 模块名称-模块服务 Map
ServiceMap 模块服务-模块名称 Map

traverseDeps(moduleName,modsToLoad,moduleList,moduleMap,modsVisited)
addModule()

添加模块到模块的哈希集moduleMap,同时注册它们的服务(即得到已加载模块序列 moduleList)

parseConfigParameters(prop)

解析每个模块的配置参数

取配置文件的一条参数配置net.floodlightcontroller.forwarding.Forwarding.match=in-port, vlan, mac, ip, transport举例

key:net.floodlightcontroller.forwarding.Forwarding.match

String configKey=key.substring(LastPeriod+1)

获到的就是 match,即 configKey=match

String systemKey = System.getProperty(key);
if (systemKey != null) {
            configValue = systemKey;
        } else {
            configValue = prop.getProperty(key);
        }

如果系统属性已经存在,则使用系统属性的值,如果不存在,则configValue = prop.getProperty(key);【即 configValue 在此处为in-port, vlan, mac, ip, transport】

floodlightModuleContext.addConfigParam(mod,configKey,configValue)

添加模块的配置参数

FloodlightModuleLoader 类下的方法

public void addConfigParam(IFloodlightModule mod, String key, String value) {
    Map moduleParams = configParams.get(mod.getClass());
    if (moduleParams == null) {
        moduleParams = new HashMap();
        configParams.put(mod.getClass(), moduleParams);
    }
    moduleParams.put(key, value);
}
initModules(moduleList)

初始化已加载模块列表下的模块

获得模块的服务实例

Map,
            IFloodlightService> simpls = module.getServiceImpls();

添加服务到 floodlightModuleContext

if (floodlightModuleContext.getServiceImpl(s.getKey()) == null) {
                    floodlightModuleContext.addService(s.getKey(),
                                                       s.getValue());

遍历已加载模块集,开始初始化模块,调用模块的方法:init

for (IFloodlightModule module : moduleSet) {
        // init the module
        if (logger.isDebugEnabled()) {
            logger.debug("Initializing " +
                         module.getClass().getCanonicalName());
        }
        module.init(floodlightModuleContext);
    }
startupModules(moduleList)

调用已加载模块的启动方法

遍历已加载模块集,调用每个模块的启动方法

for (IFloodlightModule m : moduleSet) {
        if (logger.isDebugEnabled()) {
            logger.debug("Starting " + m.getClass().getCanonicalName());
        }
        m.startUp(floodlightModuleContext);
    }
return floodlightModuleContext

返回公共环境变量

fml.runModules()

运动控制器模块和所有模块

getModuleList()

获得一个按初始化顺序的模块列表

返回一个不可修改的已加载模块序列,如果没被初始化则返回 null

public List getModuleList() {
    if (loadedModuleList == null)
        return Collections.emptyList();
    else
        return Collections.unmodifiableList(loadedModuleList);
}

runModules()

for (IFloodlightModule m : getModuleList()) {
        for (Method method : m.getClass().getDeclaredMethods()) {
            Run runAnnotation = method.getAnnotation(Run.class);
            if (runAnnotation != null) {
                RunMethod runMethod = new RunMethod(m, method);
                if(runAnnotation.mainLoop()) {
                    mainLoopMethods.add(runMethod);
                } else {
                    runMethod.run();
                }
            }
        }
    }

for 循环遍历模块中的方法,找到@run注解的方法为主方法,以下的就是 FloodlightProvider 提供的 run 方法

@Run(mainLoop=true)
public void run() throws FloodlightModuleException {
    controller.run();
}

运行控制器的模块

 mainLoopMethods.get(0).run();

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

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

相关文章

  • Floodlight 源码解读FloodlightProvider

    摘要:每个消息将通过一个的线程进行处理,并执行与所有模块的消息相关联的所有逻辑其他模块也可以注册类似交换机连接或断开和端口状态通知特定时间。默认情况下,使用地址和来识别设备。设备管理器将了解其他属性,如地址。在消息转发实现前,模块将启动。 FloodlightProvider 处理交换机之间的连接并将 OpenFlow 的消息转化成其他模块可以监听的时间 决定某些特定的 OpenFLow ...

    dadong 评论0 收藏0
  • React 源码深度解读(四):首次自定义组件渲染 - Part 1

    摘要:本篇开始介绍自定义组件是如何渲染的。组件将自定义组件命名为,结构如下经过编译后,生成如下代码构建顶层包装组件跟普通元素渲染一样,第一步先会执行创建为的。调用顺序已在代码中注释。先看图,这部分内容将在下回分解 前言 React 是一个十分庞大的库,由于要同时考虑 ReactDom 和 ReactNative ,还有服务器渲染等,导致其代码抽象化程度很高,嵌套层级非常深,阅读其源码是一个非...

    Warren 评论0 收藏0
  • 跟着大彬读源码 - Redis 1 - 启动服务,程序都干了什么?

    摘要:此时服务器处于休眠状态,并使用进行事件轮询,等待监听事件的发生。继续执行被调试程序,直至下一个断点或程序结束缩写。服务启动包括初始化基础配置数据结构对外提供服务的准备工作还原数据库执行事件循环等。 一直很羡慕那些能读 Redis 源码的童鞋,也一直想自己解读一遍,但迫于 C 大魔王的压力,解读日期遥遥无期。 相信很多小伙伴应该也都对或曾对源码感兴趣,但一来觉得自己不会 C 语言,二来也...

    sewerganger 评论0 收藏0
  • k8s与日志--journalbeat源码解读

    摘要:但是也存在诸多的问题,随着新设备的出现以及对安全的重视,这些缺点越发显得突出,例如日志消息内容无法验证数据格式松散日志检索低效有限的元数据保存无法记录二进制数据等。该服务可以为项目增加一定数量的元数据。 前言 对于日志系统的重要性不言而喻,参照沪江的一篇关于日志系统的介绍,基本上日志数据在以下几方面具有非常重要的作用: 数据查找:通过检索日志信息,定位相应的 bug ,找出解决方案 ...

    Amio 评论0 收藏0

发表评论

0条评论

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