springBoot集成Elasticsearch 报错 Health check failed的解决
作者：秒杀无心 发布时间：2022-12-07 05:18:16
标签：springBoot,Elasticsearch,Health,check,failed
springBoot集成Elasticsearch 报错 Health check failed
今天集成Elasticsearch 时启动报错
报错信息如下：
2018-11-01 20:52:51.310 INFO [hstao-supersearch,,,] 8528 --- [ main] .s.c.n.e.s.EurekaAutoServiceRegistration : Updating port to 8009
2018-11-01 20:52:51.314 INFO [hstao-supersearch,,,] 8528 --- [ main] c.i.g.hstaoSupersearchApplication : Started hstaoSupersearchApplication in 32.467 seconds (JVM running for 34.971)
2018-11-01 20:52:53.729 WARN [hstao-supersearch,,,] 8528 --- [on(6)-127.0.0.1] s.b.a.h.ElasticsearchJestHealthIndicator : Health check failed
org.apache.http.conn.HttpHostConnectException: Connect to localhost:9200 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect
at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:159) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:359) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:381) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:237) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:185) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:111) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83) ~[httpclient-4.5.3.jar:4.5.3]
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108) ~[httpclient-4.5.3.jar:4.5.3]
at io.searchbox.client.http.JestHttpClient.execute(JestHttpClient.java:50) ~[jest-0.1.7.jar:na]
at org.springframework.boot.actuate.health.ElasticsearchJestHealthIndicator.doHealthCheck(ElasticsearchJestHealthIndicator.java:44) ~[spring-boot-actuator-1.5.6.RELEASE.jar:1.5.6.RELEASE]
at org.springframework.boot.actuate.health.AbstractHealthIndicator.health(AbstractHealthIndicator.java:43) ~[spring-boot-actuator-1.5.6.RELEASE.jar:1.5.6.RELEASE]
at org.springframework.boot.actuate.health.CompositeHealthIndicator.health(CompositeHealthIndicator.java:68) [spring-boot-actuator-1.5.6.RELEASE.jar:1.5.6.RELEASE]
at org.springframework.boot.actuate.endpoint.HealthEndpoint.invoke(HealthEndpoint.java:85) [spring-boot-actuator-1.5.6.RELEASE.jar:1.5.6.RELEASE]
at org.springframework.boot.actuate.endpoint.HealthEndpoint.invoke(HealthEndpoint.java:35) [spring-boot-actuator-1.5.6.RELEASE.jar:1.5.6.RELEASE]
at org.springframework.boot.actuate.endpoint.jmx.DataEndpointMBean.getData(DataEndpointMBean.java:46) [spring-boot-actuator-1.5.6.RELEASE.jar:1.5.6.RELEASE]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_121]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_121]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_121]
at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_121]
at sun.reflect.misc.Trampoline.invoke(MethodUtil.java:71) [na:1.8.0_121]
at sun.reflect.GeneratedMethodAccessor131.invoke(Unknown Source) ~[na:na]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_121]
at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_121]
at sun.reflect.misc.MethodUtil.invoke(MethodUtil.java:275) [na:1.8.0_121]
at javax.management.modelmbean.RequiredModelMBean$4.run(RequiredModelMBean.java:1252) [na:1.8.0_121]
at java.security.AccessController.doPrivileged(Native Method) [na:1.8.0_121]
at java.security.ProtectionDomain$JavaSecurityAccessImpl.doIntersectionPrivilege(ProtectionDomain.java:80) [na:1.8.0_121]
at javax.management.modelmbean.RequiredModelMBean.invokeMethod(RequiredModelMBean.java:1246) [na:1.8.0_121]
at javax.management.modelmbean.RequiredModelMBean.invoke(RequiredModelMBean.java:1085) [na:1.8.0_121]
at org.springframework.jmx.export.SpringModelMBean.invoke(SpringModelMBean.java:90) [spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
at javax.management.modelmbean.RequiredModelMBean.getAttribute(RequiredModelMBean.java:1562) [na:1.8.0_121]
at org.springframework.jmx.export.SpringModelMBean.getAttribute(SpringModelMBean.java:109) [spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getAttribute(DefaultMBeanServerInterceptor.java:647) [na:1.8.0_121]
at com.sun.jmx.mbeanserver.JmxMBeanServer.getAttribute(JmxMBeanServer.java:678) [na:1.8.0_121]
at javax.management.remote.rmi.RMIConnectionImpl.doOperation(RMIConnectionImpl.java:1445) [na:1.8.0_121]
at javax.management.remote.rmi.RMIConnectionImpl.access$300(RMIConnectionImpl.java:76) [na:1.8.0_121]
at javax.management.remote.rmi.RMIConnectionImpl$PrivilegedOperation.run(RMIConnectionImpl.java:1309) [na:1.8.0_121]
at javax.management.remote.rmi.RMIConnectionImpl.doPrivilegedOperation(RMIConnectionImpl.java:1401) [na:1.8.0_121]
at javax.management.remote.rmi.RMIConnectionImpl.getAttribute(RMIConnectionImpl.java:639) [na:1.8.0_121]
at sun.reflect.GeneratedMethodAccessor58.invoke(Unknown Source) ~[na:na]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_121]
at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_121]
at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:346) [na:1.8.0_121]
at sun.rmi.transport.Transport$1.run(Transport.java:200) [na:1.8.0_121]
at sun.rmi.transport.Transport$1.run(Transport.java:197) [na:1.8.0_121]
at java.security.AccessController.doPrivileged(Native Method) [na:1.8.0_121]
at sun.rmi.transport.Transport.serviceCall(Transport.java:196) [na:1.8.0_121]
at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:568) [na:1.8.0_121]
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:826) [na:1.8.0_121]
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:683) [na:1.8.0_121]
at java.security.AccessController.doPrivileged(Native Method) [na:1.8.0_121]
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:682) [na:1.8.0_121]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) ~[na:1.8.0_121]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) ~[na:1.8.0_121]
at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_121]
Caused by: java.net.ConnectException: Connection refused: connect
在报错日志中看到 Connect to localhost:9200 被拒绝，检查代码发现项目中并没有 localhost:9200 的相关配置项，继续看上一步的日志
s.b.a.h.ElasticsearchJestHealthIndicator : Health check failed
可以看到执行了es的healthCheck，联想到以往集成redis也有healthCheck，便增加如下配置来试图关掉healthCheck
management.security.health.elasticsearch.enabled=false
竟然成功了，意外收获，Mark一下！
SpringBoot集成ElasticSearch出现的异常
1. 异常
在使用springboot2.2.8+elasticsearch6.8.10时，测试时报错：
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'elasticsearchClient' defined in class path resource [org/springframework/boot/autoconfigure/data/elasticsearch/ElasticsearchAutoConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.elasticsearch.client.transport.TransportClient]: Factory method 'elasticsearchClient' threw exception; nested exception is java.lang.IllegalStateException: availableProcessors is already set to [4], rejecting [4]
2. 原因
Elasticsearch 和 Redis 底层都使用到了 Netty , 在项目启动时会冲突。
涉及到的类：NettyRuntime，Netty4Util。
查看NettyRuntime类，可以看下源码:
public final class NettyRuntime {
private static final NettyRuntime.AvailableProcessorsHolder holder = new NettyRuntime.AvailableProcessorsHolder();
public static void setAvailableProcessors(int availableProcessors) {
holder.setAvailableProcessors(availableProcessors);
}
public static int availableProcessors() {
return holder.availableProcessors();
}
private NettyRuntime() {
}
static class AvailableProcessorsHolder {
private int availableProcessors;
AvailableProcessorsHolder() {
}
synchronized void setAvailableProcessors(int availableProcessors) {
ObjectUtil.checkPositive(availableProcessors, "availableProcessors");
// 简单说明：在项目启动时，redis自动设置好Netty处理器（availableProcessors就不为0），而此时elasticsearch也启动，发现Netty处理器已经被设置好了（发现availableProcessors！=0）然后会报异常。无论哪一个先启动，都会有判断去报这样的异常
if (this.availableProcessors != 0) {
// 看到这一句：跟上面报错的格式是一样的
String message = String.format(Locale.ROOT, "availableProcessors is already set to [％d], rejecting [％d]", this.availableProcessors, availableProcessors);
throw new IllegalStateException(message);
} else {
this.availableProcessors = availableProcessors;
}
}
@SuppressForbidden(
reason = "to obtain default number of available processors"
)
synchronized int availableProcessors() {
if (this.availableProcessors == 0) {
int availableProcessors = SystemPropertyUtil.getInt("io.netty.availableProcessors", Runtime.getRuntime().availableProcessors());
this.setAvailableProcessors(availableProcessors);
}
return this.availableProcessors;
}
}
}
而 Elasticsearch 底层使用了 Netty4Util ，这个类调用NettyRuntime的方法：
public static void setAvailableProcessors(final int availableProcessors) {
// we set this to false in tests to avoid tests that randomly set processors from stepping on each other
// 而这里就是解决办法：
final boolean set = Booleans.parseBoolean(System.getProperty("es.set.netty.runtime.available.processors", "true"));
if (!set) {
return;
}
/*
* This can be invoked twice, once from Netty4Transport and another time from Netty4HttpServerTransport; however,
* Netty4Runtime#availableProcessors forbids settings the number of processors twice so we prevent double invocation here.
*/
if (isAvailableProcessorsSet.compareAndSet(false, true)) {
// 看着，回去调用NettyRuntime的setAvailableProcessors
NettyRuntime.setAvailableProcessors(availableProcessors);
} else if (availableProcessors != NettyRuntime.availableProcessors()) {
/*
* We have previously set the available processors yet either we are trying to set it to a different value now or there is a bug
* in Netty and our previous value did not take, bail.
*/
// 看下面的格式跟报错的格式一样
final String message = String.format(
Locale.ROOT,
"available processors value [％d] did not match current value [％d]",
availableProcessors,
NettyRuntime.availableProcessors());
throw new IllegalStateException(message);
}
}
3. 解决
在Netty4Util源码可以看到，配置es.set.netty.runtime.available.processors设置为false就不会去检查Netty处理器是否配置。
因为得启动的时候就得去解决冲突，所以设置在 启动类那
@SpringBootApplication
public class XXXApplication {
@PostConstruct
public void init() {
// 解决netty启动冲突的问题（主要体现在启动redis和elasticsearch）
// 可以看Netty4Util.setAvailableProcessors(..)
System.setProperty("es.set.netty.runtime.available.processors", "false");
}
public static void main(String[] args) {
SpringApplication.run(CommunityApplication.class, args);
}
}
配置在main函数，调用run方法前也可以。
这个问题搞我一天时间，当时是直接copy Netty4Util类的System… , 没发现它是getProperty，导致还是出现这个异常，我真的不知道咋解决了。所以要看清楚，这里是setProperty
4. 其他注意点
一定要让本地的ElasticSearch跟SpringBoot集成的es版本保持一致。否则可能会出错。特别是一个使用6版本和一个使用7版本。
Maven可以看SpringBoot集成的es版本：
如果需要改就在这里：pom中
<properties>
<java.version>1.8</java.version>
<!--定义elasticsearch版本依赖，保证跟本地版本一致，否则可能出错-->
<!-- <elasticsearch.version>7.6.2</elasticsearch.version>-->
</properties>
7版本不太熟，改动也很大，以后有时间再升级。
来源：https://blog.csdn.net/u012480148/article/details/89919568
0
投稿猜你喜欢
实现的功能比较简单，就是随机产生了四个字符然后输出。效果图如下，下面我会详细说一下实现这个功能用到了那些知识点，并且会把 这些知识点详细的介- 本文实例讲述了C#在RichTextBox中显示不同颜色文字的方法。分享给大家供大家参考。具体实现方法如下：#region 日志记录、支持其
- 首先struts上传最大大小由两个地方决定. · struts.multipart.maxSize决定整个post的form最大是
- 本文实例为大家分享了C#实现猜数字小游戏的具体代码，供大家参考，具体内容如下效果如图：代码：using System;using Syste
- 随着互联网技术的发展，现在的网站架构基本都由原来的后端渲染，变成了：前端渲染、先后端分离的形态，而且前端技术和后端技术在各自的道路上越走越远
- 点击图标进入指定浏览器。只需在onCreate()方法里添加如下代码：String url = "http://tiger-kfp
- 有了Eureka服务注册发现、Hystrix断路器、Ribbon服务调用负载均衡，以及spring cloud config 集群配置中心，
- 1、ThreadLocal 使用原理前文我们讲过ThreadLocal的主要用途是实现线程间变量的隔离，表面上他们使用的是同一个Thread
- 本文实例分析了C#队列Queue用法。分享给大家供大家参考。具体分析如下：队列（Queue）在程序设计中扮演着重要的角色，因为它可以模拟队列
- 前段时间，有个同事说“30000000000000000000000000000000000000000000000000000000000
- 最近接了一个项目，要仿照京东写一个商品分类页，但需要滑动右边子分类，左边的主分类也跟着变换，写了个demo，需要的同学可以自取。先放一个写完
- 基于Java的简单的企业员工管理系统，供大家参考，具体内容如下首先创建了一个员工类定义员工应有的属性：工号、姓名、性别、职位、年龄、工资、部
- （一）什么是微服务网关后端写完所有的微服务之后，最终是要交给前端去调用。我们都知道每个微服务都有各自的端口号，如果前端直接通过IP加端口的方
- 什么是ContentType?我们知道浏览器可以处理各种各样的内容，比如：HTML、XML、JPG、Flash等等，那么浏览器是如何区分它们
- IDEA service层跳转实现类的快捷图标消失了，但别人IDEA同样的代码可以正常看到跳转图标。。（暗示：这只是你的IDEA 编译器的b
- 应用场景：在Android开发过程中，有时需要调用手机自身设备的功能，上篇文章主要侧重摄像头拍照功能的调用。本篇文章将综合实现拍照与视频的操
- 这篇文章主要介绍了spring cloud gateway请求跨域问题解决方案,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定
- 我们知道，spring boot自动配置功能可以根据不同情况来决定spring配置应该用哪个，不应该用哪个，举个例子：Spring的Jdbc
- /* * Copyright 2012-2013 The Haohui Network Cor
- 发现了google的gson，因为之前对于protocolbuf有一些了解，带着一些好奇心，我开始使用了gson。GitHub主页：http
