微风·六：RequestOptions：请求方式（同步/异步）探究，及异步方式问题抛出

1 RequestOptions：请求方式（同步/异步）

1.1 问题产生

在使用ES高级客户端向ES服务器发送请求，使用同步请求方式创建索引库时，有段代码RequestOptions.DEFAULT，经查阅特指同步调用方式，当然会有异步调用。

1.2 问题分析

1.2.1 同步方式

同步方式：

restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
1

1.2.1 异步方式

异步方式：

estHighLevelClient.indexAsync(indexRequest, RequestOptions.DEFAULT, actionListener);
1

1.3 问题解决

1.3.1 异步方式代码

    /**
     * 向es服务器发送请求，创建索引,请求方式：异步
     */
    @Test
    public void testCreateIndex2(){
        //目标：向es服务器发送请求，创建索引,请求方式：异步
        //1.创建request对象
        IndexRequest indexRequest = new IndexRequest("hetol");
        indexRequest.source(Constants.MAPPING,XContentType.JSON);
        //3.通过ES高级客户端向ES服务器通信
        ActionListener<IndexResponse> listener = new ActionListener<IndexResponse>() {
            @Override
            public void onResponse(IndexResponse indexResponse) {
                System.out.println("执行成功");
            }

            @Override
            public void onFailure(Exception e) {
                System.out.println("执行失败"+e.getMessage());
            }
        };
        client.indexAsync(indexRequest,RequestOptions.DEFAULT,listener);
    }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

1.3.2 异步方式代码问题抛出

在执行此代码过程中，发现有两点问题:
① 在代码执行结束，发现ES中索引库创建成功
② 在索引库创建成功的同时，发现严重作物：执行成功，可以成功后逻辑进入onResponse( )方法，百思不得其解，为什么结果却是走了onFailure( )失败的方法，报错说意外断开连接，难道这个方法就是如此吗（执行完断开连接，可是onResponse( )方法里的逻辑不是也就不能走了）？

1.3.2.1 抛出问题分析

思路：看源码，正在分析，如有见解，欢迎评论区留言、探讨。

1.4 参考资料

ES高级客户端文档操作实战
ES之6：restHighLevelClient源码