Elasticsearch Java API连接与文档CRUD操作指南

"Elasticsearch Java API使用指南" 在本文中，我们将探讨Elasticsearch Java API的使用，重点关注如何连接到Elasticsearch集群以及执行基本的文档操作，包括创建、读取、更新和删除（CRUD）。 ### 1. 集群连接 #### 1.1 作为Elasticsearch节点 Elasticsearch节点是集群中的工作单元，它们负责存储数据并参与集群的通信。在Java中，你可以通过`NodeBuilder`来创建一个节点并连接到指定的集群。以下代码示例展示了如何设置一个名为"escluster2"的节点，并开启客户端模式（client mode）： ```java import static org.elasticsearch.node.NodeBuilder.nodeBuilder; import org.elasticsearch.client.Client; import org.elasticsearch.node.Node; Node node = nodeBuilder() .clusterName("escluster2") // 设置集群名称 .client(true) // 启用客户端模式 .node(); Client client = node.client(); // 获取客户端实例 ``` #### 1.2 使用Transport连接 另一种连接方式是作为Transport客户端，它不实际存储数据，而是通过网络与集群中的其他节点通信。以下代码展示了如何创建一个TransportClient，并连接到运行在本地IP地址127.0.0.1的端口9300上的"escluster2"集群： ```java import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.ImmutableSettings; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.InetSocketTransportAddress; Settings settings = ImmutableSettings.settingsBuilder() .put("cluster.name", "escluster2") // 设置集群名称 .build(); TransportClient client = new TransportClient(settings); client.addTransportAddress(new InetSocketTransportAddress("127.0.0.1", 9300)); // 添加节点地址 ``` ### 2. 文档的CRUD操作 #### 2.1 查询文档 使用Elasticsearch的Java API查询文档，可以调用`prepareGet`方法来构建请求。以下示例展示了如何查询索引为"library"、类型为"book"、ID为"1"的文档，并获取"titile"字段和原始源数据： ```java import org.elasticsearch.action.get.GetResponse; GetResponse response = client.prepareGet("library", "book", "1") .setFields("title", "_source") // 指定返回的字段 .execute().actionGet(); ``` #### 2.2 索引文档 索引新文档或更新现有文档，可以使用`prepareIndex`方法。以下代码展示了如何将一个图书对象（Book）索引到"library"索引： ```java import org.elasticsearch.action.index.IndexRequestBuilder; import org.elasticsearch.action.index.IndexResponse; // 假设Book类已定义，包含title、author等属性 Book book = new Book("Title", "Author"); IndexRequestBuilder request = client.prepareIndex("library", "book", "1"); request.setSource(book); // 将Book对象序列化并作为源数据 IndexResponse response = request.execute().actionGet(); ``` 在处理完文档操作后，别忘了关闭客户端和节点以释放资源： ```java client.close(); node.close(); ``` 通过这些基本的API，你可以轻松地在Elasticsearch集群上执行各种操作。随着对API的深入理解和实践，你可以实现更复杂的功能，如批量操作、聚合查询、脚本计算等，从而充分利用Elasticsearch的强大功能。