elasticsearch2.1用java连接失败

2016-01-07 14:49:13 INFO  plugins:151 - [Tumbler] loaded [], sites []

2016-01-07 14:49:14 WARN  netty:138 - [Tumbler] Message not fully read (response) for [0] handler future(org.elasticsearch.client.transport.TransportClientNodesService$SimpleNodeSampler$1@4a02ea9), error [true], resetting

2016-01-07 14:49:14 INFO  transport:398 - [Tumbler] failed to get node info for [#transport#-1][buyuer-PC][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:176)

	at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:128)

	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:337)

	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(Unknown Source)

	at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

	at java.lang.Thread.run(Unknown Source)

Caused by: java.io.StreamCorruptedException: Unsupported version: 1

	at org.elasticsearch.common.io.ThrowableObjectInputStream.readStreamHeader(ThrowableObjectInputStream.java:46)

	at java.io.ObjectInputStream.<init>(Unknown Source)

	at org.elasticsearch.common.io.ThrowableObjectInputStream.<init>(ThrowableObjectInputStream.java:38)

	at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:173)

	... 23 more

Exception in thread "main" org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: []

	at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:305)

	at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:200)

	at org.elasticsearch.client.transport.support.InternalTransportClient.execute(InternalTransportClient.java:106)

	at org.elasticsearch.client.support.AbstractClient.search(AbstractClient.java:334)

	at org.elasticsearch.client.transport.TransportClient.search(TransportClient.java:416)

	at org.elasticsearch.action.search.SearchRequestBuilder.doExecute(SearchRequestBuilder.java:1122)

	at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:91)

	at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:65)

	at com.buyuer.es.ElasticSearchHandler.searcher(ElasticSearchHandler.java:97)

	at com.buyuer.es.ElasticSearchHandler.main(ElasticSearchHandler.java:155)

[2016-01-07 14:49:14,531][WARN ][transport.netty          ] [elasticsearch-001] exception caught on transport layer [[id: 0xe5ddfcbc, /127.0.0.1:61929 => /127.0.0.1:9300]], closing connection

java.lang.IllegalStateException: Message not fully read (request) for requestId [0], action [cluster/nodes/info], readerIndex [39] vs expected [57]; resetting

        at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:120)

        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(Unknown Source)

        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

        at java.lang.Thread.run(Unknown Source)

private Client client;



    public ElasticSearchHandler() {

        this("127.0.0.1");

    }



    @SuppressWarnings("resource")

    public ElasticSearchHandler(String ipAddress) {



        // 集群连接超时设置

        /*

         * Settings settings = ImmutableSettings.settingsBuilder().put("client.transport.ping_timeout", "10s").build(); client = new TransportClient(settings);

         */

        // Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", "elasticsearch-buyuer").build();

        // client = new TransportClient(settings).addTransportAddress(new InetSocketTransportAddress(ipAddress, 9300));

        

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

    }