我正在尝试将ElasticSearch REST API与Jav​​a Apache HttpAsyncClient库一起使用。我想使用持久流水线连接。这是一些测试代码(输出在注释中): @Test public void testEsPipeliningClient() throws IOException, ExecutionException, InterruptedException { testPost(HttpAsyncClients.createDefault()); //201: {"_index"…

2020年10月14日 0条评论 48点热度 阅读全文

我正在使用httpcore-nio-4.4.5.jar。我正在使用elasticsearch RestHighLevelClient与我们的Elasticsearch服务器进行交互。所有这些工作都很好,只是有一段时间我们突然变得I / O Reactor停止了错误。 在ES方面,一切似乎都很好。没有奇怪的行为。 这就是我初始化ES客户端的方式。 public synchronized RestHighLevelClient getHighLevelClient() throws ManagerException {…

2020年10月5日 0条评论 49点热度 阅读全文

我们在生产中经常遇到以下错误。原因是,服务器关闭了连接,而客户端正在尝试使用半关闭的陈旧连接。我们有逐出策略,该策略每80分钟定期运行一次,它将检查过期和空闲的连接并关闭它们。仍然我们得到这个错误。我们正计划将逐出线程间隔减少到40分钟。是否有其他解决方案可以阻止此错误? 我们正在使用PoolingNHttpClientConnectionManager。空闲时间超时为60秒。httpasyncclient版本为4.1.1。 org.apache.http.ConnectionClosedException: Co…

2020年7月31日 0条评论 32点热度 阅读全文

我正在使用httpcore-nio-4.4.5.jar。我正在使用elasticsearch RestHighLevelClient与我们的Elasticsearch服务器进行交互。所有这些工作都很好,只是有一段时间我们突然变得I / O Reactor停止了错误。 在ES方面,一切似乎都很好。没有奇怪的行为。 这就是我初始化ES客户端的方式。 public synchronized RestHighLevelClient getHighLevelClient() throws ManagerException {…

2020年1月13日 0条评论 35点热度 阅读全文

使用典型的HttpAsyncClients示例: public class AsyncClientHttpExchange { public static void main(final String[] args) throws Exception { CloseableHttpAsyncClient httpclient = HttpAsyncClients.createDefault(); try { httpclient.start(); HttpGet request = new HttpGet("htt…

2019年2月9日 0条评论 61点热度 阅读全文