Java操作ES5.x api

package com.ximua.es4j; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.cluster.node.DiscoveryNode; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.transport.client.PreBuiltTransportClient; import org.junit.Before; import org.junit.Test; import java.net.InetAddress; import java.util.HashMap; import java.util.List; import java.util.Map; public class ElasticSearch4Java { private TransportClient client; private IndexRequest source; /** * 获取连接, 第一种方式 * @throws Exception */ @Before public void before() throws Exception { //设置集群名称 Map<String, String> map = new HashMap<String, String>(); map.put("cluster.name", "elasticsearch"); Settings settings = Settings.builder().put(map).build(); //创建客户端client client = new PreBuiltTransportClient(settings) .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), Integer.parseInt("9300"))); } /** * 查看集群信息 */ @Test public void NodeHealthInfoTest() { List<DiscoveryNode> nodes = client.connectedNodes(); for (DiscoveryNode node : nodes) { System.out.println(node.getHostAddress()); } } //api 查询 @Test public void SearchDocumentTest(){ GetResponse response = client.prepareGet("website","article","1").execute().actionGet(); String result = response.getSourceAsString(); System.out.println(result); } }