这篇文章主要介绍“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<String, Plugin> 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<String> sitePlugins = PluginsHelper.sitePlugins(this.environment); //加载站点插件
//强制依赖的插件，如果没有找到
String[] mandatoryPlugins = settings.getAsArray("plugin.mandatory", null);
if (mandatoryPlugins != null) {
Set<String> 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<Plugin, List<OnModuleReference>> onModuleReferences = MapBuilder.newMapBuilder();
for (Plugin plugin : plugins.values()) {
List<OnModuleReference> 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<? extends Module> spawnModules() {
List<Module> modules = Lists.newArrayList();
Collection<Class<? extends Module>> modulesClasses = pluginsService.modules();
for (Class<? extends Module> 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<? extends LifecycleComponent> 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);
}
//REST
public void onModule(RestModule restModule) {
restModule.addRestAction(MyRestAction.class);
}
//高亮
public void onModule(HighlightModule highlightModule) {
highlightModule.registerHighlighter(MyHighlighter.class);
}可替换的模块，一般是实现了SpawnModules接口的模块，比如DiscoveryModule
@Override
public Iterable<? extends Module> spawnModules() {
Class<? extends Module> 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插件如何实现类”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
