elasticsearch插件如何实现类

136次阅读

共计 5703 个字符，预计需要花费 15 分钟才能阅读完成。

这篇文章主要介绍“elasticsearch 插件如何实现类”，在日常操作中，相信很多人在 elasticsearch 插件如何实现类问题上存在疑惑，丸趣 TV 小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”elasticsearch 插件如何实现类”的疑惑有所帮助！接下来，请跟着丸趣 TV 小编一起来学习吧！

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 插件如何实现类”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注丸趣 TV 网站，丸趣 TV 小编会继续努力为大家带来更多实用的文章！

正文完