j*a怎么连接Elasticsearch 连接并操作Elasticsearch搜索引擎数据

使用J*a API Client连接Elasticsearch需添加elasticsearch-j*a依赖并创建RestClient实例，通过ElasticsearchClient执行索引、查询、更新和删除操作，推荐用于8.x版本，替代已弃用的旧客户端。

J*a 连接并操作 Elasticsearch 主要有两种方式：使用官方的 J*a REST 客户端（已弃用）或推荐的 J*a API Client（新版，基于 Elasticsearch 7.15+）。下面以目前主流且官方推荐的方式进行说明。

1. 添加 M*en 依赖

在你的 pom.xml 中添加 Elasticsearch 的 J*a API Client 依赖：

<dependency>
    <groupId>co.elastic.clients</groupId>
    <artifactId>elasticsearch-j*a</artifactId>
    <version>8.14.0</version>
</dependency>
<p><!-- Jackson 数据绑定 -->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.15.2</version>
</dependency>
</code></p>

2. 创建客户端连接

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

立即学习“J*a免费学习笔记（深入）”；

CreateWise AI

为播客创作者设计的AI创作工具，AI自动去口癖、提交亮点和生成Show notes、标题等

177 查看详情

<pre class="brush:php;toolbar:false;">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;
<p>public class EsClient {
private static ElasticsearchClient client;</p><pre class="brush:php;toolbar:false;"><code>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;
<p>public class IndexExample {
public static void indexDocument() throws Exception {
var objectMapper = new ObjectMapper();
var client = EsClient.getClient();</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">    // 要插入的数据（Map 或 POJO）
    User user = new User("1", "张三", 25);

    IndexResponse response = client.index(i -> 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
);
<p>if (response.found()) {
System.out.println("Name: " + response.source().getName());
} else {
System.out.println("Not found");
}
</code></p>

• 执行全文搜索

<pre class="brush:php;toolbar:false;">var searchResponse = client.search(s -> s
    .index("users")
    .query(q -> q
        .match(t -> t
            .field("name")
            .query("张三")
        )
    ),
    User.class
);
<p>for (var hit : searchResponse.hits().hits()) {
System.out.println("User: " + hit.source());
}

5. 更新和删除文档

• 更新文档

<pre class="brush:php;toolbar:false;">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 推荐使用新的 J*a API Client，旧的 TransportClient 和 <code>RestHighLevelClient 已废弃。
• 确保 Elasticsearch 服务正在运行，默认端口是 9200。
• 如果启用了安全认证（如用户名密码），需要在 RestClient 中配置凭据。
• POJO 类需有 getter/setter，否则 Jackson 可能无法序列化。

基本上就这些。只要依赖正确、网络通、代码结构清晰，J*a 操作 Elasticsearch 并不复杂。

以上就是j*a怎么连接Elasticsearch 连接并操作Elasticsearch搜索引擎数据的详细内容，更多请关注其它相关文章！