项目场景:

项目用到ES 存储日志数据,


问题描述

程序使用RestHighLevelClient客户端,经常出现Request cannot be executed; I/O reactor status: STOPPED ,网上查找到原因大多是因为手动调用close()


原因分析:

查询出现异常前后的日志,发现前一天晚上有出现过OOM,第二天应用与查询ES相关的操作全部异常,怀疑因为OOM导致client 关闭,

为了验证猜测,写了个简单的测试用例,程序出现OOM后,休眠15秒,释放内存,继续调用client查询ES,抛出Request cannot be executed; I/O reactor status: STOPPED

​​​​​​​

 

	    List<MyCustomer> list = new ArrayList<>();
		new Thread(new Runnable() {
			
			@Override
			public void run() {

		        while(true){
		            list.add(new MyCustomer());
		        }
				
			}
		}).start();


		esTest.authLogTest();
		
		Thread.sleep(15000);
		list.clear();


解决方案:

优化导致OOM的代码

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐