elasticsearch插件如何实现类
这篇文章主要介绍"elasticsearch插件如何实现类"，在日常操作中，相信很多人在elasticsearch插件如何实现类问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"elasticsearch插件如何实现类"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
elasticsearch 的 基础类，主要分成 Component （组件） 和 Module （模块）。
组件
CloseableComponent 可关闭组件
AbstractComponent 可配置组件
LifecycleComponent 活动可关闭组件
AbstractLifecycleComponent 可配置的活动可关闭组件 （。。。有点长）
模块
Module 模块
PreProcessModule 预处理模块
SpawnModules 新模块
一. AbstractPlugin 类 ，一个插件类要继承自它或者实现Plugin接口
插件类需要实现的Plugin接口，每个方法所对应的组件类型是
modules() Module
services() LifecycleComponent
indexModules() Module
indexServices() CloseableIndexComponent
shardModules() Module
shardServices() CloseableIndexComponent
二. 现在插件实现类，有了，那他是怎么被加载到整个系统里面的呢？那就要请出我们插件组的各个成员了。
PluginManager类，插件管理类，负责插件的安装，卸载，下载等工作。
PluginsHelper类，插件帮助类，负责列出环境下面所有的site插件。
PluginsService类，插件服务类，负责插件的加载，实例化和维护插件信息。
整个节点启动的时候，InternalNode的构造方法里加载配置文件以后，首先会实例化 PluginsService 类，还有PluginsModule模块 。
this.pluginsService = new PluginsService(tuple.v1(), tuple.v2());this.settings = pluginsService.updatedSettings();this.environment = tuple.v2();CompressorFactory.configure(settings);NodeEnvironment nodeEnvironment = new NodeEnvironment(this.settings, this.environment);ModulesBuilder modules = new ModulesBuilder();modules.add(new PluginsModule(settings, pluginsService));modules.add(new SettingsModule(settings));modules.add(new NodeModule(this));
PluginsService类的构造方法里，会开始加载插件类，从配置文件和Classpath里面，并且处理 plugin.mandatory 配置的强依赖插件，和模块引用
public PluginsService(Settings settings, Environment environment) { super(settings); this.environment = environment; Map plugins = Maps.newHashMap(); //首先，我们从配置文件加载，默认的插件类 String[] defaultPluginsClasses = settings.getAsArray("plugin.types"); for (String pluginClass : defaultPluginsClasses) { Plugin plugin = loadPlugin(pluginClass, settings); plugins.put(plugin.name(), plugin); } // 现在, 我们查找,所有的在ClassPath下面的插件 loadPluginsIntoClassLoader(); plugins.putAll(loadPluginsFromClasspath(settings)); //加载JVM插件 Set sitePlugins = PluginsHelper.sitePlugins(this.environment); //加载站点插件 //强制依赖的插件，如果没有找到 String[] mandatoryPlugins = settings.getAsArray("plugin.mandatory", null); if (mandatoryPlugins != null) { Set missingPlugins = Sets.newHashSet(); for (String mandatoryPlugin : mandatoryPlugins) { if (!plugins.containsKey(mandatoryPlugin) && !sitePlugins.contains(mandatoryPlugin) && !missingPlugins.contains(mandatoryPlugin)) { missingPlugins.add(mandatoryPlugin); } } if (!missingPlugins.isEmpty()) { //抛出异常，整个节点启动失败！ throw new ElasticSearchException("Missing mandatory plugins [" + Strings.collectionToDelimitedString(missingPlugins, ", ") + "]"); } } logger.info("loaded {}, sites {}", plugins.keySet(), sitePlugins); this.plugins = ImmutableMap.copyOf(plugins); //现在，所有插件都加载好了,处理插件实现类的 onModule 方法的引用 ,这里有 依赖注入的秘密。 MapBuilder> onModuleReferences = MapBuilder.newMapBuilder(); for (Plugin plugin : plugins.values()) { List list = Lists.newArrayList(); //.... } this.onModuleReferences = onModuleReferences.immutableMap(); this.refreshInterval = componentSettings.getAsTime("info_refresh_interval", TimeValue.timeValueSeconds(10)); } PluginsService.info() 方法，是插件信息类，NodeService 会调用 ，是节点信息类的一部分，就是REST接口 /nodes 返回的内容
//PluginInfo类的字段static final class Fields { static final XContentBuilderString NAME = new XContentBuilderString("name"); static final XContentBuilderString DESCRIPTION = new XContentBuilderString("description"); static final XContentBuilderString URL = new XContentBuilderString("url"); static final XContentBuilderString JVM = new XContentBuilderString("jvm"); static final XContentBuilderString SITE = new XContentBuilderString("site");}InternalNode 会继续调用 modules.createInjector() 方法去实例化所有的模块。PluginsModule模块会去实例化和调用我们的插件
// 创建Plugin 类覆盖 modules 方法的模块 @Override public Iterable spawnModules() { List modules = Lists.newArrayList(); Collection> modulesClasses = pluginsService.modules(); for (Class moduleClass : modulesClasses) { modules.add(createModule(moduleClass, settings)); } modules.addAll(pluginsService.modules(settings)); return modules; } // 处理Plugin类实现了 onModule 方法的类 @Override public void processModule(Module module) { pluginsService.processModule(module); } InternalNode 的 start()方法，就是节点启动的时候，会启动Plugin类覆盖了services方法的服务
for (Class plugin : pluginsService.services()) { injector.getInstance(plugin).start(); }InternalIndicesService.createIndex() 方法，也就是创建索引的时候，会创建 Plugin类 覆盖了 indexModules() 的模块
InternalIndexService.createShard() 方法，创建分片的时候，会去创建Plugin类 覆盖了 shardModules() 的模块
同理删除索引和分片的时候，会销毁模块和关闭服务。也就是插件扩展的服务和模块是有3个生命周期的。
Global 节点级别
Index 索引级别
Shard 分片级别
三. 插件类有了，插件也被加载进系统了，那它是怎么扩展现有模块服务的，那些模块可以扩展，那些不可以？
可扩展的模块，一般都提供了 addXXX，registerXXX 等方法
//智能提示public void onModule(SuggestModule suggestModule) { suggestModule.registerSuggester(MySuggester.class);}//RESTpublic void onModule(RestModule restModule) { restModule.addRestAction(MyRestAction.class);}//高亮public void onModule(HighlightModule highlightModule) { highlightModule.registerHighlighter(MyHighlighter.class);}可替换的模块，一般是实现了SpawnModules接口的模块，比如DiscoveryModule
@Override public Iterable spawnModules() { Class defaultDiscoveryModule; if (settings.getAsBoolean("node.local", false)) { defaultDiscoveryModule = LocalDiscoveryModule.class; } else { defaultDiscoveryModule = ZenDiscoveryModule.class; } return ImmutableList.of(Modules.createModule(settings.getAsClass("discovery.type", defaultDiscoveryModule, "org.elasticsearch.discovery.", "DiscoveryModule"), settings));}根据配置项discovery.type来确定加载那个模块
不可以扩展或替换的组件，比如 Internal 开头的组件，InternalClusterService，InternalIndicesService 等是不可以替换的。
到此，关于"elasticsearch插件如何实现类"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！
