Elasticsearch 与 Kibana 实战：从部署到 C++ 客户端封装

配置通常位于 /etc/kibana/kibana.yml，需确保 elasticsearch.host 指向正确的 ES 地址（如 http://localhost:9200）。默认监听端口为 5601。

Kibana 可视化操作

通过浏览器访问 http://服务器 IP:5601 即可进入 Kibana 界面。这里可以创建索引、管理映射以及执行查询。

1. 创建索引：在 Dev Tools 中编写 DSL 语句定义字段类型（Mapping），例如将 name 设为 text，age 设为 integer。
2. 数据写入：使用 POST 请求向索引插入文档。
3. 查询数据：支持全文检索、聚合统计等复杂查询。
4. 删除操作：可按 ID 删除单条文档或清空整个索引。

C++ 客户端封装实践

虽然官方提供了多种语言客户端，但在 C++ 项目中，我们常基于 HTTP 库（如 CPR）自行封装，以便更好地控制请求细节和资源管理。

基础接口设计

我们主要封装四个核心操作，对应 SQL 的增删查改：

• Search：执行搜索查询（类似 SELECT）。
• Get：根据 ID 获取文档（类似 WHERE id=?）。
• Index：创建或更新文档（类似 INSERT/UPDATE）。
• Remove：删除文档（类似 DELETE）。

示例代码结构如下：

cpr::Response search(const std::string &indexName,
                     const std::string &docType,
                     const std::string &body,
                     const std::string &routing);

cpr::Response get(const std::string &indexName,
                  const std::string &docType,
                  const std::string &id,
                  const std::string &routing);

cpr::Response index(const std::string &indexName,
                    const std::string &docType,
                    const std::string &id,
                    const std::string &body,
                    const std::string &routing);

cpr::Response remove(const std::string &indexName,
                     const std::string &docType,
                     const std::string &id,
                     const std::string &routing);

注意：ES 7.x 之后 docType 参数已废弃，调用时可传入空字符串。

二次封装思路

为了简化业务层调用，我们将上述接口进一步封装成类。封装的核心思想是将 JSON 构建逻辑隐藏在内部，用户只需传入业务数据，由封装层负责序列化、发送请求并解析响应。

这样做的优势在于：

1. 资源复用：客户端对象可被多个模块共享，避免重复初始化。
2. 逻辑统一：统一的错误处理和重试机制。
3. 开发效率：屏蔽底层 HTTP 细节，专注于业务逻辑。

测试示例

以下是一个典型的测试流程，展示了如何初始化客户端、创建索引、插入数据并进行查询。

#include "../../common/es_oper.hpp"
#include <gflags/gflags.h>

DEFINE_bool(run_mode, false, "程序的运行模式，false-调试；true-发布；");
DEFINE_string(log_file, "", "发布模式下，用于指定日志的输出文件");
DEFINE_int32(log_level, 0, "发布模式下，用于指定日志输出等级");

int main(int argc, char* argv[]) {
    google::ParseCommandLineFlags(&argc, &argv, true);
    init_logger(FLAGS_run_mode, FLAGS_log_file, FLAGS_log_level);

    // 构建客户端连接
    std::vector<std::string> host{"http://127.0.0.1:9200/"};
    auto client = std::make_shared<elasticlient::Client>(host);

    // 1. 数据新增
    bool ret = EsInsertData(client, "test_user")
                   .append("nickname", "张三")
                   .append("phone", "15566667777")
                   .insert("00001");
    if (!ret) {
        LOG_ERROR("数据插入失败!");
        return -1;
    } else {
        LOG_INFO("数据新增成功!");
    }

    // 2. 数据更新（同 ID 覆盖）
    ret = EsInsertData(client, "test_user")
              .append("nickname", "张三")
              .append("phone", "13344445555")
              .insert("00001");
    if (!ret) {
        LOG_ERROR("数据更新失败!");
        return -1;
    } else {
        LOG_INFO("数据更新成功!");
    }

    // 注意：ES 更新有延迟，建议等待几秒后再查询
    std::this_thread::sleep_for(std::chrono::seconds(3));

    // 3. 条件查询
    Json::Value user = EsSearch(client, "test_user")
                           .append_should_match("phone.keyword", "13344445555")
                           .append_must_not_terms("nickname.keyword", {"张三"})
                           .search();

    if (user.empty() || !user.isArray()) {
        LOG_ERROR("结果为空，或者结果不是数组类型");
        return -1;
    } else {
        LOG_INFO("数据检索成功!");
    }

    int sz = user.size();
    LOG_DEBUG("检索结果条目数量：{}", sz);
    for (int i = 0; i < sz; i++) {
        LOG_INFO("nickname: {}", user[i]["_source"]["nickname"].asString());
    }

    return 0;
}

在实际使用中，如果遇到并发更新导致查询不到最新数据的情况，可以适当增加休眠时间或使用乐观锁机制。

总结

本文从实操角度出发，梳理了 Elasticsearch 与 Kibana 的部署流程，解析了索引、文档、映射等核心概念。重点演示了如何通过 C++ 封装 REST API，简化索引管理与 CRUD 操作。这种封装方式能有效降低集成成本，为后续项目中的搜索引擎应用打下基础。