- Elasticsearch实战与原理解析
- 牛冬
- 1136字
- 2020-08-27 17:43:11
4.2 提交请求
在创建好客户端之后,执行请求之前还需构建请求对象。用户可以通过调用客户端的performRequest和performRequestAsync方法来发送请求。
其中,performRequest是同步请求方法,它将阻塞调用线程,并在请求成功时返回响应,或者在请求失败时引发异常。
而performRequestAsync是异步方法,它接收一个ResponseListener对象作为参数。如果请求成功,则该参数使用响应进行调用;如果请求失败,则使用异常进行调用。
1.构建请求对象Request
请求对象Request的请求方式与The HTTP的请求方式相同,如GET、POST、HEAD等,代码如下所示:
2.请求的执行
在构建请求(Request)后,即可执行请求。请求有同步执行和异步执行两种方式。下面将分别展示如何使用performRequest方法和performRequestAsync方法发送请求。
同步方式
当以同步方式执行Request时,客户端会等待Elasticsearch服务器返回的查询结果Response。在收到Response后,客户端继续执行相关的逻辑代码。以同步方式执行的代码如下所示,我们仍然构建三层代码,分别是Controller层、Service层和ServiceImpl实现层。
其中,在Controller层的MeetElasticSearchController类中添加如下代码:
随后,在Service层的MeetElasticSearchService类中添加如下代码:
在ServiceImpl实现层的MeetElasticSearchServiceImpl类中添加如下代码:
随后编译工程,在工程根目录下输入如下命令:
通过如下命令启动工程服务:
在工程服务启动后,在浏览器中通过调用如下接口查看Elasticsearch客户端的连接情况:
在浏览器中可以看到请求发送成功,显示的Response信息如下所示。
异步方式
当以异步方式执行请求时,初级客户端不必同步等待请求结果的返回,可以直接向接口调用方返回异步接口执行成功的结果。
为了处理异步返回的响应信息或处理在请求执行过程中引发的异常信息,用户需要指定监听器。以异步方式调用的代码如下所示。我们在ServiceImpl实现层的MeetElasticSearchServiceImpl类中添加如下代码:
在异步请求处理后,如果请求执行成功,则调用ResponseListener类中的onResponse方法进行相关逻辑的处理;如果请求执行失败,则调用ResponseListener类中的onFailure方法进行相关逻辑的处理。
3.可选参数配置
不论同步请求,还是异步请求,我们都可以在请求中添加参数,添加方法如下所示:
可以将请求的主体设置为任意HttpEntity,设置方法如下所示:
还可以将其设置为一个字符串,在Elasticsearch中,默认使用application/json的内容格式,设置方法如下所示:
此外,Request还有一些可选的请求构建选项,通过RequestOptions来实现。
需要说明的是,在RequestOptions类中保存的请求,可以在同一应用程序的多个请求之间共享。因此用户可以创建一个单实例,然后在所有请求之间共享。具体方法如下所示:
上述代码中的TOKEN表示添加所有请求所需的任何头。
而AddHeader用于授权或在Elasticsearch前使用代理所需的头信息。在使用时,不需要设置Content-Type头,因为客户端将自动在请求的HttpEntity中设置Content-Type头。
在创建好RequestOptions单实例COMMON_OPTIONS后,我们就可以在发出请求时使用它了,使用方法如下所示:
Elasticsearch允许用户根据每个请求定制这些选项,如添加一个额外的标题:
RequestOptions在ServiceImpl实现层的MeetElasticSearchServiceImpl类中的代码如下所示:
4.多个并行异步操作
除单个操作的执行外,Elasticsearch的客户端还可以并行执行许多操作。下面通过ServiceImpl实现层MeetElasticSearchServiceImpl类中的示例,展示如何对多文档进行并行索引。代码如下: