Flume源代码解读五

? ? ??[ xcly原创于iteye,见http://xcly.iteye.com?]

?

本节介绍Flume存储配置项的工作方式，Flume支持zookeeper和memory两种方式。

?

? ? ?FlumeMaster启动时，创建ConfigStore。 如果为zookeeper方式，还初始化ZooKeeperService。对ConfigStore的使用通过ConfigurationManager来使用。

?

? ? ?Flume配置数据的存储定义了ConfigStore这个抽象类，memory的存储实现为MemoryBackedConfigStore，实现比较简单，Map<String, FlumeConfigData> cfgs直接存在内存map结构中。?

?

? ??ZooKeeperConfigStore和ZKClient负责和zookeeper服务器通信，编码配置，解码配置。?

?

?

?

?

?

?