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的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要介绍了Java List 集合如何去除null元素，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-01-01
这篇文章主要为大家详细介绍了java实现简易的五子棋游戏，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-06-06
这篇文章主要为大家详细介绍了Java如何解决HTTP GET方法调用带有body的问题,文中的示例代码讲解详细,感兴趣的小伙伴可以参考一下2024-02-02
详解Spring Boot配置使用Logback进行日志记录的实战
本篇文章主要介绍了详解Spring Boot配置使用Logback进行日志记录的实战，具有一定的参考价值，有兴趣的朋友可以了解一下2017-07-07
面向对象乃是Java语言的核心，是程序设计的思想，在面向对象程式设计方法中，封装（英语：Encapsulation）是指一种将抽象性函式接口的实现细节部分包装、隐藏起来的方法。封装可以被认为是一个保护屏障，防止该类的代码和数据被外部类定义的代码随机访问2021-10-10
在本篇文章里小编给大家整理了一篇关于java封装实例用法及相关知识点，有兴趣的朋友们可以参考下。2021-01-01
SpringBoot3结合gRpc实现远程服务调用的流程步骤
gRPC是一个现代开源高性能远程过程调用(RPC)框架,可以在任何环境中运行,它由Google开发,旨在帮助开发人员更轻松地构建分布式应用,特别是当代码可能在不同地方运行的时候,本文介绍了SpringBoot3结合gRpc实现远程服务调用的流程步骤,需要的朋友可以参考下2024-07-07
这篇文章主要介绍了通过代码示例了解submit与execute的区别,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-09-09
这篇文章主要介绍了java 中JDBC连接数据库代码和步骤详解及实例代码的相关资料,需要的朋友可以参考下2017-02-02
SpringBoot中将@Bean方法解析为BeanDefinition详解
这篇文章主要介绍了SpringBoot中将@Bean方法解析为BeanDefinition详解,得到的BeanDefinition是ConfigurationClassBeanDefinition类型,会为BeanDefinition设置factoryMethodName,这意味着当实例化这个bean的时候将采用工厂方法,需要的朋友可以参考下2023-12-12
最新评论