2013-07-25 2 views
7

Я только что распаковал elasticsearch-0.90.2.zip в Windows XP и начал bin/elasticsearch.bat.ElasticSearch 0.90.2 StreamCorruptedException при запросе порта 9300

Я установил JAVA_HOME в C: \ Program Files \ Java \ jre7, так как это было проблемой при первом запуске.

Я пытаюсь подключить его из Google Chrome 27.0.1453.116.

Согласно elasticsearch.yml, «ElasticSearch по умолчанию связывается с адресом 0.0.0.0», но 0.0.0.0:9200 отвечает 108 (net :: ERR_ADDRESS_INVALID).

локальный: 9200 или 127.0.0.1:9200 отвечает правильно: { "ОК": правда и т.д.

локальный: 9300 отвечает 324 (Net :: ERR_EMPTY_RESPONSE), и отображает StreamCorruptedException в окне консоли:

[2013-07-25 10:42:30,419][WARN ][transport.netty   ] [Happy Birthday] exc 
eption caught on transport layer [[id: 0x478ae9b7, /127.0.0.1:1627 => /127.0.0.1 
:9300]], closing connection 
java.io.StreamCorruptedException: invalid internal transport message format 
     at org.elasticsearch.transport.netty.SizeHeaderFrameDecoder.decode(SizeH 
eaderFrameDecoder.java:27) 
     at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.callD 
ecode(FrameDecoder.java:425) 
     at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.messa 
geReceived(FrameDecoder.java:303) 
     at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.h 
andleUpstream(SimpleChannelUpstreamHandler.java:70) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:564) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$Default 
ChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) 
     at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(Ope 
nChannelsHandler.java:74) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:564) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:559) 
     at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(C 
hannels.java:268) 
     at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(C 
hannels.java:255) 
     at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioW 
orker.java:88) 
     at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.p 
rocess(AbstractNioWorker.java:109) 
     at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector 
.run(AbstractNioSelector.java:312) 
     at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.r 
un(AbstractNioWorker.java:90) 
     at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(NioWo 
rker.java:178) 
     at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(Thread 
RenamingRunnable.java:108) 
     at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.ru 
n(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) 
[2013-07-25 10:42:30,435][WARN ][transport.netty   ] [Happy Birthday] exc 
eption caught on transport layer [[id: 0x478ae9b7, /127.0.0.1:1627 :> /127.0.0.1 
:9300]], closing connection 
java.io.StreamCorruptedException: invalid internal transport message format 
     at org.elasticsearch.transport.netty.SizeHeaderFrameDecoder.decode(SizeH 
eaderFrameDecoder.java:27) 
     at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.callD 
ecode(FrameDecoder.java:425) 
     at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.clean 
up(FrameDecoder.java:482) 
     at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.chann 
elDisconnected(FrameDecoder.java:365) 
     at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.h 
andleUpstream(SimpleChannelUpstreamHandler.java:102) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:564) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$Default 
ChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) 
     at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(Ope 
nChannelsHandler.java:74) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:564) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:559) 
     at org.elasticsearch.common.netty.channel.Channels.fireChannelDisconnect 
ed(Channels.java:396) 
     at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.c 
lose(AbstractNioWorker.java:361) 
     at org.elasticsearch.common.netty.channel.socket.nio.NioServerSocketPipe 
lineSink.handleAcceptedSocket(NioServerSocketPipelineSink.java:81) 
     at org.elasticsearch.common.netty.channel.socket.nio.NioServerSocketPipe 
lineSink.eventSunk(NioServerSocketPipelineSink.java:36) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendDow 
nstream(DefaultChannelPipeline.java:574) 
     at org.elasticsearch.common.netty.channel.Channels.close(Channels.java:8 
12) 
     at org.elasticsearch.common.netty.channel.AbstractChannel.close(Abstract 
Channel.java:197) 
     at org.elasticsearch.transport.netty.NettyTransport.exceptionCaught(Nett 
yTransport.java:505) 
     at org.elasticsearch.transport.netty.MessageChannelHandler.exceptionCaug 
ht(MessageChannelHandler.java:224) 
     at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.h 
andleUpstream(SimpleChannelUpstreamHandler.java:112) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:564) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$Default 
ChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) 
     at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.excep 
tionCaught(FrameDecoder.java:377) 
     at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.h 
andleUpstream(SimpleChannelUpstreamHandler.java:112) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:564) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$Default 
ChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) 
     at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(Ope 
nChannelsHandler.java:74) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:564) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:559) 
     at org.elasticsearch.common.netty.channel.Channels.fireExceptionCaught(C 
hannels.java:525) 
     at org.elasticsearch.common.netty.channel.AbstractChannelSink.exceptionC 
aught(AbstractChannelSink.java:48) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.notifyH 
andlerException(DefaultChannelPipeline.java:658) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:566) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$Default 
ChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791) 
     at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(Ope 
nChannelsHandler.java:74) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:564) 
     at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUps 
tream(DefaultChannelPipeline.java:559) 
     at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(C 
hannels.java:268) 
     at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(C 
hannels.java:255) 
     at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioW 
orker.java:88) 
     at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.p 
rocess(AbstractNioWorker.java:109) 
     at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector 
.run(AbstractNioSelector.java:312) 
     at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.r 
un(AbstractNioWorker.java:90) 
     at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(NioWo 
rker.java:178) 
     at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(Thread 
RenamingRunnable.java:108) 
     at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.ru 
n(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) 

Я читал о подобных ситуациях, но сейчас нет другого узла работает, нет сети, ничего не использует порт, это мой первый автономный ElasticSearch двигатель на локальном компьютере с конфигурацией по умолчанию.

Я не могу представить, что должно быть на порту 1627 - возможно, это ключ. Что я не так - или какое-либо решение?

+0

Если соединение через порт 9200 отвечает, тогда в чем проблема? – ramseykhalaf

+0

Возможно, ничего, но я думал, что что-то испорчено. – user2618018

+0

Помог ли мой ответ прояснить что-то для вас? – javanna

ответ

13

Ничто не повреждено. Порт 9300 используется для межузловой связи и использует внутренний двоичный протокол, поэтому вы не можете использовать его в браузере. Чтобы использовать порт 9300, вы должны использовать Java API, либо клиент узла, либо транспортный клиент, который понимает внутренний двоичный протокол.

Из браузера вы должны использовать только порт 9200, который предоставляет API REST.

0

Я столкнулся с той же проблемой. Как я выяснил, проблема связана с внутренними конфигами (по умолчанию /etc/elasticsearch/elasticsearch.yml). Существует сложный параметр http.enabled, который был установлен на false по умолчанию. Для исправления нужно просто установить его на true:

http.port: 9200 http.enabled: true

Я надеюсь, что это поможет.

Смежные вопросы