ElasticSearch 0.90.2 StreamCorruptedException khi hỏi cổng 9300

Question

Tôi vừa giải nén elasticsearch-0.90.2.zip trên Windows XP và bắt đầu bin/elasticsearch.bat.

Tôi đã đặt JAVA_HOME thành C: \ Program Files \ Java \ jre7, vì đây là sự cố lúc chạy đầu tiên.

Tôi đang cố gắng kết nối nó từ Google Chrome 27.0.1453.116.

Theo elasticsearch.yml, "ElasticSearch, theo mặc định, tự liên kết với địa chỉ 0.0.0.0", nhưng 0.0.0.0:9200 phản hồi 108 (net :: ERR_ADDRESS_INVALID).

localhost: 9200 hoặc 127.0.0.1:9200 đáp ứng một cách chính xác: { "ok": đúng vv

localhost: 9300 đáp ứng 324 (net :: ERR_EMPTY_RESPONSE), và hiển thị StreamCorruptedException trong cửa sổ giao diện điều khiển:

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

Tôi đã đọc về các tình huống tương tự, nhưng hiện tại không có nút nào khác chạy, không kết nối mạng, không sử dụng cổng, nó là công cụ Tìm kiếm Đàn hồi độc lập đầu tiên trên máy cục bộ với cấu hình mặc định.

Tôi không thể tưởng tượng những gì nên có trên cổng 1627 - có lẽ đó là đầu mối. Tôi làm gì sai - hoặc giải pháp nào?

Answer 1

Không có gì bị hỏng. Cổng 9300 được sử dụng để liên lạc giữa các nút và sử dụng giao thức nhị phân bên trong, do đó bạn không thể sử dụng nó từ trình duyệt. Để sử dụng cổng 9300, bạn phải sử dụng Java API, cả ứng dụng khách Node hoặc ứng dụng Giao vận, cả hai đều hiểu giao thức nhị phân bên trong.

Từ trình duyệt, bạn chỉ nên sử dụng cổng 9200, là cổng hiển thị API REST.

Answer 2

Tôi đã gặp vấn đề tương tự. Theo tôi phát hiện vấn đề là bên trong configs (/etc/elasticsearch/elasticsearch.yml theo mặc định). Có một thông số phức tạp http.enabled được đặt thành false theo mặc định. Đối với sửa chữa, bạn chỉ cần đặt nó vào true:

http.port: 9200 http.enabled: true

Tôi hy vọng nó sẽ giúp.