elasticsearch构造Client实现java客户端调用接口示例分析
elasticsearch通过构造一个client对外提供了一套丰富的java调用接口。总体来说client分为两类cluster信息方面的client及数据（index）方面的client。这两个大类由可以分为通用操作和admin操作两类。
client的继承关系
（1.5版本，其它版本可能不一样）：
通过这个继承关系图可以很清楚的了解client的实现，及功能。总共有三类即client， indicesAdminClient和ClusterAdminClient。它都有自己的实现类，但最后都是通过client接口对外提供服务。client作为对外的总接口，首先通过admin()方法组合了admin的相关操作，它本身也提供了所有对数据和cluster的通用操作。
方法实现上
所有的接口都通过两种方式实现了异步调用，一个是返回一个ActionFuture，另外一种方式是接受一个ActionListener。
以index方法为例
如下所示
ActionFuture<IndexResponse> index(IndexRequest request) ;
void index(IndexRequest request, ActionListener<IndexResponse> listener);
第一个方法会返回一个future，第二个方法则需要传递一个Listener。这也是异步实现的两个基本方式。client使用了门面模式，所有的实现都在AbstractClient类中，还以index方法为例，代码如下所示：
@Override
public ActionFuture<IndexResponse> index(final IndexRequest request) {
return execute(IndexAction.INSTANCE, request);
}
@Override
public void index(final IndexRequest request, final ActionListener<IndexResponse> listener) {
execute(IndexAction.INSTANCE, request, listener);
}实现如上所示，之所以说它是门面模式是因为所有的方法都被集成到了client中，但是执行过程都是在对应的action中执行。在execute方法中，获取到相应的action实例，真正的逻辑是在对应的transportaction中实现。
execute方法代码
如下所示：
@SuppressWarnings("unchecked")
@Override
public <Request extends ActionRequest, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder, Client>> ActionFuture<Response> execute(Action<Request, Response, RequestBuilder, Client> action, Request request) {
headers.applyTo(request);
TransportAction<Request, Response> transportAction = actions.get((ClientAction)action);
return transportAction.execute(request);
}
@SuppressWarnings("unchecked")
@Override
public <Request extends ActionRequest, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder, Client>> void execute(Action<Request, Response, RequestBuilder, Client> action, Request request, ActionListener<Response> listener) {
headers.applyTo(request);
TransportAction<Request, Response> transportAction = actions.get((ClientAction)action);
transportAction.execute(request, listener);
}每一种操作都对应有相应的transportAction，这些transportAction才是最终的执行者。这里先以index为例简单说明，在后面索引功能分析中会看到更多这种的结果。
public class IndexAction extends ClientAction<IndexRequest, IndexResponse, IndexRequestBuilder> {
public static final IndexAction INSTANCE = new IndexAction();
public static final String NAME = "indices:data/write/index";
private IndexAction() {
super(NAME);
}
@Override
public IndexResponse newResponse() {
return new IndexResponse();
}
@Override
public IndexRequestBuilder newRequestBuilder(Client client) {
return new IndexRequestBuilder(client);
}
}在IndexAction中只是简单的定义了一个NAME，及几个简单的方法。这个名字会在启动时作为对于的transportHandler的key注册到TransportService中。在execute方法中，会根据action的将transportAction取出如上一段代码所示。真正的执行逻辑在InternalTransportClient中，这里先略过它的实现，后面会有详细分析。所有这些action的注册都是在actionModule中实现，注册过程会在后面跟action一起分析。
总结：
client模块通过代理模式，将所有的操作都集成到client接口中。这样外部调用只需要初始化client就能够完成所有的调用功能。这些接口的执行逻辑均在对应的transportAction中。这种精巧的设计给使用者带来很大的便利 。
以上就是elasticsearch构造Client实现java客户端调用接口示例分析的详细内容，更多关于elasticsearch构造java客户端调用接口Client的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要介绍了浅谈mybatis中SQL语句给boolean类型赋值问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-11-11
这篇文章主要为大家详细介绍了java树形菜单对象生成，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-05-05
本文通过四种方法给大家介绍java命令执行jar包的方式，每种方法通过实例代码给大家详解，需要的朋友参考下吧2019-11-11
这篇文章主要介绍了java 关键字static详细介绍及如何使用的相关资料,需要的朋友可以参考下2017-03-03
详解Intellij IDEA的Facets和Artifacts
这篇文章主要介绍了Intellij IDEA的Facets和Artifacts的相关知识，本文通过实例给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友参考下吧2020-09-09
这篇文章主要介绍了浅谈Spring Security LDAP简介，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-05-05
这篇文章主要介绍了java 如何给对象中的包装类设置默认值，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-03-03
本篇文章主要介绍了spring boot 日志配置 ，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-03-03
本篇文章主要介绍了SpringMVC——如何获取请求参数详解，详细的介绍了每种参数注解的用法。具有一定的参考价值，感兴趣的小伙伴们可以参考一下。2016-12-12
Java入门绊脚石之Override和Overload的区别详解
重写是子类对父类的允许访问的方法的实现过程进行重新编写, 返回值和形参都不能改变。即外壳不变，核心重写！重写的好处在于子类可以根据需要，定义特定于自己的行为。重载是在一个类里面，方法名字相同，而参数不同。返回类型可以相同也可以不同2021-10-10
最新评论