• 首页
  • 预防
  • 致病
  • 添加剂
  • 含毒
  • 过期

    • 为什么 elasticsearch 获取节点信息失败

    作者&投稿：苍虽 （若有异议请与网页底部的电邮联系）
    为什么 elasticsearch 获取节点信息失败~

    为什么执行elasticsearch的api会出错
    5.3.3 条件运算符和条件表达式
    如果在条件语句中，只执行单个的赋值语句时， 常可使用条件表达式来实现。不但使程序简洁，也提高了运行效率。
    条件运算符为?和：，它是一个三目运算符，即有三个参与运算的量。
    由条件运算符组成条件表达式的一般形式为：
    表达式1? 表达式2： 表达式3
    其求值规则为：如果表达式1的值为真，则以表达式2 的值作为条件表达式的值，否则以表达式2的值作为整个条件表达式的值。
    条件表达式通常用于赋值语句之中。
    例如条件语句：
    if(a>b) max=a;
    else max=b;
    可用条件表达式写为
    max=(a>b)?a:b;

    "size": 50,
    "query": {
    "filtered": {
    "query": {
    "bool": {
    "must": {
    "bool": {
    "should": [
    {
    "match": {
    "_all": {
    "query": "Happy Pharrel Williams",
    "type": "boolean"
    }
    }
    },
    {
    "flt": {

    在程序中，使用嵌入式node启动节点正常，方式如下：
    Node node = NodeBuilder.nodeBuilder().node();
    node.start();

    但是，如果使用 TransportClient 建立 es 的 Client，方式如下：
    TransportClient client = new TransportClient(settings);
    client.addTransportAddress(new InetSocketTransportAddress("127.0.0.1", 9300));

    这是 ES 2.3 官网上面提供的 TransportClient 方式：https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/transport-client.html
    使用 TransportClient 方式，启动程序后，程序可以正常启动，但是控制台一直不停报错，貌似是在一直监测节点，而节点一直没有被发现，所以不停报错，错误信息如下，应用程序控制台错误信息：
    2016-05-23 19:40:15.823 INFO 27655 --- [ main] org.elasticsearch.client.transport : [Aliyah Bishop] failed to get node info for [#transport#-1][XXX-MBP.lan][inet[/127.0.0.1:9300]], disconnecting...

    org.elasticsearch.transport.RemoteTransportException: Failed to deserialize exception response from stream
    Caused by: org.elasticsearch.transport.TransportSerializationException: Failed to deserialize exception response from stream
    at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:173)
    at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:125)
    at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
    at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
    at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
    at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:296)
    at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462)
    at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443)
    at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303)
    at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
    at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
    at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
    at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:268)
    at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:255)
    at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
    at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
    at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
    at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
    at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
    at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
    at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)
    Caused by: java.io.StreamCorruptedException: Unsupported version: 1
    at org.elasticsearch.common.io.ThrowableObjectInputStream.readStreamHeader(ThrowableObjectInputStream.java:46)
    at java.io.ObjectInputStream.<init>(ObjectInputStream.java:299)
    at org.elasticsearch.common.io.ThrowableObjectInputStream.<init>(ThrowableObjectInputStream.java:38)
    at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:170)
    ... 23 common frames omitted

    ………….

    failed to load elasticsearch nodes : org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: []

    es 控制台报错信息：
    [2016-05-23 21:45:56,807][WARN ][transport.netty ] [node-1] exception caught on transport layer [[id: 0x8e4b89bc, /127.0.0.1:62566 => /127.0.0.1:9300]], closing connection
    java.lang.IllegalStateException: Message not fully read (request) for requestId [233], action [cluster/nodes/info], readerIndex [39] vs expected [57]; resetting
    at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:121)
    at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
    at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
    at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
    at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
    at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:462)
    at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:443)
    at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303)
    at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
    at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
    at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
    at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(OpenChannelsHandler.java:75)
    at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
    at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
    at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
    at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
    at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
    at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
    at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:337)
    at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
    at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
    at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
    at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)

    而且，当我使用嵌入式node启动节点后，系统会自动启动一个node节点，node.name 也是随机的，并且并没有将该节点加入启动的es集群中，我加入的索引和数据也不能出现在 my-cluster 集群中
    所以有两个问题：
    1、为什么我使用嵌入式node启动节点，启动后的节点不会加入到集群中？
    2、使用 TransportClient 方式建立 Client，启动程序后，程序的控制台，和服务器端的es一直报错，获取节点信息失败，是什么原因？即上面的错误信息
    下面是环境版本信息：
    服务器端 es 版本：2.3.3
    jdk 版本：1.7.0_79
    spring-data-elasticsearch 版本：1.2.0.RELEASE（即：elasticsearch-1.4.4.jar）
    服务器端 es 配置，elasticsearch.yml：
    cluster.name: my-cluster
    node.name: node-1
    http 端口为：9200
    节点间的通信端口为：9300
    关于第二个问题尝试了很多解决方案，比如：
    1、应用 和 es 的 jdk 环境版本不一致。已检查过一致
    https://github.com/elastic/elasticsearch/issues/3835
    2、es 多个节点之间的JDK版本不一致。我使用的只是单节点，并且都在我本地机器上
    http://jontai.me/blog/2013/06/elasticsearch-remotetransportexception-failed-to-deserialize-exception-response-from-stream/
    3、idk 版本过低，建议1.7+。已是1.7+
    最后附上两种启动节点方式的完整代码
    1、嵌入式 node 启动
    import org.elasticsearch.client.Client;
    import org.elasticsearch.node.Node;
    import org.elasticsearch.node.NodeBuilder;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;

    @Configuration
    @EnableElasticsearchRepositories(basePackages = "xx.xxx.domain.repository.elastic")
    public class ElasticsearchConfiguration {

    @Bean
    public Client client() {
    Node node = NodeBuilder.nodeBuilder().node();
    node.start();
    return node.client();
    }
    }

    2、TransportClient 方式
    import org.elasticsearch.client.Client;
    import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.settings.ImmutableSettings;
    import org.elasticsearch.common.settings.Settings;
    import org.elasticsearch.common.transport.InetSocketTransportAddress;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
    import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
    import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;

    @Configuration
    @EnableElasticsearchRepositories(basePackages = "xx.xxx.domain.repository.elastic")
    public class ElasticsearchConfiguration {

    @Bean
    public Client client() {

    TransportClient client = new TransportClient();
    client.addTransportAddress(new
    InetSocketTransportAddress("127.0.0.1", 9300));

    return client;
    }

    @Bean
    public ElasticsearchOperations elasticsearchTemplate() {
    return new ElasticsearchTemplate(client());
    }
    }

    为什么执行elasticsearch的api会出错
    5.3.3 条件运算符和条件表达式
    如果在条件语句中，只执行单个的赋值语句时， 常可使用条件表达式来实现。不但使程序简洁，也提高了运行效率。
    条件运算符为?和：，它是一个三目运算符，即有三个参与运算的量。
    由条件运算符组成条件表达式的一般形式为：
    表达式1? 表达式2： 表达式3
    其求值规则为：如果表达式1的值为真，则以表达式2 的值作为条件表达式的值，否则以表达式2的值作为整个条件表达式的值。
    条件表达式通常用于赋值语句之中。
    例如条件语句：
    if(a>b) max=a;
    else max=b;
    可用条件表达式写为
    max=(a>b)?a:b;

    大通回族土族自治县17165758435： 搜索引擎 Elasticsearch 好在哪里,为什么 Wikimedia 打算要用它 - ？
    边荀硫酸： ElasticSearch是一个基于Lucene的搜索服务器.它提供了一个分布式多用户能力的全文搜索引擎,基于RESTful web接口.

    大通回族土族自治县17165758435： 为什么 elasticsearch 获取节点信息失败 - ？
    边荀硫酸： 用 TransportClient 方式,启动程序后,程序可以正常启动,但是控制台一直不停报错,貌似是在一直监测节点,而节点一直没有被发现,所以不停报错,错误信息如下,应用程序控制台错误信息:2016-05-23 19:40:15.823 INFO 27655 --- [ main...

    大通回族土族自治县17165758435： elasticsearch(搜索服务器) - 搜狗百科？
    边荀硫酸： 我们有达到几万亿文档的集群.

    大通回族土族自治县17165758435： elasticsearch的实时搜索性能为什么比solr好 - ？
    边荀硫酸： 对比性能其实很不好回答,因为没有我还不知道有 benchmark做了很深入的,而且没有偏见的性能对比.就实时搜索而言(Near Real Time Search), feature 实现主要是lucene layer. Elasticsearch 比 SOLR 提前实现这个feature.但是现在Solr ...

    大通回族土族自治县17165758435： elasticsearch.bat 闪退有哪些原因 - ？
    边荀硫酸： 1、打开一个cmd 窗口(一般是win+r,输入cmd回车)2、cd/d bat所在文件夹3、输入bat文件名 如 elasticsearch.bat 回车运行,这时能看到错误提示,根据提示排查错误即可.

    大通回族土族自治县17165758435： Elasticsearch是什么以及核心概念 - ？
    边荀硫酸： 人是构成团队最核心的力量.3个(包含3个)以上的人就可以构成团队. 目标是通过人员具体实现的,所以人员的选择是团队中非常重要的一个部分.在一个团队中可能需要有人出主意,有人定计划,有人实施,有人协调不同的人一起去工作,还有人去监督团队工作的进展,评价团队最终的贡献.不同的人通过分工来共同完成团队的目标,在人员选择方面要考虑人员的能力如何,技能是否互补,人员的经验如何.

    大通回族土族自治县17165758435： elasticsearch for windows为什么不能创建索引 - ？
    边荀硫酸： 1.使用基于磁盘的索引,手动分区,然后定期重建较小的分区(被称为“增量”).通过尽可能的减小重建部分的大小,可以将平均索引滞后时间降低到30~60秒.在0.9.x版本中,这是唯一可用的方法.在一个巨大的文档集上,这可能是最有效的一种方法2.版本1.x(从版本1.10-beta开始)增加了实时索引(简写为Rt索引)的支持,用于及时更新全文数据.在RT索引上的更新,可以在1~2毫秒(0.001-0.002秒)内出现在搜索结果中.然而,RT实时索引在处理较大数据量的批量索引上效率并不高.

    大通回族土族自治县17165758435： elasticsearch 可以替代数据库吗 - ？
    边荀硫酸： 我们使用Elasticsearch存储的文档数量接近50亿(算上1份复制,接近100亿文档),总共10个数据节点和2个元数据节点(48GB内存,8核心CPU,ES使用内存达到70%),每天的文档增量大概是3000W条(速度 持续增加中).目前来看,单...

    大通回族土族自治县17165758435： mysql同步数据到elasticsearch用什么工具 - ？
    边荀硫酸： 1.如何实现mysql与elasticsearch的数据同步?逐条转换为json显然不合适,需要借助第三方工具或者自己实现.核心功能点:同步增、删、改、查同步.2、mysql与elasticsearch同步的方法有哪些?优缺点对比?目前该领域比较牛的插件有:1)...

    你可能想看的相关专题

  • texas instruments
  • elasticsearch doc
  • ascus是tct最轻的症状吗
  • vivienne westwood
  • java elasticsearch
  • elasticsearch terms
  • php elasticsearch
  • johnnie walker
  • alien swarm
  • es搜索为什么这么快
  • channel

    • 本站内容来自于网友发表，不代表本站立场，仅表示其个人看法，不对其真实性、正确性、有效性作任何的担保
    相关事宜请发邮件给我们
    © 星空见康网