What if all configured nodes in Elasticsearch are not available? 01/18 Update SLTechnology News&Howtos

What if all configured nodes in Elasticsearch are not available?

2025-01-18 Update From: SLTechnology News&Howtos shulou NAV: SLTechnology News&Howtos > Internet Technology >

Shulou(Shulou.com)06/02 Report--

In this issue, the editor will bring you about what to do if all the configured nodes in Elasticsearch are not available. The article is rich in content and analyzes and describes for you from a professional point of view. I hope you can get something after reading this article.

In order to use the scoring mechanism of Elasticsearch, we use docker to quickly build an error when elasticsearch; uses spring boot to connect to ES: the node cannot be found.

Environment:

[jdk]: 1.8

[ES]: 6.5.4 single node (ip:172.26.0.251)

[springboot]: 2.1.2

Code snippet:

Elasticsearch.yml configuration for es:

Cluster.name: "docker-cluster" network.host: 0.0.0.0 node.name: cloud http.cors.enabled: true http.cors.allow-origin: "*" node.master: true node.data: true

Application.yml of the project

Spring.data.elasticsearch.cluster-name = docker-cluster spring.data.elasticsearch.cluster-nodes = 172.26.0.251 spring.data.elasticsearch.repositories.enabled = true spring.data.elasticsearch.client-transport-sniff = true # sniffing Settings only introduces the related package org.elasticsearch.client transport org.nlpcn elasticsearch in the pom.xml file -sql es connection configuration class @ Configuration @ EnableConfigurationProperties (ElasticsearchProperties.class) @ ConditionalOnClass (TransportClient.class) public class ElasticsearchAutoConfiguration {private final Logger logger = LoggerFactory.getLogger (this.getClass ()) Private ElasticsearchProperties elasticsearchProperties; public ElasticsearchAutoConfiguration (ElasticsearchProperties elasticsearchProperties) {logger.debug ("ElasticsearchAutoConfiguration elasticsearchProperties: {}", JSON .toJSONString (elasticsearchProperties)); this.elasticsearchProperties = elasticsearchProperties;} @ Bean (destroyMethod = "close") public TransportClient client () throws Exception {TransportClient client = new PreBuiltTransportClient (settings ()); String clusterNodes = elasticsearchProperties.getClusterNodes () Assert.hasText (clusterNodes, "[Assertion failed] clusterNodes settings missing."); for (String clusterNode: split (clusterNodes, ElasticsearchProperties.COMMA)) {String hostName = substringBeforeLast (clusterNode, ElasticsearchProperties.COLON); String port = substringAfterLast (clusterNode, ElasticsearchProperties.COLON); Assert.hasText (hostName, "[Assertion failed] missing host name in 'clusterNodes'") Assert.hasText (port, "[Assertion failed] missing port in 'clusterNodes'"); logger.info ("adding transport node:" + clusterNode); client.addTransportAddress (new TransportAddress (InetAddress.getByName (hostName), Integer.valueOf (port);} client.connectedNodes (); return client } @ Bean public ElasticClientKit elasticClientKit () throws Exception {ElasticClientKit elasticClientKit = new ElasticClientKit (); elasticClientKit.setTransportClient (client ()); return elasticClientKit;} @ Bean public ElasticAdminKit elasticAdminKit () throws Exception {ElasticAdminKit elasticAdminKit = new ElasticAdminKit (); elasticAdminKit.setTransportClient (client ()); return elasticAdminKit } private Settings settings () {return Settings.builder () .put ("cluster.name", elasticsearchProperties.getClusterName ()) .put ("client.transport.sniff", elasticsearchProperties.getClientTransportSniff ()) .put ("client.transport.ignore_cluster_name" ElasticsearchProperties .getClientIgnoreClusterName () .put ("client.transport.ping_timeout", elasticsearchProperties .getClientPingTimeout ()) .put ("client.transport.nodes_sampler_interval", elasticsearchProperties .getClientNodesSamplerInterval ()) / / .put ("xpack.security.user" "elastic:1qaz2wsx") .build () }}

Console error message:

2019-04-16 13 nio-9999-exec-2 46 c.j.p.w.e.GlobalExceptionHandler 18.257 [svr-demo] ERROR 4492-- [nio-9999-exec-2] c.j.p.w.e.GlobalExceptionHandler: None of the configured nodes are available: [{# transport#-1} {_ 56HAY5MSUefZh20v5asSQ} {172.26.0.251} {172.26.0.251} {172.26.0.251}]

Org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: [{# transport#-1} {_ 56HAY5MSUefZh20v5asSQ} {172.26.0.251} {172.26.0.251:9300}]

At org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable (TransportClientNodesService.java:349)

At org.elasticsearch.client.transport.TransportClientNodesService.execute (TransportClientNodesService.java:247)

At org.elasticsearch.client.transport.TransportProxyClient.execute (TransportProxyClient.java:60)

At org.elasticsearch.client.transport.TransportClient.doExecute (TransportClient.java:381)

At org.elasticsearch.client.support.AbstractClient.execute (AbstractClient.java:407)

At org.elasticsearch.client.support.AbstractClient.execute (AbstractClient.java:396)

At org.elasticsearch.action.ActionRequestBuilder.execute (ActionRequestBuilder.java:46)

At org.elasticsearch.action.ActionRequestBuilder.get (ActionRequestBuilder.java:53)

At com.jkzl.phr.elasticsearch.ElasticClientKit.count (ElasticClientKit.java:442)

At com.jkzl.phr.elasticsearch.ElasticClientKit.list (ElasticClientKit.java:446)

At com.jkzl.phr.elasticsearch.ElasticClientKit.list (ElasticClientKit.java:233)

At com.jkzl.phr.elasticsearch.ElasticClientKit.list (ElasticClientKit.java:227)

At com.jkzl.phr.demo.score.service.ElkScoreService.getMapList (ElkScoreService.java:17)

At com.jkzl.phr.demo.score.controller.ElkScoreDemoController.find (ElkScoreDemoController.java:34)

At sun.reflect.NativeMethodAccessorImpl.invoke0 (NativeMethod)

At sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)

At sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)

At java.lang.reflect.Method.invoke (Method.java:498)

At org.springframework.web.method.support.InvocableHandlerMethod.doInvoke (InvocableHandlerMethod.java:189)

At org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest (InvocableHandlerMethod.java:138)

At org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle (ServletInvocableHandlerMethod.java:102)

At org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod (RequestMappingHandlerAdapter.java:895)

At org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal (RequestMappingHandlerAdapter.java:800)

At org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle (AbstractHandlerMethodAdapter.java:87)

At org.springframework.web.servlet.DispatcherServlet.doDispatch (DispatcherServlet.java:1038)

At org.springframework.web.servlet.DispatcherServlet.doService (DispatcherServlet.java:942)

At org.springframework.web.servlet.FrameworkServlet.processRequest (FrameworkServlet.java:1005)

At org.springframework.web.servlet.FrameworkServlet.doGet (FrameworkServlet.java:897)

At javax.servlet.http.HttpServlet.service (HttpServlet.java:634)

At org.springframework.web.servlet.FrameworkServlet.service (FrameworkServlet.java:882)

At javax.servlet.http.HttpServlet.service (HttpServlet.java:741)

At org.apache.catalina.core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain.java:231)