您的位置:首页 > 科技 > 能源 > 营销策划公司怎么选广告_鄂应用官方app下载_百度怎么提交收录_上海营销公司

营销策划公司怎么选广告_鄂应用官方app下载_百度怎么提交收录_上海营销公司

2024/12/24 7:59:13 来源:https://blog.csdn.net/infinilabs/article/details/144679854  浏览:    关键词:营销策划公司怎么选广告_鄂应用官方app下载_百度怎么提交收录_上海营销公司
营销策划公司怎么选广告_鄂应用官方app下载_百度怎么提交收录_上海营销公司

在 上一篇文章 中,我们介绍了 Easysearch Java SDK 2.0.x 的基本使用和批量操作。本文将深入探讨索引管理相关的功能,包括索引的创建、删除、开关、刷新、滚动等操作,以及新版 SDK 提供的同步和异步两种调用方式。

SDK 的对象构建有两种方式

1. 传统的 Builder 方式

最基础的方式,像这样:

CreateIndexResponse createResponse = client.indices().create(new CreateIndexRequest.Builder().index("my-index").aliases("foo",new Alias.Builder().isWriteIndex(true).build()).build()
);

优点简单直观,但稍显笨重。

2. Lambda 表达式方式

这才是推荐的写法,简洁优雅:

CreateIndexResponse createResponse = client.indices().create(c -> c.index("my-index").aliases("foo", a -> a.isWriteIndex(true)));

Lambda 方式不仅代码少,最大的优点是不用记那么多 Builder 类名。尤其是写复杂查询的时候,代码层次感特别强:

// 命名建议:用 b0、b1 这样的简写表示嵌套层级
SearchResponse<Doc> results = client.search(b0 -> b0.index("my-index").query(b1 -> b1.bool(b2 -> b2.must(b3 -> b3.match(b4 -> b4.field("title").query("搜索"))).filter(b3 -> b3.range(b4 -> b4.field("date").gte("2024-01-01"))))),Doc.class
);

好了,说回索引管理

啥是索引管理?

简单来说就是对索引进行增删改查的一些基本操作。比如:

  • 建个新索引
  • 删掉不要的索引
  • 关闭/打开某个索引
  • 刷新一下让数据立马能搜到
  • 清个缓存
  • 整理一下索引段(让搜索更快)

新版 SDK 在这块的设计特别贴心,同步异步都支持,用起来特别顺手。

同步方式怎么用?

上代码!下面这段代码基本涵盖了日常用到的所有索引管理操作:

    String index = "test1";// 先看看索引在不在if (client.indices().exists(r -> r.index(index)).value()) {LOGGER.info("Deleting index " + index);// 在的话就删掉重来DeleteIndexResponse deleteIndexResponse =client.indices().delete(new DeleteIndexRequest.Builder().index(index).build());LOGGER.info(deleteIndexResponse.toString());}// 建个新的LOGGER.info("Creating index " + index);CreateIndexResponse createIndexResponse =client.indices().create(req -> req.index(index));// 关闭索引CloseIndexResponse closeIndexResponse =client.indices().close(req -> req.index(index));// 打开索引OpenResponse openResponse =client.indices().open(req -> req.index(index));// 刷新一下,让刚写入的数据马上能搜到RefreshResponse refreshResponse =client.indices().refresh(req -> req.index(index));// 把内存里的数据都写到磁盘上FlushResponse flushResponse =client.indices().flush(req -> req.index(index));// 整理一下索引段,搜索会快很多// maxNumSegments(1L) 意思是整理成一个段ForcemergeResponse forcemergeResponse =client.indices().forcemerge(req -> req.index(index).maxNumSegments(1L));

看代码就能明白,这些操作都特别直观,基本上方法名就能告诉你它是干啥的。而且返回的 Response 对象里都带着详细的执行结果,出了问题很容易排查。

异步方式又是咋回事?

有时候你可能不想等着这些操作一个个完成,这时候就可以用异步方式:

String index = "test1";EasysearchAsyncClient asyncClient = SampleClient.createAsyncClient();// 用CompletableFuture串起来一串操作asyncClient.indices().exists(req -> req.index(index)).thenCompose(exists -> {if (exists.value()) {LOGGER.info("Deleting index " + index);return asyncClient.indices().delete(r -> r.index(index)).thenAccept(deleteResponse -> {LOGGER.info(deleteResponse);});}return CompletableFuture.completedFuture(null);}).thenCompose(v -> {LOGGER.info("Creating index " + index);return asyncClient.indices().create(req -> req.index(index));}).whenComplete((createResponse, throwable) -> {if (throwable != null) {LOGGER.error("哎呀出错了", throwable);} else {LOGGER.info("搞定!");}}).get(30, TimeUnit.SECONDS); // 最多等30秒

异步方式看起来代码多了点,但是好处也很明显:

  1. 不会卡住主线程
  2. 可以并发执行多个操作
  3. 配合 CompletableFuture 能实现很多花样

小贴士

  1. 选哪种方式?

    • 简单场景用同步,代码简单直观
    • 要并发或者不想阻塞就用异步
  2. 记得处理异常

    • 同步的就直接 try-catch
    • 异步的用 whenComplete 或 exceptionally 来处理
  3. 性能方面

    • force merge 挺耗资源的,建议半夜执行
    • refresh 太频繁会影响写入性能,根据需要权衡

自动翻转 (Rollover)

在管理 Easysearch 索引时,我们经常需要控制单个索引的大小和时间跨度。Easysearch 的 Rollover API 提供了一个优雅的解决方案,允许我们基于特定条件自动创建新索引。本文将介绍如何使用 Java API 实现索引 rollover。

什么是 Rollover?

Rollover 是一种索引管理机制,当现有索引满足一个或多个条件时(如达到一定大小、文档数量或时间),会自动创建一个新索引。这对于日志管理等场景特别有用。

实现示例

首先,我们需要创建一个初始索引并设置别名:

String index = "test-00001";
// 如果索引存在则删除
if (client.indices().exists(r -> r.index(index)).value()) {client.indices().delete(new DeleteIndexRequest.Builder().index(index).build());
}// 创建索引并设置别名
client.indices().create(req -> req.index(index).aliases("test_log", a -> a.isWriteIndex(true)));

配置 Rollover 条件

有两种方式配置 rollover 条件:

方式一:使用 Java API

RolloverResponse res = client.indices().rollover(req -> req.alias("test_log").conditions(c -> c.maxDocs(100L)        // 文档数量超过100.maxAge(b -> b.time("7d"))  // 索引年龄超过7天.maxSize("5gb")));    // 索引大小超过5GB

方式二:使用 JSON 配置

String conditionsJson = """
{"conditions": {"max_docs": 100,"max_age": "7d","max_size": "5gb"}
}
""";RolloverResponse response = client.indices().rollover(req -> req.alias("test_log").withJson(new StringReader(conditionsJson))
);

Rollover 条件说明

  • max_docs: 索引中的最大文档数
  • max_age: 索引最大存在时间
  • max_size: 索引的最大存储大小

当满足任一条件时,系统会自动创建新索引。新索引的命名规则是将原索引名称中的数字部分加 1。


想要了解更多?

  • 客户端 Maven 地址: https://mvnrepository.com/artifact/com.infinilabs/easysearch-client/2.0.2
  • 更详细的文档和示例代码在 官网 持续更新中,请随时关注!

大家有啥问题或者建议,也欢迎随时反馈!

关于 Easysearch

INFINI Easysearch 是一个分布式的搜索型数据库,实现非结构化数据检索、全文检索、向量检索、地理位置信息查询、组合索引查询、多语种支持、聚合分析等。Easysearch 可以完美替代 Elasticsearch,同时添加和完善多项企业级功能。Easysearch 助您拥有简洁、高效、易用的搜索体验。

官网文档:https://infinilabs.cn/docs/latest/easysearch

作者:张磊,极限科技(INFINI Labs)搜索引擎研发负责人,对 Elasticsearch 和 Lucene 源码比较熟悉,目前主要负责公司的 Easysearch 产品的研发以及客户服务工作。

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com