Elasticsearch Java 客户端：无法连接到远程服务器

Question

我需要使用此处提供的 url 连接到位于远程的 ElasticSearch 索引： http://api.exiletools.com/info/indexer.html

但是，我不知道如何在 Java 中做到这一点。

Docs on ES Java Client 根本没有太多信息。
我也没有找到任何JavaDocs，它们存在吗？

现在，有一些用 Python 编写的工作示例，确认服务器已启动并正在运行，连接部分如下所示：

es = Elasticsearch([{
  'host':'api.exiletools.com',
  'port':80,
  'http_auth':'apikey:DEVELOPMENT-Indexer'
}])

我想做什么：

client = new TransportClient()
                    .addTransportAddress(new InetSocketTransportAddress("apikey:DEVELOPMENT-Indexer@api.exiletools.com/index", 9300));

还尝试了端口 9200 和 80

这会导致： java.nio.channels.UnresolvedAddressException
和 NoNodeAvailableException

Answer 1

Shop Indexer API 在端口 80 上提供了一个 HTTP 入口点，以通过 HTTP 协议与其 ES 集群进行通信。 ES TransportClient 不是正确的客户端，因为它只能通过 TCP 进行通信。

由于 Elasticsearch 不提供开箱即用的 HTTP 客户端，因此您需要为此使用特定的库（例如 Jest），或者您可以汇总自己的 REST 客户端。

实现后者的一种简单方法是使用 Spring 的RestTemplate：

// create the REST template
RestTemplate rest = new RestTemplate()
// add the authorization header
HttpHeaders headers = new HttpHeaders();
headers.add("Authorization", "DEVELOPMENT-Indexer");

// define URL and query
String url = "http://api.exiletools.com/index/_search";
String allQuery = "{\"query\":{\"matchAll\":{}}}";

// make the request
HttpEntity<String> httpReq = new HttpEntity<String>(allQuery, headers);
ResponseEntity<String> resp = rest.exchange(url, HttpMethod.POST, httpReq, String.class)

// retrieve the JSON response
String body = resp.getBody();