使用Java API Client连接Elasticsearch需添加elasticsearch-java依赖并创建RestClient实例，通过ElasticsearchClient执行索引、查询、更新和删除操作，推荐用于8.x版本，替代已弃用的旧客户端。
Java 连接并操作 Elasticsearch 主要有两种方式：使用官方的 Java REST 客户端（已弃用）或推荐的 Java API Client（新版，基于 Elasticsearch 7.15+）。下面以目前主流且官方推荐的方式进行说明。
1. 添加 Maven 依赖
在你的 pom.xml 中添加 Elasticsearch 的 Java API Client 依赖：
co.elastic.clients elasticsearch-java8.14.0
com.fasterxml.jackson.core jackson-databind2.15.2
2. 创建客户端连接
使用 TransportClient 已被弃用，现在推荐使用基于 HTTP 的 Java API Client。以下是一个创建连接的示例：
import co.elastic.clients.elasticsearch.ElasticsearchClient; import co.elastic.clients.json.jackson.JacksonJsonpMapper; import co.elastic.clients.transport.ElasticsearchTransport; import co.elastic.clients.transport.rest_client.RestClientTransport; import org.apache.http.HttpHost; import org.elasticsearch.client.RestClient;
public class EsClient { private static ElasticsearchClient client;
public static ElasticsearchClient getClient() { if (client == null) { // 创建低级别客户端（Apache HttpClient） RestClient restClient = RestClient.builder( new HttpHost("localhost", 9200) ).build(); // 创建传输层 ElasticsearchTransport transport = new RestClientTransport( restClient, new JacksonJsonpMapper() ); // 创建高级客户端 client = new ElasticsearchClient(transport); } return client; } public static void close() throws IOException { if (client != null) { client._transport().close(); } }}
3. 索引文档（插入数据）
向 Elasticsearch 插入一条 JSON 文档：
import co.elastic.clients.elasticsearch.core.IndexResponse; import com.fasterxml.jackson.databind.ObjectMapper;public class IndexExample { public static void indexDocument() throws Exception { var objectMapper = new ObjectMapper(); var client = EsClient.getClient();
// 要插入的数据（Map 或 POJO） User user = new User("1", "张三", 25); IndexResponse response = client.index(i -youjiankuohaophpcn i .index("users") // 索引名 .id(user.getId()) // 文档 ID .document(user) ); System.out.println("Indexed with version: " + response.version()); }}
// 用户类示例 class User { private String id; private String name; private int age;
// 构造函数、getter 和 setter 省略}
4. 查询文档
根据 ID 获取文档或执行搜索查询：
- 根据 ID 获取文档
var response = client.get(g -> g
.index("users")
.id("1"),
User.class
);
if (response.found()) {
System.out.println("Name: " + response.source().getName());
} else {
System.out.println("Not found");
}
var searchResponse = client.search(s -> s .index("users") .query(q -> q .match(t -> t .field("name") .query("张三") ) ), User.class );for (var hit : searchResponse.hits().hits()) { System.out.println("User: " + hit.source()); }
5. 更新和删除文档
- 更新文档
client.update(u -> u
.index("users")
.id("1")
.doc(new User("1", "李四", 26)),
User.class
);
client.delete(d -> d
.index("users")
.id("1")
);
注意事项
- Elasticsearch 8.x 推荐使用新的 Java API Client，旧的
TransportClient 和RestHighLevelClient已废弃。 - 确保 Elasticsearch 服务正在运行，默认端口是 9200。
- 如果启用了安全认证（如用户名密码），需要在 RestClient 中配置凭据。
- POJO 类需有 getter/setter，否则 Jackson 可能无法序列化。
基本上就这些。只要依赖正确、网络通、代码结构清晰，Java 操作 Elasticsearch 并不复杂。
