java怎么连接Elasticsearch 连接并操作Elasticsearch搜索引擎数据

使用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-java
    8.14.0



com.fasterxml.jackson.core
jackson-databind
2.15.2

2. 创建客户端连接

使用 TransportClient 已被弃用，现在推荐使用基于 HTTP 的 Java API Client。以下是一个创建连接的示例：

立即学习“Java免费学习笔记（深入）”；

ChartCube

图标魔方 - 在线图表制作工具

下载

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 并不复杂。