IllegalStateException: I/O reactor has been shut down

使用 bulk  批量插入数据到 es 集群时，如果关掉其中的一个节点，会出现后续的所有插入都报错：
 

[b]java.lang.IllegalStateException: I/O reactor has been shut down

[/b]	at org.apache.http.util.Asserts.check(Asserts.java:34)

	at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.connect(DefaultConnectingIOReactor.java:224)

	at org.apache.http.nio.pool.AbstractNIOConnPool.processPendingRequest(AbstractNIOConnPool.java:481)

	at org.apache.http.nio.pool.AbstractNIOConnPool.lease(AbstractNIOConnPool.java:280)

	at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:295)

	at org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)

	at org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)

	at org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)

	at org.elasticsearch.client.RestClient.performRequestAsync(RestClient.java:301)

	at org.elasticsearch.client.RestClient.access$1000(RestClient.java:95)

	at org.elasticsearch.client.RestClient$1.failed(RestClient.java:328)

	at org.apache.http.concurrent.BasicFuture.failed(BasicFuture.java:134)

 

[b]java.lang.IllegalStateException: Request cannot be executed; I/O reactor status: STOPPED

[/b]	at org.apache.http.util.Asserts.check(Asserts.java:46)

	at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase.ensureRunning(CloseableHttpAsyncClientBase.java:90)

	at org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:123)

	at org.elasticsearch.client.RestClient.performRequestAsync(RestClient.java:301)

	at org.elasticsearch.client.RestClient.performRequestAsync(RestClient.java:291)

	at org.elasticsearch.client.RestHighLevelClient.internalPerformRequestAsync(RestHighLevelClient.java:1567)

	at org.elasticsearch.client.RestHighLevelClient.performRequestAsync(RestHighLevelClient.java:1530)

	at org.elasticsearch.client.RestHighLevelClient.performRequestAsyncAndParseEntity(RestHighLevelClient.java:1498)

	at org.elasticsearch.client.RestHighLevelClient.bulkAsync(RestHighLevelClient.java:488)

通过 debug 发现，是由于发生了异常导致 httpAsyncClient shutdown 导致的，但是不知道有什么方法阻止 client shutdown 操作，因为项目实时性要求较高，每次一批操作完后重新 build restClient 的操作性能会很低。
 

@Override

public void afterBulk(long executionId, BulkRequest request, Throwable failure) {

    if (failure != null) {

        logger.error("错误描述: 写ES错误, exMsg: ", failure);

    }

}

 
不知道各位老师有什么好的解决方案 。