当前位置: 首页 > 知识库问答 >
问题:

Spring Data Elasticsearch自动重新连接

东门胤
2023-03-14

我有一个Spring Boot应用程序,我使用ElasticsearchTemplate连接到我的ElasticSearch。然而,当它工作时,我关闭了Elasticsearch,每次我使用ElasticTemplate方法时,我都会得到一个组织。elasticsearch。客户运输NoNodeAvailableException。这很好,因为ElasticSearch不起作用。

然而,当ElasticSearch恢复工作时,我仍然得到一个组织。elasticsearch。客户运输NoNodeAvailableException好像这不是试图重新连接,但一旦失去连接,我需要重新启动整个应用程序。

如何解决这个问题?有没有办法让它在ES关闭后尝试重新连接到ealsticSearch?

共有1个答案

马安邦
2023-03-14

TransportClient每5秒发送一个心跳信号,以验证节点是否处于活动状态,如果没有,则丢弃它。

启用嗅探后,客户端将连接到新发现的节点或再次出现的旧节点。

因此,将TransportClient设置中的“client.transport.sniff”属性设置为true应该会有所帮助。看见https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.5/transport-client.html

顺便说一句:考虑切换到rest客户端,因为使用传输客户端将阻止您升级到未来的elasticsearch版本(https://www.elastic.co/blog/state-of-the-official-elasticsearch-java-clients)

 类似资料:
  • 问题内容: 我正在尝试通过Mongoose设置MongoDB自动重新连接功能。我尝试通过该选项的所有方式均无效,或者至少未发出该事件。 我尝试过的 如果其中之一是正确的,则应触发该事件并在控制台中记录一条消息,但是这永远不会发生。 如果重新连接前有延迟,有人知道如何配置吗? 提前致谢 对于任何寻找到这一点,看看这个和这个问题在猫鼬库。 问题答案: 我和您有同样的问题,而robertklep的解决方

  • 下面是我到目前为止的代码: 有人能解释一下在和情况下我该做什么吗?以及如何知道网络已断开并重新连接?

  • 问题内容: 我正在尝试在我的项目中实现连接Mqtt Broker的目的(同时订阅和发布)。问题是,当我使用订阅功能(实现接口)时,我无法弄清楚如果连接断开,我该如何重新连接。MqttCallback接口具有connectionLost方法,但是对于调试导致连接丢失的调试很有用。我进行了搜索,但找不到建立自动重新连接的方法。您可以提出有关此问题的方法或文档吗? 问题答案: 最好的方法是构造连接逻辑,

  • 我有一个很好的小Spring Boot JPA web应用程序。它部署在Amazon Beanstalk上,并使用Amazon RDS持久化数据。然而,它并不经常使用,因此会在一段时间后失效,这是一种例外: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:从服务器成功接收的最后一个数据包是79,870,633毫秒之前。 成功发送到服务

  • 问题内容: 我有一个客户端,一个服务器和一个数据库。客户端通过EJB远程接口与服务器通信。作为服务器-我使用Wildfly 8.2.0。作为数据库- 我使用MySQL。服务器通过JPA /休眠与MySQL通信。当我关闭MySQL服务器时,Wildfly当然会引发异常。但是,当我再次打开MySQL时- Wildfly仍然会抛出相同的错误。我必须关闭Wildfly,然后重新将Wildfly重新连接到数

  • 问题内容: 我在使用ActiveMQ和Spring时遇到问题。我像这样设置它们: 正在使用故障转移传输: 我遇到的问题是,如果一个盒子掉了,我们应该开始在另一个盒子上发送消息,但是它似乎仍在使用旧的连接(每次发送都超时)。如果我重新启动该程序,它将再次连接并且一切正常。 我的理解是应该自行修复(重新连接到新盒子),并且每次都应请求新连接,因此应该可以。我想知道这是否可能做得不好(是否在缓存与旧服务