1

我在使用带有防护罩的弹性搜索（2.3）时遇到了身份验证问题。elasticsearch 实例托管在云上的某个地方，我没有太多的调整权限。

我正在使用 Sense chrome-plugin 发出测试请求，并且在发送第一个请求之前它要求输入用户名/密码（我假设它是 REST api 接口的某种基本 HTTP 身份验证）。Sense 插件的所有查询都很好。

现在，我必须使用 Java API 在客户端应用程序中对这个实例进行查询。我创建了 TransportClient，就像下面的代码片段一样：

String hostBasedClusterName = StatsConstants.ES_HOST.split("\\.", 2)[0];
String clusterName = System.getProperty("cluster", hostBasedClusterName);

Settings settings = Settings.settingsBuilder()
                        .put("cluster.name", clusterName)
                        .put("shield.transport.ssl", "true")
                        .put("shield.user", String.format("%s:%s", StatsConstants.ES_USERNAME, StatsConstants.ES_PASSWORD))
                        .build();

client = TransportClient.builder()
                         .addPlugin(ShieldPlugin.class)
                         .settings(settings)
                         .build()
                         .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(StatsConstants.ES_HOST), StatsConstants.ES_PORT));

根据其他样本和文档，它似乎很好。但是，当我尝试创建客户端时，我收到了 StreamCorruptedException 异常：

 2016-05-13 13:53:47,396  WARN netty:788 - NettyTransport.java - [Burstarr] exception caught on transport layer [[id: 0x4ac12d10, ...]], closing connection
 java.io.StreamCorruptedException: invalid internal transport message format, got (48,54,54,50)
      at org.elasticsearch.transport.netty.SizeHeaderFrameDecoder.decode(SizeHeaderFrameDecoder.java:68)
      at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:425)
      at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:303)
      at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)

客户端版本是 2.3.2，使用文档中描述的屏蔽客户端库，编译很好，没有警告，只是当它尝试创建该对象时，它会抛出异常。

对于你们中的一些人来说，这似乎微不足道——但对我来说，这是我第一次涉足 Java/elasticsearch 世界......

更新- 在我做了更多的挖掘/阅读之后，当有人抱怨使用的代理时，我发现了类似的错误/异常。我不使用任何代理，它直接连接到服务器；

4

1 回答 1

2

问题解决了。在这里添加回应以减轻其他一些可怜的灵魂的负担......

来自 solr 背景，我试图连接到与 web 服务 (http/https) 相同的端口。好吧，那是完全错误的。我应该连接到端口 9343。

于 2016-05-17T11:12:21.103 回答