ElasticSearch 0.90.2 StreamCorruptedException na porcie z pytaniem 9300

Question

Właśnie rozpakowałem plik elasticsearch-0.90.2.zip w systemie Windows XP i uruchomiłem bin/elasticsearch.bat.

Ustawiłem JAVA_HOME na C: \ Program Files \ Java \ jre7, ponieważ był to problem przy pierwszym uruchomieniu.

Próbuję połączyć go z Google Chrome 27.0.1453.116.

Zgodnie z elasticsearch.yml, "ElasticSearch, domyślnie, wiąże się z adresem 0.0.0.0", ale 0.0.0.0:9200 odpowiada 108 (net :: ERR_ADDRESS_INVALID).

localhost: 9200 lub 127.0.0.1:9200 reaguje poprawnie: { "ok": true, itp

localhost: 9300 odpowiada 324 (net :: ERR_EMPTY_RESPONSE) i wyświetla StreamCorruptedException w oknie konsoli:

[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) 

Czytałem o podobnych sytuacjach, ale teraz nie ma innego uruchomiony węzeł, brak sieci, nie używa portu, to jest mój pierwszy samodzielny silnik ElasticSearch na lokalnym komputerze z domyślnej konfiguracji.

Nie mogę sobie wyobrazić, co powinno być na porcie 1627 - być może jest to wskazówka. Co mam nie tak - lub jakieś rozwiązanie?

Answer 1

Nic nie jest uszkodzone. Port 9300 służy do komunikacji między węzłami i wykorzystuje wewnętrzny protokół binarny, dlatego nie można go używać z przeglądarki. Aby korzystać z portu 9300, musisz użyć klienta Java API, klienta węzła lub klienta transportu, który obaj rozumieją wewnętrzny protokół binarny.

Z przeglądarki należy korzystać tylko z portu 9200, który udostępnia interfejs API REST.

Answer 2

Spotkałem ten sam problem. Jak odkryłem problem jest domyślnie w konfiguracjach (/etc/elasticsearch/elasticsearch.yml). Istnieje trudny parametr http.enabled, który został domyślnie ustawiony na false. Do poprawki wystarczy ustawić go true:

http.port: 9200 http.enabled: true

Mam nadzieję, że to pomoże.